/*

* 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:

*

*/

#include "btrfcommpushserverconnection.h"

#include "fs_methodcall.h"

#include "pushexception.h"

#include "pusherrorcodes.h"

#include "serviceclasshandler.h"

#include "bluetoothnamelookup.h"

#include "javacommonutils.h"

using namespace std;

using namespace java::util;

using namespace java::push;

namespace java

{

namespace bluetooth

{

const wchar_t BT_GOEP_PROTOCOL[]=L"btgoep";

OS_EXPORT RFCOMMPushServerConnection::RFCOMMPushServerConnection(

    const wstring aUri, const wstring aFilter,ServerConnectionFactoryBase* aFactory):

        mAcceptMonitor(NULL),

        mConnectionListener(0),

        mConnectionUri(aUri),

        mConnectionFilter(aFilter),

        mRFCOMMServer(NULL),

        mConnectionFactory(aFactory),

        mClientConnection(0),

        mIsGOEP(false),

        mPendingConnection(false),

        mListening(false),

        mCreatedByPush(false),

        mClearServiceClassBitsFlag(true)

{

    JELOG2(EJavaBluetooth);

    // Create Bluetooth Parameters

    mBtUrlParams = new BtUrlParams(mConnectionUri, mConnectionFilter);

    mFunctionServer = new BluetoothFunctionServer();

    // Create a Server Object and store it as member.

    mRFCOMMServer = new RFCOMMServerConnection(mFunctionServer);

}

OS_EXPORT RFCOMMPushServerConnection::~RFCOMMPushServerConnection()

{

    JELOG2(EJavaBluetooth);

    delete mBtUrlParams;

    deleteServer();

    delete mFunctionServer;

}

/**

 * This method is called by Push framework to start listening.

 * Steps to be followed to start listening.

 * 1. Prompt user to switch in Bluetooth if it is switched off.

 * 2. Create BtRFCOMMServer and ask it to start listening.

 *

 *

 */

OS_EXPORT void RFCOMMPushServerConnection::open(ConnectionListener* aListener)

{

    JELOG2(EJavaBluetooth);

    mConnectionListener = aListener;

    bool authenticate = mBtUrlParams->getParamAuthenticate();

    bool authorize = mBtUrlParams->getParamAuthorize();

    bool encrypt = mBtUrlParams->getParamEncrypt();

    int error = 0;

    // Open RFCOMM Server.

    error = mRFCOMMServer->openServer(authorize, authenticate, encrypt);

    if (error < 0)

    {

        std::string errTxt("ERROR!!! Unable to Open RFCOMM Server.");

        throw PushException(COMMON_SRV_CONN_PLUGIN_ERROR, errTxt, __FILE__,

                            __FUNCTION__, __LINE__);

    }

    int channel = mRFCOMMServer->GetRfListeningChannel();

    std::wstring uuid = mBtUrlParams->getServiceUuid();

    std::wstring serviceName = mBtUrlParams->getParamName();

    LOG1(EJavaBluetooth, EInfo,

         "  RFCOMMPushServerConnection::open Protocol:%S",

         mBtUrlParams->getProtocol().c_str());

    if (0 == mBtUrlParams->getProtocol().compare(BT_GOEP_PROTOCOL))

    {

        mIsGOEP = true;

    }

    // Initialize Services

    error = mRFCOMMServer->initializeServiceRecord(

                channel, uuid,serviceName, mIsGOEP);

    if (error < 0)

    {

        std::string errTxt("ERROR!!! Unable to Initialize channel Server.");

        throw PushException(COMMON_SRV_CONN_PLUGIN_ERROR, errTxt, __FILE__,

                            __FUNCTION__, __LINE__);

    }

    // Restore Persistent Record (if any)

    mRFCOMMServer->restorePersistentRecord();

    // Ask server to start

    mRFCOMMServer->asyncAccept(this, mBtUrlParams);

    // We are listening now.

    mListening = true;

    // Reset the flag

    mClearServiceClassBitsFlag = true;

}

/*

 * When server is push registered, and manual launched server is closed,

 * it is not required to clear the service class bits

 * associated with this service.

 */

OS_EXPORT void RFCOMMPushServerConnection::unsetClearServiceClassBitsFlag()

{

    JELOG2(EJavaBluetooth);

    mClearServiceClassBitsFlag = false;

}

OS_EXPORT void RFCOMMPushServerConnection::close()

{

    JELOG2(EJavaBluetooth);

    if (true == mClearServiceClassBitsFlag)

    {

        ServiceClassHandler::setDeviceServiceClass(0);

    }

    mPendingConnection = false;

    mAcceptMonitor = NULL;

    mListening = false;

    mRFCOMMServer->CloseServer();

}

/*

 * Gets the connection URI used to open this server connection.

 */

OS_EXPORT std::wstring RFCOMMPushServerConnection::getUri() const

{

    JELOG2(EJavaBluetooth);

    return mConnectionUri;

}

/*

 * Gets the connection Filter string associate with this connection.

 */

OS_EXPORT std::wstring RFCOMMPushServerConnection::getFilter() const

{

    JELOG2(EJavaBluetooth);

    return mConnectionFilter;

}

OS_EXPORT void RFCOMMPushServerConnection::setFilter(

    const std::wstring& aFilter)

{

    JELOG2(EJavaBluetooth);

    mConnectionFilter = aFilter;

}

void RFCOMMPushServerConnection::handleConnectionRequest(

    BluetoothClientConnection* aClientConnection, TInt err)

{

    JELOG2(EJavaBluetooth);

    //Here we handle checking of parameters and deciding to invoke push.

    //Check all parameters

    if (KErrNone != err)

    {

        if (NULL != mAcceptMonitor)

        {

            mAcceptMonitor->notify();

        }

        mListening = false;

        return;

    }

    mConnectionFactory->setPendingMsgFlag(mConnectionUri, true);

    std::wstring* remoteDeviceName = NULL;

    BluetoothNameLookup * nameLookup = NULL;

    long long remoteDevAddr = aClientConnection->getRemoteAddress();

    TRAPD(lookupErr,

    {

        nameLookup = BluetoothNameLookup::NewL();

        remoteDeviceName = nameLookup->doDeviceNameLookupL(remoteDevAddr);

        delete nameLookup;

    }

         );

    if (KErrNone != lookupErr)

    {

        remoteDeviceName = new std::wstring(

            JavaCommonUtils::longLongToWstring(remoteDevAddr));

    }

    mConnectionListener->msgArrived(*remoteDeviceName);

    delete remoteDeviceName;

    // This means that when jsr gets this object, it must complete

    // acceptAndOpen immediately

    mPendingConnection = true;

    mListening = false;

    // Store this as member. We can later return this when queried from jsr.

    mClientConnection = aClientConnection;

    if (NULL != mAcceptMonitor)

    {

        mAcceptMonitor->notify();

    }

}

OS_EXPORT void RFCOMMPushServerConnection::setAcceptMonitor(

    java::util::Monitor* aMonitor)

{

    mAcceptMonitor = aMonitor;

    mRFCOMMServer->avoidFilter();

}

OS_EXPORT void RFCOMMPushServerConnection::unsetAcceptMonitor()

{

    mAcceptMonitor = NULL;

}

OS_EXPORT bool RFCOMMPushServerConnection::isActive()

{

    JELOG2(EJavaBluetooth);

    bool result = (mPendingConnection || mListening);

    LOG1(EJavaBluetooth, EInfo,

         "+ RFCOMMPushServerConnection::isActive: bool result: %d", result);

    return result;

}

OS_EXPORT bool RFCOMMPushServerConnection::isGOEPConnection()

{

    return mIsGOEP;

}

OS_EXPORT bool RFCOMMPushServerConnection::isConnectionAccepted()

{

    return mPendingConnection;

}

OS_EXPORT bool RFCOMMPushServerConnection::isListening()

{

    return mListening;

}

OS_EXPORT bool RFCOMMPushServerConnection::isCreatedByPush()

{

    return mCreatedByPush;

}

OS_EXPORT void RFCOMMPushServerConnection::setCreatedByPush()

{

    mCreatedByPush = true;

}

OS_EXPORT

RFCOMMServerConnection* RFCOMMPushServerConnection::getServerObject()

{

    JELOG2(EJavaBluetooth);

    if (mRFCOMMServer)

    {

        LOG(EJavaBluetooth,EInfo,

            "-  RFCOMMPushServerConnection::getServerObject Returning existing RFCOMM Server");

        return mRFCOMMServer;

    }

    else

    {

        mRFCOMMServer = new RFCOMMServerConnection(mFunctionServer);

        LOG(EJavaBluetooth, EInfo,

            "-  RFCOMMPushServerConnection::getServerObject Returning new RFCOMM Server");

        return mRFCOMMServer;

    }

}

OS_EXPORT void RFCOMMPushServerConnection::deleteServer()

{

    JELOG2(EJavaBluetooth);

    if (mRFCOMMServer)

    {

        delete mRFCOMMServer;

        mRFCOMMServer = NULL;

        return;

    }

}

OS_EXPORT

BluetoothClientConnection* RFCOMMPushServerConnection::getConnectedClient()

{

    JELOG2(EJavaBluetooth);

    //NOTE: ISSUE: IS there a chance that there can be multiple clients

    //connecting to the push midlet before launch of midlet?

    //In that case we need to return clients in the order in which they were

    //accepted.

    //Code will be something like return acceptedConnections->deQueue()

    //and in handleConnectionRequest we must

    //have acceptedConnection->enQueue(client);

    //

    mConnectionFactory->setPendingMsgFlag(mConnectionUri, false);

    // Handed over the accepted connection. And hence, resetting the flag  back

    mPendingConnection = false;

    return mClientConnection;

}

} //end namespace bluetooth

} //end namespace java