Put back the option to start the api without access to kubernetes

- The kubernetes api client setup can be disabled using the property
  'csm.platform.kubernetesAccessEnabled=false' with a runtime error if
  trying to use it
- If enabled, the kubernetes context can be overriden with the JVM
  property 'useKubernetesContext=my-context' (renamed from
  localKubernetesContext)

Author: sjoubert

src/main/kotlin/com/cosmotech/api/utils/KubernetesApiConfig.kt

@@ -8,14 +8,16 @@ import io.kubernetes.client.util.ClientBuilder
 import io.kubernetes.client.util.KubeConfig
 import java.io.FileReader
 import java.io.IOException
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty
 import org.springframework.context.annotation.Bean
 import org.springframework.context.annotation.Configuration
 
 @Configuration
 open class KubernetesApiConfig {
   @Bean
+  @ConditionalOnProperty(name = ["csm.platform.kubernetesAccessEnabled"], havingValue = "true", matchIfMissing = true)
   open fun coreV1Api(csmPlatformProperties: CsmPlatformProperties): CoreV1Api {
-    val kubernetesContext = System.getProperty("localKubernetesContext")
+    val kubernetesContext = System.getProperty("useKubernetesContext")
     if (kubernetesContext != null) {
       // Locate kube config file
       val kubeConfigPath =

src/main/kotlin/com/cosmotech/api/utils/KubernetesService.kt

@@ -12,7 +12,7 @@ import org.springframework.stereotype.Service
 private const val SECRET_LABEL = "cosmotech.com/context"
 
 @Service
-class KubernetesService(private val kubernetesApi: CoreV1Api) : SecretManager {
+class KubernetesService(private val kubernetesApi: CoreV1Api?) : SecretManager {
 
   private val logger = LoggerFactory.getLogger(KubernetesService::class.java)
 
@@ -30,22 +30,23 @@ class KubernetesService(private val kubernetesApi: CoreV1Api) : SecretManager {
   }
 
   private fun deleteSecretFromKubernetes(namespace: String, secretName: String) {
+    val api = checkKubernetesContext()
     val secretNameLower = secretName.lowercase()
     val labelSelector = buildLabelSector(secretNameLower)
 
-    val secrets =
-        kubernetesApi.listNamespacedSecret(namespace).labelSelector(labelSelector).execute()
+    val secrets = api.listNamespacedSecret(namespace).labelSelector(labelSelector).execute()
     if (secrets.items.isEmpty()) {
       logger.debug("Secret does not exists in namespace $namespace: cannot delete it")
     } else {
       logger.info("Secret exists in namespace $namespace: deleting it")
-      kubernetesApi.deleteNamespacedSecret(secretNameLower, namespace).execute()
+      api.deleteNamespacedSecret(secretNameLower, namespace).execute()
     }
   }
 
   private fun getSecretFromKubernetes(namespace: String, secretName: String): Map<String, String> {
+    val api = checkKubernetesContext()
     val secretNameLower = secretName.lowercase()
-    val result = kubernetesApi.readNamespacedSecret(secretNameLower, namespace).execute()
+    val result = api.readNamespacedSecret(secretNameLower, namespace).execute()
 
     logger.debug("Secret retrieved for namespace $namespace")
     return result.data?.mapValues { Base64.getDecoder().decode(it.value).toString(Charsets.UTF_8) }
@@ -57,6 +58,7 @@ class KubernetesService(private val kubernetesApi: CoreV1Api) : SecretManager {
       secretName: String,
       secretData: Map<String, String>
   ) {
+    val api = checkKubernetesContext()
     logger.debug("Creating secret $secretName in namespace $namespace")
 
     val secretNameLower = secretName.lowercase()
@@ -72,17 +74,20 @@ class KubernetesService(private val kubernetesApi: CoreV1Api) : SecretManager {
     body.data = secretData.mapValues { Base64.getEncoder().encode(it.value.toByteArray()) }
     body.type = "Opaque"
 
-    val secrets =
-        kubernetesApi.listNamespacedSecret(namespace).labelSelector(labelSelector).execute()
+    val secrets = api.listNamespacedSecret(namespace).labelSelector(labelSelector).execute()
     if (secrets.items.isEmpty()) {
       logger.debug("Secret does not exists in namespace $namespace: creating it")
-      kubernetesApi.createNamespacedSecret(namespace, body).execute()
+      api.createNamespacedSecret(namespace, body).execute()
     } else {
       logger.debug("Secret already exists in namespace $namespace: replacing it")
-      kubernetesApi.replaceNamespacedSecret(secretNameLower, namespace, body).execute()
+      api.replaceNamespacedSecret(secretNameLower, namespace, body).execute()
     }
     logger.info("Secret created/replaced")
   }
 
+  private fun checkKubernetesContext(): CoreV1Api {
+    return kubernetesApi ?: throw IllegalStateException("Kubernetes API is not available")
+  }
+
   private fun buildLabelSector(secretName: String) = "$SECRET_LABEL=$secretName"
 }