Complete operator functionality (#235)

* Make the operator work

Signed-off-by: carlosthe19916 <2582866+carlosthe19916@users.noreply.github.com>

* Upgrade xbuilder version

Signed-off-by: carlosthe19916 <2582866+carlosthe19916@users.noreply.github.com>

* Upgrade xbuilder version

Signed-off-by: carlosthe19916 <2582866+carlosthe19916@users.noreply.github.com>

Signed-off-by: carlosthe19916 <2582866+carlosthe19916@users.noreply.github.com>

Author: carlosthe19916

application/pom.xml

@@ -58,7 +58,7 @@
         <dependency>
             <groupId>io.github.project-openubl</groupId>
             <artifactId>quarkus-xbuilder</artifactId>
-            <version>2.0.0.Beta2</version>
+            <version>2.0.0-Beta4</version>
         </dependency>
         <dependency>
             <groupId>io.github.project-openubl</groupId>

application/src/main/java/io/github/project/openubl/ublhub/files/health/impl/S3ReadinessCheck.java

@@ -27,27 +27,32 @@
 import java.net.http.HttpClient;
 import java.net.http.HttpRequest;
 import java.net.http.HttpResponse;
+import java.util.Optional;
 
 @ApplicationScoped
 @StorageProvider(StorageProvider.Type.S3)
 public class S3ReadinessCheck implements StorageReadinessCheck {
 
     @ConfigProperty(name = "openubl.storage.s3.health.url")
-    String s3HostHealthCheckUrl;
+    Optional<String> s3HostHealthCheckUrl;
 
     private final HttpClient client = HttpClient.newHttpClient();
 
     @Override
     public boolean isHealthy() {
-        try {
-            HttpRequest request = HttpRequest.newBuilder()
-                    .uri(new URI(s3HostHealthCheckUrl))
-                    .GET()
-                    .build();
-            HttpResponse<Void> response = client.send(request, HttpResponse.BodyHandlers.discarding());
-            return response.statusCode() == 200;
-        } catch (URISyntaxException | IOException | InterruptedException e) {
-            return false;
+        if (s3HostHealthCheckUrl.isPresent()) {
+            try {
+                HttpRequest request = HttpRequest.newBuilder()
+                        .uri(new URI(s3HostHealthCheckUrl.get()))
+                        .GET()
+                        .build();
+                HttpResponse<Void> response = client.send(request, HttpResponse.BodyHandlers.discarding());
+                return response.statusCode() == 200;
+            } catch (URISyntaxException | IOException | InterruptedException e) {
+                return false;
+            }
+        } else {
+            return true;
         }
     }
 }

application/src/main/java/io/github/project/openubl/ublhub/models/TsidUtil.java

@@ -25,7 +25,7 @@
 
 public class TsidUtil {
 
-    @ConfigProperty(name = "ublhub.tsid.bytes")
+    @ConfigProperty(name = "openubl.ublhub.tsid.bytes")
     int tsidBytes;
 
     @Produces

application/src/main/java/io/github/project/openubl/ublhub/scheduler/SchedulerManager.java

@@ -30,7 +30,7 @@
 @ApplicationScoped
 public class SchedulerManager {
 
-    @ConfigProperty(name = "openubl.scheduler.type")
+    @ConfigProperty(name = "openubl.ublhub.scheduler.type")
     String schedulerType;
 
     @Inject

application/src/main/java/io/github/project/openubl/ublhub/security/DisabledAuthController.java

@@ -29,7 +29,7 @@
 @ApplicationScoped
 public class DisabledAuthController extends AuthorizationController {
 
-    @ConfigProperty(name = "ublhub.disable.authorization")
+    @ConfigProperty(name = "openubl.ublhub.disable.authorization")
     boolean disableAuthorization;
 
     @Override

application/src/main/java/io/github/project/openubl/ublhub/ubl/builder/idgenerator/impl/GeneratedIDGenerator.java

@@ -42,7 +42,7 @@ public class GeneratedIDGenerator implements IDGenerator {
     public static final String SERIE_PROPERTY = "serie";
     public static final String NUMERO_PROPERTY = "numero";
 
-    @ConfigProperty(name = "openubl.xbuilder.timezone")
+    @ConfigProperty(name = "openubl.ublhub.timezone")
     String timezone;
 
     @Inject

application/src/main/resources/application.properties

@@ -1,6 +1,9 @@
 # Resources
 quarkus.native.resources.includes=schemas/*.json
 
+# For Key generation
+quarkus.security.security-providers=BC
+
 # Resteasy
 quarkus.resteasy-reactive.path=/api
 
@@ -141,20 +144,19 @@ quarkus.smallrye-openapi.info-license-url=https://www.apache.org/licenses/LICENS
 quarkus.smallrye-openapi.store-schema-directory=src/jreleaser/templates/article
 
 # XBuilder
-openubl.scheduler.type=vertx
-openubl.xbuilder.timezone=America/Lima
-
 quarkus.xbuilder.moneda=PEN
 quarkus.xbuilder.unidad-medida=NIU
 quarkus.xbuilder.igv-tasa=0.18
-quarkus.xbuilder.icb-tasa=0.2
+quarkus.xbuilder.icb-tasa=0.3
 
 # XSender
 quarkus.xsender.enable-logging-feature=false
 
 # Ublhub
-ublhub.disable.authorization=true
-ublhub.tsid.bytes=256
+openubl.ublhub.timezone=America/Lima
+openubl.ublhub.scheduler.type=vertx
+openubl.ublhub.disable.authorization=true
+openubl.ublhub.tsid.bytes=256
 
 # Profiles
 %basic.ublhub.disable.authorization=false

operator/src/main/java/io/github/project/openubl/operator/Constants.java

@@ -16,6 +16,8 @@
  */
 package io.github.project.openubl.operator;
 
+import io.github.project.openubl.operator.cdrs.v2alpha1.UblhubSpec;
+
 import java.util.Map;
 
 public class Constants {
@@ -44,6 +46,7 @@ public class Constants {
     public static final String INGRESS_SUFFIX = "-" + UBLHUB_NAME + "-ingress";
     public static final String SECRET_SUFFIX = "-" + UBLHUB_NAME + "-secret";
     public static final String DEPLOYMENT_SUFFIX = "-" + UBLHUB_NAME + "-deployment";
+    public static final String PVC_SUFFIX = "-" + UBLHUB_NAME + "-pvc";
 
     public static final String BASIC_AUTH_SECRET_SUFFIX = "-basic-auth";
 
@@ -56,6 +59,14 @@ public class Constants {
 
 
     public static final String CERTIFICATES_FOLDER = "/mnt/certificates";
-    public static final String WORKSPACES_FOLDER = "/mnt/workspace";
+    public static final String STORAGE_FOLDER = "/mnt/ublhub-storage";
 
+    public static final UblhubSpec.XBuilderSpec defaultXBuilderConfig = UblhubSpec.XBuilderSpec.builder()
+            .moneda("PEN")
+            .igvTasa("0.18")
+            .icbTasa("0.4")
+            .build();
+    public static final UblhubSpec.XSenderSpec defaultXSenderConfig = UblhubSpec.XSenderSpec.builder()
+            .enableLoggingFeature(false)
+            .build();
 }

operator/src/main/java/io/github/project/openubl/operator/cdrs/v2alpha1/UblhubFileStoragePVC.java

@@ -0,0 +1,78 @@
+/*
+ * Copyright 2019 Project OpenUBL, Inc. and/or its affiliates
+ * and other contributors as indicated by the @author tags.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package io.github.project.openubl.operator.cdrs.v2alpha1;
+
+import io.fabric8.kubernetes.api.model.PersistentVolumeClaim;
+import io.fabric8.kubernetes.api.model.PersistentVolumeClaimBuilder;
+import io.fabric8.kubernetes.api.model.PersistentVolumeClaimSpec;
+import io.fabric8.kubernetes.api.model.PersistentVolumeClaimSpecBuilder;
+import io.fabric8.kubernetes.api.model.Quantity;
+import io.fabric8.kubernetes.api.model.ResourceRequirementsBuilder;
+import io.github.project.openubl.operator.Constants;
+import io.github.project.openubl.operator.utils.CRDUtils;
+import io.javaoperatorsdk.operator.api.reconciler.Context;
+import io.javaoperatorsdk.operator.processing.dependent.kubernetes.CRUDKubernetesDependentResource;
+
+import java.util.Map;
+
+public class UblhubFileStoragePVC extends CRUDKubernetesDependentResource<PersistentVolumeClaim, Ublhub> {
+
+    public UblhubFileStoragePVC() {
+        super(PersistentVolumeClaim.class);
+    }
+
+    @Override
+    public PersistentVolumeClaim desired(Ublhub cr, Context context) {
+        return newPersistentVolumeClaim(cr, context);
+    }
+
+    @SuppressWarnings("unchecked")
+    private PersistentVolumeClaim newPersistentVolumeClaim(Ublhub cr, Context context) {
+        final var labels = (Map<String, String>) context.managedDependentResourceContext()
+                .getMandatory(Constants.CONTEXT_LABELS_KEY, Map.class);
+
+        PersistentVolumeClaim pvc = new PersistentVolumeClaimBuilder()
+                .withNewMetadata()
+                .withName(getPersistentVolumeClaimName(cr))
+                .withNamespace(cr.getMetadata().getNamespace())
+                .withLabels(labels)
+                .endMetadata()
+                .withSpec(getPersistentVolumeClaimSpec(cr))
+                .build();
+        return pvc;
+    }
+
+    private PersistentVolumeClaimSpec getPersistentVolumeClaimSpec(Ublhub cr) {
+        return new PersistentVolumeClaimSpecBuilder()
+                .withAccessModes("ReadWriteOnce")
+                .withResources(new ResourceRequirementsBuilder()
+                        .addToRequests("storage", new Quantity(cr.getSpec().getStorageSpec().getFilesystemSpec().getSize()))
+                        .build()
+                )
+                .build();
+    }
+
+    public static String getPersistentVolumeClaimName(Ublhub cr) {
+        return cr.getMetadata().getName() + "-filesystem" + Constants.PVC_SUFFIX;
+    }
+
+    public static boolean isTlsConfigured(Ublhub cr) {
+        var tlsSecret = CRDUtils.getValueFromSubSpec(cr.getSpec().getHttpSpec(), UblhubSpec.HttpSpec::getTlsSecret);
+        return tlsSecret.isPresent() && !tlsSecret.get().trim().isEmpty();
+    }
+
+}

operator/src/main/java/io/github/project/openubl/operator/cdrs/v2alpha1/UblhubSpec.java

@@ -72,9 +72,17 @@ public class UblhubSpec {
     @JsonPropertyDescription("In this section you can configure Oidc settings.")
     private OidcSpec oidcSpec;
 
-    @JsonProperty("sunat")
-    @JsonPropertyDescription("In this section you can configure SUNAT settings.")
-    private SunatSpec sunatSpec;
+    @JsonProperty("storage")
+    @JsonPropertyDescription("In this section you can configure the Storage.")
+    private StorageSpec storageSpec;
+
+    @JsonProperty("xbuilder")
+    @JsonPropertyDescription("XBuilder settings.")
+    private XBuilderSpec xBuilderSpec;
+
+    @JsonProperty("xsender")
+    @JsonPropertyDescription("XSender settings.")
+    private XSenderSpec xSenderSpec;
 
     @Data
     @Builder
@@ -152,12 +160,78 @@ public static class OidcSpec {
     @Builder
     @AllArgsConstructor
     @NoArgsConstructor
-    public static class SunatSpec {
-        @JsonPropertyDescription("Padron Reducido Url.")
-        private String padronReducidoUrl;
+    public static class StorageSpec {
+        public enum Type {
+            filesystem,
+            s3
+        }
+
+        @JsonPropertyDescription("Typo of chosen storage.")
+        private Type type;
+
+        @JsonProperty("filesystem")
+        @JsonPropertyDescription("Filesystem settings.")
+        private StorageFilesystemSpec filesystemSpec;
+
+        @JsonProperty("s3")
+        @JsonPropertyDescription("Filesystem settings.")
+        private StorageS3Spec s3Spec;
+    }
 
-        @JsonPropertyDescription("Cron for downloading the Padron Reducido.")
-        private String padronReducidoCron;
+    @Data
+    @Builder
+    @AllArgsConstructor
+    @NoArgsConstructor
+    public static class StorageFilesystemSpec {
+        @JsonPropertyDescription("Size of the PVC to create.")
+        private String size;
     }
 
+    @Data
+    @Builder
+    @AllArgsConstructor
+    @NoArgsConstructor
+    public static class StorageS3Spec {
+        @JsonPropertyDescription("Only if you are using Minio, otherwise leave it empty")
+        private String host;
+
+        @JsonPropertyDescription("Only if you are using Minio, otherwise leave it empty")
+        private String healthUrl;
+
+        @JsonPropertyDescription("Region")
+        private String region;
+
+        @JsonPropertyDescription("Bucket")
+        private String bucket;
+
+        @JsonPropertyDescription("Access key id")
+        private String accessKeyId;
+
+        @JsonPropertyDescription("Secret access key")
+        private String secretAccessKey;
+    }
+
+    @Data
+    @Builder
+    @AllArgsConstructor
+    @NoArgsConstructor
+    public static class XBuilderSpec {
+        @JsonPropertyDescription("Default currency")
+        private String moneda = "PEN";
+
+        @JsonPropertyDescription("Default IGV")
+        private String igvTasa;
+
+        @JsonPropertyDescription("Default ICB")
+        private String icbTasa;
+    }
+
+    @Data
+    @Builder
+    @AllArgsConstructor
+    @NoArgsConstructor
+    public static class XSenderSpec {
+        @JsonPropertyDescription("Enable logging feature")
+        private Boolean enableLoggingFeature = false;
+    }
 }