//
// SwitchRMI  Framework
// Copyright (c) 2000-2002 by Michael J. Henderson & Associates.
//
// Michael Henderson
// http://switchrmi.sf.net
// mailto:mikehenderson@dunelm.org.uk
//
// This library is free software.
//
// You may redistribute it and/or modify it under the terms of the GNU
// Lesser General Public License as published by the Free Software Foundation.
//
// Version 2.1 of the license should be included with this distribution in
// the file LICENSE, as well as License.html. If the license is not
// included with this distribution, you may find a copy at the FSF web
// site at 'www.gnu.org' or 'www.fsf.org', or you may write to the
// Free Software Foundation, 675 Mass Ave, Cambridge, MA 02139 USA.
//
// This library is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied waranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
// Lesser General Public License for more details.
//
// $Id: RmiEmailService.java,v 1.1 2002/11/11 22:19:48 mikehenderson Exp $
package com.mjh.switchrmi.transport.smtp;

import com.mjh.switchrmi.*;

import java.util.*;

import javax.mail.*;
import javax.mail.internet.*;

import javax.naming.*;

import org.apache.log4j.*;

public class RmiEmailService
{
    private static final String CONFIG_RESOURCE_PROPERTY_NAME = 
            "switchrmi.configuration";
    private static final String POP3 = "pop3";
    private static final String IMAP = "imap";
    private static final Logger log = 
            Logger.getLogger(RmiEmailService.class.getName());
    private String provider = "pop3";
    private String user;
    private String password;
    private String host;
    private int pollingInterval = 1000 * 60 * 2;
    private Session session;
    private Store store;
    private Folder defaultFolder;
    private Folder folder;
    private SmtpServiceHandler handler;

    RmiEmailService(Properties props)
             throws Exception
    {
        provider = props.getProperty("mail.store.protocol", POP3);
        log.debug("provider = " + provider);
        host = props.getProperty("mail." + provider + ".host");
        log.debug("host = " + host);
        user = props.getProperty("mail." + provider + ".user");
        log.debug("user = " + user);
        password = props.getProperty("mail." + provider + ".password");
        log.debug("password = " + password);

        String intervalString = props.getProperty("interval");

        if (intervalString != null)
        {
            pollingInterval = (new Integer(intervalString)).intValue() * 1000 * 60;
        }

        String resourceName = props.getProperty(Context.PROVIDER_URL);
        String factoryName = props.getProperty(Context.INITIAL_CONTEXT_FACTORY);
        Hashtable env = new Hashtable();

        env.put(Context.PROVIDER_URL, resourceName);
        env.put(Context.INITIAL_CONTEXT_FACTORY, factoryName);

        Context jndiContext = new InitialContext(env);

        handler = new SmtpServiceHandler(jndiContext);
        session = Session.getInstance(props, null);

        if (log.isDebugEnabled())
        {
            session.setDebug(true);
        }

        store = session.getStore(provider);
        store.connect(host, user, password);
        defaultFolder = store.getDefaultFolder();
        folder = defaultFolder.getFolder("INBOX");
    }

    /**
     * DOCUMENT ME!
     * 
     * @param args DOCUMENT ME!
     */
    public static void main(String[] args)
    {
        try
        {
            RmiEmailService service = 
                    new RmiEmailService(System.getProperties());

            service.run();
        }
        catch (Exception ex)
        {
            System.err.println("Unable to start Pop3MailService: " + ex);
        }

        System.exit(-1);
    }

    /**
     * DOCUMENT ME!
     * 
     * @throws Exception DOCUMENT ME!
     */
    public void run() throws Exception
    {
        while (true)
        {
            runOnce();
            Thread.sleep(pollingInterval);
        }
    }

    /**
     * DOCUMENT ME!
     * 
     * @throws Exception DOCUMENT ME!
     */
    public void runOnce() throws Exception
    {
        folder.open(Folder.READ_WRITE);

        Message[] message = folder.getMessages();

        log.debug("message.length = " + message.length);

        for (int i = 0; i < message.length; i++)
        {
            Message msg = message[i];
            String subject = msg.getSubject();

            System.out.println("subject = " + subject);

            if (subject.toLowerCase().indexOf("switchrmi") != -1)
            {
                handler.setMessage(msg);
                handler.invoke();
                System.out.println("Method was invoked");
                msg.setFlag(Flags.Flag.DELETED, true);
            }
        }

        if (!provider.equals(POP3))
        {
            folder.expunge();
        }

        folder.close(true);
    }
}