/*
 * Copyright 2010 LinkedIn, Inc
 * 
 * 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.List;
import java.util.Properties;

import javax.mail.Message;
import javax.mail.MessagingException;
import javax.mail.Session;
import javax.mail.internet.AddressException;
import javax.mail.internet.InternetAddress;
import javax.mail.internet.MimeMessage;

import org.apache.log4j.Logger;

import com.sun.mail.smtp.SMTPTransport;

/**
 * The mailman send you mail, if you ask him
 * 
 */
public class Mailman {

	private static Logger logger = Logger.getLogger(Mailman.class.getName());

	private final String _mailHost;
	private final String _mailUser;
	private final String _mailPassword;
	private final String _mailSender;
	
	private final String protocol = "smtp";

	public Mailman(String mailHost, String mailUser, String mailPassword,
			String mailSender) {
		this._mailHost = mailHost;
		this._mailUser = mailUser;
		this._mailPassword = mailPassword;
		this._mailSender = mailSender;
	}

	public void sendEmail(String fromAddress, List<String> toAddress,
			String subject, String body) throws MessagingException {
		//session
		Properties props = new Properties();
		props.put("mail." + protocol + ".host", _mailHost);
		props.put("mail." + protocol + ".auth", "true");
		
		Session session = Session.getInstance(props, null);
		session.setDebug(true);
		
//		//email message
//		Message msg = new MimeMessage(session);
//		msg.setFrom(new InternetAddress(fromAddress));
//		for(String str : toAddress) {
//			msg.addRecipients(Message.RecipientType.TO, InternetAddress.parse(str));
//		}
//		
//		msg.setSubject(subject);
//		msg.setText(body);
//		
//		//transport
//		SMTPTransport t = (SMTPTransport)session.getTransport(protocol);
//		
//		try {
//			t.connect(_mailHost, _mailUser, _mailPassword);
//			t.sendMessage(msg, msg.getAllRecipients());
//		}
//		catch (Exception e) {
//			logger.error(e);
//		}
//		finally {
//			t.close();
//		}
	}

	public void sendEmailIfPossible(String fromAddress, List<String> toAddress,
			String subject, String body) {
		try {
			sendEmail(fromAddress, toAddress, subject, body);
		} catch (AddressException e) {
			logger.warn("Error while sending email, invalid email: "
					+ e.getMessage());
		} catch (MessagingException e) {
			logger.warn("Error while sending email: " + e.getMessage());
		}
	}

}
