EOL - Background Work (EXPOSUREAPP-14794) (#5852)

* Stop Dcc Wallet info

* App starter

* Update AppStarterTest.kt

Author: mtwalli

Corona-Warn-App/src/main/java/de/rki/coronawarnapp/CoronaWarnApplication.kt

@@ -6,7 +6,6 @@ import android.content.Context
 import android.content.IntentFilter
 import android.os.Bundle
 import android.view.WindowManager
-import androidx.core.app.NotificationManagerCompat
 import androidx.localbroadcastmanager.content.LocalBroadcastManager
 import androidx.work.WorkManager
 import coil.Coil
@@ -15,10 +14,9 @@ import dagger.android.AndroidInjector
 import dagger.android.DispatchingAndroidInjector
 import dagger.android.HasAndroidInjector
 import de.rki.coronawarnapp.bugreporting.loghistory.LogHistoryTree
-import de.rki.coronawarnapp.eol.AppEol
 import de.rki.coronawarnapp.exception.reporting.ErrorReportReceiver
 import de.rki.coronawarnapp.exception.reporting.ReportingConstants.ERROR_REPORT_LOCAL_BROADCAST_CHANNEL
-import de.rki.coronawarnapp.initializer.Initializer
+import de.rki.coronawarnapp.initializer.AppStarter
 import de.rki.coronawarnapp.util.BuildVersionWrap
 import de.rki.coronawarnapp.util.CWADebug
 import de.rki.coronawarnapp.util.coroutine.AppScope
@@ -27,29 +25,22 @@ import de.rki.coronawarnapp.util.di.AppInjector
 import de.rki.coronawarnapp.util.di.ApplicationComponent
 import de.rki.coronawarnapp.util.hasAPILevel
 import kotlinx.coroutines.CoroutineScope
-import kotlinx.coroutines.flow.first
 import kotlinx.coroutines.flow.launchIn
 import kotlinx.coroutines.flow.onEach
-import kotlinx.coroutines.launch
 import timber.log.Timber
 import javax.inject.Inject
-import javax.inject.Provider
 
 class CoronaWarnApplication : Application(), HasAndroidInjector {
 
+    @Inject lateinit var appStarter: AppStarter
     @Inject lateinit var component: ApplicationComponent
     @Inject lateinit var androidInjector: DispatchingAndroidInjector<Any>
-
     @Inject lateinit var workManager: WorkManager
     @Inject lateinit var imageLoaderFactory: ImageLoaderFactory
     @Inject lateinit var foregroundState: ForegroundState
-    @Inject lateinit var initializers: Provider<Set<@JvmSuppressWildcards Initializer>>
     @AppScope @Inject lateinit var appScope: CoroutineScope
     @LogHistoryTree @Inject lateinit var rollingLogHistory: Timber.Tree
 
-    @Inject lateinit var appEol: AppEol
-    @Inject lateinit var notificationManager: NotificationManagerCompat
-
     override fun androidInjector(): AndroidInjector<Any> = androidInjector
 
     override fun onCreate() {
@@ -68,19 +59,7 @@ class CoronaWarnApplication : Application(), HasAndroidInjector {
             compPreview.inject(this)
         }
 
-        appScope.launch {
-            if (!appEol.isEol.first()) {
-                initializers.get().forEach { initializer ->
-                    Timber.d("initialize => %s", initializer::class.simpleName)
-                    initializer.initialize()
-                }
-            } else {
-                Timber.d("EOL -> cancel all notification")
-                notificationManager.cancelAll()
-                Timber.d("EOL -> no work scheduled")
-                workManager.cancelAllWork()
-            }
-        }
+        appStarter.start()
 
         Timber.plant(rollingLogHistory)
 

Corona-Warn-App/src/main/java/de/rki/coronawarnapp/ccl/dccwalletinfo/update/DccWalletInfoUpdateTrigger.kt

@@ -8,6 +8,7 @@ import de.rki.coronawarnapp.ccl.dccwalletinfo.calculation.DccWalletInfoCalculati
 import de.rki.coronawarnapp.covidcertificate.person.core.PersonCertificates
 import de.rki.coronawarnapp.covidcertificate.person.core.PersonCertificatesProvider
 import de.rki.coronawarnapp.covidcertificate.person.core.PersonCertificatesSettings
+import de.rki.coronawarnapp.eol.AppEol
 import de.rki.coronawarnapp.tag
 import de.rki.coronawarnapp.util.coroutine.AppScope
 import kotlinx.coroutines.CoroutineScope
@@ -29,6 +30,7 @@ class DccWalletInfoUpdateTrigger @Inject constructor(
     private val personCertificateProvider: PersonCertificatesProvider,
     private val personCertificatesSettings: PersonCertificatesSettings,
     private val dccWalletInfoCalculationManager: DccWalletInfoCalculationManager,
+    private val appEol: AppEol,
 ) {
 
     init {
@@ -45,16 +47,24 @@ class DccWalletInfoUpdateTrigger @Inject constructor(
                 // delay to collect rapid changes and do only one recalculation
                 .debounce(1000L)
                 .collectLatest {
-                    runCatching {
-                        triggerNow(admissionScenarioId())
-                    }.onFailure {
-                        Timber.tag(TAG).d(it, "Failed to calculate dccWallet")
+                    if (!appEol.isEol.first()) {
+                        runCatching {
+                            triggerNow(admissionScenarioId())
+                        }.onFailure {
+                            Timber.tag(TAG).d(it, "Failed to calculate dccWallet")
+                        }
+                    } else {
+                        Timber.tag(TAG).d("EOL -> quit")
                     }
                 }
         }
     }
 
     suspend fun triggerAfterConfigChange(configurationChanged: Boolean = false) {
+        if (appEol.isEol.first()) {
+            Timber.tag(TAG).d("EOL -> quit")
+            return
+        }
         Timber.tag(TAG).d("triggerAfterConfigChange()")
         dccWalletInfoCalculationManager.triggerAfterConfigChange(
             admissionScenarioId = admissionScenarioId(),

Corona-Warn-App/src/main/java/de/rki/coronawarnapp/contactdiary/retention/ContactDiaryRetentionCalculation.kt

@@ -38,6 +38,23 @@ class ContactDiaryRetentionCalculation @Inject constructor(
         return list.filter { entity -> isOutOfRetention(entity.date) }
     }
 
+    suspend fun clearOutdatedEntries() {
+        clearObsoleteContactDiaryLocationVisits()
+        Timber.d("Obsolete contact diary location visits cleaned up")
+
+        clearObsoleteContactDiaryPersonEncounters()
+        Timber.d("Obsolete contact diary person encounters cleaned up")
+
+        clearObsoleteRiskPerDate()
+        Timber.d("Obsolete Aggregated Risk Per Date Results cleaned up")
+
+        clearObsoleteCoronaTests()
+        Timber.d("Obsolete Contact Diary Corona Tests cleaned up")
+
+        clearObsoleteSubmissions()
+        Timber.d("Obsolete Contact Diary Submissions cleaned up")
+    }
+
     suspend fun clearObsoleteContactDiaryLocationVisits() {
         val list = repository.locationVisits.first()
         Timber.d("Contact Diary Location Visits total count: ${list.size}")

Corona-Warn-App/src/main/java/de/rki/coronawarnapp/initializer/AppStarter.kt

@@ -0,0 +1,50 @@
+package de.rki.coronawarnapp.initializer
+
+import androidx.core.app.NotificationManagerCompat
+import androidx.work.WorkManager
+import de.rki.coronawarnapp.contactdiary.retention.ContactDiaryRetentionCalculation
+import de.rki.coronawarnapp.eol.AppEol
+import de.rki.coronawarnapp.reyclebin.cleanup.RecycleBinCleanUpScheduler
+import de.rki.coronawarnapp.util.coroutine.AppScope
+import kotlinx.coroutines.CoroutineScope
+import kotlinx.coroutines.flow.first
+import kotlinx.coroutines.launch
+import timber.log.Timber
+import javax.inject.Inject
+import javax.inject.Singleton
+
+@Singleton
+class AppStarter @Inject constructor(
+    @AppScope private val appScope: CoroutineScope,
+    private val initializers: Set<@JvmSuppressWildcards Initializer>,
+    private val appEol: AppEol,
+    private val notificationManager: NotificationManagerCompat,
+    private val workManager: WorkManager,
+    private val recycleBinCleanUpScheduler: RecycleBinCleanUpScheduler,
+    private val contactDiaryRetentionCalculation: ContactDiaryRetentionCalculation,
+) {
+    fun start() = appScope.launch {
+        try {
+            if (!appEol.isEol.first()) {
+                initializers.forEach { initializer ->
+                    Timber.d("initialize => %s", initializer::class.simpleName)
+                    initializer.initialize()
+                }
+            } else {
+                Timber.d("EOL -> cancel all notifications")
+                notificationManager.cancelAll()
+
+                Timber.d("EOL -> cancel all scheduled workers")
+                workManager.cancelAllWork()
+
+                Timber.d("EOL -> clean recycle bin entries")
+                recycleBinCleanUpScheduler.initialize()
+
+                Timber.d("EOL -> clean contact diary entries")
+                contactDiaryRetentionCalculation.clearOutdatedEntries()
+            }
+        } catch (e: Exception) {
+            Timber.d(e, "Starter failed!")
+        }
+    }
+}

Corona-Warn-App/src/test/java/de/rki/coronawarnapp/CoronaWarnApplicationTest.kt

@@ -5,26 +5,21 @@ import coil.ImageLoaderFactory
 import dagger.android.DispatchingAndroidInjector
 import de.rki.coronawarnapp.coronatest.CoronaTestRepository
 import de.rki.coronawarnapp.environment.EnvironmentSetup
-import de.rki.coronawarnapp.eol.AppEol
-import de.rki.coronawarnapp.initializer.Initializer
+import de.rki.coronawarnapp.initializer.AppStarter
 import de.rki.coronawarnapp.notification.GeneralNotifications
 import de.rki.coronawarnapp.util.CWADebug
 import de.rki.coronawarnapp.util.device.ForegroundState
 import de.rki.coronawarnapp.util.di.AppInjector
 import de.rki.coronawarnapp.util.di.ApplicationComponent
-import io.github.classgraph.ClassGraph
-import io.kotest.matchers.collections.shouldContainAll
 import io.mockk.MockKAnnotations
 import io.mockk.Runs
-import io.mockk.coVerify
 import io.mockk.every
 import io.mockk.impl.annotations.MockK
 import io.mockk.just
 import io.mockk.mockk
 import io.mockk.mockkObject
 import io.mockk.mockkStatic
 import kotlinx.coroutines.CoroutineScope
-import kotlinx.coroutines.flow.flowOf
 import kotlinx.coroutines.test.advanceUntilIdle
 import kotlinx.coroutines.test.runTest
 import org.conscrypt.Conscrypt
@@ -33,7 +28,6 @@ import org.junit.jupiter.api.Test
 import testhelpers.BaseTest
 import timber.log.Timber
 import java.security.Security
-import javax.inject.Provider
 
 class CoronaWarnApplicationTest : BaseTest() {
 
@@ -45,8 +39,7 @@ class CoronaWarnApplicationTest : BaseTest() {
     @MockK lateinit var coronaTestRepository: CoronaTestRepository
     @MockK lateinit var environmentSetup: EnvironmentSetup
     @MockK lateinit var imageLoaderFactory: ImageLoaderFactory
-    @MockK lateinit var appEol: AppEol
-    private val initializers = DaggerInitializersTestComponent.create().initializers
+    @MockK lateinit var appStarter: AppStarter
 
     @BeforeEach
     fun setup() {
@@ -64,12 +57,11 @@ class CoronaWarnApplicationTest : BaseTest() {
             every { initAfterInjection(any()) } just Runs
         }
 
-        every { appEol.isEol } returns flowOf(false)
-
         mockkObject(AppInjector)
         AppInjector.apply {
             every { init(any()) } returns applicationComponent
         }
+        every { appStarter.start() } returns mockk()
     }
 
     private fun setupAppComponent(scope: CoroutineScope) {
@@ -80,9 +72,8 @@ class CoronaWarnApplicationTest : BaseTest() {
                 app.androidInjector = androidInjector
                 app.foregroundState = foregroundState
                 app.workManager = workManager
-                app.appEol = appEol
-                app.initializers = Provider { initializers }
                 app.appScope = scope
+                app.appStarter = appStarter
                 app.rollingLogHistory = object : Timber.Tree() {
                     override fun log(priority: Int, tag: String?, message: String, t: Throwable?) = Unit
                 }
@@ -92,28 +83,10 @@ class CoronaWarnApplicationTest : BaseTest() {
     }
 
     @Test
-    fun `test initializers`() = runTest {
+    fun `test app starter`() = runTest {
         setupAppComponent(this)
-        val app = createInstance()
-        app.onCreate()
         advanceUntilIdle()
-        val scanResult = ClassGraph()
-            .acceptPackages("de.rki.coronawarnapp")
-            .enableClassInfo()
-            .scan()
-
-        val initializersClasses = scanResult
-            .getClassesImplementing(Initializer::class.java)
-            .filterNot { it.isAbstract }
-
-        println("initializersClasses [${initializersClasses.size}]")
-        val injected = app.initializers.get().map { it::class.simpleName }.toSet()
-        val existing = initializersClasses.map { it.simpleName }.toSet()
-        injected shouldContainAll existing
-
-        coVerify {
-            app.initializers.get().forEach { initializer -> initializer.initialize() }
-        }
+        appStarter.start()
     }
 
     private fun createInstance() = CoronaWarnApplication()

Corona-Warn-App/src/test/java/de/rki/coronawarnapp/ccl/dccwalletinfo/update/DccWalletInfoUpdateTriggerTest.kt

@@ -9,6 +9,7 @@ import de.rki.coronawarnapp.covidcertificate.person.core.PersonCertificates
 import de.rki.coronawarnapp.covidcertificate.person.core.PersonCertificatesProvider
 import de.rki.coronawarnapp.covidcertificate.person.core.PersonCertificatesSettings
 import de.rki.coronawarnapp.covidcertificate.vaccination.core.VaccinationCertificate
+import de.rki.coronawarnapp.eol.AppEol
 import io.kotest.assertions.throwables.shouldNotThrow
 import io.mockk.MockKAnnotations
 import io.mockk.Runs
@@ -39,6 +40,7 @@ internal class DccWalletInfoUpdateTriggerTest : BaseTest() {
     @MockK lateinit var appConfigProvider: AppConfigProvider
     @MockK lateinit var cclSettings: CclSettings
     @MockK lateinit var personCertificatesSettings: PersonCertificatesSettings
+    @MockK lateinit var appEol: AppEol
 
     private val vc1 = mockk<VaccinationCertificate>().apply {
         every { qrCodeHash } returns "hash1"
@@ -82,6 +84,7 @@ internal class DccWalletInfoUpdateTriggerTest : BaseTest() {
         coEvery { cclSettings.saveAdmissionScenarioId(any()) } returns Job()
 
         coEvery { personCertificatesSettings.cleanSettingsNotIn(any()) } just Runs
+        every { appEol.isEol } returns flowOf(false)
     }
 
     @Test
@@ -257,6 +260,7 @@ internal class DccWalletInfoUpdateTriggerTest : BaseTest() {
         appConfigProvider = appConfigProvider,
         personCertificateProvider = personCertificateProvider,
         personCertificatesSettings = personCertificatesSettings,
-        dccWalletInfoCalculationManager = dccWalletInfoCalculationManager
+        dccWalletInfoCalculationManager = dccWalletInfoCalculationManager,
+        appEol = appEol,
     )
 }