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

import com.mjh.switchrmi.*;

import java.io.IOException;
import java.io.InputStream;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.io.OutputStream;

import java.lang.reflect.Method;

import org.apache.log4j.Logger;

public class RawProtocol implements RmiProtocol
{
    private static final Logger log = 
            Logger.getLogger(RawProtocol.class.getName());

    public RawProtocol()
    {
    }

    public String getName()
    {
        return RmiProtocol.RAWRPC;
    }

    public String getMimeType()
    {
        return RmiProtocol.RAWRPC_CONTENT_TYPE;
    }

    public RmiRequest createRequest(Method method, Object[] args, 
                                    RmiContext context)
    {
        return new RmiRequestImpl(method, args);
    }

    public RmiResponse createResponse(RmiRequest request, Object result, 
                                      RmiContext context)
    {
        return new RmiResponseImpl(request, result);
    }

    public void writeRequest(RmiRequest request, RmiContext context)
                      throws Exception
    {
        writeObject(request, context);
    }

    public RmiResponse readResponse(RmiContext context)
                             throws Exception
    {
        return (context.getTransport().getType().equals(RmiTransport.SYNCHRONOUS))
               ? (RmiResponse) readObject(context) : new RmiResponseImpl(null);
    }

    public RmiRequest readRequest(RmiContext context)
                           throws Exception
    {
        return (RmiRequest) readObject(context);
    }

    public void writeResponse(RmiResponse response, RmiContext context)
                       throws Exception
    {
        if (context.getTransport().getType().equals(RmiTransport.SYNCHRONOUS))
        {
            writeObject(response, context);
        }
    }

    private void writeObject(Object object, RmiContext context)
                      throws Exception
    {
        ObjectOutputStream out = 
                new ObjectOutputStream(context.getTransport()
                                              .getOutputStream(context));

        out.writeObject(object);
        out.flush();
    }

    private Object readObject(RmiContext context)
                       throws Exception
    {
        ObjectInputStream in = 
                new ObjectInputStream(context.getTransport()
                                             .getInputStream(context));

        return in.readObject();
    }

    private void debug(String msg)
    {
        if (log.isDebugEnabled())
        {
            log.debug(msg);
        }
    }
}