source: trunk/src/org/expeditee/agents/mail/MailSession.java@ 238

package org.expeditee.agents.mail;

import java.util.Date;
import java.util.Properties;

import javax.mail.Authenticator;
import javax.mail.Message;
import javax.mail.PasswordAuthentication;
import javax.mail.Session;
import javax.mail.Transport;
import javax.mail.internet.InternetAddress;
import javax.mail.internet.MimeMessage;

import org.expeditee.gui.AttributeValuePair;
import org.expeditee.gui.Frame;
import org.expeditee.gui.MessageBay;
import org.expeditee.items.Text;

public class MailSession {
        private static MailSession _theMailSession = null;

        private Session _session;

        private Transport _transport;

        private String _address;

        private MailSession(Frame settingsFrame) {
                Properties props = System.getProperties();

                String username = null;
                String password = "";

                // Set the settings
                for (Text item : settingsFrame.getBodyTextItems(false)) {
                        AttributeValuePair avp = new AttributeValuePair(item.getText());
                        if (!avp.hasPair())
                                continue;
                        String attributeFullCase = avp.getAttribute();
                        String attribute = attributeFullCase.toLowerCase();

                        if (attribute.equals("user")) {
                                username = avp.getValue();
                                props.setProperty("mail.user", username);
                        } else if (attribute.equals("password")) {
                                password = avp.getValue();
                                props.setProperty("mail.password", password);
                        } else if (attribute.equals("address")) {
                                _address = avp.getValue();
                        } else if (attribute.equals("smtpserver")) {
                                props.setProperty("mail.transport.protocol", "smtp");
                                props.setProperty("mail.host", avp.getValue());
                                props.setProperty("mail.smtp.starttls.enable", "true");
                                props.setProperty("mail.smtp.host", avp.getValue());
                                props.setProperty("mail.smtp.auth", "true");
                        }
                }

                // Create the authenticator
                Authenticator auth = null;
                if (username != null) {
                        auth = new SMTPAuthenticator(username, password);
                }
                java.security.Security
                                .addProvider(new com.sun.net.ssl.internal.ssl.Provider());

                // -- Attaching to default Session, or we could start a new one --
                _session = Session.getDefaultInstance(props, auth);
                try {
                        // -- Send the message --
                        _transport = _session.getTransport();
                        _transport.connect();
                } catch (Exception e) {
                        MessageBay.errorMessage("Error in ExpMail setup");
                }
        }

        public static boolean sendTextMessage(String to, String cc, String subject,
                        String body) {
                if (_theMailSession == null) {
                        MessageBay.errorMessage("Add mail settings to profile frame");
                        return false;
                } else if (to == null) {
                        MessageBay.errorMessage("Add tag @to:<sendToEmailAddress>");
                        return false;
                }

                try {
                        // -- Create a new message --
                        Message msg = new MimeMessage(_theMailSession._session);

                        // -- Set the FROM and TO fields --
                        msg.setFrom(new InternetAddress(_theMailSession._address));
                        msg.setRecipients(Message.RecipientType.TO, InternetAddress.parse(
                                        to, false));

                        // -- We could include CC recipients too --
                        if (cc != null) {
                                msg.setRecipients(Message.RecipientType.CC, InternetAddress
                                                .parse(cc, false));
                        }

                        // -- Set the subject and body text --
                        msg.setSubject(subject);
                        msg.setContent(body.toString(), "text/plain");

                        // -- Set some other header information --
                        msg.setHeader("ExpMail", "Expeditee");
                        msg.setSentDate(new Date());

                        Transport.send(msg, msg.getRecipients(Message.RecipientType.TO));
                } catch (Exception e) {
                        MessageBay.errorMessage("Error sending mail: " + e.getMessage());
                        return false;
                }
                MessageBay.displayMessage("Message sent OK.");
                return true;
        }

        public static void init(Frame settingsFrame) {

                if (settingsFrame == null)
                        return;

                if (_theMailSession == null)
                        _theMailSession = new MailSession(settingsFrame);
        }

        private class SMTPAuthenticator extends javax.mail.Authenticator {
                private String _username;

                private String _password;

                public SMTPAuthenticator(String username, String password) {
                        _username = username;
                        _password = password;
                }

                @Override
                public PasswordAuthentication getPasswordAuthentication() {
                        return new PasswordAuthentication(_username, _password);
                }
        }

        public static void finalise() {
                try {
                        if (_theMailSession._transport != null)
                                _theMailSession._transport.close();
                } catch (Exception e) {

                }
        }
}