wait for save of kubeconfig to finish (#640)

Signed-off-by: Andre Dietisheim <[email protected]>

Author: adietish

src/main/kotlin/com/redhat/devtools/intellij/kubernetes/model/AllContexts.kt

@@ -143,6 +143,7 @@ open class AllContexts(
 				this.client.get()
 			)
 			this.current?.close()
+			newClient.config.save().join()
 			all.clear() // causes reload of all contexts when accessed afterwards
 			val newCurrent = this.current // gets new current from all
 			if (toWatch != null) {
@@ -197,7 +198,6 @@ open class AllContexts(
 	private fun replaceClient(new: ClientAdapter<out KubernetesClient>, old: ClientAdapter<out KubernetesClient>?)
 			: ClientAdapter<out KubernetesClient> {
 		old?.close()
-		new.config.save()
 		this.client.set(new)
 		return new
 	}

src/main/kotlin/com/redhat/devtools/intellij/kubernetes/model/client/ClientConfig.kt

@@ -12,11 +12,13 @@ package com.redhat.devtools.intellij.kubernetes.model.client
 
 import com.intellij.openapi.application.ApplicationManager
 import com.redhat.devtools.intellij.common.utils.ConfigHelper
+import com.redhat.devtools.intellij.kubernetes.CompletableFutureUtils.PLATFORM_EXECUTOR
 import io.fabric8.kubernetes.api.model.Context
 import io.fabric8.kubernetes.api.model.NamedContext
 import io.fabric8.kubernetes.client.Client
 import io.fabric8.kubernetes.client.Config
 import io.fabric8.kubernetes.client.internal.KubeConfigUtils
+import java.util.concurrent.CompletableFuture
 
 /**
  * An adapter to access [io.fabric8.kubernetes.client.Config].
@@ -45,26 +47,31 @@ open class ClientConfig(private val client: Client) {
 		KubeConfigAdapter()
 	}
 
-	fun save() {
-		runAsync {
-			if (!kubeConfig.exists()) {
-				return@runAsync
-			}
-			val fromFile = kubeConfig.load() ?: return@runAsync
-			val currentContextInFile = KubeConfigUtils.getCurrentContext(fromFile)
-			if (setCurrentContext(
-					currentContext,
-					currentContextInFile,
-					fromFile
-				).or( // no short-circuit
-				setCurrentNamespace(
-					currentContext?.context,
-					currentContextInFile?.context)
-				)
-			) {
-				kubeConfig.save(fromFile)
-			}
-		}
+	fun save(): CompletableFuture<Boolean> {
+		return CompletableFuture.supplyAsync(
+			{
+				if (!kubeConfig.exists()) {
+					return@supplyAsync false
+				}
+				val fromFile = kubeConfig.load() ?: return@supplyAsync false
+				val currentContextInFile = KubeConfigUtils.getCurrentContext(fromFile)
+				if (setCurrentContext(
+						currentContext,
+						currentContextInFile,
+						fromFile
+					).or( // no short-circuit
+						setCurrentNamespace(
+							currentContext?.context,
+							currentContextInFile?.context
+						)
+					)
+				) {
+					kubeConfig.save(fromFile)
+				}
+				return@supplyAsync true
+			},
+			PLATFORM_EXECUTOR
+		)
 	}
 
 	private fun setCurrentContext(