AbstractMailer.java

/*
 * Copyright 2012 LinkedIn Corp.
 *
 * Licensed under the Apache License, Version 2.0 (the "License"); you may not
 * use this file except in compliance with the License. You may obtain a copy of
 * the License at
 *
 * http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
 * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
 * License for the specific language governing permissions and limitations under
 * the License.
 */

package azkaban.utils;

import java.util.Collection;

public class AbstractMailer {

  public static final int DEFAULT_SMTP_PORT = 25;
  private static final int MB_IN_BYTES = 1048576;
  private final String clientHostname;
  private final int clientPort;
  private final boolean usesSSL;
  private final boolean usesAuth;

  private final String mailHost;
  private final int mailPort;
  private final String mailUser;
  private final String mailPassword;
  private final String mailSender;
  private final String azkabanName;
  private final String tls;

  private final String referenceURL;

  private final long attachmentMazSizeInByte;

  public AbstractMailer(final Props props) {
    this.azkabanName = props.getString("azkaban.name", "azkaban");
    this.mailHost = props.getString("mail.host", "localhost");
    this.mailPort = props.getInt("mail.port", DEFAULT_SMTP_PORT);
    this.mailUser = props.getString("mail.user", "");
    this.mailPassword = props.getString("mail.password", "");
    this.tls = props.getString("mail.tls", "false");
    final long maxAttachmentSizeInMB =
        props.getInt("mail.max.attachment.size.mb", 100);

    this.attachmentMazSizeInByte = maxAttachmentSizeInMB * MB_IN_BYTES;

    this.mailSender = props.getString("mail.sender", "");
    this.usesAuth = props.getBoolean("mail.useAuth", true);

    this.clientHostname = props.get("server.hostname");
    this.clientPort = props.getInt("server.port");
    this.usesSSL = props.getBoolean("server.useSSL");

    if (this.usesSSL) {
      this.referenceURL =
          "https://" + this.clientHostname
              + (this.clientPort == 443 ? "/" : ":" + this.clientPort + "/");
    } else {
      this.referenceURL =
          "http://" + this.clientHostname
              + (this.clientPort == 80 ? "/" : ":" + this.clientPort + "/");
    }
  }

  public String getReferenceURL() {
    return this.referenceURL;
  }

  protected EmailMessage createEmailMessage(final String subject, final String mimetype,
      final Collection<String> emailList) {
    final EmailMessage message = new EmailMessage(this.mailHost, this.mailPort, this.mailUser,
        this.mailPassword);
    message.setFromAddress(this.mailSender);
    message.addAllToAddress(emailList);
    message.setMimeType(mimetype);
    message.setSubject(subject);
    message.setAuth(this.usesAuth);
    message.setTLS(this.tls);

    return message;
  }

  public EmailMessage prepareEmailMessage(final String subject, final String mimetype,
      final Collection<String> emailList) {
    return createEmailMessage(subject, mimetype, emailList);
  }

  public String getAzkabanName() {
    return this.azkabanName;
  }

  public String getMailHost() {
    return this.mailHost;
  }

  public String getMailUser() {
    return this.mailUser;
  }

  public String getMailPassword() {
    return this.mailPassword;
  }

  public String getMailSender() {
    return this.mailSender;
  }

  public int getMailPort() {
    return this.mailPort;
  }

  /**
   * Attachment maximum size in bytes
   */
  public long getAttachmentMaxSize() {
    return this.attachmentMazSizeInByte;
  }

  public boolean hasMailAuth() {
    return this.usesAuth;
  }
}