/* * Copyright (C) 2023 The Android Open Source Project * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package com.android.healthconnect.controller.data.access import com.android.healthconnect.controller.permissions.api.IGetGrantedHealthPermissionsUseCase import com.android.healthconnect.controller.permissions.data.HealthPermission.FitnessPermission import com.android.healthconnect.controller.permissions.data.HealthPermissionType import com.android.healthconnect.controller.permissions.data.PermissionsAccessType import com.android.healthconnect.controller.service.IoDispatcher import com.android.healthconnect.controller.shared.HealthPermissionReader import com.android.healthconnect.controller.shared.app.AppInfoReader import com.android.healthconnect.controller.shared.app.AppMetadata import com.android.healthconnect.controller.shared.usecase.UseCaseResults import javax.inject.Inject import javax.inject.Singleton import kotlinx.coroutines.CoroutineDispatcher import kotlinx.coroutines.withContext @Singleton class LoadAccessUseCase @Inject constructor( private val loadPermissionTypeContributorAppsUseCase: ILoadPermissionTypeContributorAppsUseCase, private val loadGrantedHealthPermissionsUseCase: IGetGrantedHealthPermissionsUseCase, private val healthPermissionReader: HealthPermissionReader, private val appInfoReader: AppInfoReader, @IoDispatcher private val dispatcher: CoroutineDispatcher ) : ILoadAccessUseCase { /** Returns a map of [AppAccessState] to apps. */ override suspend operator fun invoke( permissionType: HealthPermissionType ): UseCaseResults>> = withContext(dispatcher) { try { val appsWithFitnessPermissions: List = healthPermissionReader.getAppsWithFitnessPermissions() val contributingApps: List = loadPermissionTypeContributorAppsUseCase.invoke(permissionType) val readAppMetadataSet: MutableSet = mutableSetOf() val writeAppMetadataSet: MutableSet = mutableSetOf() val writeAppPackageNameSet: MutableSet = mutableSetOf() val inactiveAppMetadataSet: MutableSet = mutableSetOf() appsWithFitnessPermissions.forEach { val permissionsPerPackage: List = loadGrantedHealthPermissionsUseCase(it) // Apps that can READ the given healthPermissionType. if (permissionsPerPackage.contains( FitnessPermission(permissionType, PermissionsAccessType.READ).toString())) { readAppMetadataSet.add(appInfoReader.getAppMetadata(it)) } // Apps that can WRITE the given healthPermissionType. if (permissionsPerPackage.contains( FitnessPermission(permissionType, PermissionsAccessType.WRITE) .toString())) { writeAppMetadataSet.add(appInfoReader.getAppMetadata(it)) writeAppPackageNameSet.add(it) } } // Apps that are inactive: can no longer WRITE, but still have data in Health // Connect. contributingApps.forEach { app -> if (!writeAppPackageNameSet.contains(app.packageName)) { inactiveAppMetadataSet.add(app) } } val appAccess = mapOf( AppAccessState.Read to alphabeticallySortedMetadataList(readAppMetadataSet), AppAccessState.Write to alphabeticallySortedMetadataList(writeAppMetadataSet), AppAccessState.Inactive to alphabeticallySortedMetadataList(inactiveAppMetadataSet)) UseCaseResults.Success(appAccess) } catch (ex: Exception) { UseCaseResults.Failed(ex) } } private fun alphabeticallySortedMetadataList( packageNames: Set ): List { return packageNames.sortedBy { appMetadata -> appMetadata.appName } } } interface ILoadAccessUseCase { suspend fun invoke( permissionType: HealthPermissionType ): UseCaseResults>> }