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

import com.mjh.switchrmi.*;

import java.io.*;

import java.lang.reflect.Method;

import javax.activation.*;

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

import javax.naming.*;

import org.apache.log4j.*;

/**
 * @author michaelh
 *
 * To change this generated comment edit the template variable "typecomment":
 * Window>Preferences>Java>Templates.
 * To enable and disable the creation of type comments go to
 * Window>Preferences>Java>Code Generation.
 */
public class SmtpServiceHandler
{
    private static final Logger log = 
            Logger.getLogger(SmtpServiceHandler.class.getName());
    private Message message;
    private Context jndiContext;

    /**
     * Constructor for SmtpServiceHandler.
     */
    public SmtpServiceHandler(Context ctx)
    {
        jndiContext = ctx;
    }

    public void setMessage(Message msg)
    {
        message = msg;
    }

    public void invoke() throws Exception
    {
        RmiHandler handler = new RmiHandler();
        Multipart multipart = (Multipart) message.getContent();
        MimeBodyPart text = (MimeBodyPart) multipart.getBodyPart(0);
        MimeBodyPart attachment = (MimeBodyPart) multipart.getBodyPart(1);
        String objectUrl = (String) text.getContent();

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

        RmiContext context = new RmiContextImpl(true, objectUrl, jndiContext);

        context.setTransport(new SmtpHandlerTransport(attachment));
        handler.serviceInvoke(context, null);
    }

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

    private void debug(Exception ex)
    {
        log.debug("Exception", ex);
    }

    class SmtpHandlerTransport
        extends RmiTransportBase
    {
        private MimeBodyPart methodInfo;

        public SmtpHandlerTransport(MimeBodyPart part)
        {
            methodInfo = part;
            super.setType(RmiTransport.ASYNCHRONOUS);
            super.setName("smtp-service");
        }

        public InputStream getInputStream(RmiContext context)
        {
            InputStream in = null;

            try
            {
                in = methodInfo.getInputStream();
            }
            catch (Exception ex)
            {
                log.debug(ex);
            }

            return in;
        }

        public OutputStream getOutputStream(RmiContext context)
        {
            return new ByteArrayOutputStream();
        }
    }
}