1 /*
<lambda>null2  * Copyright (C) 2023 The Android Open Source Project
3  *
4  * Licensed under the Apache License, Version 2.0 (the "License");
5  * you may not use this file except in compliance with the License.
6  * You may obtain a copy of the License at
7  *
8  *      http://www.apache.org/licenses/LICENSE-2.0
9  *
10  * Unless required by applicable law or agreed to in writing, software
11  * distributed under the License is distributed on an "AS IS" BASIS,
12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13  * See the License for the specific language governing permissions and
14  * limitations under the License.
15  */
16 package com.android.healthconnect.controller.data.access
17 
18 import android.health.connect.HealthConnectManager
19 import android.health.connect.RecordTypeInfoResponse
20 import android.health.connect.datatypes.Record
21 import androidx.core.os.asOutcomeReceiver
22 import com.android.healthconnect.controller.permissions.data.HealthPermissionType
23 import com.android.healthconnect.controller.permissions.data.fromHealthPermissionCategory
24 import com.android.healthconnect.controller.service.IoDispatcher
25 import com.android.healthconnect.controller.shared.app.AppInfoReader
26 import com.android.healthconnect.controller.shared.app.AppMetadata
27 import javax.inject.Inject
28 import javax.inject.Singleton
29 import kotlinx.coroutines.CoroutineDispatcher
30 import kotlinx.coroutines.suspendCancellableCoroutine
31 import kotlinx.coroutines.withContext
32 
33 @Singleton
34 class LoadPermissionTypeContributorAppsUseCase
35 @Inject
36 constructor(
37     private val appInfoReader: AppInfoReader,
38     private val healthConnectManager: HealthConnectManager,
39     @IoDispatcher private val dispatcher: CoroutineDispatcher
40 ) : ILoadPermissionTypeContributorAppsUseCase {
41 
42     /** Returns a list of [AppMetadata]s that have data in this [HealthPermissionType]. */
43     override suspend operator fun invoke(permissionType: HealthPermissionType): List<AppMetadata> =
44         withContext(dispatcher) {
45             try {
46                 val recordTypeInfoMap: Map<Class<out Record>, RecordTypeInfoResponse> =
47                     suspendCancellableCoroutine { continuation ->
48                         healthConnectManager.queryAllRecordTypesInfo(
49                             Runnable::run, continuation.asOutcomeReceiver())
50                     }
51                 val packages =
52                     recordTypeInfoMap.values
53                         .filter {
54                             fromHealthPermissionCategory(it.permissionCategory) == permissionType &&
55                                 it.contributingPackages.isNotEmpty()
56                         }
57                         .map { it.contributingPackages }
58                         .flatten()
59                 packages
60                     .map { appInfoReader.getAppMetadata(it.packageName) }
61                     .sortedBy { it.appName }
62             } catch (e: Exception) {
63                 emptyList()
64             }
65         }
66 }
67 
68 interface ILoadPermissionTypeContributorAppsUseCase {
invokenull69     suspend fun invoke(permissionType: HealthPermissionType): List<AppMetadata>
70 }
71