feature(s3-connector): checkpoint s3 connector; pom commit

camunda · Dec 4, 2024 · c6da398 · c6da398
1 parent 5733bcf
commit c6da398
Show file tree

Hide file tree

Showing 4 changed files with 24 additions and 6 deletions.
diff --git a/bundle/default-bundle/pom.xml b/bundle/default-bundle/pom.xml
@@ -37,6 +37,10 @@
       <groupId>io.camunda.connector</groupId>
       <artifactId>connector-aws-bedrock</artifactId>
     </dependency>
+    <dependency>
+      <groupId>io.camunda.connector</groupId>
+      <artifactId>connector-aws-s3</artifactId>
+    </dependency>
     <dependency>
       <groupId>io.camunda.connector</groupId>
       <artifactId>connector-aws-textract</artifactId>

diff --git a/bundle/pom.xml b/bundle/pom.xml
@@ -144,6 +144,11 @@
         <artifactId>connector-aws-sagemaker</artifactId>
         <version>${project.version}</version>
       </dependency>
+      <dependency>
+        <groupId>io.camunda.connector</groupId>
+        <artifactId>connector-aws-s3</artifactId>
+        <version>${project.version}</version>
+      </dependency>
       <dependency>
         <groupId>io.camunda.connector</groupId>
         <artifactId>connector-email</artifactId>

diff --git a/...ors/email/src/main/java/io/camunda/connector/email/client/jakarta/utils/JakartaUtils.java b/...ors/email/src/main/java/io/camunda/connector/email/client/jakarta/utils/JakartaUtils.java
@@ -20,8 +20,10 @@
 import io.camunda.connector.email.outbound.protocols.actions.SortFieldPop3;
 import io.camunda.connector.email.outbound.protocols.actions.SortOrder;
 import jakarta.mail.*;
+import jakarta.mail.internet.ContentType;
 import jakarta.mail.internet.MimeMultipart;
 import jakarta.validation.constraints.NotNull;
+import java.io.ByteArrayInputStream;
 import java.io.IOException;
 import java.io.InputStream;
 import java.time.OffsetDateTime;
@@ -32,9 +34,9 @@
 
 public class JakartaUtils {
 
+  public static final String HTML_CHARSET = "text/html; charset=utf-8";
   private static final Logger LOGGER = LoggerFactory.getLogger(JakartaUtils.class);
   private static final String REGEX_PATH_SPLITTER = "[./]";
-  public static final String HTML_CHARSET = "text/html; charset=utf-8";
 
   public Session createSession(Configuration configuration) {
     return Session.getInstance(
@@ -282,11 +284,19 @@ private void processBodyPart(
       throws MessagingException, IOException {
     BodyPart bodyPart = multipart.getBodyPart(i);
     switch (bodyPart.getContent()) {
-      case InputStream attachment when bodyPart
-              .getDisposition()
-              .equalsIgnoreCase(Part.ATTACHMENT) ->
+      case InputStream attachment when Part.ATTACHMENT.equalsIgnoreCase(
+              bodyPart.getDisposition()) ->
+          emailBodyBuilder.addAttachment(
+              new EmailAttachment(
+                  attachment,
+                  bodyPart.getFileName(),
+                  new ContentType(bodyPart.getContentType()).getBaseType()));
+      case String textAttachment when Part.ATTACHMENT.equalsIgnoreCase(bodyPart.getDisposition()) ->
           emailBodyBuilder.addAttachment(
-              new EmailAttachment(attachment, bodyPart.getFileName(), bodyPart.getContentType()));
+              new EmailAttachment(
+                  new ByteArrayInputStream(textAttachment.getBytes()),
+                  bodyPart.getFileName(),
+                  new ContentType(bodyPart.getContentType()).getBaseType()));
       case String plainText when bodyPart.isMimeType("text/plain") ->
           emailBodyBuilder.withBodyAsPlainText(plainText);
       case String html when bodyPart.isMimeType("text/html") ->

diff --git a/connectors/pom.xml b/connectors/pom.xml
@@ -32,7 +32,6 @@
     <module>soap</module>
     <module>webhook</module>
     <module>idp-extraction</module>
-      <module>aws/aws-s3</module>
   </modules>
 
   <properties>