FIN-348 resolve an issue in the test context causing memory leaks.

Author: gjong

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

@@ -37,7 +37,7 @@ public ProcessEngineConfiguration(
     public ProcessEngine processEngine() throws IOException {
         var configuration = new StandaloneProcessEngineConfiguration();
 
-        configuration.setHistory(org.camunda.bpm.engine.ProcessEngineConfiguration.HISTORY_FULL)
+        configuration.setHistory(org.camunda.bpm.engine.ProcessEngineConfiguration.HISTORY_AUTO)
                 .setJobExecutorActivate(true)
                 .setMetricsEnabled(true)
                 .setJdbcDriver(camundaDatasourceConfiguration.getDriverClassName())

bpmn-process/src/test/java/com/jongsoft/finance/bpmn/process/ProcessExtension.java

@@ -7,8 +7,8 @@
 import java.lang.annotation.Retention;
 import java.lang.annotation.RetentionPolicy;
 
-@MicronautTest(startApplication = false)
-@TestInstance(TestInstance.Lifecycle.PER_METHOD)
+@MicronautTest
+@TestInstance(TestInstance.Lifecycle.PER_CLASS)
 @Retention(RetentionPolicy.RUNTIME)
 @ExtendWith({
         ProcessTestExtension.class

bpmn-process/src/test/java/com/jongsoft/finance/bpmn/process/ProcessTestExtension.java

@@ -8,24 +8,42 @@
 import org.junit.jupiter.api.extension.ExtensionContext;
 import org.junit.jupiter.api.extension.ParameterContext;
 import org.junit.jupiter.api.extension.ParameterResolutionException;
+import org.mockito.Mockito;
 
 import java.lang.reflect.AnnotatedElement;
 import java.util.List;
 import java.util.function.Consumer;
 
 public class ProcessTestExtension extends MicronautJunit5Extension {
 
+    static {
+        new EventBus(Mockito.mock(ApplicationEventPublisher.class));
+    }
+
     public interface ProcessExecution<T extends ProcessExecution> {
         ProcessExecution<?> obtainChildProcess(String processKey);
         T verifyCompleted();
         <Y> T yankVariable(String variableName, Consumer<Y> consumer);
     }
 
+    private RuntimeContext runtimeContext;
+
+    @Override
+    public void beforeAll(ExtensionContext extensionContext) throws Exception {
+        super.beforeAll(extensionContext);
+        runtimeContext = new RuntimeContext(applicationContext);
+    }
+
+    @Override
+    public void afterAll(ExtensionContext extensionContext) throws Exception {
+        runtimeContext.clean();
+        super.afterAll(extensionContext);
+    }
+
     @Override
     protected void beforeEach(ExtensionContext context, @Nullable Object testInstance, @Nullable AnnotatedElement method, List<Property> propertyAnnotations) {
         super.beforeEach(context, testInstance, method, propertyAnnotations);
-
-        new EventBus(applicationContext.getBean(ApplicationEventPublisher.class));
+        runtimeContext.resetMocks();
     }
 
     @Override
@@ -37,7 +55,7 @@ public boolean supportsParameter(ParameterContext parameterContext, ExtensionCon
     @Override
     public Object resolveParameter(ParameterContext parameterContext, ExtensionContext extensionContext) throws ParameterResolutionException {
         if (isProcessContext(parameterContext)) {
-            return new RuntimeContext(applicationContext);
+            return runtimeContext;
         }
         return super.resolveParameter(parameterContext, extensionContext);
     }

bpmn-process/src/test/java/com/jongsoft/finance/bpmn/process/RuntimeContext.java

@@ -42,7 +42,7 @@
 @Slf4j
 public class RuntimeContext {
 
-    private final ApplicationContext applicationContext;
+    private ApplicationContext applicationContext;
 
     private ProcessEngine processEngine;
 
@@ -63,10 +63,14 @@ public RuntimeContext(ApplicationContext applicationContext) {
         this.processEngine = applicationContext.getBean(ProcessEngine.class);
         idGenerator = new MutableLong(100);
 
-        resetMocks();
         setupDefaultMocks();
     }
 
+    void clean() {
+        processEngine.close();
+        storageTokens.clear();
+    }
+
     public RuntimeContext withStorage() {
         var storageService = applicationContext.getBean(StorageService.class);
         Mockito.when(storageService.store(Mockito.any())).thenAnswer((Answer<String>) invocation -> {
@@ -254,17 +258,22 @@ public <T> T verifyInteraction(Class<T> type) {
         return Mockito.verify(applicationContext.getBean(type));
     }
 
-    private void resetMocks() {
-        Mockito.reset(applicationContext.getBean(AuthenticationFacade.class));
-        Mockito.reset(applicationContext.getBean(CurrentUserProvider.class));
-        Mockito.reset(applicationContext.getBean(AccountProvider.class));
-        Mockito.reset(applicationContext.getBean(TransactionProvider.class));
-        Mockito.reset(applicationContext.getBean(ImportProvider.class));
-        Mockito.reset(applicationContext.getBean(TransactionCreationHandler.class));
-        Mockito.reset(applicationContext.getBean(TransactionRuleProvider.class));
-        Mockito.reset(applicationContext.getBean(CategoryProvider.class));
-        Mockito.reset(userAccount);
+    void resetMocks() {
+        Mockito.reset(
+                applicationContext.getBean(AuthenticationFacade.class),
+                applicationContext.getBean(CurrentUserProvider.class),
+                applicationContext.getBean(AccountProvider.class),
+                applicationContext.getBean(TransactionProvider.class),
+                applicationContext.getBean(ImportProvider.class),
+                applicationContext.getBean(TransactionCreationHandler.class),
+                applicationContext.getBean(TransactionRuleProvider.class),
+                applicationContext.getBean(CategoryProvider.class),
+                applicationContext.getBean(StorageService.class),
+                userAccount);
+
+        setupDefaultMocks();
     }
+
     private void setupDefaultMocks() {
         Mockito.when(applicationContext.getBean(AuthenticationFacade.class).authenticated())
                 .thenReturn("test-user");