Quarkus sample (#5)

* fix: quakus sample wip

* fix: tests

Author: csviri

pom.xml

@@ -189,6 +189,7 @@
             </plugins>
         </pluginManagement>
         <plugins>
+
             <plugin>
                 <groupId>org.commonjava.maven.plugins</groupId>
                 <artifactId>directory-maven-plugin</artifactId>

samples/spring-boot/manual-test.http renamed to samples/manual-test.http

@@ -9,7 +9,7 @@
   </parent>
   <groupId>io.javaoperatorsdk.admissioncontroller.sample</groupId>
   <artifactId>quarkus-sample</artifactId>
-  <version>1.0.0-SNAPSHOT</version>
+  <name>Admission Controller Framework - Samples - Quarkus</name>
   <properties>
     <compiler-plugin.version>3.8.1</compiler-plugin.version>
     <maven.compiler.release>11</maven.compiler.release>
@@ -40,6 +40,11 @@
       <groupId>io.quarkus</groupId>
       <artifactId>quarkus-resteasy</artifactId>
     </dependency>
+    <dependency>
+      <groupId>io.javaoperatorsdk</groupId>
+      <artifactId>operator-framework-framework-core</artifactId>
+      <version>${project.version}</version>
+    </dependency>
     <dependency>
       <groupId>io.quarkus</groupId>
       <artifactId>quarkus-junit5</artifactId>
@@ -50,6 +55,10 @@
       <artifactId>rest-assured</artifactId>
       <scope>test</scope>
     </dependency>
+    <dependency>
+      <groupId>org.jboss.resteasy</groupId>
+      <artifactId>resteasy-jackson2-provider</artifactId>
+    </dependency>
   </dependencies>
   <build>
     <plugins>

samples/quarkus/pom.xml

@@ -0,0 +1,35 @@
+package io.javaoperatorsdk.admissioncontroller.sample.quarkus;
+
+import javax.enterprise.context.Dependent;
+import javax.inject.Named;
+import javax.inject.Singleton;
+
+import io.fabric8.kubernetes.api.model.Pod;
+import io.javaoperatorsdk.admissioncontroller.AdmissionController;
+import io.javaoperatorsdk.admissioncontroller.NotAllowedException;
+
+@Dependent
+public class AdmissionControllerConfig {
+
+  public static final String APP_NAME_LABEL_KEY = "app.kubernetes.io/name";
+
+  @Singleton
+  @Named("mutatingController")
+  public AdmissionController<Pod> mutatingController() {
+    return new AdmissionController<>((resource, operation) -> {
+      resource.getMetadata().getLabels().putIfAbsent(APP_NAME_LABEL_KEY, "mutation-test");
+      return resource;
+    });
+  }
+
+  @Singleton
+  @Named("validatingController")
+  public AdmissionController<Pod> validatingController() {
+    return new AdmissionController<>((resource, operation) -> {
+      if (resource.getMetadata().getLabels().get(APP_NAME_LABEL_KEY) == null) {
+        throw new NotAllowedException("Missing label: " + APP_NAME_LABEL_KEY);
+      }
+    });
+  }
+
+}

samples/quarkus/src/main/java/io/javaoperatorsdk/admissioncontroller/sample/quarkus/AdmissionControllerConfig.java

@@ -0,0 +1,41 @@
+package io.javaoperatorsdk.admissioncontroller.sample.quarkus;
+
+import javax.inject.Inject;
+import javax.inject.Named;
+import javax.ws.rs.*;
+import javax.ws.rs.core.MediaType;
+
+import io.fabric8.kubernetes.api.model.Pod;
+import io.fabric8.kubernetes.api.model.admission.v1.AdmissionReview;
+import io.javaoperatorsdk.admissioncontroller.AdmissionController;
+
+@Path("/")
+public class AdmissionEndpoint {
+
+  private AdmissionController<Pod> mutationController;
+  private AdmissionController<Pod> validationController;
+
+  @Inject
+  public AdmissionEndpoint(@Named("mutatingController") AdmissionController<Pod> mutationController,
+      @Named("validatingController") AdmissionController<Pod> validationController) {
+    this.mutationController = mutationController;
+    this.validationController = validationController;
+  }
+
+  @POST
+  @Path("mutate")
+  @Consumes(MediaType.APPLICATION_JSON)
+  @Produces(MediaType.APPLICATION_JSON)
+  public AdmissionReview mutate(AdmissionReview admissionReview) {
+    return mutationController.handle(admissionReview);
+  }
+
+  @POST
+  @Path("validate")
+  @Consumes(MediaType.APPLICATION_JSON)
+  @Produces(MediaType.APPLICATION_JSON)
+  public AdmissionReview hello(AdmissionReview admissionReview) {
+    return validationController.handle(admissionReview);
+  }
+
+}

samples/quarkus/src/main/java/io/javaoperatorsdk/admissioncontroller/sample/quarkus/AdmissionEndpoint.java

@@ -0,0 +1,48 @@
+package io.javaoperatorsdk.admissioncontroller.sample.quarkus;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.nio.charset.StandardCharsets;
+
+import org.junit.jupiter.api.Test;
+
+import io.quarkus.test.junit.QuarkusTest;
+import io.restassured.http.ContentType;
+
+import static io.restassured.RestAssured.given;
+import static org.hamcrest.CoreMatchers.is;
+
+@QuarkusTest
+public class AdmissionEndpointTest {
+
+  @Test
+  public void mutates() {
+    given().contentType(ContentType.JSON)
+        .body(jsonRequest())
+        .when().post("/mutate")
+        .then()
+        .statusCode(200)
+        .body(is(
+            "{\"apiVersion\":\"admission.k8s.io/v1\",\"kind\":\"AdmissionReview\",\"response\":{\"allowed\":true,\"patch\":\"W3sib3AiOiJhZGQiLCJwYXRoIjoiL21ldGFkYXRhL2xhYmVscy9hcHAua3ViZXJuZXRlcy5pb34xbmFtZSIsInZhbHVlIjoibXV0YXRpb24tdGVzdCJ9XQ==\",\"patchType\":\"JSONPatch\",\"uid\":\"0df28fbd-5f5f-11e8-bc74-36e6bb280816\"}}"));
+  }
+
+  @Test
+  public void validates() {
+    given().contentType(ContentType.JSON)
+        .body(jsonRequest())
+        .when().post("/validate")
+        .then()
+        .statusCode(200)
+        .body(is(
+            "{\"apiVersion\":\"admission.k8s.io/v1\",\"kind\":\"AdmissionReview\",\"response\":{\"allowed\":false,\"status\":{\"apiVersion\":\"v1\",\"kind\":\"Status\",\"code\":403,\"message\":\"Missing label: app.kubernetes.io/name\"},\"uid\":\"0df28fbd-5f5f-11e8-bc74-36e6bb280816\"}}"));
+  }
+
+  private String jsonRequest() {
+    try (InputStream is = this.getClass().getResourceAsStream("/admission-request.json")) {
+      return new String(is.readAllBytes(), StandardCharsets.UTF_8);
+    } catch (IOException e) {
+      throw new IllegalStateException(e);
+    }
+  }
+
+}

samples/quarkus/src/main/java/org/acme/getting/started/GreetingResource.java

@@ -0,0 +1,9 @@
+package io.javaoperatorsdk.admissioncontroller.sample.quarkus;
+
+import io.quarkus.test.junit.NativeImageTest;
+
+@NativeImageTest
+public class NativeAdmissionEndpointIT extends AdmissionEndpointTest {
+
+  // Execute the same tests but in native mode.
+}