auth/auth-batch/src/main/java/org/onap/aaf/auth/javax/JavaxMailer.java

   1 /**
   2  * ============LICENSE_START====================================================
   3  * org.onap.aaf
   4  * ===========================================================================
   5  * Copyright (c) 2018 AT&T Intellectual Property. All rights reserved.
   6  * ===========================================================================
   7  * Licensed under the Apache License, Version 2.0 (the "License");
   8  * you may not use this file except in compliance with the License.
   9  * You may obtain a copy of the License at
  10  *
  11  *      http://www.apache.org/licenses/LICENSE-2.0
  12  *
  13  * Unless required by applicable law or agreed to in writing, software
  14  * distributed under the License is distributed on an "AS IS" BASIS,
  15  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  16  * See the License for the specific language governing permissions and
  17  * limitations under the License.
  18  * ============LICENSE_END====================================================
  19  *
  20  */
  21 package org.onap.aaf.auth.javax;
  22
  23 import java.util.ArrayList;
  24 import java.util.List;
  25
  26 import javax.mail.Address;
  27 import javax.mail.Message;
  28 import javax.mail.MessagingException;
  29 import javax.mail.Session;
  30 import javax.mail.Transport;
  31 import javax.mail.internet.InternetAddress;
  32 import javax.mail.internet.MimeMessage;
  33
  34 import org.onap.aaf.auth.env.AuthzTrans;
  35 import org.onap.aaf.auth.org.Mailer;
  36 import org.onap.aaf.auth.org.OrganizationException;
  37
  38 public class JavaxMailer implements Mailer {
  39     private Session session;
  40
  41       public JavaxMailer() {
  42
  43             // Get the default Session object.
  44             session = Session.getDefaultInstance(System.getProperties());
  45
  46       }
  47
  48       @Override
  49         public int sendEmail(AuthzTrans trans, boolean testMode, String mailFrom, List<String> to, List<String> cc, String subject, String body,
  50                 Boolean urgent) throws OrganizationException {
  51
  52             int status = 1;
  53
  54
  55             try {
  56                 // Create a default MimeMessage object.
  57                 MimeMessage message = new MimeMessage(session);
  58
  59                 // Set From: header field of the header.
  60                 message.setFrom(new InternetAddress(mailFrom));
  61
  62                 if (!testMode) {
  63                     // Set To: header field of the header. This is a required field
  64                     // and calling module should make sure that it is not null or
  65                     // blank
  66                     message.addRecipients(Message.RecipientType.TO,getAddresses(to));
  67
  68                     // Set CC: header field of the header.
  69                     if ((cc != null) && (cc.size() > 0)) {
  70                         message.addRecipients(Message.RecipientType.CC,getAddresses(cc));
  71                     }
  72
  73                     // Set Subject: header field
  74                     message.setSubject(subject);
  75
  76                     if (urgent) {
  77                         message.addHeader("X-Priority", "1");
  78                     }
  79
  80                     // Now set the actual message
  81                     message.setText(body);
  82                 } else {
  83
  84                     // override recipients
  85                     message.addRecipients(Message.RecipientType.TO,
  86                             InternetAddress.parse(mailFrom));
  87
  88                     // Set Subject: header field
  89                     message.setSubject("[TESTMODE] " + subject);
  90
  91                     if (urgent) {
  92                         message.addHeader("X-Priority", "1");
  93                     }
  94
  95                     ArrayList<String> newBody = new ArrayList<>();
  96
  97                     Address temp[] = getAddresses(to);
  98                     String headerString = "TO:\t" + InternetAddress.toString(temp) + "\n";
  99
 100                     temp = getAddresses(cc);
 101                     headerString += "CC:\t" + InternetAddress.toString(temp) + "\n";
 102
 103                     newBody.add(headerString);
 104
 105                     newBody.add("Text: \n");
 106
 107                     newBody.add(body);
 108                     String outString = "";
 109                     for (String s : newBody) {
 110                         outString += s + "\n";
 111                     }
 112
 113                     message.setText(outString);
 114                 }
 115                 // Send message
 116                 Transport.send(message);
 117                 status = 0;
 118
 119             } catch (MessagingException mex) {
 120                 System.out.println("Error messaging: "+ mex.getMessage());
 121                 System.out.println("Error messaging: "+ mex.toString());
 122                 throw new OrganizationException("Exception send email message "
 123                         + mex.getMessage());
 124             }
 125
 126             return status;
 127         }
 128
 129         /**
 130          * Convert the delimiter String into Internet addresses with the default
 131          * delimiter of ";"
 132          * @param strAddress
 133          * @return
 134          */
 135         private Address[] getAddresses(List<String> strAddress) throws OrganizationException {
 136             return this.getAddresses(strAddress,";");
 137         }
 138         /**
 139          * Convert the delimiter String into Internet addresses with the
 140          * delimiter of provided
 141          * @param strAddresses
 142          * @param delimiter
 143          * @return
 144          */
 145         private Address[] getAddresses(List<String> strAddresses, String delimiter) throws OrganizationException {
 146             Address[] addressArray = new Address[strAddresses.size()];
 147             int count = 0;
 148             for (String addr : strAddresses)
 149             {
 150                 try{
 151                     addressArray[count] = new InternetAddress(addr);
 152                     count++;
 153                 } catch (Exception e){
 154                     throw new OrganizationException("Failed to parse the email address "+ addr +": "+e.getMessage());
 155                 }
 156             }
 157             return addressArray;
 158         }
 159
 160 }