package com.pritom.src;
import com.sun.mail.imap.IMAPFolder;
import com.sun.mail.imap.SortTerm;
import javax.mail.*;
import javax.mail.internet.InternetAddress;
import javax.mail.internet.MimeBodyPart;
import javax.mail.search.*;
import java.io.File;
import java.util.*;
/**
* @author PRITOM
* @date 2016-11-25
*/
public class ReadEmailFromServer {
public static void main(String[] args) {
gmail();
//bleep();
//yahoo();;
//office();
}
private static void office() {
String PROTOCOL = "imaps", HOST = "outlook.office365.com", USER = "xxxxx@outlook.com",
PASSWORD = "xxxxx", ENCRYPTION_TYPE = "tls", PORT = "993";
readEmail(PROTOCOL, HOST, USER, PASSWORD, ENCRYPTION_TYPE, PORT);
}
private static void yahoo() {
String PROTOCOL = "imaps", HOST = "mail.yahoo.com", USER = "xxxxx@yahoo.com",
PASSWORD = "xxxxx", ENCRYPTION_TYPE = "tls", PORT = "993";
readEmail(PROTOCOL, HOST, USER, PASSWORD, ENCRYPTION_TYPE, PORT);
}
private static void bleep() {
String PROTOCOL = "imaps", HOST = "bleep.xxxxx.com", USER = "pritom@xxxxx.com",
PASSWORD = "xxxxx", ENCRYPTION_TYPE = "tls", PORT = "993";
readEmail(PROTOCOL, HOST, USER, PASSWORD, ENCRYPTION_TYPE, PORT);
}
private static void gmail() {
String PROTOCOL = "imaps", HOST = "imap.gmail.com", USER = "xxxxx@gmail.com",
PASSWORD = "xxxxx", ENCRYPTION_TYPE = "tls", PORT = "993";
readEmail(PROTOCOL, HOST, USER, PASSWORD, ENCRYPTION_TYPE, PORT);
}
private static void readEmail(String PROTOCOL, String HOST, String USER, String PASSWORD, String ENCRYPTION_TYPE, String PORT) {
Properties props = new Properties();
props.setProperty("mail.store.protocol", PROTOCOL);
if(ENCRYPTION_TYPE.length() > 0 && !ENCRYPTION_TYPE.equalsIgnoreCase("none")) {
if(PROTOCOL.equalsIgnoreCase("imap")) {
props.setProperty("mail.imap.socketFactory.class", "javax.net.ssl.SSLSocketFactory");
props.setProperty("mail.imap.socketFactory.fallback", "false");
props.setProperty("mail.imap.ssl.enable", "true");
props.setProperty("mail.imap.socketFactory.port", PORT.length() > 0 ? PORT : "993");
if(ENCRYPTION_TYPE.equalsIgnoreCase("tls")) {
props.setProperty("mail.imap.starttls.enable", "true");
}
}
else if(PROTOCOL.equalsIgnoreCase("pop3")) {
props.setProperty("mail.pop3.socketFactory.class", "javax.net.ssl.SSLSocketFactory");
props.setProperty("mail.pop3.socketFactory.fallback", "false");
props.setProperty("mail.pop3.ssl.enable", "true");
props.setProperty("mail.pop3.socketFactory.port", PORT.length() > 0 ? PORT : "995");
if(ENCRYPTION_TYPE.equalsIgnoreCase("tls")) {
props.setProperty("mail.pop3.starttls.enable", "true");
}
}
}
try {
Session session = Session.getInstance(props, null);
Store store = session.getStore();
store.connect(HOST, USER, PASSWORD);
printAllFolders(store);
IMAPFolder inbox = (IMAPFolder) store.getFolder("INBOX");
inbox.open(Folder.READ_ONLY);
SortTerm[] sortTerms = new SortTerm[1];
sortTerms[0] = SortTerm.ARRIVAL;
Message[] messages = inbox.getSortedMessages(sortTerms, getSearchCriteria());
int maxReadNumber = 1;
int total = messages.length > maxReadNumber ? maxReadNumber : messages.length;
println("\nTotal_Email = " + messages.length);
boolean ascending = false;
for (int index = 0; index < total; index++) {
int message_index = ascending ? index : messages.length - index - 1;
Message message = messages[message_index];
String subject = message.getSubject();
println("-------------------------------------------------------------------------------------------");
println("-------------------------------------------------------------------------------------------");
println("------------------" + (index + 1) + "/" + messages.length + "----------------------" + subject);
println("-------------------------------------------------------------------------------------------");
println("-------------------------------------------------------------------------------------------");
printAllHeaders(message);
if (message.getContent() instanceof String) {
println("\tContent---------------Type=" + message.getContentType());
String body = message.getContent().toString();
body = body.length() > 100 ? body.substring(0, 100) + "..." : body;
println("\t\t" + toSingleLine(body));
}
else {
Map output = processMultipart((Multipart) message.getContent());
Object[] keys = output.keySet().toArray();
for (int i = 0; i < keys.length; i++) {
println("\t" + keys[i].toString().toUpperCase() + "-------------------------------------------");
if (keys[i].toString() == "attachments") {
List attachments = (List) output.get("attachments");
for (int j = 0; j < attachments.size(); j++) {
Map attachment = (Map) attachments.get(j);
/* You can save attachments to your local machine by uncomment line below */
//String toFile = saveFileFromEmailAttachment(attachment);
//println("File_Saved_To=" + toFile);
println("\t\tFile_Name=" + attachment.get("fileName"));
}
}
else {
String body = output.get(keys[i].toString()).toString().trim();
body = body.length() > 100 ? body.substring(0, 100) + "..." : body;
println("\t\t[[[" + toSingleLine(body) + "]]]");
}
}
}
if (total == index + 1) {
println("-------------------------------------------------------------------------------------------");
println("-------------------------------------------------------------------------------------------");
println("-------------------------------------------------------------------------------------------");
}
}
inbox.close(false);
store.close();
}
catch (Exception ex) {
ex.printStackTrace();
}
}
private static void printAllFolders(Store store) throws Exception {
println("Folders:::");
Folder[] folders = store.getDefaultFolder().list();
for (Folder folder : folders) {
println("\t" + folder.getFullName());
for (Folder subFolder : folder.list()) {
println("\t\t" + subFolder.getFullName());
}
}
}
private static void printAllHeaders(Message message) throws Exception {
Enumeration enumeration = message.getAllHeaders();
while (enumeration.hasMoreElements()) {
Header header = (Header) enumeration.nextElement();
boolean show = !header.getName().startsWith("X-") && !header.getName().equals("Received");
show = show && !header.getName().startsWith("Authentication-") && !header.getName().startsWith("DKIM-");
if (show) {
println("\t" + header.getName() + "===" + toSingleLine(header.getValue()));
}
}
}
private static SearchTerm getSearchCriteria() throws Exception {
if (true) {
//return null;
//return new FlagTerm(new Flags(Flags.Flag.SEEN), false);
//return new MessageIDTerm("CAD-oc7fMFqioVurtMPnGm63mWAA51wELBaLhtm38zvthTv0+DQ@mail.gmail.com");
}
FlagTerm unread = new FlagTerm(new Flags(Flags.Flag.SEEN), false);
FromTerm fromTerm = new FromTerm(new InternetAddress("pritomkucse@gmail.com"));
Calendar cal = Calendar.getInstance();
/* Set date to 1 day back from now */
cal.roll(Calendar.DATE, false);
ReceivedDateTerm latest = new ReceivedDateTerm(DateTerm.GT, cal.getTime());
SearchTerm andTerm = new AndTerm(unread, latest);
SearchTerm notFromTerm = new NotTerm(new FromTerm(new InternetAddress("black_listed_domain.com")));
SubjectTerm subjectTerm = new SubjectTerm("Notable");
OrTerm orTerm = new OrTerm(fromTerm, new OrTerm(andTerm, subjectTerm));
AndTerm andTerm1 = new AndTerm(orTerm, notFromTerm);
/**
* (FROM_pritomkucse@gmail.com OR (NOT_REED AND YESTERDAY) OR SUBJECT_CONTAINS_Notable) AND NOT_FROM_*@black_listed_domain.com
*/
/* Custom search term, actually download email from server then check (slow) */
SearchTerm searchTerm = new SearchTerm() {
@Override
public boolean match(Message message) {
try {
if (message.getSubject().contains("forwarding")) {
return true;
}
}
catch (MessagingException ex) {
ex.printStackTrace();
}
return false;
}
};
return andTerm1;
}
private static String saveFileFromEmailAttachment(Map attachment) {
try {
File dir = createAndGetDirectory();
String fileName = attachment.get("fileName").toString();
File toFile = new File(dir, fileName);
MimeBodyPart mimeBodyPart = (MimeBodyPart) attachment.get("mimeBodyPart");
mimeBodyPart.saveFile(toFile);
return toFile.getAbsolutePath();
}
catch (Exception e) {
e.printStackTrace();
return e.getMessage();
}
}
private static File createAndGetDirectory() {
File file = new File("attachments");
if (!file.exists()) {
file.mkdir();
}
return file;
}
private static Map processMultipart(Multipart multipart) throws Exception {
Map output = new HashMap();
output.put("html", "");
output.put("text", "");
List attachments = new ArrayList();
for(int i = 0; i < multipart.getCount(); i++) {
Map result = processBodyPart(multipart.getBodyPart(i));
if (result != null) {
if (result.containsKey("type")) {
if (result.get("type").toString().equalsIgnoreCase("html")) {
output.put("html", result.get("content").toString());
}
else if (result.get("type").toString().equalsIgnoreCase("text")) {
output.put("text", result.get("content").toString());
}
else if (result.get("type").toString().equalsIgnoreCase("attachment")) {
attachments.add(result);
}
}
if (result.containsKey("html")) {
output.put("html", result.get("html").toString());
}
if (result.containsKey("text")) {
output.put("text", result.get("text").toString());
}
if (result.containsKey("attachments")) {
List thisAttachments = (List) result.get("attachments");
for (int i2 = 0; i2 < thisAttachments.size(); i2++) {
attachments.add(thisAttachments.get(i2));
}
}
}
}
output.put("attachments", attachments);
return output;
}
private static Map processBodyPart(BodyPart bodyPart) throws Exception {
if(bodyPart.isMimeType("text/html") && bodyPart.getFileName() == null) {
Map data = new HashMap();
data.put("type", "html");
data.put("content", bodyPart.getContent().toString());
return data;
}
else if(bodyPart.isMimeType("text/plain") && bodyPart.getFileName() == null) {
Map data = new HashMap();
data.put("type", "text");
data.put("content", bodyPart.getContent().toString());
return data;
}
else if(Part.ATTACHMENT.equalsIgnoreCase(bodyPart.getDisposition()) && bodyPart.getFileName() != null) {
try {
Map map = new HashMap();
map.put("type", "attachment");
map.put("fileName", bodyPart.getFileName());
String fileType = bodyPart.getContentType();
map.put("fileType", fileType.contains(":") ? fileType.substring(0, fileType.indexOf(";")) : fileType);
map.put("mimeBodyPart", bodyPart);
return map;
}
catch (Exception ex) {
println("Error_Content=" + bodyPart.getContentType());
ex.printStackTrace();
}
}
else if(bodyPart.getContentType().contains("multipart")) {
Map o = processMultipart((Multipart) bodyPart.getContent());
return o;
}
return null;
}
private static String toSingleLine(String str) throws Exception {
return str.replaceAll("\\s+", " ");
}
private static void println(Object o) {
System.out.println(o);
}
}
