D-Net

package eu.dnetlib.goldoa.service.utils;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

import org.springframework.stereotype.Service;

import javax.mail.*;

import javax.mail.internet.AddressException;

import javax.mail.internet.InternetAddress;

import javax.mail.internet.MimeMessage;

import java.io.IOException;

import java.util.Properties;

/**

 * Created by antleb on 3/9/15.

 */

@Service

public class MailLibrary {

	private String mailhost;

	private String from ;

	private String replyTo;

	private String smtpPort;

	private String username;

	private String password;

	private String authenticate ;

	private String mode ;

	private String debug ;

	private Properties props ;

	private Log log = LogFactory.getLog(MailLibrary.class);

	public void init() {

		props = new Properties();

		log.debug("mode : "  + mode);

		if (mode.equals("plain")) {

			props.put("mail.transport.protocol", "smtp");

			props.put("mail.smtp.host", mailhost);

			props.put("mail.smtp.port", smtpPort);

		} else if (mode.equals("ssl")) {

			props.put("mail.transport.protocol", "smtps");

			props.put("mail.smtps.host", mailhost);

			props.put("mail.smtps.port", smtpPort);

			props.put("mail.smtps.auth", "true");

			props.put("mail.smtps.user", username);

			props.put("mail.smtps.password", password);

		} else {

			throw new IllegalArgumentException("Unkown mode '" + mode + "'");

		}

		props.setProperty("mail.debug", this.debug + "");

	}

	public void sendEmail(String email, String subject, String text) throws AddressException, MessagingException {

		sendEmail(new String[]{email}, subject, text);

	}

	public void sendEmail(String[] recipients, String subject, String text) throws AddressException, MessagingException {

		Session session = Session.getInstance(props,

				(Boolean.parseBoolean(this.authenticate) ? new SMTPAuthenticator() : null));

		session.setDebug(Boolean.parseBoolean(this.debug));

		Message msg = new MimeMessage(session);

		msg.setFrom(new InternetAddress(this.from));

		msg.setReplyTo(new InternetAddress[]{new InternetAddress(replyTo)});

		msg.setSubject(subject);

		msg.setContent(text, "text/plain");

		for (String recipient : recipients)

			msg.addRecipient(javax.mail.Message.RecipientType.TO,

					new InternetAddress(recipient));

		Transport tr = session.getTransport();

		if (Boolean.parseBoolean(this.authenticate)) {

			tr.connect(mailhost, Integer.parseInt(smtpPort), username, password);

		} else {

			tr.connect();

		}

		try {

			System.out.println(msg.getContent().toString());

		} catch (IOException e) {

			e.printStackTrace();

		}

		tr.sendMessage(msg, msg.getAllRecipients());

		tr.close();

	}

	private class SMTPAuthenticator extends javax.mail.Authenticator {

		public PasswordAuthentication getPasswordAuthentication() {

			return new PasswordAuthentication(username, password);

		}

	}

	public String getMailhost() {

		return mailhost;

	}

	public void setMailhost(String mailhost) {

		this.mailhost = mailhost;

	}

	public String getFrom() {

		return from;

	}

	public void setFrom(String from) {

		this.from = from;

	}

	public String getReplyTo() {

		return replyTo;

	}

	public void setReplyTo(String replyTo) {

		this.replyTo = replyTo;

	}

	public String getSmtpPort() {

		return smtpPort;

	}

	public void setSmtpPort(String smtpPort) {

		this.smtpPort = smtpPort;

	}

	public String getUsername() {

		return username;

	}

	public void setUsername(String username) {

		this.username = username;

	}

	public String getPassword() {

		return password;

	}

	public void setPassword(String password) {

		this.password = password;

	}

	public String isAuthenticate() {

		return authenticate;

	}

	public void setAuthenticate(String authenticate) {

		this.authenticate = authenticate;

	}

	public String getMode() {

		return mode;

	}

	public void setMode(String mode) {

		this.mode = mode;

	}

	public String isDebug() {

		return debug;

	}

	public void setDebug(String debug) {

		this.debug = debug;

	}

}