/*

 * Component Name: Headset Simulator

 * Author: Comarch S.A.

 * Version: 1.0

 * Copyright (c) 2010 Comarch S.A.

 *  

 * This Software is submitted by Comarch S.A. to Symbian Foundation Limited on 

 * the basis of the Member Contribution Agreement entered between Comarch S.A. 

 * and Symbian Foundation Limited on 5th June 2009 (“Agreement”) and may be 

 * used only in accordance with the terms and conditions of the Agreement. 

 * Any other usage, duplication or redistribution of this Software is not 

 * allowed without written permission of Comarch S.A.

 * 

 */

#include "hsremotecontrolserver.h"

#include "hscore.h" 

#include "hsremotecontroldatahandler.h"

#include "hsremotecontroltools.h"

#include "debug.h"

_LIT8(KHsATVGS,"AT+VGS=");

_LIT8(KHsATCommandEnding,"\r\n");

_LIT8(KHsATVGM,"AT+VGM=");

CHsControlServer* CHsControlServer::NewL( RSocketServ& aSocketServ,

        CHsCore* aHsCore )

    {

    CHsControlServer* self = CHsControlServer::NewLC( aSocketServ, aHsCore );

    CleanupStack::Pop( self );

    return self;

    }

CHsControlServer* CHsControlServer::NewLC( RSocketServ& aSocketServ,

        CHsCore* aHsCore )

    {

    CHsControlServer* self = new ( ELeave ) CHsControlServer( aSocketServ,

            aHsCore );

    CleanupStack::PushL( self );

    self->ConstructL();

    return self;

    }

CHsControlServer::CHsControlServer( RSocketServ& aSocketServ, CHsCore* aHsCore ) :

    iState( ENone ), iSocketServ( aSocketServ ), iHsCore( aHsCore )

    {

    }

void CHsControlServer::ConstructL()

    {

    iDataHandler = CHsRemoteControlDataHandler::NewL();

    }

CHsControlServer::~CHsControlServer()

    {

    TRACE_FUNC_ENTRY

    CancelListen();

    if ( iSocket )

        {

        delete iSocket;

        }

    if ( iListenSocket )

        {

        delete iListenSocket;

        }

    if ( iDataHandler )

        {

        delete iDataHandler;

        }

    TRACE_FUNC_EXIT

    }

void CHsControlServer::StartRemoteControlServerL()

    {

    TRACE_FUNC_ENTRY

    if ( iState != ENone )

        {

        TRACE_INFO (_L("ControlServer is already listening"))

        TRACE_FUNC_EXIT

        User::Leave( KErrInUse );

        }

    iState = EConnecting;

    TProtocolDesc ProtocolDesc;

    User::LeaveIfError( iSocketServ.FindProtocol( KHsRFComm(), ProtocolDesc ) );

    if ( iListenSocket )

        {

        // Return value may be ignored

        iListenSocket->Shutdown( RSocket::EImmediate );

        delete iListenSocket;

        iListenSocket = NULL;

        }

    iListenSocket = CBluetoothSocket::NewL( *this, iSocketServ,

            ProtocolDesc.iSockType, ProtocolDesc.iProtocol );

    User::LeaveIfError( iListenSocket->GetOpt(

            KRFCOMMGetAvailableServerChannel, KSolBtRFCOMM, iServerPort ) );

    TBTSockAddr btSockAddr;

    btSockAddr.SetPort( iServerPort );

    RegisterSdpL( iServerPort );

    User::LeaveIfError( iListenSocket->Bind( btSockAddr ) );

    TRACE_INFO( ( _L("Control Server port =  %d"), iServerPort) )

    User::LeaveIfError( iListenSocket->Listen( KHsSizeOfListenQueue ) );

    TBTServiceSecurity secSettings;

    TUid settingsUID = TUid::Uid( (TInt) KHsRemoteControlServiceID );

    secSettings.SetUid( settingsUID );

    secSettings.SetAuthentication( EFalse );

    secSettings.SetAuthorisation( EFalse );

    secSettings.SetEncryption( EFalse );

    btSockAddr.SetSecurity( secSettings );

    if ( iSocket )

        {

        // Return value may be ignored

        iSocket->Shutdown( RSocket::EImmediate );

        delete iSocket;

        iSocket = NULL;

        }

    iSocket = CBluetoothSocket::NewL( *this, iSocketServ );

    User::LeaveIfError( iListenSocket->Accept( *iSocket ) );

    iInitialized = ETrue;

    TRACE_INFO( _L("CHSControlServer::Listen() status = OK" ) )

    TRACE_FUNC_EXIT

    }

void CHsControlServer::CancelListen()

    {

    TRACE_FUNC_ENTRY

    if ( iState == EWaiting )//Client is connected to socket

        {

        iSocket->CancelAll();

        // Return value may be ignored

        iSocket->Shutdown( RSocket::EImmediate );

        delete iSocket;

        iSocket = NULL;

        iListenSocket->CancelAll();

        // Return value may be ignored

        iListenSocket->Shutdown( RSocket::EImmediate );

        delete iListenSocket;

        iListenSocket = NULL;

        }

    else

        { //Sockets are ready, but client is not connected

        delete iSocket;

        iSocket = NULL;

        delete iListenSocket;

        iListenSocket = NULL;

        }

    DeleteRecordSdp();

    iInitialized = EFalse;

    iState = ENone;

    TRACE_FUNC_EXIT

    }

void CHsControlServer::SetConnectionObserver(

        MRemoteControllerConnectionObserver &aRemoteControllerObserver )

    {

    iConnectionObserver = &aRemoteControllerObserver;

    }

void CHsControlServer::HandleConnectCompleteL( TInt aErr )

    {

    TRACE_FUNC_ENTRY

    TRACE_INFO( ( _L("aErr = %d"), aErr) );

    TRACE_FUNC_EXIT

    }

void CHsControlServer::HandleAcceptCompleteL( TInt aErr )

    {

    TRACE_FUNC_ENTRY

    TRACE_INFO( ( _L("aErr = %d"), aErr) );

    iState = EWaiting;

    Receive();

    if ( iConnectionObserver )

        {

        iConnectionObserver->HandleRemoteControllerConnected( aErr );

        }

    TRACE_FUNC_EXIT

    }

void CHsControlServer::HandleShutdownCompleteL( TInt aErr )

    {

    TRACE_FUNC_ENTRY

    TRACE_INFO( ( _L("aErr = %d"), aErr) );

    TRACE_FUNC_EXIT

    }

void CHsControlServer::HandleSendCompleteL( TInt aErr )

    {

    TRACE_FUNC_ENTRY

    TRACE_INFO( ( _L8("ControlServer sent %d bytes of data: [%S] with err [%d]")

            ,iSendDataBuffer.Length(), &iSendDataBuffer, aErr) )

    TInt error = KErrNone;

    if ( aErr == KErrNone )

        {

        iSendDataBuffer.Zero();

        if ( iTempDataBuffer.Length() > 0 )

            {

            iSendDataBuffer.Append( iTempDataBuffer );

            iTempDataBuffer.Zero();

            error = iSocket->Write( iSendDataBuffer );

            }

        }

    Receive();

    User::LeaveIfError( error );

    TRACE_FUNC_EXIT

    }

void CHsControlServer::HandleReceiveCompleteL( TInt aErr )

    {

    TRACE_FUNC_ENTRY

    TRACE_INFO( ( _L8("[ControlServer] received %d bytes of data: [%S]"

            "with err [%d]"), iReceiveDataBuffer.Length(), &iReceiveDataBuffer,

            aErr) )

    if ( aErr == KErrNone )

        {

        TInt error = KErrNone;

        if ( iSendDataBuffer.Length() > 0 )

            {

            error = iSocket->Write( iSendDataBuffer );

            }

        else if ( iTempDataBuffer.Length() > 0 )

            {

            iSendDataBuffer.Append( iTempDataBuffer );

            iTempDataBuffer.Zero();

            error = iSocket->Write( iSendDataBuffer );

            }

        TRAP_IGNORE( HandleRequestL( iReceiveDataBuffer ) );

        Receive();

        User::LeaveIfError( error );

        }

    else

        {

        TRACE_INFO( _L("ControlClient is disconnected") )

        if ( iConnectionObserver )

            {

            iConnectionObserver->HandleRemoteControllerDisconnected( aErr );

            }

        CancelListen();

        StartRemoteControlServerL();

        }

    TRACE_FUNC_EXIT

    }

void CHsControlServer::HandleIoctlCompleteL( TInt /*aErr*/)

    {

    TRACE_FUNC_ENTRY

    TRACE_FUNC_EXIT

    }

void CHsControlServer::HandleActivateBasebandEventNotifierCompleteL(

        TInt /*aErr*/, TBTBasebandEventNotification& /*aEventNotification*/)

    {

    TRACE_FUNC_ENTRY

    TRACE_FUNC_EXIT

    }

TInt CHsControlServer::Send( const TDesC8& aData )

    {

    TRACE_FUNC_ENTRY

    TInt error = KErrNone;

    if ( iState != EWaiting )

        {

        error = KErrNotReady;

        TRACE_INFO( _L("ControlServer not ready") )

        return error;

        }

    if ( iSendDataBuffer.Length() == 0 )

        {

        iSendDataBuffer.Append( iTempDataBuffer );

        iTempDataBuffer.Zero();

        iSendDataBuffer.Append( aData );

        }

    else

        {

        iTempDataBuffer.Append( aData );

        }

    if ( iSendDataBuffer.Length() > 0 )

        {

        iSocket->CancelRecv();

        error = iSocket->Write( iSendDataBuffer );

        Receive();

        }

    else

        {

        Receive();

        }

    TRACE_FUNC_EXIT

    return error;

    }

void CHsControlServer::Receive()

    {

    TRACE_FUNC_ENTRY

    // Return value may be ignored, 

    // error will be notified to HandleReceiveCompleteL

    iSocket->RecvOneOrMore( iReceiveDataBuffer, 0, iDataLength );

    TRACE_FUNC_EXIT

    }

void CHsControlServer::RegisterSdpL( TInt aChannel )

    {

    TRACE_FUNC_ENTRY

    User::LeaveIfError( iSdpServer.Connect() );

    User::LeaveIfError( iSdpDB.Open( iSdpServer ) );

    TUUID serviceUUID( KHsRemoteControlServiceID );

    iSdpDB.CreateServiceRecordL( serviceUUID, iSdpRecordHandle );

    CSdpAttrValueDES* valDES = CSdpAttrValueDES::NewDESL( NULL );

    CleanupStack::PushL( valDES );

    valDES->StartListL()->BuildDESL()->StartListL()->BuildUUIDL( TUUID(

            KL2CAPUUID ) )->EndListL()->BuildDESL()->StartListL()->BuildUUIDL(

            TUUID( KRFCommUUID ) )->BuildUintL(

            TSdpIntBuf <TUint8> ( aChannel ) )->EndListL()->EndListL();

    iSdpDB.UpdateAttributeL( iSdpRecordHandle,

            KSdpAttrIdProtocolDescriptorList, *valDES );

    CleanupStack::PopAndDestroy( valDES );

    iSdpDB.UpdateAttributeL( iSdpRecordHandle, KSdpAttrIdBasePrimaryLanguage

            + KSdpAttrIdOffsetServiceName, KServiceName );

    iSdpDB.UpdateAttributeL( iSdpRecordHandle, KSdpAttrIdBasePrimaryLanguage

            + KSdpAttrIdOffsetServiceDescription, KServiceDesc );

    UpdateAvailabilityL( ETrue );

    TRACE_INFO ( _L("CHsControlServer::RegisterSdpL, status = OK") )

    TRACE_FUNC_EXIT

    }

void CHsControlServer::UpdateAvailabilityL( TBool aAvailable )

    {

    TInt state = ( aAvailable ? KServicAvailable : KServiceUnavailable );

    // Set availability

    iSdpDB.UpdateAttributeL( iSdpRecordHandle, KSdpAttrIdServiceAvailability,

            state );

    // Mark record changed

    iSdpDB.UpdateAttributeL( iSdpRecordHandle, KSdpAttrIdServiceRecordState,

            ++iRecordState );

    }

void CHsControlServer::DeleteRecordSdp()

    {

    TRACE_FUNC_ENTRY

    iSdpDB.DeleteRecord( iSdpRecordHandle );

    iSdpRecordHandle = 0;

    iSdpDB.Close();

    iSdpServer.Close();

    TRACE_FUNC_EXIT

    }

void CHsControlServer::HandleRequestL( TDes8 &aRequest )

    {

    TRACE_FUNC_ENTRY

    TBuf8 <KHsRemoteControlPackageLength> buf;

    THsControlCommandData dummyBuf( KNullDesC8 );

    THsRemoteControlCommand command( dummyBuf, EHsLast );

    if ( iDataHandler )

        {

        TInt err = iDataHandler->RecognizeCommand( aRequest, command );

        if ( KErrNone != err )

            {

            User::Leave( KErrArgument );

            }

        }

    THsRemoteControlCommandType type = EHsLast;

    command.GetType( type );

    switch ( type )

        {

        case EHsTurnOn:

            {

            command.GetData( buf );

            RBuf8 cod;

            RBuf8 sdp;

            RBuf8 plugin;

            cod.CleanupClosePushL();

            sdp.CleanupClosePushL();

            plugin.CleanupClosePushL();

            RetrieveStartupParamsL( buf, cod, sdp, plugin );

            iHsCore->StartSimulationL( cod, sdp, plugin );

            CleanupStack::PopAndDestroy( 3 );

            }

            break;

        case EHsTurnOff:

            {

            iHsCore->StopSimulation();

            }

            break;

        case EHsConnectLastconnected:

            {

            iHsCore->ConnectWithLastConnectedL();

            }

            break;

        case EHsConnectDevAddress:

            {

            command.GetData( buf );

            iHsCore->ConnectWithDevAddress( buf.Expand() );

            }

            break;

        case EHsConnectName:

            {

            command.GetData( buf );

            iHsCore->ConnectWithName( buf.Expand() );

            }

            break;

        case EHsDisconnectAGs:

            {

            iHsCore->DisconnectClients();

            }

            break;

        case EHsAcceptCall:

            {

            User::LeaveIfError( iHsCore->AcceptIncomingCall() );

            }

            break;

        case EHsReleaseCall:

            {

            User::LeaveIfError( iHsCore->ReleaseOngoingCall() );

            }

            break;

        case EHsSetSpeakerVolume:

            {

            command.GetData( buf );

            RBuf8 tempBuf;

            tempBuf.CreateL( buf.Length() + KHsATCommandEnding().Length()

                    + KHsATVGS().Length() );

            tempBuf.Copy( KHsATVGS );

            tempBuf.Append( buf );

            tempBuf.Append( KHsATCommandEnding );

            iHsCore->Send( tempBuf );

            tempBuf.Close();

            }

            break;

        case EHsSetMicVolume:

            {

            command.GetData( buf );

            RBuf8 tempBuf;

            tempBuf.CreateL( buf.Length() + KHsATCommandEnding().Length()

                    + KHsATVGM().Length() );

            tempBuf.Copy( KHsATVGM );

            tempBuf.Append( buf );

            tempBuf.Append( KHsATCommandEnding );

            iHsCore->Send( tempBuf );

            tempBuf.Close();

            }

            break;

        case EHsSendAnyAt:

            {

            command.GetData( buf );

            User::LeaveIfError( iHsCore->Send( buf ) );

            }

            break;

        default:

            User::Leave( KErrArgument );

        }

    TRACE_FUNC_EXIT

    }

void CHsControlServer::RetrieveStartupParamsL( const TDesC8& aParams,

        RBuf8& aPluginCod, RBuf8& aPluginSdp, RBuf8& aPluginProfile )

    {

    TRACE_FUNC_ENTRY

    TInt sepPos = aParams.Find( KHsRemoteRequestParamSeparator );

    User::LeaveIfError( sepPos );

    aPluginCod.CreateL( aParams.Left( sepPos ) );

    sepPos += 2;

    TInt sepPos2 = aParams.Mid( sepPos, aParams.Length() - sepPos ).Find(

            KHsRemoteRequestParamSeparator );

    User::LeaveIfError( sepPos2 );

    aPluginSdp.CreateL( aParams.Mid( sepPos, sepPos2 ) );

    sepPos += 2;

    sepPos += sepPos2;