//
// 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: RmiMailet.java,v 1.1 2002/11/11 22:19:48 mikehenderson Exp $
//
package com.mjh.switchrmi.transport.smtp.james;

import com.mjh.switchrmi.*;
import com.mjh.switchrmi.transport.smtp.SmtpServiceHandler;

import java.util.*;

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

import javax.naming.*;

import org.apache.mailet.GenericMailet;
import org.apache.mailet.Mail;
import org.apache.mailet.MailetConfig;

public class RmiMailet extends GenericMailet
{
    Context jndiContext;

    public void init(MailetConfig config)
              throws MessagingException
    {
        try
        {
            String configurationName = 
                    config.getInitParameter("rpcServiceConfiguration");
            Hashtable env = new Hashtable();

            env.put(Context.PROVIDER_URL, configurationName);
            jndiContext = new InitialContext(env);
        }
        catch (Exception ex)
        {
            throw new MessagingException(ex.toString());
        }
    }

    public void service(Mail mail)
                 throws MessagingException
    {
        try
        {
            MimeMessage message = mail.getMessage();

            String subject = message.getSubject();

            if (subject.startsWith("RPC:"))
            {
                Multipart multipart = (Multipart) message.getContent();

                if (multipart.getCount() == 2)
                {
                    SmtpServiceHandler handler = 
                            new SmtpServiceHandler(jndiContext);

                    handler.setMessage(message);

                    handler.invoke();
                }
            }
        }
        catch (Exception ex)
        {
            debug(ex);
            throw new MessagingException(ex.toString());
        }
    }

    private void debug(String msg)
    {
        System.out.println(msg);
    }

    private void debug(Exception ex)
    {
        debug(ex.toString());
        ex.printStackTrace();
    }
}