Merge pull request #10554 from rvsathe/master

Hexagonal Architecture code Reshma sathe

core-java-modules/core-java-networking-3/pom.xml

@@ -36,16 +36,29 @@
             <version>${assertj.version}</version>
             <scope>test</scope>
         </dependency>
+        <dependency>
+            <groupId>junit</groupId>
+            <artifactId>junit</artifactId>
+            <version>4.11</version>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>com.sun.mail</groupId>
+            <artifactId>javax.mail</artifactId>
+            <version>1.6.2</version>
+        </dependency>
     </dependencies>
 
     <build>
         <finalName>core-java-networking-3</finalName>
-        <plugins>
+        <pluginManagement>
-            <plugin>
+            <plugins>
-                <groupId>org.apache.maven.plugins</groupId>
+                <plugin>
-                <artifactId>maven-compiler-plugin</artifactId>
+                    <groupId>org.apache.maven.plugins</groupId>
-            </plugin>
+                    <artifactId>maven-compiler-plugin</artifactId>
-        </plugins>
+                </plugin>
+            </plugins>
+        </pluginManagement>
     </build>
 
     <properties>

core-java-modules/core-java-networking-3/src/main/java/com/baeldung/downloadattachments/DownloadEmailAttachments.java

@@ -0,0 +1,112 @@
+package com.baeldung.downloadattachments;
+
+import java.io.File;
+import java.io.IOException;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Properties;
+
+import javax.mail.Address;
+import javax.mail.Folder;
+import javax.mail.Message;
+import javax.mail.MessagingException;
+import javax.mail.Multipart;
+import javax.mail.NoSuchProviderException;
+import javax.mail.Part;
+import javax.mail.Session;
+import javax.mail.Store;
+import javax.mail.internet.MimeBodyPart;
+
+public class DownloadEmailAttachments {
+    private String downloadDirectory;
+
+    public void setSaveDirectory(String dir) {
+        this.downloadDirectory = dir;
+    }
+
+    public void downloadEmailAttachments(String host, String port, String userName, String password) throws NoSuchProviderException, MessagingException, IOException {
+        Properties properties = setMailServerProperties(host, port);
+        Store store = setSessionStoreProperties(userName, password, properties);
+        Folder inbox = store.getFolder("INBOX");
+        inbox.open(Folder.READ_ONLY);
+        Message[] arrayMessages = inbox.getMessages();
+        for (int i = 0; i < arrayMessages.length; i++) {
+            Message message = arrayMessages[i];
+            Address[] fromAddress = message.getFrom();
+            String from = fromAddress[0].toString();
+            String subject = message.getSubject();
+            String sentDate = message.getSentDate().toString();
+            List<String> attachments = new ArrayList<String>();
+            if (message.getContentType().contains("multipart")) {
+                attachments = downloadAttachments(message);
+            }
+
+            System.out.println("Message #" + (i + 1) + ":");
+            System.out.println(" From: " + from);
+            System.out.println(" Subject: " + subject);
+            System.out.println(" Sent Date: " + sentDate);
+            System.out.println(" Attachments: " + attachments);
+        }
+        inbox.close(false);
+        store.close();
+    }
+
+    public List<String> downloadAttachments(Message message) throws IOException, MessagingException {
+        List<String> downloadedAttachments = new ArrayList<String>();
+        Multipart multiPart = (Multipart) message.getContent();
+        int numberOfParts = multiPart.getCount();
+        for (int partCount = 0; partCount < numberOfParts; partCount++) {
+            MimeBodyPart part = (MimeBodyPart) multiPart.getBodyPart(partCount);
+            if (Part.ATTACHMENT.equalsIgnoreCase(part.getDisposition())) {
+                String file = part.getFileName();
+                part.saveFile(downloadDirectory + File.separator + part.getFileName());
+                downloadedAttachments.add(file);
+            }
+        }
+
+        return downloadedAttachments;
+    }
+
+    public Store setSessionStoreProperties(String userName, String password, Properties properties) throws NoSuchProviderException, MessagingException {
+        Session session = Session.getDefaultInstance(properties);
+
+        Store store = session.getStore("pop3");
+        store.connect(userName, password);
+        return store;
+    }
+
+    public Properties setMailServerProperties(String host, String port) {
+        Properties properties = new Properties();
+
+        properties.put("mail.pop3.host", host);
+        properties.put("mail.pop3.port", port);
+
+        properties.setProperty("mail.pop3.socketFactory.class", "javax.net.ssl.SSLSocketFactory");
+        properties.setProperty("mail.pop3.socketFactory.fallback", "false");
+        properties.setProperty("mail.pop3.socketFactory.port", String.valueOf(port));
+        return properties;
+    }
+
+    public static void main(String[] args) {
+        String host = "pop.gmail.com";
+        String port = "995";
+        String userName = "your_email";
+        String password = "your_password";
+
+        String saveDirectory = "valid_folder_path";
+
+        DownloadEmailAttachments receiver = new DownloadEmailAttachments();
+        receiver.setSaveDirectory(saveDirectory);
+        try {
+            receiver.downloadEmailAttachments(host, port, userName, password);
+        } catch (NoSuchProviderException ex) {
+            System.out.println("No provider for pop3.");
+            ex.printStackTrace();
+        } catch (MessagingException ex) {
+            System.out.println("Could not connect to the message store");
+            ex.printStackTrace();
+        } catch (IOException ex) {
+            ex.printStackTrace();
+        }
+    }
+}

core-java-modules/core-java-networking-3/src/test/java/com/baeldung/downloadattachments/DownloadEmailAttachmentsLiveTest.java

@@ -0,0 +1,25 @@
+package com.baeldung.downloadattachments;
+
+import static org.junit.Assert.fail;
+import org.junit.Test;
+
+public class DownloadEmailAttachmentsLiveTest {
+    @Test
+    public void when_Run_then_downloadAttachments() {
+
+        String host = "pop.gmail.com";
+        String port = "995";
+        String userName = "your_email";
+        String password = "your_password";
+
+        String saveDirectory = "valid_folder_path";
+
+        DownloadEmailAttachments receiver = new DownloadEmailAttachments();
+        receiver.setSaveDirectory(saveDirectory);
+        try {
+            receiver.downloadEmailAttachments(host, port, userName, password);
+        } catch (Exception ex) {
+            fail("Exception: " + ex);
+        }
+    }
+}