1 /* <lambda>null2 * Copyright (C) 2024 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 17 package com.android.settings.network.telephony.ims 18 19 import android.content.Context 20 import android.content.pm.PackageManager 21 import android.telephony.SubscriptionManager 22 import android.telephony.ims.ProvisioningManager 23 import android.telephony.ims.ProvisioningManager.FeatureProvisioningCallback 24 import android.telephony.ims.feature.MmTelFeature.MmTelCapabilities.MmTelCapability 25 import android.telephony.ims.stub.ImsRegistrationImplBase.ImsRegistrationTech 26 import android.util.Log 27 import kotlinx.coroutines.Dispatchers 28 import kotlinx.coroutines.asExecutor 29 import kotlinx.coroutines.channels.awaitClose 30 import kotlinx.coroutines.flow.Flow 31 import kotlinx.coroutines.flow.callbackFlow 32 import kotlinx.coroutines.flow.catch 33 import kotlinx.coroutines.flow.conflate 34 import kotlinx.coroutines.flow.distinctUntilChanged 35 import kotlinx.coroutines.flow.flowOf 36 import kotlinx.coroutines.flow.flowOn 37 import kotlinx.coroutines.flow.onEach 38 39 class ProvisioningRepository( 40 private val context: Context, 41 private val provisioningManagerFactory: (Int) -> ProvisioningManager = 42 ProvisioningManager::createForSubscriptionId, 43 ) { 44 45 fun imsFeatureProvisionedFlow( 46 subId: Int, 47 @MmTelCapability capability: Int, 48 @ImsRegistrationTech tech: Int, 49 ): Flow<Boolean> { 50 if (!SubscriptionManager.isValidSubscriptionId(subId) || 51 !context.packageManager.hasSystemFeature(PackageManager.FEATURE_TELEPHONY_IMS)) { 52 return flowOf(false) 53 } 54 val provisioningManager = provisioningManagerFactory(subId) 55 return callbackFlow { 56 val callback = 57 object : FeatureProvisioningCallback() { 58 override fun onFeatureProvisioningChanged( 59 receivedCapability: Int, 60 receivedTech: Int, 61 isProvisioned: Boolean, 62 ) { 63 if (capability == receivedCapability && tech == receivedTech) 64 trySend(isProvisioned) 65 } 66 67 override fun onRcsFeatureProvisioningChanged( 68 capability: Int, 69 tech: Int, 70 isProvisioned: Boolean, 71 ) {} 72 } 73 74 provisioningManager.registerFeatureProvisioningChangedCallback( 75 Dispatchers.Default.asExecutor(), 76 callback, 77 ) 78 trySend(provisioningManager.getProvisioningStatusForCapability(capability, tech)) 79 80 awaitClose { 81 provisioningManager.unregisterFeatureProvisioningChangedCallback(callback) 82 } 83 } 84 .catch { e -> 85 Log.w(TAG, "[$subId] error while imsFeatureProvisionedFlow", e) 86 emit(false) 87 } 88 .distinctUntilChanged() 89 .conflate() 90 .onEach { 91 Log.d(TAG, "[$subId] changed: capability=$capability tech=$tech isProvisioned=$it") 92 } 93 .flowOn(Dispatchers.Default) 94 } 95 96 companion object { 97 private const val TAG = "ProvisioningRepository" 98 } 99 } 100