Refactor from run-input-processing to plain simulation service

flawmop · Sep 21, 2024 · 33a4afd · 33a4afd
1 parent 4f34bcc
commit 33a4afd
Show file tree

Hide file tree

Showing 37 changed files with 131 additions and 132 deletions.
diff --git a/.github/workflows/acceptance-stage.yml b/.github/workflows/acceptance-stage.yml
@@ -9,7 +9,7 @@ concurrency: acceptance
 env:
   OWNER: flawmop
   REGISTRY: ghcr.io
-  APP_REPO: run-input-processing-svc
+  APP_REPO: simulation-svc
   DEPLOY_REPO: portal-deploy
   VERSION: ${{ github.sha }}
 

diff --git a/.github/workflows/commit-stage.yml b/.github/workflows/commit-stage.yml
@@ -4,8 +4,8 @@ on: push
 env:
   OWNER: flawmop
   REGISTRY: ghcr.io
-  IMAGE_NAME: flawmop/run-input-processing-svc
-  APP_REPO: run-input-processing-svc
+  IMAGE_NAME: flawmop/simulation-svc
+  APP_REPO: simulation-svc
   DEPLOY_REPO: portal-deploy
   VERSION: ${{ github.sha }}
 

diff --git a/README.md b/README.md
@@ -1 +1 @@
-Run Input Processing Service
+Simulation Service
diff --git a/k8s/deployment.yml b/k8s/deployment.yml
@@ -1,22 +1,22 @@
 apiVersion: apps/v1
 kind: Deployment
 metadata:
-  name: run-input-processing-svc
+  name: simulation-svc
   labels:
-    app: run-input-processing-svc
+    app: simulation-svc
 spec:
   replicas: 1
   selector:
     matchLabels:
-      app: run-input-processing-svc
+      app: simulation-svc
   template:
     metadata:
       labels:
-        app: run-input-processing-svc
+        app: simulation-svc
     spec:
       containers:
-        - name: run-input-processing-svc
-          image: ghcr.io/flawmop/run-input-processing-svc
+        - name: simulation-svc
+          image: ghcr.io/flawmop/simulation-svc
           imagePullPolicy: IfNotPresent
           lifecycle:
             preStop:
@@ -25,9 +25,9 @@ spec:
           ports:
             - containerPort: 9002
           volumeMounts:
-            - name: run-input-processing-config-volume
+            - name: simulation-config-volume
               mountPath: /workspace/config
       volumes:
-        - name: run-input-processing-config-volume
+        - name: simulation-config-volume
           configMap:
-            name: run-input-processing-config
+            name: simulation-config
diff --git a/k8s/kustomization.yml b/k8s/kustomization.yml
@@ -6,11 +6,11 @@ resources:
   - service.yml
 
 configMapGenerator:
-  - name: run-input-processing-config
+  - name: simulation-config
     files:
       - application.yml
 
 generatorOptions:
   #disableNameSuffixHash: true
   labels:
-    app: run-input-processing-svc
+    app: simulation-svc
diff --git a/k8s/service.yml b/k8s/service.yml
@@ -1,13 +1,13 @@
 apiVersion: v1
 kind: Service
 metadata:
-  name: run-input-processing-svc
+  name: simulation-svc
   labels:
-    app: run-input-processing-svc
+    app: simulation-svc
 spec:
   type: ClusterIP
   selector:
-    app: run-input-processing-svc
+    app: simulation-svc
   ports:
   - protocol: TCP
     port: 80

diff --git a/...cosoft/portal/svc/rip/RipIdentifiers.java → ...svc/simulation/SimulationIdentifiers.java b/...cosoft/portal/svc/rip/RipIdentifiers.java → ...svc/simulation/SimulationIdentifiers.java
@@ -1,14 +1,13 @@
-package com.insilicosoft.portal.svc.rip;
+package com.insilicosoft.portal.svc.simulation;
 
-public final class RipIdentifiers {
+public final class SimulationIdentifiers {
 
   /** Also used in {@code application.yml} */
   public static final String BINDING_NAME_SIMULATION_INPUT = "simulation-input";
   public static final String PARAM_NAME_SIMULATION_FILE = "mpfile";
   public static final String REQUEST_MAPPING_SIMULATION = "/simulation";
-  public static final String REQUEST_MAPPING_SUBMISSION = "/submission";
   public static final String ROLE_USER = "user";
 
-  private RipIdentifiers() {}
+  private SimulationIdentifiers() {}
 
 }
diff --git a/...oft/portal/svc/rip/RipSvcApplication.java → .../simulation/SimulationSvcApplication.java b/...oft/portal/svc/rip/RipSvcApplication.java → .../simulation/SimulationSvcApplication.java
@@ -1,13 +1,13 @@
-package com.insilicosoft.portal.svc.rip;
+package com.insilicosoft.portal.svc.simulation;
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 
 @SpringBootApplication
-public class RipSvcApplication {
+public class SimulationSvcApplication {
 
   public static void main(String[] args) {
-    SpringApplication.run(RipSvcApplication.class, args);
+    SpringApplication.run(SimulationSvcApplication.class, args);
   }
 
 }
diff --git a/...ft/portal/svc/rip/config/AsyncConfig.java → ...al/svc/simulation/config/AsyncConfig.java b/...ft/portal/svc/rip/config/AsyncConfig.java → ...al/svc/simulation/config/AsyncConfig.java
@@ -1,4 +1,4 @@
-package com.insilicosoft.portal.svc.rip.config;
+package com.insilicosoft.portal.svc.simulation.config;
 
 import org.slf4j.Logger ;
 import org.slf4j.LoggerFactory ;

diff --git a/...tal/svc/rip/config/JpaAuditingConfig.java → .../simulation/config/JpaAuditingConfig.java b/...tal/svc/rip/config/JpaAuditingConfig.java → .../simulation/config/JpaAuditingConfig.java
@@ -1,4 +1,4 @@
-package com.insilicosoft.portal.svc.rip.config;
+package com.insilicosoft.portal.svc.simulation.config;
 
 import java.util.Optional;
 

diff --git a/...portal/svc/rip/config/SecurityConfig.java → ...svc/simulation/config/SecurityConfig.java b/...portal/svc/rip/config/SecurityConfig.java → ...svc/simulation/config/SecurityConfig.java
@@ -1,4 +1,4 @@
-package com.insilicosoft.portal.svc.rip.config;
+package com.insilicosoft.portal.svc.simulation.config;
 
 import static org.springframework.security.config.http.SessionCreationPolicy.STATELESS;
 import static org.springframework.security.config.Customizer.withDefaults;
@@ -22,7 +22,7 @@
 import org.springframework.security.provisioning.InMemoryUserDetailsManager;
 import org.springframework.security.web.SecurityFilterChain;
 
-import com.insilicosoft.portal.svc.rip.RipIdentifiers;
+import com.insilicosoft.portal.svc.simulation.SimulationIdentifiers;
 
 /**
  * Security configuration.
@@ -53,8 +53,8 @@ SecurityFilterChain filterChain(HttpSecurity http) throws Exception {
     http.authorizeHttpRequests((authz) -> authz.requestMatchers(EndpointRequest.to(InfoEndpoint.class),
                                                                 EndpointRequest.to(MetricsEndpoint.class),
                                                                 EndpointRequest.to(PrometheusScrapeEndpoint.class)).authenticated()
-                                               .requestMatchers(RipIdentifiers.REQUEST_MAPPING_SUBMISSION.concat("/**"))
-                                                               .hasRole(RipIdentifiers.ROLE_USER))
+                                               .requestMatchers(SimulationIdentifiers.REQUEST_MAPPING_SIMULATION.concat("/**"))
+                                                               .hasRole(SimulationIdentifiers.ROLE_USER))
         .oauth2ResourceServer((oauth2) -> oauth2.jwt(withDefaults()))
         .sessionManagement(sessionManagement -> sessionManagement.sessionCreationPolicy(STATELESS))
         .csrf(AbstractHttpConfigurer::disable)

diff --git a/.../rip/controller/SubmissionController.java → ...tion/controller/SimulationController.java b/.../rip/controller/SubmissionController.java → ...tion/controller/SimulationController.java
@@ -1,4 +1,4 @@
-package com.insilicosoft.portal.svc.rip.controller;
+package com.insilicosoft.portal.svc.simulation.controller;
 
 import java.io.IOException ;
 
@@ -12,24 +12,24 @@
 import org.springframework.web.bind.annotation.RequestPart ;
 import org.springframework.web.multipart.MultipartFile;
 
-import com.insilicosoft.portal.svc.rip.RipIdentifiers;
-import com.insilicosoft.portal.svc.rip.exception.FileProcessingException;
-import com.insilicosoft.portal.svc.rip.exception.InputVerificationException;
-import com.insilicosoft.portal.svc.rip.service.InputProcessorService;
-import com.insilicosoft.portal.svc.rip.service.SubmissionService;
+import com.insilicosoft.portal.svc.simulation.SimulationIdentifiers;
+import com.insilicosoft.portal.svc.simulation.exception.FileProcessingException;
+import com.insilicosoft.portal.svc.simulation.exception.InputVerificationException;
+import com.insilicosoft.portal.svc.simulation.service.InputProcessorService;
+import com.insilicosoft.portal.svc.simulation.service.SubmissionService;
 
 import io.micrometer.core.annotation.Timed;
 
 /**
- * Submission controller
+ * Simulation controller
  *
  * @author geoff
  */
 @Controller
-@RequestMapping(RipIdentifiers.REQUEST_MAPPING_SUBMISSION)
-public class SubmissionController {
+@RequestMapping(SimulationIdentifiers.REQUEST_MAPPING_SIMULATION)
+public class SimulationController {
 
-  private static final Logger log = LoggerFactory.getLogger(SubmissionController.class);
+  private static final Logger log = LoggerFactory.getLogger(SimulationController.class);
 
   private final InputProcessorService inputProcessorService;
   private final SubmissionService submissionService;
@@ -40,14 +40,14 @@ public class SubmissionController {
    * @param inputProcessorService Input processing implementation.
    * @param submissionService Submission service.
    */
-  public SubmissionController(final InputProcessorService inputProcessorService,
+  public SimulationController(final InputProcessorService inputProcessorService,
                               final SubmissionService submissionService) {
     this.inputProcessorService = inputProcessorService;
     this.submissionService = submissionService;
   }
 
   @GetMapping()
-  @Timed(value = "submission.get", description = "GET request")
+  @Timed(value = "simulation.get", description = "GET request")
   public ResponseEntity<String> get() {
     return ResponseEntity.ok(inputProcessorService.get());
   }
@@ -59,16 +59,16 @@ public ResponseEntity<String> get() {
    * @return Response entity.
    * @throws FileProcessingException If problems processing file.
    */
-  @PostMapping(RipIdentifiers.REQUEST_MAPPING_SIMULATION)
-  @Timed(value = "submission.simulation", description = "Simulation POST Multipart request")
+  @PostMapping()
+  @Timed(value = "simulation.post", description = "Simulation POST Multipart request")
   public ResponseEntity<String> createSimulation(final @RequestPart(required=false,
-                                                                    value=RipIdentifiers.PARAM_NAME_SIMULATION_FILE)
+                                                                    value=SimulationIdentifiers.PARAM_NAME_SIMULATION_FILE)
                                                        MultipartFile file)
                                                  throws FileProcessingException,
                                                         InputVerificationException {
 
     if (file == null) {
-      final String message = "No Multipart file! Did you supply the parameter '" + RipIdentifiers.PARAM_NAME_SIMULATION_FILE + "' in the POST request?";
+      final String message = "No Multipart file! Did you supply the parameter '" + SimulationIdentifiers.PARAM_NAME_SIMULATION_FILE + "' in the POST request?";
       log.warn("~createSimulation() : ".concat(message));
       throw new FileProcessingException(message);
     }

diff --git a/...p/controller/advice/ControllerAdvice.java → ...n/controller/advice/ControllerAdvice.java b/...p/controller/advice/ControllerAdvice.java → ...n/controller/advice/ControllerAdvice.java
@@ -1,4 +1,4 @@
-package com.insilicosoft.portal.svc.rip.controller.advice;
+package com.insilicosoft.portal.svc.simulation.controller.advice;
 
 import org.springframework.http.HttpStatus;
 import org.springframework.http.ResponseEntity;
@@ -7,8 +7,8 @@
 import org.springframework.web.multipart.MaxUploadSizeExceededException;
 import org.springframework.web.multipart.MultipartException;
 
-import com.insilicosoft.portal.svc.rip.exception.FileProcessingException;
-import com.insilicosoft.portal.svc.rip.exception.InputVerificationException;
+import com.insilicosoft.portal.svc.simulation.exception.FileProcessingException;
+import com.insilicosoft.portal.svc.simulation.exception.InputVerificationException;
 
 /**
  * REST controller advice.

diff --git a/...rtal/svc/rip/event/SimulationMessage.java → ...c/simulation/event/SimulationMessage.java b/...rtal/svc/rip/event/SimulationMessage.java → ...c/simulation/event/SimulationMessage.java
@@ -1,4 +1,4 @@
-package com.insilicosoft.portal.svc.rip.event;
+package com.insilicosoft.portal.svc.simulation.event;
 
 import java.math.BigDecimal;
 import java.util.List;

diff --git a/...ip/exception/FileProcessingException.java → ...on/exception/FileProcessingException.java b/...ip/exception/FileProcessingException.java → ...on/exception/FileProcessingException.java
@@ -1,4 +1,4 @@
-package com.insilicosoft.portal.svc.rip.exception;
+package com.insilicosoft.portal.svc.simulation.exception;
 
 /**
  * File processing exception.

diff --git a/...exception/InputVerificationException.java → ...exception/InputVerificationException.java b/...exception/InputVerificationException.java → ...exception/InputVerificationException.java
@@ -1,4 +1,4 @@
-package com.insilicosoft.portal.svc.rip.exception;
+package com.insilicosoft.portal.svc.simulation.exception;
 
 /**
  * Input verification exception.

diff --git a/...oft/portal/svc/rip/persistence/State.java → ...tal/svc/simulation/persistence/State.java b/...oft/portal/svc/rip/persistence/State.java → ...tal/svc/simulation/persistence/State.java
@@ -1,4 +1,4 @@
-package com.insilicosoft.portal.svc.rip.persistence;
+package com.insilicosoft.portal.svc.simulation.persistence;
 
 public enum State {
   APPROVED, COMPLETED, CREATED, FAILED, REJECTED

diff --git a/...l/svc/rip/persistence/entity/Message.java → ...imulation/persistence/entity/Message.java b/...l/svc/rip/persistence/entity/Message.java → ...imulation/persistence/entity/Message.java
@@ -1,6 +1,6 @@
-package com.insilicosoft.portal.svc.rip.persistence.entity;
+package com.insilicosoft.portal.svc.simulation.persistence.entity;
 
-import com.insilicosoft.portal.svc.rip.value.MessageLevel;
+import com.insilicosoft.portal.svc.simulation.value.MessageLevel;
 
 import jakarta.persistence.Embeddable;
 import jakarta.persistence.EnumType;

diff --git a/...vc/rip/persistence/entity/Simulation.java → ...lation/persistence/entity/Simulation.java b/...vc/rip/persistence/entity/Simulation.java → ...lation/persistence/entity/Simulation.java
@@ -1,4 +1,4 @@
-package com.insilicosoft.portal.svc.rip.persistence.entity;
+package com.insilicosoft.portal.svc.simulation.persistence.entity;
 
 import static jakarta.persistence.GenerationType.IDENTITY;
 
@@ -12,8 +12,8 @@
 
 import org.springframework.data.jpa.domain.support.AuditingEntityListener;
 
-import com.insilicosoft.portal.svc.rip.event.SimulationMessage;
-import com.insilicosoft.portal.svc.rip.value.MessageLevel;
+import com.insilicosoft.portal.svc.simulation.event.SimulationMessage;
+import com.insilicosoft.portal.svc.simulation.value.MessageLevel;
 
 import jakarta.persistence.CollectionTable;
 import jakarta.persistence.Column;

diff --git a/...vc/rip/persistence/entity/Submission.java → ...lation/persistence/entity/Submission.java b/...vc/rip/persistence/entity/Submission.java → ...lation/persistence/entity/Submission.java
@@ -1,4 +1,4 @@
-package com.insilicosoft.portal.svc.rip.persistence.entity;
+package com.insilicosoft.portal.svc.simulation.persistence.entity;
 
 import static jakarta.persistence.GenerationType.IDENTITY;
 
@@ -11,7 +11,7 @@
 import org.springframework.data.annotation.CreatedDate;
 import org.springframework.data.jpa.domain.support.AuditingEntityListener;
 
-import com.insilicosoft.portal.svc.rip.persistence.State;
+import com.insilicosoft.portal.svc.simulation.persistence.State;
 
 import jakarta.persistence.CollectionTable;
 import jakarta.persistence.Column;

diff --git a/...ence/repository/SimulationRepository.java → ...ence/repository/SimulationRepository.java b/...ence/repository/SimulationRepository.java → ...ence/repository/SimulationRepository.java
@@ -1,8 +1,8 @@
-package com.insilicosoft.portal.svc.rip.persistence.repository;
+package com.insilicosoft.portal.svc.simulation.persistence.repository;
 
 import org.springframework.data.jpa.repository.JpaRepository;
 
-import com.insilicosoft.portal.svc.rip.persistence.entity.Simulation;
+import com.insilicosoft.portal.svc.simulation.persistence.entity.Simulation;
 
 /**
  * Repository for {@link Simulation} objects.

diff --git a/...ence/repository/SubmissionRepository.java → ...ence/repository/SubmissionRepository.java b/...ence/repository/SubmissionRepository.java → ...ence/repository/SubmissionRepository.java
@@ -1,8 +1,8 @@
-package com.insilicosoft.portal.svc.rip.persistence.repository;
+package com.insilicosoft.portal.svc.simulation.persistence.repository;
 
 import org.springframework.data.jpa.repository.JpaRepository;
 
-import com.insilicosoft.portal.svc.rip.persistence.entity.Submission;
+import com.insilicosoft.portal.svc.simulation.persistence.entity.Submission;
 
 /**
  * Simulation(s) submission request from user.

diff --git a/...vc/rip/service/InputProcessorService.java → ...lation/service/InputProcessorService.java b/...vc/rip/service/InputProcessorService.java → ...lation/service/InputProcessorService.java
@@ -1,8 +1,8 @@
-package com.insilicosoft.portal.svc.rip.service;
+package com.insilicosoft.portal.svc.simulation.service;
 
-import com.insilicosoft.portal.svc.rip.exception.FileProcessingException;
-import com.insilicosoft.portal.svc.rip.exception.InputVerificationException;
-import com.insilicosoft.portal.svc.rip.persistence.entity.Submission;
+import com.insilicosoft.portal.svc.simulation.exception.FileProcessingException;
+import com.insilicosoft.portal.svc.simulation.exception.InputVerificationException;
+import com.insilicosoft.portal.svc.simulation.persistence.entity.Submission;
 
 /**
  * Interface to input processing.