Apache
/
nifi
mirror of https://github.com/apache/nifi.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

NIFI-7366 - ConsumeEWS Processor parse EML 

https://issues.apache.org/jira/browse/NIFI-7366

This commit allows to retrieve ItemAttachement (such as EML) file when pulling mail.

Signed-off-by: Pierre Villard <pierre.villard.fr@gmail.com>

This closes #4215.
This commit is contained in:
Jérémie 2020-04-16 18:19:20 -04:00 committed by Pierre Villard
parent 58118cf904
commit 8e9dbd7335
No known key found for this signature in database
GPG Key ID: BEE1599F0726E9CD
1 changed files with 19 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
nifi-nar-bundles/nifi-email-bundle/nifi-email-processors/src/main/java/org/apache/nifi/processors/email/ConsumeEWS.java
View File

@ -21,6 +21,7 @@ import microsoft.exchange.webservices.data.core.ExchangeService;
import microsoft.exchange.webservices.data.core.PropertySet;
import microsoft.exchange.webservices.data.core.enumeration.misc.ExchangeVersion;
import microsoft.exchange.webservices.data.core.enumeration.property.BodyType;
import microsoft.exchange.webservices.data.core.enumeration.property.BasePropertySet;
import microsoft.exchange.webservices.data.core.enumeration.property.WellKnownFolderName;
import microsoft.exchange.webservices.data.core.enumeration.search.FolderTraversal;
import microsoft.exchange.webservices.data.core.enumeration.search.LogicalOperator;
@ -36,6 +37,7 @@ import microsoft.exchange.webservices.data.core.service.schema.ItemSchema;
import microsoft.exchange.webservices.data.credential.ExchangeCredentials;
import microsoft.exchange.webservices.data.credential.WebCredentials;
import microsoft.exchange.webservices.data.property.complex.FileAttachment;
import microsoft.exchange.webservices.data.property.complex.ItemAttachment;
import microsoft.exchange.webservices.data.search.FindFoldersResults;
import microsoft.exchange.webservices.data.search.FindItemsResults;
import microsoft.exchange.webservices.data.search.FolderView;
@ -451,13 +453,25 @@ public class ConsumeEWS extends AbstractProcessor {
if(ewsMessage.getHasAttachments()){
ewsMessage.getAttachments().forEach(x->{
try {
FileAttachment file = (FileAttachment)x;
file.load();
if(x instanceof FileAttachment) {
FileAttachment file = (FileAttachment) x;
file.load();
String type = file.getContentType() == null ? "text/plain" : file.getContentType();
ByteArrayDataSource bds = new ByteArrayDataSource(file.getContent(), type);
String type = file.getContentType() == null ? "text/plain" : file.getContentType();
ByteArrayDataSource bds = new ByteArrayDataSource(file.getContent(), type);
mm.attach(bds,file.getName(), "", EmailAttachment.ATTACHMENT);
mm.attach(bds, file.getName(), "", EmailAttachment.ATTACHMENT);
} else { // x instanceof ItemAttachment
ItemAttachment eml = (ItemAttachment) x;
PropertySet oPropSetForBodyText = new PropertySet(BasePropertySet.FirstClassProperties);
oPropSetForBodyText.add(ItemSchema.MimeContent);
eml.load(oPropSetForBodyText);
Item it = eml.getItem();
ByteArrayDataSource bds = new ByteArrayDataSource(it.getMimeContent().getContent(), "text/plain");
mm.attach(bds, eml.getName(), "", EmailAttachment.ATTACHMENT);
}
} catch (MessagingException e) {
e.printStackTrace();
} catch (Exception e) {