chore(email-tests): spotless code

camunda · Feb 20, 2025 · 401decd · 401decd
1 parent 5976431
commit 401decd
Show file tree

Hide file tree

Showing 4 changed files with 20 additions and 28 deletions.
diff --git a/...est/connectors-e2e-test-mail/src/test/java/io/camunda/connector/e2e/InboundEmailTest.java b/...est/connectors-e2e-test-mail/src/test/java/io/camunda/connector/e2e/InboundEmailTest.java
@@ -27,21 +27,18 @@
 import io.camunda.connector.runtime.inbound.search.SearchQueryClient;
 import io.camunda.connector.runtime.inbound.state.ProcessImportResult;
 import io.camunda.connector.runtime.inbound.state.ProcessStateStore;
-import io.camunda.process.test.api.CamundaAssert;
 import io.camunda.process.test.api.CamundaSpringProcessTest;
 import io.camunda.zeebe.model.bpmn.BpmnModelInstance;
 import io.camunda.zeebe.model.bpmn.instance.Process;
 import jakarta.mail.Flags;
 import jakarta.mail.MessagingException;
-import java.time.Duration;
 import java.util.Arrays;
 import java.util.Map;
 import java.util.concurrent.Executors;
 import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicInteger;
 import org.awaitility.core.ConditionTimeoutException;
-import org.junit.Ignore;
 import org.junit.jupiter.api.Assertions;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Disabled;

diff --git a/connectors/email/src/test/java/io/camunda/connector/email/integration/BaseEmailTest.java b/connectors/email/src/test/java/io/camunda/connector/email/integration/BaseEmailTest.java
@@ -125,8 +125,7 @@ protected static byte[] getBodyAsByteArray(Message message) {
       if (message.getContent() instanceof Multipart multipart) {
         for (int i = 0; i < multipart.getCount(); i++) {
           MimeBodyPart bodyPart = (MimeBodyPart) multipart.getBodyPart(i);
-          if (Part.ATTACHMENT.equalsIgnoreCase(
-                  bodyPart.getDisposition())) {
+          if (Part.ATTACHMENT.equalsIgnoreCase(bodyPart.getDisposition())) {
             return bodyPart.getInputStream().readAllBytes();
           }
         }

diff --git a/connectors/email/src/test/java/io/camunda/connector/email/integration/InboundEmailTest.java b/connectors/email/src/test/java/io/camunda/connector/email/integration/InboundEmailTest.java
@@ -11,22 +11,18 @@
 import io.camunda.connector.email.config.ImapConfig;
 import io.camunda.connector.email.inbound.model.EmailInboundConnectorProperties;
 import io.camunda.connector.email.inbound.model.EmailListenerConfig;
+import io.camunda.connector.email.inbound.model.HandlingStrategy;
+import jakarta.mail.Flags;
+import jakarta.mail.MessagingException;
 import java.io.IOException;
 import java.nio.file.Files;
 import java.nio.file.Path;
 import java.util.Arrays;
 import java.util.List;
-
-import io.camunda.connector.email.inbound.model.HandlingStrategy;
-import jakarta.mail.Flags;
-import jakarta.mail.MessagingException;
 import org.junit.jupiter.api.Assertions;
 import org.junit.jupiter.api.BeforeEach;
-import org.junit.jupiter.api.parallel.Execution;
-import org.junit.jupiter.api.parallel.ExecutionMode;
 import org.junit.jupiter.params.ParameterizedTest;
 import org.junit.jupiter.params.provider.MethodSource;
-import org.mockito.verification.VerificationMode;
 
 public class InboundEmailTest extends BaseEmailTest {
 
@@ -51,8 +47,8 @@ public void beforeEach() {
 
   @ParameterizedTest
   @MethodSource("createEmailInboundConnectorProperties")
-  public void shouldReceiveEmail(
-      EmailInboundConnectorProperties emailInboundConnectorProperties) throws MessagingException {
+  public void shouldReceiveEmail(EmailInboundConnectorProperties emailInboundConnectorProperties)
+      throws MessagingException {
     InboundConnectorContext inboundConnectorContext = mock(InboundConnectorContext.class);
 
     ImapConfig pollingConfig =

diff --git a/connectors/email/src/test/java/io/camunda/connector/email/integration/OutboundEmailTest.java b/connectors/email/src/test/java/io/camunda/connector/email/integration/OutboundEmailTest.java
@@ -78,22 +78,22 @@ public static Stream<String> createEmailOutboundPop3ReadConnectorProperties() {
 
   public static Stream<String> createEmailOutboundImapDeleteConnectorProperties() {
     return getStreamFromPath(
-            "src/test/resources/integration/outbound-imap-delete-connector-happy-path.json");
+        "src/test/resources/integration/outbound-imap-delete-connector-happy-path.json");
   }
 
   public static Stream<String> createEmailOutboundImapSearchConnectorProperties() {
     return getStreamFromPath(
-            "src/test/resources/integration/outbound-imap-search-connector-happy-path.json");
+        "src/test/resources/integration/outbound-imap-search-connector-happy-path.json");
   }
 
   public static Stream<String> createEmailOutboundImapListConnectorProperties() {
     return getStreamFromPath(
-            "src/test/resources/integration/outbound-imap-list-connector-happy-path.json");
+        "src/test/resources/integration/outbound-imap-list-connector-happy-path.json");
   }
 
   public static Stream<String> createEmailOutboundImapReadConnectorProperties() {
     return getStreamFromPath(
-            "src/test/resources/integration/outbound-imap-read-connector-happy-path.json");
+        "src/test/resources/integration/outbound-imap-read-connector-happy-path.json");
   }
 
   @BeforeEach
@@ -169,7 +169,7 @@ public void shouldUseImapDelete(String emailRequest) {
     emailRequest = emailRequest.replace("{{PORT}}", super.getUnsecureImapPort());
     emailRequest = emailRequest.replace("{{MESSAGE_ID}}", messageId);
     OutboundConnectorContext outboundConnectorContext =
-            this.contextBuilder.variables(emailRequest).build();
+        this.contextBuilder.variables(emailRequest).build();
 
     Object object = this.jakartaEmailActionExecutor.execute(outboundConnectorContext);
 
@@ -203,7 +203,7 @@ public void shouldUseImapSearch(String emailRequest) {
 
     emailRequest = emailRequest.replace("{{PORT}}", super.getUnsecureImapPort());
     OutboundConnectorContext outboundConnectorContext =
-            this.contextBuilder.variables(emailRequest).build();
+        this.contextBuilder.variables(emailRequest).build();
 
     Object object = this.jakartaEmailActionExecutor.execute(outboundConnectorContext);
 
@@ -212,7 +212,7 @@ public void shouldUseImapSearch(String emailRequest) {
     Assertions.assertInstanceOf(SearchEmailsResponse.class, searchResult);
     Assertions.assertEquals("subject", ((SearchEmailsResponse) searchResult).subject());
     Assertions.assertEquals(
-            super.getLastMessageId(), ((SearchEmailsResponse) searchResult).messageId());
+        super.getLastMessageId(), ((SearchEmailsResponse) searchResult).messageId());
   }
 
   @ParameterizedTest
@@ -259,7 +259,7 @@ public void shouldUseImapList(String emailRequest) throws JsonProcessingExceptio
 
     emailRequest = emailRequest.replace("{{PORT}}", super.getUnsecureImapPort());
     OutboundConnectorContext outboundConnectorContext =
-            this.contextBuilder.variables(emailRequest).build();
+        this.contextBuilder.variables(emailRequest).build();
 
     Object object = this.jakartaEmailActionExecutor.execute(outboundConnectorContext);
 
@@ -272,14 +272,14 @@ public void shouldUseImapList(String emailRequest) throws JsonProcessingExceptio
       case "SENT_DATE", "RECEIVED_DATE" -> {
         if (jsonNodeValue.get("sortOrder").asText().equals("ASC")) {
           Assertions.assertEquals(
-                  "subject 1", ((ListEmailsResponse) ((List<?>) object).getFirst()).subject());
+              "subject 1", ((ListEmailsResponse) ((List<?>) object).getFirst()).subject());
           Assertions.assertEquals(
-                  "subject 2", ((ListEmailsResponse) ((List<?>) object).get(1)).subject());
+              "subject 2", ((ListEmailsResponse) ((List<?>) object).get(1)).subject());
         }
       }
-        default ->
-              throw new IllegalStateException(
-                      "Unexpected value: " + jsonNodeValue.get("sortField").asText());
+      default ->
+          throw new IllegalStateException(
+              "Unexpected value: " + jsonNodeValue.get("sortField").asText());
     }
   }
 
@@ -311,7 +311,7 @@ public void shouldUseImapRead(String emailRequest) {
     emailRequest = emailRequest.replace("{{PORT}}", super.getUnsecureImapPort());
     emailRequest = emailRequest.replace("{{MESSAGE_ID}}", messageId);
     OutboundConnectorContext outboundConnectorContext =
-            this.contextBuilder.variables(emailRequest).build();
+        this.contextBuilder.variables(emailRequest).build();
 
     Object object = this.jakartaEmailActionExecutor.execute(outboundConnectorContext);