BC-7234 - read configmap for understanding the how to interact with t…

…he k8s API (#9)

.github/workflows/push.yml

@@ -53,6 +53,13 @@ jobs:
           -Dsonar.host.url=https://sonarcloud.io \
           -Dsonar.organization=schulcloud-verbund \
           -Dsonar.projectKey=hpi-schul-cloud_doido-mongo
+      
+      - name: Upload Report
+        uses: actions/upload-artifact@v4
+        if: always()
+        with:
+          name: report
+          path: target/jacoco-report
 
 
 
@@ -78,13 +85,6 @@ jobs:
         run: |
          ./mvnw install -Dnative -Dquarkus.native.container-build=true
          ls -la
-      
-      - name: Upload Report
-        uses: actions/upload-artifact@v3
-        if: always()
-        with:
-          name: my-report
-          path: target/jacoco-report/jacoco.xml
 
       - name: Login to registry
         uses: docker/login-action@v3

lombok.config

@@ -0,0 +1,2 @@
+config.stopBubbling = true
+lombok.addLombokGeneratedAnnotation = true

pom.xml

@@ -65,6 +65,17 @@
       <groupId>io.quarkus</groupId>
       <artifactId>quarkus-resteasy-reactive-jackson</artifactId>
     </dependency>
+    <dependency>
+      <groupId>org.projectlombok</groupId>
+      <artifactId>lombok</artifactId>
+      <version>1.18.30</version>
+      <scope>provided</scope>
+    </dependency>
+    <dependency>
+      <groupId>commons-validator</groupId>
+      <artifactId>commons-validator</artifactId>
+      <version>1.8.0</version>
+    </dependency>
   </dependencies>
   <build>
     <plugins>

src/main/java/de/svs/doido/mongo/ConfigmapApi.java

@@ -0,0 +1,23 @@
+package svs.doido.mongo;
+
+import jakarta.ws.rs.Path;
+import jakarta.ws.rs.GET;
+import jakarta.ws.rs.Produces;
+import jakarta.ws.rs.core.MediaType;
+import jakarta.inject.Inject;
+import svs.doido.mongo.dto.Configmap;
+import svs.doido.mongo.kubernetes.configmap.Read;
+
+@Path("/configmap")
+public class ConfigmapApi {
+
+    @Inject
+    Read cfg;
+
+    @GET
+    @Path("/{namespace}/{configmapName}")
+    @Produces(MediaType.APPLICATION_JSON)
+    public Configmap configmaps(String namespace, String configmapName) {
+        return cfg.readConfigmap(namespace,configmapName);
+    }
+}

src/main/java/de/svs/doido/mongo/dto/Configmap.java

@@ -0,0 +1,28 @@
+package svs.doido.mongo.dto;
+
+import lombok.Getter;
+import lombok.Setter;
+import lombok.ToString;
+import lombok.EqualsAndHashCode;
+import org.apache.commons.validator.routines.UrlValidator;
+import jakarta.enterprise.context.RequestScoped;
+
+
+@ToString
+@EqualsAndHashCode
+@RequestScoped
+public class Configmap {
+    @Getter
+    @Setter
+    private String name = "";
+
+    @Getter
+    private String uri = "";
+
+    public void setUri(String uriIn) {
+        UrlValidator urlValidator = new UrlValidator( UrlValidator.ALLOW_ALL_SCHEMES|UrlValidator.ALLOW_LOCAL_URLS );
+        if (urlValidator.isValid( uriIn )) {
+            uri = uriIn;
+        }
+    }
+}

src/main/java/de/svs/doido/mongo/kubernetes/configmap/Read.java

@@ -0,0 +1,26 @@
+package svs.doido.mongo.kubernetes.configmap;
+
+import svs.doido.mongo.dto.Configmap;
+import io.fabric8.kubernetes.api.model.ConfigMap;
+import io.fabric8.kubernetes.api.model.ObjectMeta;
+import io.fabric8.kubernetes.client.KubernetesClient;
+import jakarta.inject.Inject;
+import jakarta.enterprise.context.RequestScoped;
+
+
+@RequestScoped
+public class Read {
+
+    @Inject
+    Configmap cfg;
+
+    @Inject
+    KubernetesClient client;
+
+    public Configmap readConfigmap(String namespace, String name) {
+        ConfigMap configmap = client.configMaps().inNamespace(namespace).withName(name).get();
+        cfg.setName(configmap.getMetadata().getName());
+        cfg.setUri(configmap.getData().get("uri"));
+        return cfg;
+    }
+}

src/test/java/de/svs/doido/mongo/ConfigmapApiTest.java

@@ -0,0 +1,66 @@
+package svs.doido.mongo;
+
+import io.quarkus.test.junit.QuarkusTest;
+import io.quarkus.test.kubernetes.client.KubernetesTestServer;
+import io.quarkus.test.kubernetes.client.WithKubernetesTestServer;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.AfterEach;
+import jakarta.inject.Inject;
+
+import io.fabric8.kubernetes.client.KubernetesClient;
+import io.fabric8.kubernetes.client.server.mock.KubernetesServer;
+import io.fabric8.kubernetes.api.model.Namespace;
+import io.fabric8.kubernetes.api.model.NamespaceBuilder;
+import io.fabric8.kubernetes.api.model.ConfigMap;
+import io.fabric8.kubernetes.api.model.ConfigMapBuilder;
+
+import java.util.HashMap;
+
+import static io.restassured.RestAssured.given;
+import static org.hamcrest.CoreMatchers.is;
+
+
+
+
+@WithKubernetesTestServer
+@QuarkusTest
+class ConfigmapApiTest {
+
+    @KubernetesTestServer
+    KubernetesServer mockServer;
+    @Inject
+    KubernetesClient client;
+
+    @BeforeEach
+    public void before() {
+        final Namespace namespace1 = new NamespaceBuilder().withNewMetadata().withName("namespaceA").and().build();
+        final ConfigMap cfgTest = new ConfigMapBuilder().withNewMetadata().withName("test").withNamespace("namespaceA").and().build();
+        final HashMap<String,String> data = new HashMap<String,String>();
+        data.put("uri","http://www.test.de");
+        cfgTest.setData(data);
+
+        // Set up Kubernetes so that our "pretend" pods namespaces created
+        client.namespaces().resource(namespace1).create();
+        client.configMaps().resource(cfgTest).create();
+    }
+
+    @AfterEach
+    public void after() {
+        final Namespace namespace1 = new NamespaceBuilder().withNewMetadata().withName("namespaceA").and().build();
+
+        // Set up Kubernetes so that our "pretend" namespaces are deleted
+        client.namespaces().resource(namespace1).delete();
+    }
+
+
+    @Test
+    void testInteractionWithAPIServerForConfigmaps() {
+        given()
+            .when().get("/configmap/namespaceA/test")
+            .then()
+            .statusCode(200)
+            .body("size()", is(2));
+    }
+
+}

src/test/java/de/svs/doido/mongo/dto/ConfigmapTest.java

@@ -0,0 +1,38 @@
+package svs.doido.mongo.dto;
+
+import io.quarkus.test.junit.QuarkusTest;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.BeforeEach;
+import static org.junit.jupiter.api.Assertions.assertEquals;
+
+@QuarkusTest
+class ConfigmapTest {
+
+    private Configmap c;
+
+    @BeforeEach
+    public void before() {
+        c = new Configmap();
+    }
+
+    @Test
+    void testGetterSetterName() {
+        String name = "hausboot";
+        c.setName(name);
+        assertEquals(name,c.getName());
+    }
+
+    @Test
+    void testGetterSetterUri() {
+        String uri = "proto://foo.bar.com/";
+        c.setUri(uri);
+        assertEquals(uri,c.getUri());
+    }
+
+    @Test
+    void testGetterSetterUriFail() {
+        String uri = "proto:foo.bar.com/";
+        c.setUri(uri);
+        assertEquals("", c.getUri());
+    }
+}