kubeconfig update

Author: csviri

src/main/java/com/csviri/kubeapi/APIServer.java

@@ -14,6 +14,7 @@ public class APIServer {
     private final APIServerConfig config;
     private BinaryManager binaryManager;
     private CertManager certManager;
+    private KubeConfigManager kubeConfigManager;
     private Process etcdProcess;
     private Process apiServerProcess;
 
@@ -25,6 +26,7 @@ public APIServer(APIServerConfig config) {
         this.config = config;
         this.binaryManager = new BinaryManager(config.getJenvtestDirectory());
         this.certManager = new CertManager(config.getJenvtestDirectory());
+        this.kubeConfigManager = new KubeConfigManager(certManager);
     }
 
     public void start() {
@@ -33,6 +35,7 @@ public void start() {
         cleanPreviousState();
         startEtcd();
         startApiServer();
+        kubeConfigManager.updateKubeConfig();
     }
 
     private void prepareLogDirectory() {

src/main/java/com/csviri/kubeapi/CertManager.java

@@ -66,6 +66,9 @@ private void generateUserCertificates() throws IOException, InterruptedException
     public String getClientCertPath() {
         return new File(jenvtestDir, CLIENT_CERT_NAME).getAbsolutePath();
     }
+    public String getClientKeyPath() {
+        return new File(jenvtestDir, CLIENT_KEY_NAME).getAbsolutePath();
+    }
 
     public String getAPIServerKeyPath() {
         return new File(jenvtestDir, API_SERVER_KEY_NAME).getAbsolutePath();

src/main/java/com/csviri/kubeapi/KubeConfigManager.java

@@ -3,36 +3,39 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import java.io.IOException;
+
 public class KubeConfigManager {
 
     private static final Logger log = LoggerFactory.getLogger(KubeConfigManager.class);
+    private CertManager certManager;
 
-    public void updateKubeConfig() {
-        log.debug("Adding settings to kubeconfig");
-        addUser();
-        addCluster();
-        addContext();
-        setDefaultContext();
-    }
-
-    public void removeFromKubeConfig() {
-        log.debug("Removing settings from kubeconfig");
-    }
-
-    private void addUser() {
-
+    public KubeConfigManager(CertManager certManager) {
+        this.certManager = certManager;
     }
 
-    private void addCluster() {
-
+    public void updateKubeConfig() {
+        log.debug("Updating kubeconfig");
+        execAndWait("kubectl", "config", "set-cluster", "jenvtest", "--server=https://127.0.0.1:6443",
+                "--certificate-authority=" + certManager.getAPIServerCertPath());
+        execAndWait("kubectl", "config", "set-credentials", "jenvtest",
+                "--client-certificate=" + certManager.getClientCertPath(), "--client-key=" + certManager.getClientKeyPath());
+        execAndWait("kubectl", "config", "set-context", "jenvtest", "--cluster=jenvtest",
+                "--namespace=default", "--user=jenvtest");
+        execAndWait("kubectl", "config", "use-context", "jenvtest");
     }
 
-    private void addContext() {
-
+    // todo
+    public void removeFromKubeConfig() {
+        log.debug("Cleanig up kubeconfig");
     }
 
-    private void setDefaultContext() {
-
+    private void execAndWait(String... arguments) {
+        try {
+            var process = new ProcessBuilder(arguments).start();
+            process.waitFor();
+        } catch (InterruptedException | IOException e) {
+            throw new KubeApiException(e);
+        }
     }
-
 }

src/main/java/com/csviri/kubeapi/junit/APIServerExtension.java

@@ -0,0 +1,4 @@
+package com.csviri.kubeapi.junit;
+
+public class APIServerExtension {
+}

src/main/java/com/csviri/kubeapi/junit/EnableAPIServer.java

@@ -0,0 +1,5 @@
+package com.csviri.kubeapi.junit;
+
+
+public @interface EnableAPIServer {
+}