TySS-Dev/capod
1
0
Fork 0
mirror of https://github.com/d4rken-org/capod.git synced 2026-09-14 18:26:11 -04:00
Code Issues Packages Projects Releases Wiki Activity

fix(monitor): Gate AAP lifecycle on BLUETOOTH_CONNECT permission

Browse Source
This commit is contained in:
darken
2026-04-17 21:48:55 +02:00
committed by Matthias Urhahn
parent 79886e0bfb
commit 250d0ab154
1 changed files with 33 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/src/main/java/eu/darken/capod/monitor/core/aap/AapLifecycleManager.kt
+33 -9
View File
@@ -6,12 +6,20 @@ import eu.darken.capod.common.debug.logging.asLog
import eu.darken.capod.common.debug.logging.log
import eu.darken.capod.common.debug.logging.logTag
import eu.darken.capod.common.flow.setupCommonEventHandlers
import eu.darken.capod.common.permissions.Permission
import eu.darken.capod.main.core.PermissionTool
import kotlinx.coroutines.CoroutineScope
import kotlinx.coroutines.flow.catch
import kotlinx.coroutines.delay
import kotlinx.coroutines.flow.distinctUntilChanged
import kotlinx.coroutines.flow.emptyFlow
import kotlinx.coroutines.flow.flatMapLatest
import kotlinx.coroutines.flow.launchIn
import kotlinx.coroutines.flow.map
import kotlinx.coroutines.flow.merge
import kotlinx.coroutines.flow.retryWhen
import javax.inject.Inject
import javax.inject.Singleton
import kotlin.time.Duration.Companion.milliseconds
/**
* Launches AAP auto-connect and key persistence in [appScope],
@@ -27,17 +35,33 @@ class AapLifecycleManager @Inject constructor(
private val aapLearnedSettingsPersister: AapLearnedSettingsPersister,
private val stemConfigSender: StemConfigSender,
private val stemPressReaction: StemPressReaction,
private val permissionTool: PermissionTool,
) {
fun start() {
log(TAG) { "start()" }
merge(
aapAutoConnect.monitor(),
aapKeyPersister.monitor(),
aapLearnedSettingsPersister.monitor(),
stemConfigSender.monitor(),
stemPressReaction.monitor(),
)
.catch { e -> log(TAG, WARN) { "AAP lifecycle error: ${e.asLog()}" } }
permissionTool.missingPermissions
.map { Permission.BLUETOOTH_CONNECT in it }
.distinctUntilChanged()
.flatMapLatest { missingConnect ->
if (missingConnect) {
log(TAG) { "AAP lifecycle paused: BLUETOOTH_CONNECT missing" }
emptyFlow()
} else {
log(TAG) { "AAP lifecycle active: BLUETOOTH_CONNECT granted" }
merge(
aapAutoConnect.monitor(),
aapKeyPersister.monitor(),
aapLearnedSettingsPersister.monitor(),
stemConfigSender.monitor(),
stemPressReaction.monitor(),
)
.retryWhen { cause, attempt ->
log(TAG, WARN) { "AAP lifecycle error (attempt ${attempt + 1}): ${cause.asLog()}" }
delay((1_000L * (attempt + 1).coerceAtMost(5)).milliseconds)
true
}
}
}
.setupCommonEventHandlers(TAG) { "aapActive" }
.launchIn(appScope)
}