Feature/refresh api in pieces

.editorconfig

@@ -2,5 +2,5 @@ root = true
 
 [*.java]
 indent_style = space
-indent_size = 2
+indent_size = 4
 ij_java_continuation_indent_size = 4

bpmn-process/src/main/java/com/jongsoft/finance/ProcessMapper.java

@@ -2,39 +2,42 @@
 
 import com.jongsoft.lang.Control;
 import com.jongsoft.lang.control.Try;
+
 import io.micronaut.serde.ObjectMapper;
+
 import jakarta.inject.Singleton;
+
 import lombok.extern.slf4j.Slf4j;
 
 @Slf4j
 @Singleton
 public class ProcessMapper {
 
-  private final ObjectMapper objectMapper;
-
-  public ProcessMapper(ObjectMapper objectMapper) {
-    this.objectMapper = objectMapper;
-  }
-
-  public <T> String writeSafe(T entity) {
-    return Control.Try(() -> objectMapper.writeValueAsString(entity))
-        .recover(x -> {
-          log.warn("Could not serialize entity {}", entity, x);
-          return null;
-        })
-        .get();
-  }
-
-  public <T> T readSafe(String json, Class<T> clazz) {
-    return Control.Try(() -> objectMapper.readValue(json, clazz))
-        .recover(x -> {
-          log.warn("Could not deserialize json {}", json, x);
-          return null;
-        })
-        .get();
-  }
-
-  public <T> Try<T> read(String json, Class<T> clazz) {
-    return Control.Try(() -> objectMapper.readValue(json, clazz));
-  }
+    private final ObjectMapper objectMapper;
+
+    public ProcessMapper(ObjectMapper objectMapper) {
+        this.objectMapper = objectMapper;
+    }
+
+    public <T> String writeSafe(T entity) {
+        return Control.Try(() -> objectMapper.writeValueAsString(entity))
+                .recover(x -> {
+                    log.warn("Could not serialize entity {}", entity, x);
+                    return null;
+                })
+                .get();
+    }
+
+    public <T> T readSafe(String json, Class<T> clazz) {
+        return Control.Try(() -> objectMapper.readValue(json, clazz))
+                .recover(x -> {
+                    log.warn("Could not deserialize json {}", json, x);
+                    return null;
+                })
+                .get();
+    }
+
+    public <T> Try<T> read(String json, Class<T> clazz) {
+        return Control.Try(() -> objectMapper.readValue(json, clazz));
+    }
 }

bpmn-process/src/main/java/com/jongsoft/finance/bpmn/KnownProcesses.java

@@ -2,16 +2,16 @@
 
 public class KnownProcesses {
 
-  private KnownProcesses() {
-    // private constructor
-  }
+    private KnownProcesses() {
+        // private constructor
+    }
 
-  /**
-   * The process identifier for the process that monitors for contract ending and sends the user a
-   * notification before hand.
-   */
-  public static final String CONTRACT_WARN_EXPIRY = "ContractEndWarning";
+    /**
+     * The process identifier for the process that monitors for contract ending and sends the user a
+     * notification before hand.
+     */
+    public static final String CONTRACT_WARN_EXPIRY = "ContractEndWarning";
 
-  /** The process identifier for the process that handles any type of scheduling. */
-  public static final String PROCESS_SCHEDULE = "ProcessScheduler";
+    /** The process identifier for the process that handles any type of scheduling. */
+    public static final String PROCESS_SCHEDULE = "ProcessScheduler";
 }

bpmn-process/src/main/java/com/jongsoft/finance/bpmn/ProcessEngineConfiguration.java

@@ -5,14 +5,15 @@
 import com.jongsoft.finance.ProcessVariable;
 import com.jongsoft.finance.bpmn.camunda.*;
 import com.jongsoft.finance.importer.api.TransactionDTO;
+
 import io.micronaut.context.ApplicationContext;
 import io.micronaut.context.annotation.Bean;
 import io.micronaut.context.annotation.Factory;
 import io.micronaut.context.annotation.Requires;
 import io.micronaut.serde.ObjectMapper;
-import java.io.IOException;
-import java.util.List;
+
 import lombok.extern.slf4j.Slf4j;
+
 import org.camunda.bpm.engine.HistoryService;
 import org.camunda.bpm.engine.ProcessEngine;
 import org.camunda.bpm.engine.RuntimeService;
@@ -21,89 +22,93 @@
 import org.springframework.core.io.Resource;
 import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
 
+import java.io.IOException;
+import java.util.List;
+
 @Slf4j
 @Factory
 @Requires(notEnv = "no-camunda")
 public class ProcessEngineConfiguration {
 
-  private final ApplicationContext applicationContext;
-  private final CamundaDatasourceConfiguration camundaDatasourceConfiguration;
-
-  public ProcessEngineConfiguration(
-      ApplicationContext applicationContext,
-      CamundaDatasourceConfiguration camundaDatasourceConfiguration) {
-    this.applicationContext = applicationContext;
-    this.camundaDatasourceConfiguration = camundaDatasourceConfiguration;
-  }
-
-  @Bean
-  public ProcessEngine processEngine() throws IOException {
-    var configuration = new StandaloneProcessEngineConfiguration();
-
-    configuration
-        .setHistory(camundaDatasourceConfiguration.getHistoryLevel())
-        .setJobExecutorActivate(true)
-        .setMetricsEnabled(true)
-        .setJdbcDriver(camundaDatasourceConfiguration.getDriverClassName())
-        .setJdbcUrl(camundaDatasourceConfiguration.getUrl())
-        .setJdbcUsername(camundaDatasourceConfiguration.getUsername())
-        .setJdbcPassword(camundaDatasourceConfiguration.getPassword())
-        .setDatabaseSchemaUpdate(camundaDatasourceConfiguration.getAutoUpdate())
-        .setProcessEngineName("fintrack")
-        .setHistoryCleanupEnabled(true)
-        .setSkipIsolationLevelCheck(true)
-        .setExpressionManager(
-            new MicronautExpressionManager(new MicronautElResolver(applicationContext)));
-
-    configuration.setHistoryCleanupBatchSize(250);
-    configuration.setHistoryCleanupBatchWindowStartTime("01:00");
-    configuration.setHistoryCleanupBatchWindowEndTime("03:00");
-    configuration.setHistoryTimeToLive("P1D");
-    configuration.setResolverFactories(List.of(new MicronautBeanResolver(applicationContext)));
-    configuration.setCustomPreVariableSerializers(List.of(
-        new JsonRecordSerializer<>(
-            applicationContext.getBean(ObjectMapper.class), ProcessVariable.class),
-        new JsonRecordSerializer<>(
-            applicationContext.getBean(ObjectMapper.class), TransactionDTO.class)));
-
-    var processEngine = configuration.buildProcessEngine();
-    log.info("Created camunda process engine");
-
-    deployResources(processEngine);
-    return processEngine;
-  }
-
-  @Bean
-  public HistoryService historyService(ProcessEngine processEngine) {
-    return processEngine.getHistoryService();
-  }
-
-  @Bean
-  public TaskService taskService(ProcessEngine processEngine) {
-    return processEngine.getTaskService();
-  }
-
-  @Bean
-  public RuntimeService runtimeService(ProcessEngine processEngine) {
-    return processEngine.getRuntimeService();
-  }
-
-  private void deployResources(ProcessEngine processEngine) throws IOException {
-    log.info("Searching for deployable camunda processes");
-
-    PathMatchingResourcePatternResolver resourceLoader = new PathMatchingResourcePatternResolver();
-    for (String extension : List.of("dmn", "cmmn", "bpmn")) {
-      for (Resource resource :
-          resourceLoader.getResources(CLASSPATH_ALL_URL_PREFIX + extension + "/*/*." + extension)) {
-        log.info("Deploying model: {}", resource.getFilename());
-        processEngine
-            .getRepositoryService()
-            .createDeployment()
-            .name("MicronautAutoDeployment")
-            .addInputStream(resource.getFilename(), resource.getInputStream())
-            .enableDuplicateFiltering(true)
-            .deploy();
-      }
+    private final ApplicationContext applicationContext;
+    private final CamundaDatasourceConfiguration camundaDatasourceConfiguration;
+
+    public ProcessEngineConfiguration(
+            ApplicationContext applicationContext,
+            CamundaDatasourceConfiguration camundaDatasourceConfiguration) {
+        this.applicationContext = applicationContext;
+        this.camundaDatasourceConfiguration = camundaDatasourceConfiguration;
+    }
+
+    @Bean
+    public ProcessEngine processEngine() throws IOException {
+        var configuration = new StandaloneProcessEngineConfiguration();
+
+        configuration
+                .setHistory(camundaDatasourceConfiguration.getHistoryLevel())
+                .setJobExecutorActivate(true)
+                .setMetricsEnabled(true)
+                .setJdbcDriver(camundaDatasourceConfiguration.getDriverClassName())
+                .setJdbcUrl(camundaDatasourceConfiguration.getUrl())
+                .setJdbcUsername(camundaDatasourceConfiguration.getUsername())
+                .setJdbcPassword(camundaDatasourceConfiguration.getPassword())
+                .setDatabaseSchemaUpdate(camundaDatasourceConfiguration.getAutoUpdate())
+                .setProcessEngineName("fintrack")
+                .setHistoryCleanupEnabled(true)
+                .setSkipIsolationLevelCheck(true)
+                .setExpressionManager(new MicronautExpressionManager(
+                        new MicronautElResolver(applicationContext)));
+
+        configuration.setHistoryCleanupBatchSize(250);
+        configuration.setHistoryCleanupBatchWindowStartTime("01:00");
+        configuration.setHistoryCleanupBatchWindowEndTime("03:00");
+        configuration.setHistoryTimeToLive("P1D");
+        configuration.setResolverFactories(List.of(new MicronautBeanResolver(applicationContext)));
+        configuration.setCustomPreVariableSerializers(List.of(
+                new JsonRecordSerializer<>(
+                        applicationContext.getBean(ObjectMapper.class), ProcessVariable.class),
+                new JsonRecordSerializer<>(
+                        applicationContext.getBean(ObjectMapper.class), TransactionDTO.class)));
+
+        var processEngine = configuration.buildProcessEngine();
+        log.info("Created camunda process engine");
+
+        deployResources(processEngine);
+        return processEngine;
+    }
+
+    @Bean
+    public HistoryService historyService(ProcessEngine processEngine) {
+        return processEngine.getHistoryService();
+    }
+
+    @Bean
+    public TaskService taskService(ProcessEngine processEngine) {
+        return processEngine.getTaskService();
+    }
+
+    @Bean
+    public RuntimeService runtimeService(ProcessEngine processEngine) {
+        return processEngine.getRuntimeService();
+    }
+
+    private void deployResources(ProcessEngine processEngine) throws IOException {
+        log.info("Searching for deployable camunda processes");
+
+        PathMatchingResourcePatternResolver resourceLoader =
+                new PathMatchingResourcePatternResolver();
+        for (String extension : List.of("dmn", "cmmn", "bpmn")) {
+            for (Resource resource : resourceLoader.getResources(
+                    CLASSPATH_ALL_URL_PREFIX + extension + "/*/*." + extension)) {
+                log.info("Deploying model: {}", resource.getFilename());
+                processEngine
+                        .getRepositoryService()
+                        .createDeployment()
+                        .name("MicronautAutoDeployment")
+                        .addInputStream(resource.getFilename(), resource.getInputStream())
+                        .enableDuplicateFiltering(true)
+                        .deploy();
+            }
+        }
     }
-  }
 }

bpmn-process/src/main/java/com/jongsoft/finance/bpmn/camunda/CamundaDatasourceConfiguration.java

@@ -2,32 +2,33 @@
 
 import io.micronaut.context.annotation.ConfigurationProperties;
 import io.micronaut.core.bind.annotation.Bindable;
+
 import jakarta.validation.constraints.NotBlank;
 import jakarta.validation.constraints.NotNull;
 
 @ConfigurationProperties("datasources.default")
 public interface CamundaDatasourceConfiguration {
 
-  @Bindable(defaultValue = "jdbc:h2:mem:fintrack;DB_CLOSE_DELAY=1000")
-  @NotBlank
-  String getUrl();
+    @Bindable
+    @NotBlank
+    String getUrl();
 
-  @Bindable(defaultValue = "sa")
-  @NotBlank
-  String getUsername();
+    @Bindable
+    @NotBlank
+    String getUsername();
 
-  @Bindable(defaultValue = "")
-  @NotNull
-  String getPassword();
+    @Bindable
+    @NotNull
+    String getPassword();
 
-  @Bindable(defaultValue = "org.h2.Driver")
-  @NotBlank
-  String getDriverClassName();
+    @Bindable
+    @NotBlank
+    String getDriverClassName();
 
-  @Bindable(defaultValue = "false")
-  @NotBlank
-  String getAutoUpdate();
+    @Bindable(defaultValue = "false")
+    @NotBlank
+    String getAutoUpdate();
 
-  @Bindable(defaultValue = "auto")
-  String getHistoryLevel();
+    @Bindable(defaultValue = "auto")
+    String getHistoryLevel();
 }