Fabio/aves
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

#1493 analysis service: ensure init sequence, safer notification update

Browse source
This commit is contained in:
Thibault Deckers 2025-04-13 22:14:05 +02:00
parent 63130de577
commit 353cde0ee8
1 changed files with 17 additions and 16 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

29
android/app/src/main/kotlin/deckers/thibault/aves/AnalysisWorker.kt
View file

@ -14,6 +14,7 @@ import androidx.work.ForegroundInfo
import androidx.work.WorkManager import androidx.work.WorkManager
import androidx.work.WorkerParameters import androidx.work.WorkerParameters
import app.loup.streams_channel.StreamsChannel import app.loup.streams_channel.StreamsChannel
import deckers.thibault.aves.channel.calls.Coresult.Companion.safeSuspend
import deckers.thibault.aves.channel.calls.DeviceHandler import deckers.thibault.aves.channel.calls.DeviceHandler
import deckers.thibault.aves.channel.calls.GeocodingHandler import deckers.thibault.aves.channel.calls.GeocodingHandler
import deckers.thibault.aves.channel.calls.MediaFetchObjectHandler import deckers.thibault.aves.channel.calls.MediaFetchObjectHandler
@ -44,11 +45,12 @@ class AnalysisWorker(context: Context, parameters: WorkerParameters) : Coroutine
private var backgroundChannel: MethodChannel? = null private var backgroundChannel: MethodChannel? = null
override suspend fun doWork(): Result { override suspend fun doWork(): Result {
Log.i(LOG_TAG, "Start analysis worker $id")
defaultScope.launch { defaultScope.launch {
// prevent ANR triggered by slow operations in main thread // prevent ANR triggered by slow operations in main thread
createNotificationChannel() createNotificationChannel()
setForeground(createForegroundInfo()) setForeground(createForegroundInfo())
} }.join()
suspendCoroutine { cont -> suspendCoroutine { cont ->
workCont = cont workCont = cont
onStart() onStart()
@ -68,7 +70,6 @@ class AnalysisWorker(context: Context, parameters: WorkerParameters) : Coroutine
} }
private fun onStart() { private fun onStart() {
Log.i(LOG_TAG, "Start analysis worker $id")
runBlocking { runBlocking {
FlutterUtils.initFlutterEngine(applicationContext, SHARED_PREFERENCES_KEY, PREF_CALLBACK_HANDLE_KEY) { FlutterUtils.initFlutterEngine(applicationContext, SHARED_PREFERENCES_KEY, PREF_CALLBACK_HANDLE_KEY) {
flutterEngine = it flutterEngine = it
@ -132,12 +133,7 @@ class AnalysisWorker(context: Context, parameters: WorkerParameters) : Coroutine
result.success(null) result.success(null)
} }
"updateNotification" -> { "updateNotification" -> defaultScope.launch { safeSuspend(call, result, ::updateNotification) }
val title = call.argument<String>("title")
val message = call.argument<String>("message")
setForegroundAsync(createForegroundInfo(title, message))
result.success(null)
}
"stop" -> { "stop" -> {
workCont?.resume(null) workCont?.resume(null)
@ -180,17 +176,22 @@ class AnalysisWorker(context: Context, parameters: WorkerParameters) : Coroutine
.setContentIntent(openAppIntent) .setContentIntent(openAppIntent)
.addAction(stopAction) .addAction(stopAction)
.build() .build()
return if (Build.VERSION.SDK_INT == 34) {
// from Android 14 (API 34), foreground service type is mandatory for long-running workers: // from Android 14 (API 34), foreground service type is mandatory for long-running workers:
// https://developer.android.com/guide/background/persistent/how-to/long-running // https://developer.android.com/guide/background/persistent/how-to/long-running
ForegroundInfo(NOTIFICATION_ID, notification, ServiceInfo.FOREGROUND_SERVICE_TYPE_DATA_SYNC) return when {
} else if (Build.VERSION.SDK_INT >= 35) { Build.VERSION.SDK_INT >= 35 -> ForegroundInfo(NOTIFICATION_ID, notification, ServiceInfo.FOREGROUND_SERVICE_TYPE_MEDIA_PROCESSING)
ForegroundInfo(NOTIFICATION_ID, notification, ServiceInfo.FOREGROUND_SERVICE_TYPE_MEDIA_PROCESSING) Build.VERSION.SDK_INT == 34 -> ForegroundInfo(NOTIFICATION_ID, notification, ServiceInfo.FOREGROUND_SERVICE_TYPE_DATA_SYNC)
} else { else -> ForegroundInfo(NOTIFICATION_ID, notification)
ForegroundInfo(NOTIFICATION_ID, notification)
} }
} }
private suspend fun updateNotification(call: MethodCall, result: MethodChannel.Result) {
val title = call.argument<String>("title")
val message = call.argument<String>("message")
setForeground(createForegroundInfo(title, message))
result.success(null)
}
companion object { companion object {
private val LOG_TAG = LogUtils.createTag<AnalysisWorker>() private val LOG_TAG = LogUtils.createTag<AnalysisWorker>()
private const val BACKGROUND_CHANNEL = "deckers.thibault/aves/analysis_service_background" private const val BACKGROUND_CHANNEL = "deckers.thibault/aves/analysis_service_background"