feat(core): Run the maintenance service

Run the maintenance service in core and add the initial job to
deduplicate packages.

Signed-off-by: Martin Nonnenmacher <[email protected]>

Author: mnonnenmacher

core/build.gradle.kts

@@ -59,6 +59,7 @@ dependencies {
     implementation(projects.services.authorizationService)
     implementation(projects.services.hierarchyService)
     implementation(projects.services.infrastructureService)
+    implementation(projects.services.maintenanceService)
     implementation(projects.services.reportStorageService)
     implementation(projects.services.secretService)
     implementation(projects.storage.storageSpi)

core/src/main/kotlin/di/Module.kt

@@ -71,6 +71,7 @@ import org.eclipse.apoapsis.ortserver.services.ReportStorageService
 import org.eclipse.apoapsis.ortserver.services.RepositoryService
 import org.eclipse.apoapsis.ortserver.services.SecretService
 import org.eclipse.apoapsis.ortserver.services.VulnerabilityService
+import org.eclipse.apoapsis.ortserver.services.maintenance.MaintenanceService
 import org.eclipse.apoapsis.ortserver.storage.Storage
 
 import org.koin.core.module.dsl.singleOf
@@ -117,6 +118,8 @@ fun ortServerModule(config: ApplicationConfig) = module {
         val keycloakGroupPrefix = get<ApplicationConfig>().tryGetString("keycloak.groupPrefix").orEmpty()
         DefaultAuthorizationService(get(), get(), get(), get(), get(), keycloakGroupPrefix)
     }
+
+    singleOf(::MaintenanceService)
     single { OrchestratorService(get(), get(), get()) }
     single { OrganizationService(get(), get(), get(), get()) }
     single { ProductService(get(), get(), get(), get()) }

core/src/main/kotlin/plugins/Lifecycle.kt

@@ -27,9 +27,12 @@ import kotlinx.coroutines.Dispatchers
 import kotlinx.coroutines.launch
 
 import org.eclipse.apoapsis.ortserver.services.AuthorizationService
+import org.eclipse.apoapsis.ortserver.services.maintenance.MaintenanceService
+import org.eclipse.apoapsis.ortserver.services.maintenance.jobs.DeduplicatePackagesJob
 import org.eclipse.apoapsis.ortserver.utils.logging.runBlocking
 import org.eclipse.apoapsis.ortserver.utils.logging.withMdcContext
 
+import org.koin.ktor.ext.get
 import org.koin.ktor.ext.inject
 
 import org.slf4j.MDC
@@ -41,6 +44,7 @@ import org.slf4j.MDC
 fun Application.configureLifecycle() {
     environment.monitor.subscribe(DatabaseReady) {
         val authorizationService by inject<AuthorizationService>()
+        val maintenanceService by inject<MaintenanceService>()
 
         val mdcContext = MDC.getCopyOfContextMap()
 
@@ -50,6 +54,14 @@ fun Application.configureLifecycle() {
                 syncRoles(authorizationService)
             }
         }
+
+        thread {
+            MDC.setContextMap(mdcContext)
+            runBlocking(Dispatchers.IO) {
+                maintenanceService.addJob(DeduplicatePackagesJob(get()))
+                maintenanceService.run()
+            }
+        }
     }
 }