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

import com.mjh.util.*;

import java.net.*;

import java.util.*;

import javax.naming.*;

import org.apache.log4j.*;

public class RmiContextImpl implements RmiContext
{
    private static final Logger log = 
            Logger.getLogger(RmiContext.class.getName());
    private String targetUrl;
    private RmiTransport transport;
    private RmiProtocol protocol;
    private UrlInfo urlInfo;
    private Object sessionID;
    private Object target;
    private Context jndiContext;
    boolean isService;

    public RmiContextImpl()
    {
    }

    public RmiContextImpl(boolean isService)
    {
        this.isService = isService;
    }

    public RmiContextImpl(boolean isService, String url, Context ctx)
                   throws Exception
    {
        this(isService, url, ctx, null);
    }

    public RmiContextImpl(boolean isService, String url, Context ctx, 
                          String protocolName)
                   throws Exception
    {
        this.isService = isService;
        setUrl(url);
        urlInfo = new RmiUrlInfo(url);

        if (log.isDebugEnabled())
        {
            log.debug("urlInfo = " + urlInfo);
        }

        jndiContext = ctx;

        String string = (isService()) ? "service/" : "client/";
        String jndiName = "/switchrmi/" + string + "transport/"
                          + getTransportName();

        if (log.isDebugEnabled())
        {
            log.debug("jndiName = " + jndiName);
        }

        transport = (RmiTransport) ctx.lookup(jndiName);

        if (log.isDebugEnabled())
        {
            log.debug("transport = " + transport);
        }

        if (log.isDebugEnabled())
        {
            log.debug("protocolName = " + protocolName);
            log.debug("getProtocolName() = " + getProtocolName());
        }

        String name = (protocolName == null
                      || protocolName.trim().length() == 0)
                      ? getProtocolName() : protocolName;

        jndiName = "/switchrmi/" + string + "protocol/" + name;

        if (log.isDebugEnabled())
        {
            log.debug("jndiName = " + jndiName);
        }

        protocol = (RmiProtocol) ctx.lookup(jndiName);

        if (log.isDebugEnabled())
        {
            log.debug("protocol = " + protocol);
        }
    }

    public boolean isClient()
    {
        return !isService;
    }

    public boolean isService()
    {
        return isService;
    }

    public void setUrl(String url)
    {
        targetUrl = url;
    }

    public String getUrl()
    {
        return targetUrl;
    }

    public void setTransport(RmiTransport transport)
    {
        this.transport = transport;
    }

    public RmiTransport getTransport()
    {
        return transport;
    }

    public void setProtocol(RmiProtocol protocol)
    {
        this.protocol = protocol;
    }

    public RmiProtocol getProtocol()
    {
        return protocol;
    }

    public String getObjectName()
    {
        return ((RmiUrlInfo) urlInfo).getObjectName();
    }

    public String getTransportName()
    {
        return ((RmiUrlInfo) urlInfo).getTransportName();
    }

    public String getProtocolName()
    {
        return ((RmiUrlInfo) urlInfo).getProtocolName();
    }

    public void setTarget(Object target)
    {
        this.target = target;
    }

    public Object lookup(String name)
                  throws Exception
    {
        return jndiContext.lookup(name);
    }

    public Context getJndiContext()
    {
        return jndiContext;
    }

    public Object getTarget()
    {
        return target;
    }

    public void setSessionIdentifier(Object identifier)
    {
        sessionID = identifier;

        if (log.isDebugEnabled())
        {
            log.debug("context.setSessionIdentifier() sessionID = " + sessionID);
        }
    }

    public Object getSessionIdentifier()
    {
        if (log.isDebugEnabled())
        {
            log.debug("context.getSessionIdentifier() sessionID = " + sessionID);
        }

        return sessionID;
    }

    public UrlInfo getUrlInfo()
                       throws MalformedURLException
    {
        return getTransport().getUrlInfo(this);
    }
}