/*
* Copyright (c) 2008 Nokia Corporation and/or its subsidiary(-ies).
* All rights reserved.
* This component and the accompanying materials are made available
* under the terms of "Eclipse Public License v1.0"
* which accompanies this distribution, and is available
* at the URL "http://www.eclipse.org/legal/epl-v10.html".
*
* Initial Contributors:
* Nokia Corporation - initial contribution.
*
* Contributors:
*
* Description:
*
*/


package com.nokia.mj.impl.socket;

import java.io.IOException;
import javax.microedition.io.*;
import com.nokia.mj.impl.gcf.utils.*;
import com.nokia.mj.impl.utils.Logger;
import com.nokia.mj.impl.connectionmanager.ConnectionManager;
import com.nokia.mj.impl.connectionmanager.AccessPoint;
import com.nokia.mj.impl.rt.support.ApplicationInfo;
import com.nokia.mj.impl.utils.Uid;

/**
 * Socket Server Connection Implementation class.
 */

public class ServerSocketConnectionImpl implements ServerSocketConnection
{
    private int iMode;

    private int iNativeHandle;

    private int iPort;

    private UrlParser iUri;

    private boolean iConnectionOpen = false;

    private int iSockDesc;

    private int iSocketServerFactoryHandle;

    private ConnectionManager cminstance = null;

    private AccessPoint apn = null;

    /**
     * Constructs the ServerSocketConnectionImpl.
     *
     * @param uri
     *            the uri on which this server socket is opened
     * @param mode
     *            the with which server connection is opened
     */

    public ServerSocketConnectionImpl(UrlParser aUri, int aMode)
    throws IOException
    {
        Logger.LOG(Logger.ESOCKET, Logger.EInfo,
                   " + ServerSocketConnectionImpl: ServerSocketConnectionImpl");
        iMode = aMode;
        if (aUri.port == -1) // socket://:
            iPort = 0;
        else
            iPort = aUri.port;
        iUri = aUri;
        int ret[] = new int[1];
        iNativeHandle = _createSocketServerNativePeer(iUri.toString(), aMode,
                        iPort, ret);

        iSocketServerFactoryHandle = ret[0];

        Logger.LOG(Logger.ESOCKET, Logger.EInfo,
                   " iSocketServerFactory returned is "
                   + iSocketServerFactoryHandle);
        if (iNativeHandle == 0)
        {
            // push exception was thrown since for this url, push connection is
            // already registered
            throw new IOException(
                "Unable to open serversocket connection: failed to create native peer");
        }

        iSockDesc = _openServerSocket(iNativeHandle,
                                      iSocketServerFactoryHandle, iUri.toString());
        Logger.LOG(Logger.ESOCKET, Logger.EInfo,
                   "SocketDescriptor returned is " + iSockDesc);
        if (iSockDesc < 0)
        {
            throw new IOException(
                "Unable to open serversocket connection. POSIX error code: "
                + iSockDesc);
        }

        iConnectionOpen = true;
        Logger.LOG(Logger.ESOCKET, Logger.EInfo,
                   " - ServerSocketConnectionImpl: ServerSocketConnectionImpl");
    }

    /**
     * Get the local socket address of this connection.
     *
     * @return the local address
     * @throws IOException
     *             in case of any IO errors
     */

    public String getLocalAddress() throws IOException
    {
        Logger.LOG(Logger.ESOCKET, Logger.EInfo,
                   "+SocketServerConnectionImpl::getLocalAddress \n");
        String addr[] = new String[1];
        if (iConnectionOpen == false)
        {
            throw new IOException(
                "getLocalAddress failed: connection is already closed");
        }
        int apId = -1;
        int apType = -1;
        try
        {

            Uid appSuite = ApplicationInfo.getInstance().getSuiteUid();
            cminstance = ConnectionManager.getInstance();
            AccessPoint apn = cminstance.getApplicationDefault(appSuite);
            if (apn != null)
            {
                apId = apn.getNapId();
                apType = apn.getType();

                if ((apType!=AccessPoint.NAP_SNAP) && (apType!=AccessPoint.NAP_IAP))
                {
                    apType = -1;
                    apId = -1;
                }
                Logger.LOG(Logger.ESOCKET, Logger.EInfo,
                           "+SocketServerConnectionImpl:: getApplicationDefault returned,  \n"+apn.getNapId()+" type = "+apn.getType());                
            }
        }
        catch (Exception e)
        {

        }
        int retValue = _getLocalAddress(iNativeHandle, iSockDesc, apId, apType, addr);
        if (retValue < 0)
        {
            throw new IOException(
                "getLocalAddress failed. POSIX error code: "
                + retValue);
        }
        Logger.LOG(Logger.ESOCKET, Logger.EInfo,
                   "-SocketServerConnectionImpl::getLocalAddress()");
        return addr[0];
    }

    /**
     * Get the local port of this connection.
     *
     * @return the local port
     * @throws IOException
     *             in case of any IO errors
     */

    public int getLocalPort() throws IOException
    {
        Logger.LOG(Logger.ESOCKET, Logger.EInfo,
                   "+SocketServerConnectionImpl::getLocalPort\n");
        if (iConnectionOpen == false)
        {
            throw new IOException(
                "getLocalPort failed: connection is already closed");
        }
        int result = _getLocalPort(iNativeHandle, iSockDesc);
        if (result < 0)
        {
            throw new IOException(
                "getLocalPort failed. POSIX error code: " + result);
        }
        Logger.LOG(Logger.ESOCKET, Logger.EInfo,
                   "-SocketServerConnectionImpl::getLocalPort\n");
        return result;
    }

    /**
     * Wait for an incoming connection.
     *
     * @return the accepted incoming stream connection
     * @throws IOException
     *             in case of any IO errors
     */

    synchronized public StreamConnection acceptAndOpen() throws IOException
    {

        Logger.LOG(Logger.ESOCKET, Logger.EInfo,
                   "+ServerSocketConnectionImpl::acceptAndOpen \n");
        if (iConnectionOpen == false)
        {
            throw new IOException(
                "acceptAndOpen failed: connection is already closed");
        }
        int sockDesc = -1;
        sockDesc = _accept(iNativeHandle);
        if (sockDesc < 0)
        {
            throw new IOException(
                "acceptAndOpen failed. POSIX error code: " + sockDesc);
        }
        if (iPort == 0)
            iPort = getLocalPort();
        Logger.LOG(Logger.ESOCKET, Logger.EInfo,
                   "+ServerSocketConnectionImpl::acceptAndOpen - dynamic port = "
                   + iPort);
        SocketConnectionImpl con = new SocketConnectionImpl(iUri, iMode,
                sockDesc, cminstance, apn);
        Logger.LOG(Logger.ESOCKET, Logger.EInfo, "sockDesc:" + sockDesc);
        Logger.LOG(Logger.ESOCKET, Logger.EInfo,
                   "-SocketServerConnectionImpl::acceptAndOpen \n");
        return con;
    }

    /**
     * Close the socket connection.
     */

    public void close() throws IOException
    {

        if (iConnectionOpen == false)
        {
            return;
        }
        Logger.LOG(Logger.ESOCKET, Logger.EInfo,
                   "+SocketServerConnectionImpl::Close \n");
        int ret = _close(iNativeHandle, iSocketServerFactoryHandle, iUri
                         .toString(), iSockDesc);
        if (ret != 0)
        {
            throw new IOException("Close failed. POSIX error code:: "
                                  + ret);
        }
        iConnectionOpen = false;
        Logger.LOG(Logger.ESOCKET, Logger.EInfo,
                   "-SocketServerConnectionImpl::Close \n");
    }

    private native int _createSocketServerNativePeer(String uri, int mode,
            int port, int[] sd);

    private native int _getLocalPort(int iNativeHandle, int iSockDesc);

    private native int _accept(int iNativeHandle);

    private native int _getLocalAddress(int iNativeHandle, int iSockDesc,int midletIapId,int apType,
                                        String[] addr);

    private native int _close(int iNativeHandle,
                              int iSocketServerFactoryHandle, String urls, int iSockDesc);

    private native int _openServerSocket(int iNativeHandle,
                                         int iSocketServerFactoryHandle, String url);
}