//
// SwitchRMI  Framework
// Copyright (c) 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: HttpRmiServlet.java,v 1.1 2002/11/11 22:19:48 mikehenderson Exp $
package com.mjh.switchrmi.transport.http;

import com.mjh.switchrmi.*;

import java.util.*;

import javax.naming.*;

import javax.servlet.ServletConfig;
import javax.servlet.ServletException;
import javax.servlet.http.Cookie;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;

import org.apache.log4j.Logger;

public class HttpRmiServlet extends HttpServlet
{
    private static final Logger log = 
            Logger.getLogger(HttpRmiServlet.class.getName());
    public final static String CONFIG_INIT_PARAM_NAME = 
            "switchrmi.configuration";
    private Context jndiContext;

    /**
     * Creates a new HttpRmiServlet object.
     */
    public HttpRmiServlet()
    {
    }

    /**
     * DOCUMENT ME!
     * 
     * @param config DOCUMENT ME!
     * @throws ServletException DOCUMENT ME!
     */
    public void init(ServletConfig config)
              throws ServletException
    {
        boolean debug = log.isDebugEnabled();

        super.init(config);

        try
        {
            if (debug)
            {
                log.debug("config = " + config);
            }

            java.util.Enumeration e = config.getInitParameterNames();

            while (e.hasMoreElements())
            {
                String name = (String) e.nextElement();

                if (debug)
                {
                    log.debug(name + "  = " + config.getInitParameter(name));
                }
            }

            String resourceName = 
                    config.getInitParameter(CONFIG_INIT_PARAM_NAME);
            Hashtable env = new Hashtable();

            env.put(Context.PROVIDER_URL, resourceName);
            env.put(Context.INITIAL_CONTEXT_FACTORY, 
                    "com.mjh.switchrmi.jndi.JndiContextImplFactory");
            jndiContext = new InitialContext(env);

            if (debug)
            {
                log.debug("jndiContext = " + jndiContext);
            }
        }
        catch (Exception ex)
        {
            if (debug)
            {
                log.debug("Exception in RmiServlet(): ", ex);
            }

            throw new ServletException(ex.toString());
        }
    }

    protected void doGet(HttpServletRequest request, 
                         HttpServletResponse response)
    {
        doPost(request, response);
    }

    protected void doPost(HttpServletRequest request, 
                          HttpServletResponse response)
    {
        boolean debug = log.isDebugEnabled();
        RmiHandler handler = new RmiHandler();
        RmiContext context = null;

        try
        {
            context = new RmiContextImpl(true, 
                                         request.getRequestURL().toString(), 
                                         jndiContext);

            HttpServletTransport transport = 
                    (HttpServletTransport) context.getTransport();

            transport.setServletRequest(request);
            transport.setServletResponse(response);

            HttpSession session = request.getSession();
            Cookie[] cookies = request.getCookies();

            handler.serviceInvoke(context, new HttpSessionScopeAccess(session));
        }
        catch (Exception ex)
        {
            try
            {
                if (debug)
                {
                    log.debug("Problem: ", ex);
                }

                if (context != null)
                {
                    handler.handleFault(ex, context);
                }
            }
            catch (Exception ex1)
            {
                if (debug)
                {
                    log.debug("Exception:", ex1);
                }
            }
        }
        finally
        {
            handler.reset();
            handler = null;
        }
    }
}