fix: sekeleton

Author: csviri

core/src/main/java/io/javaoperatorsdk/admissioncontroller/api/AdmissionControllerException.java

@@ -0,0 +1,23 @@
+package io.javaoperatorsdk.admissioncontroller.api;
+
+public class AdmissionControllerException extends RuntimeException {
+
+    public AdmissionControllerException() {
+    }
+
+    public AdmissionControllerException(String message) {
+        super(message);
+    }
+
+    public AdmissionControllerException(String message, Throwable cause) {
+        super(message, cause);
+    }
+
+    public AdmissionControllerException(Throwable cause) {
+        super(cause);
+    }
+
+    public AdmissionControllerException(String message, Throwable cause, boolean enableSuppression, boolean writableStackTrace) {
+        super(message, cause, enableSuppression, writableStackTrace);
+    }
+}

core/src/main/java/io/javaoperatorsdk/admissioncontroller/api/Validator.java

@@ -0,0 +1,16 @@
+package io.javaoperatorsdk.admissioncontroller.api.clone;
+
+import io.fabric8.kubernetes.api.model.HasMetadata;
+
+public interface Cloner {
+
+  /**
+   * Returns a deep copy of the given object if not {@code null} or {@code null} otherwise.
+   *
+   * @param object the object to be cloned
+   * @param <R> the type of the object to be cloned
+   * @return a deep copy of the given object if it isn't {@code null}, {@code null} otherwise
+   */
+  <R> R clone(R object);
+
+}

core/src/main/java/io/javaoperatorsdk/admissioncontroller/api/clone/Cloner.java

@@ -0,0 +1,21 @@
+package io.javaoperatorsdk.admissioncontroller.api.clone;
+
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
+
+public class ObjectMapperCloner implements Cloner{
+
+    private final ObjectMapper OBJECT_MAPPER = new ObjectMapper();
+
+    @Override
+    public <R> R clone(R object) {
+        if (object == null) {
+            return null;
+        }
+        try {
+            return (R) OBJECT_MAPPER.readValue(OBJECT_MAPPER.writeValueAsString(object), object.getClass());
+        } catch (JsonProcessingException e) {
+            throw new IllegalStateException(e);
+        }
+    }
+}

core/src/main/java/io/javaoperatorsdk/admissioncontroller/api/clone/ObjectMapperCloner.java

@@ -0,0 +1,30 @@
+package io.javaoperatorsdk.admissioncontroller.api.mutation;
+
+import io.fabric8.kubernetes.api.model.admission.v1.AdmissionRequest;
+import io.fabric8.kubernetes.api.model.admission.v1.AdmissionResponse;
+import io.javaoperatorsdk.admissioncontroller.api.clone.Cloner;
+import io.javaoperatorsdk.admissioncontroller.api.clone.ObjectMapperCloner;
+
+public class DefaultRequestResponseMutator<T> implements RequestResponseMutator {
+
+    private final Mutator<T> mutator;
+    private final Cloner cloner;
+
+    public DefaultRequestResponseMutator(Mutator<T> mutator) {
+        this(mutator, new ObjectMapperCloner());
+    }
+
+    public DefaultRequestResponseMutator(Mutator<T> mutator, Cloner cloner) {
+        this.mutator = mutator;
+        this.cloner = cloner;
+    }
+
+    @Override
+    public AdmissionResponse mutate(AdmissionRequest admissionRequest) {
+        admissionRequest.getObject();
+
+
+        return null;
+    }
+
+}

core/src/main/java/io/javaoperatorsdk/admissioncontroller/api/mutation/DefaultRequestResponseMutator.java

@@ -0,0 +1,24 @@
+package io.javaoperatorsdk.admissioncontroller.api.mutation;
+
+import io.fabric8.kubernetes.api.model.admission.v1.AdmissionReview;
+
+public class MutatingAdmissionController<T> {
+
+    private final RequestResponseMutator requestResponseMutator;
+
+    public MutatingAdmissionController(Mutator<T> mutator) {
+        this(new DefaultRequestResponseMutator<>(mutator));
+    }
+
+    public MutatingAdmissionController(RequestResponseMutator requestResponseMutator) {
+        this.requestResponseMutator = requestResponseMutator;
+    }
+
+    public AdmissionReview handle(AdmissionReview admissionReview) {
+        var response = requestResponseMutator.mutate(admissionReview.getRequest());
+        AdmissionReview responseAdmissionReview = new AdmissionReview();
+        responseAdmissionReview.setResponse(response);
+        response.setUid(admissionReview.getRequest().getUid());
+        return responseAdmissionReview;
+    }
+}

core/src/main/java/io/javaoperatorsdk/admissioncontroller/api/mutation/MutatingAdmissionController.java

@@ -0,0 +1,7 @@
+package io.javaoperatorsdk.admissioncontroller.api.mutation;
+
+public interface Mutator<T> {
+
+    T mutate(T resource);
+
+}

core/src/main/java/io/javaoperatorsdk/admissioncontroller/api/mutation/Mutator.java

@@ -0,0 +1,10 @@
+package io.javaoperatorsdk.admissioncontroller.api.mutation;
+
+import io.fabric8.kubernetes.api.model.admission.v1.AdmissionRequest;
+import io.fabric8.kubernetes.api.model.admission.v1.AdmissionResponse;
+
+public interface RequestResponseMutator {
+
+    AdmissionResponse mutate(AdmissionRequest admissionRequest);
+
+}

core/src/main/java/io/javaoperatorsdk/admissioncontroller/api/mutation/RequestResponseMutator.java

@@ -0,0 +1,11 @@
+package io.javaoperatorsdk.admissioncontroller.api.validation;
+
+import io.fabric8.kubernetes.api.model.admission.v1.AdmissionReview;
+
+public class ValidatingAdmissionController {
+
+    public AdmissionReview handle(AdmissionReview admissionReview) {
+        return null;
+    }
+
+}

core/src/main/java/io/javaoperatorsdk/admissioncontroller/api/validation/ValidatingAdmissionController.java

@@ -0,0 +1,7 @@
+package io.javaoperatorsdk.admissioncontroller.api.validation;
+
+import io.javaoperatorsdk.admissioncontroller.api.AdmissionControllerException;
+
+public class ValidationException extends AdmissionControllerException {
+
+}