refactor(workers): Use the SecretService for resolving secret values

Use the `SecretService` to resolve secret values instead of creating a
separate instance of `SecretStorage` in `WorkerContextImpl`.

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

Author: mnonnenmacher

workers/common/src/main/kotlin/common/context/WorkerContextImpl.kt

@@ -81,11 +81,8 @@ internal class WorkerContextImpl(
     /** The service for accessing secrets. */
     private val secretService: SecretService
 ) : WorkerContext {
-    /** The object for accessing secrets. */
-    private val secretStorage by lazy { SecretStorage.createStorage(configManager) }
-
     /** A cache for the secrets that have already been loaded. */
-    private val secretsCache = ConcurrentHashMap<String, Deferred<String>>()
+    private val secretsCache = ConcurrentHashMap<Secret, Deferred<String>>()
 
     /** A cache for the configuration secrets that have already been loaded. */
     private val configSecretsCache = ConcurrentHashMap<String, Deferred<String>>()
@@ -130,10 +127,10 @@ internal class WorkerContextImpl(
     private val currentContext by lazy { ortRun.resolvedJobConfigContext?.let(::Context) }
 
     override suspend fun resolveSecret(secret: Secret): String =
-        singleTransform(secret, secretsCache, this::resolveSecret, ::extractSecretKey)
+        singleTransform(secret, secretsCache, ::resolveSecretValue) { it }
 
     override suspend fun resolveSecrets(vararg secrets: Secret): Map<Secret, String> =
-        parallelTransform(secrets.toList(), secretsCache, this::resolveSecret, ::extractSecretKey)
+        parallelTransform(secrets.toList(), secretsCache, ::resolveSecretValue) { it }
 
     override suspend fun resolvePluginConfigSecrets(
         config: Map<String, ResolvablePluginConfig>?
@@ -263,10 +260,10 @@ internal class WorkerContextImpl(
         }
 
     /**
-     * Resolve the secret with the given [path] using the [SecretStorage] owned by this instance.
+     * Resolve the value of the provided [secret] using the [secretService].
      */
-    private fun resolveSecret(path: String): String =
-        secretStorage.getSecret(Path(path)).value
+    private fun resolveSecretValue(secret: Secret): String =
+        secretService.getSecretValue(secret)?.value ?: error("Could not resolve secret at path '${secret.path}'")
 
     /**
      * Resolve the given [secret] from the configuration manager.
@@ -287,11 +284,6 @@ internal class WorkerContextImpl(
         }
 }
 
-/**
- * A key extraction function for [Secret]s. As key for the given [secret] its path is used.
- */
-private fun extractSecretKey(secret: Secret): String = secret.path
-
 /**
  * Return a key extraction function for configuration files that are downloaded to the given [directory] and optionally
  * renamed to the given [targetName]. The resulting function ensures that all relevant components are reflected in

workers/common/src/test/kotlin/common/context/WorkerContextTest.kt

@@ -47,6 +47,7 @@ import io.mockk.runs
 import io.mockk.slot
 import io.mockk.unmockkAll
 import io.mockk.verify
+import org.eclipse.apoapsis.ortserver.components.secrets.SecretService
 
 import org.eclipse.apoapsis.ortserver.config.ConfigFileProviderFactoryForTesting
 import org.eclipse.apoapsis.ortserver.config.ConfigManager
@@ -63,6 +64,7 @@ import org.eclipse.apoapsis.ortserver.model.Secret
 import org.eclipse.apoapsis.ortserver.model.SecretSource
 import org.eclipse.apoapsis.ortserver.model.repositories.OrtRunRepository
 import org.eclipse.apoapsis.ortserver.model.repositories.RepositoryRepository
+import org.eclipse.apoapsis.ortserver.model.repositories.SecretRepository
 import org.eclipse.apoapsis.ortserver.secrets.Path as SecretPath
 import org.eclipse.apoapsis.ortserver.secrets.SecretStorage
 import org.eclipse.apoapsis.ortserver.secrets.SecretValue
@@ -572,9 +574,6 @@ class WorkerContextTest : WordSpec({
         "be aware of later changes of authentication data" {
             val context = helper.context()
 
-            // Make sure the secrets provider is initialized.
-            context.resolveSecret(createSecret(SecretsProviderFactoryForTesting.PASSWORD_PATH.path))
-
             val resolverFun = context.credentialResolverFun
 
             val secretsProvider = SecretsProviderFactoryForTesting.instance()
@@ -650,8 +649,19 @@ private class ContextFactoryTestHelper {
     /** Mock for the [RepositoryRepository]. */
     val repositoryRepository: RepositoryRepository = mockk()
 
+    /** Mock for the [SecretRepository]. */
+    val secretRepository: SecretRepository = mockk()
+
+    /** The [SecretService] used by the test factory. */
+    val secretService = SecretService(
+        mockk(),
+        secretRepository,
+        SecretStorage(SecretsProviderFactoryForTesting().createProvider())
+    )
+
     /** The factory to be tested. */
-    val factory: WorkerContextFactory = WorkerContextFactory(config, ortRunRepository, repositoryRepository, mockk())
+    val factory: WorkerContextFactory =
+        WorkerContextFactory(config, ortRunRepository, repositoryRepository, secretService)
 
     /**
      * Prepare the mock [OrtRunRepository] to be queried for the test run ID. Return a mock run that is also returned