added IT and unit tests

service/application/src/main/java/com/solace/maas/ep/common/model/SempEntityType.java

@@ -18,7 +18,7 @@ public String getValue() {
         return value;
     }
 
-    public SempEntityType fromValue(String value) {
+    public static SempEntityType fromValue(String value) {
         for (SempEntityType entityType : SempEntityType.values()) {
             if (entityType.getValue().equals(value)) {
                 return entityType;

service/application/src/test/java/com/solace/maas/ep/common/model/SempEntityTypeTest.java

@@ -0,0 +1,37 @@
+package com.solace.maas.ep.common.model;
+
+import org.junit.jupiter.api.Test;
+
+public class SempEntityTypeTest {
+
+    @Test
+    void testFromValue() {
+        SempEntityType entityType = SempEntityType.fromValue("solaceQueue");
+        assert entityType == SempEntityType.solaceQueue;
+    }
+
+    @Test
+    void testGetValue() {
+        SempEntityType entityType = SempEntityType.solaceQueue;
+        assert entityType.getValue().equals("solaceQueue");
+    }
+
+    @Test
+    void testUnsupportedEntityType() {
+        try {
+            SempEntityType entityType = SempEntityType.fromValue("unsupported");
+        } catch (IllegalArgumentException e) {
+            assert e.getMessage().equals("Unsupported entity type: unsupported");
+        }
+    }
+
+    @Test
+    void testFromValueNull() {
+        try {
+            SempEntityType entityType = SempEntityType.fromValue(null);
+        } catch (IllegalArgumentException e) {
+            assert e.getMessage().equals("Unsupported entity type: null");
+        }
+    }
+
+}

service/application/src/test/java/com/solace/maas/ep/event/management/agent/subscriber/EmRestartSimulatingPersistentMessageHandlerObserverTest.java

@@ -0,0 +1,34 @@
+package com.solace.maas.ep.event.management.agent.subscriber;
+
+import org.junit.jupiter.api.Test;
+
+import static org.assertj.core.api.AssertionsForClassTypes.assertThat;
+
+public class EmRestartSimulatingPersistentMessageHandlerObserverTest {
+
+    @Test
+    void testOnPhaseChangeRestartSimulated() {
+        EmaRestartSimulatingPersistentMessageHandlerObserver emaRestartSimulatingPersistentMessageHandlerObserver = new EmaRestartSimulatingPersistentMessageHandlerObserver();
+        emaRestartSimulatingPersistentMessageHandlerObserver.setRestartSimulated(true);
+        assertThat(emaRestartSimulatingPersistentMessageHandlerObserver.onPhaseChange(null, PersistentMessageHandlerObserverPhase.PRE_PROCESSOR_EXECUTION)).isFalse();
+        assertThat(emaRestartSimulatingPersistentMessageHandlerObserver.onPhaseChange(null, PersistentMessageHandlerObserverPhase.PRE_ACKNOWLEDGED)).isFalse();
+        assertThat(emaRestartSimulatingPersistentMessageHandlerObserver.onPhaseChange(null, PersistentMessageHandlerObserverPhase.ACKNOWLEDGED)).isTrue();
+        assertThat(emaRestartSimulatingPersistentMessageHandlerObserver.onPhaseChange(null, PersistentMessageHandlerObserverPhase.FAILED)).isTrue();
+        assertThat(emaRestartSimulatingPersistentMessageHandlerObserver.onPhaseChange(null, PersistentMessageHandlerObserverPhase.PROCESSOR_COMPLETED)).isTrue();
+        assertThat(emaRestartSimulatingPersistentMessageHandlerObserver.onPhaseChange(null, PersistentMessageHandlerObserverPhase.PROCESSING_INITIATED)).isTrue();
+        assertThat(emaRestartSimulatingPersistentMessageHandlerObserver.onPhaseChange(null, PersistentMessageHandlerObserverPhase.RECEIVED)).isTrue();
+    }
+
+    @Test
+    void testOnPhaseChangeRestartNotSimulated() {
+        EmaRestartSimulatingPersistentMessageHandlerObserver emaRestartSimulatingPersistentMessageHandlerObserver = new EmaRestartSimulatingPersistentMessageHandlerObserver();
+        emaRestartSimulatingPersistentMessageHandlerObserver.setRestartSimulated(false);
+        assertThat(emaRestartSimulatingPersistentMessageHandlerObserver.onPhaseChange(null, PersistentMessageHandlerObserverPhase.PRE_PROCESSOR_EXECUTION)).isTrue();
+        assertThat(emaRestartSimulatingPersistentMessageHandlerObserver.onPhaseChange(null, PersistentMessageHandlerObserverPhase.PRE_ACKNOWLEDGED)).isTrue();
+        assertThat(emaRestartSimulatingPersistentMessageHandlerObserver.onPhaseChange(null, PersistentMessageHandlerObserverPhase.ACKNOWLEDGED)).isTrue();
+        assertThat(emaRestartSimulatingPersistentMessageHandlerObserver.onPhaseChange(null, PersistentMessageHandlerObserverPhase.FAILED)).isTrue();
+        assertThat(emaRestartSimulatingPersistentMessageHandlerObserver.onPhaseChange(null, PersistentMessageHandlerObserverPhase.PROCESSOR_COMPLETED)).isTrue();
+        assertThat(emaRestartSimulatingPersistentMessageHandlerObserver.onPhaseChange(null, PersistentMessageHandlerObserverPhase.PROCESSING_INITIATED)).isTrue();
+        assertThat(emaRestartSimulatingPersistentMessageHandlerObserver.onPhaseChange(null, PersistentMessageHandlerObserverPhase.RECEIVED)).isTrue();
+    }
+}

service/terraform-plugin/src/test/java/com/solace/maas/ep/event/management/agent/plugin/terraform/TerraformCommandIT.java

@@ -82,6 +82,7 @@ public void reset_mocks() {
         Mockito.reset(terraformClient);
     }
 
+
     @Test
     public void testWriteHCLWithDefaultFile() throws IOException {
 

service/terraform-plugin/src/test/java/com/solace/maas/ep/event/management/agent/plugin/terraform/TerraformLogProcessingServiceTest.java

@@ -0,0 +1,30 @@
+package com.solace.maas.ep.event.management.agent.plugin.terraform;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.solace.maas.ep.event.management.agent.plugin.command.model.CommandResult;
+import com.solace.maas.ep.event.management.agent.plugin.command.model.JobStatus;
+import com.solace.maas.ep.event.management.agent.plugin.terraform.manager.TerraformLogProcessingService;
+import org.junit.jupiter.api.Test;
+
+import java.util.Map;
+
+import static org.assertj.core.api.AssertionsForInterfaceTypes.assertThat;
+
+
+public class TerraformLogProcessingServiceTest {
+
+
+    @Test
+    void testBuildTfStateFileDeletionFailureResult(){
+        RuntimeException rootCause = new RuntimeException("rootCause");
+        ObjectMapper objectMapper = new ObjectMapper();
+        TerraformLogProcessingService terraformLogProcessingService = new TerraformLogProcessingService(objectMapper);
+        CommandResult result = terraformLogProcessingService.buildTfStateFileDeletionFailureResult(rootCause);
+        assertThat(result.getStatus()).isEqualTo(JobStatus.error);
+        assertThat(result.getLogs().size()).isEqualTo(1);
+        Map<String, Object> log = result.getLogs().get(0);
+        assertThat(log.get("message")).isEqualTo("Failed removing Terraform state: rootCause");
+        assertThat(log.get("level")).isEqualTo("ERROR");
+        assertThat(log.get("timestamp")).isNotNull();
+    }
+}