[ 
https://issues.apache.org/jira/browse/NIFI-4326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16149631#comment-16149631
 ] 

ASF GitHub Bot commented on NIFI-4326:
--------------------------------------

Github user kevdoran commented on a diff in the pull request:

    https://github.com/apache/nifi/pull/2111#discussion_r136450708
  
    --- Diff: 
nifi-nar-bundles/nifi-email-bundle/nifi-email-processors/src/main/java/org/apache/nifi/processors/email/ExtractEmailHeaders.java
 ---
    @@ -168,21 +173,40 @@ public void process(final InputStream rawIn) throws 
IOException {
                                 }
                             }
                         }
    -                    if 
(Array.getLength(originalMessage.getAllRecipients()) > 0) {
    -                        for (int toCount = 0; toCount < 
ArrayUtils.getLength(originalMessage.getRecipients(Message.RecipientType.TO)); 
toCount++) {
    -                            attributes.put(EMAIL_HEADER_TO + "." + 
toCount, 
originalMessage.getRecipients(Message.RecipientType.TO)[toCount].toString());
    +
    +                    // Get Non-Strict Recipient Addresses
    +                    InternetAddress[] recipients;
    +                    if 
(originalMessage.getHeader(Message.RecipientType.TO.toString(), ",") != null) {
    +                        recipients = 
InternetAddress.parseHeader(originalMessage.getHeader(Message.RecipientType.TO.toString(),
 ","), false);
    +                        for (int toCount = 0; toCount < 
ArrayUtils.getLength(recipients); toCount++) {
    +                            attributes.put(EMAIL_HEADER_TO + "." + 
toCount, recipients[toCount].toString());
                             }
    -                        for (int toCount = 0; toCount < 
ArrayUtils.getLength(originalMessage.getRecipients(Message.RecipientType.BCC)); 
toCount++) {
    -                            attributes.put(EMAIL_HEADER_BCC + "." + 
toCount, 
originalMessage.getRecipients(Message.RecipientType.BCC)[toCount].toString());
    +                    }
    +                    if 
(originalMessage.getHeader(Message.RecipientType.BCC.toString(), ",") != null) {
    +                        recipients = 
InternetAddress.parseHeader(originalMessage.getHeader(Message.RecipientType.BCC.toString(),
 ","), false);
    +                        for (int toCount = 0; toCount < 
ArrayUtils.getLength(recipients); toCount++) {
    +                            attributes.put(EMAIL_HEADER_BCC + "." + 
toCount, recipients[toCount].toString());
                             }
    -                        for (int toCount = 0; toCount < 
ArrayUtils.getLength(originalMessage.getRecipients(Message.RecipientType.CC)); 
toCount++) {
    -                            attributes.put(EMAIL_HEADER_CC + "." + 
toCount, 
originalMessage.getRecipients(Message.RecipientType.CC)[toCount].toString());
    +                    }
    +                    if 
(originalMessage.getHeader(Message.RecipientType.CC.toString(), ",") != null) {
    +                        recipients = 
InternetAddress.parseHeader(originalMessage.getHeader(Message.RecipientType.CC.toString(),
 ","), false);
    +                        for (int toCount = 0; toCount < 
ArrayUtils.getLength(recipients); toCount++) {
    +                            attributes.put(EMAIL_HEADER_CC + "." + 
toCount, recipients[toCount].toString());
                             }
                         }
    -                    // Incredibly enough RFC-2822 specified From as a 
"mailbox-list" so an array I returned by getFrom
    -                    for (int toCount = 0; toCount < 
ArrayUtils.getLength(originalMessage.getFrom()); toCount++) {
    -                        attributes.put(EMAIL_HEADER_FROM + "." + toCount, 
originalMessage.getFrom()[toCount].toString());
    +
    +                    // Get Non-Strict Sender Addresses
    +                    InternetAddress[] sender = null;
    +                    if (originalMessage.getHeader("From",",") != null) {
    +                        sender = 
(InternetAddress[])ArrayUtils.addAll(sender, 
InternetAddress.parseHeader(originalMessage.getHeader("From", ","), false));
    +                    }
    +                    if (originalMessage.getHeader("Sender",",") != null) {
    +                        sender = 
(InternetAddress[])ArrayUtils.addAll(sender, 
InternetAddress.parseHeader(originalMessage.getHeader("Sender", ","), false));
    --- End diff --
    
    I don't think we should combine the values of the Sender and From headers 
here, for two reasons: 
    
    1. It breaks the documentation for the processor that states 
email.headers.from will contain the values in From
    2. If From is a mailbox-list, Sender might be a single mailbox in the From 
mailbox-list, so the result here could be a duplicate email address.
    
    I think this could break expectations from folks already using the 
ExtractEmailHeaders processor. If this functionality is needed, a new header 
field (ie, email.headers.sender) should be added. However, in that case, this 
functionality could already be achieved using the Additional Headers capability 
offered by ExtractEmailHeaders.



> ExtractEmailHeaders.java unhandled Exceptions
> ---------------------------------------------
>
>                 Key: NIFI-4326
>                 URL: https://issues.apache.org/jira/browse/NIFI-4326
>             Project: Apache NiFi
>          Issue Type: Bug
>          Components: Core Framework
>    Affects Versions: 1.3.0
>         Environment: jdk 1.8.0_121-b13
>            Reporter: Benjamin Wood
>            Priority: Minor
>             Fix For: 1.4.0
>
>   Original Estimate: 0.5h
>  Remaining Estimate: 0.5h
>
> The ExtractEmailHeaders  processor throws a NullPointerException if there is 
> no TO, CC, and BCC recipients.
> If there are no recipients "originalMessage.getAllRecipients()" returns NULL, 
> and not a 0 length array.
> If an address is empty (<> or " ") then getRecipients() will throw an "Empty 
> Address" AddressException
> It's possible this is only an issue with Oracle Java.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

Reply via email to