/*
 * 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 "hsremotecontroller.h"
#include "hsrcbttools.h"
#include "hsrccommand.h"
#include "debug.h"

EXPORT_C CHsRemoteController* CHsRemoteController::NewL(
        MHsRCObserver* aObserver )
    {
    CHsRemoteController* self = CHsRemoteController::NewLC( aObserver );
    CleanupStack::Pop( self );
    return self;
    }

EXPORT_C CHsRemoteController* CHsRemoteController::NewLC(
        MHsRCObserver* aObserver )
    {
    CHsRemoteController* self = new ( ELeave ) CHsRemoteController( aObserver );
    CleanupStack::PushL( self );
    self->ConstructL();
    return self;
    }

EXPORT_C CHsRemoteController::~CHsRemoteController()
    {
    TRACE_FUNC_ENTRY
    if ( iBTManager )
        {
        delete iBTManager;
        }

    if ( iSocket )
        {
        if ( iConnected )
            {
            iSocket->CancelAll();
            // Return value may be ignored
            iSocket->Shutdown( RSocket::EImmediate );
            }
        delete iSocket;
        }

    iSocketServ.Close();

    TRACE_FUNC_EXIT
    }

EXPORT_C void CHsRemoteController::ConnectHsDevAddrL(
        const TBTDevAddr& aDevAddr, const TUUID& aService )
    {
    TRACE_FUNC_ENTRY
    if ( iConnected )
        {
        User::Leave( KErrInUse );
        }
    if ( iObserver )
        {
        iObserver->HandleConnectingToHs();
        }
    iBTManager->SetService( aService );

    iBTManager->ConnectDevAddrL( aDevAddr );

    TRACE_FUNC_EXIT
    }

EXPORT_C void CHsRemoteController::ConnectHsDevNameL( const TDesC& aHsName,
        const TUUID& aService )
    {
    TRACE_FUNC_ENTRY
    if ( iConnected )
        {
        User::Leave( KErrInUse );
        }
    if ( iObserver )
        {
        iObserver->HandleConnectingToHs();
        }
    iBTManager->SetService( aService );
    iBTManager->ConnectDevNameL( aHsName );

    TRACE_FUNC_EXIT

    }

EXPORT_C void CHsRemoteController::CancelConnectingToHs()
    {
    TRACE_FUNC_ENTRY
    if ( iBTManager )
        {
        iBTManager->CancelConnecting();
        }
    TRACE_FUNC_EXIT
    }

EXPORT_C void CHsRemoteController::DisconnectFromHs()
    {
    TRACE_FUNC_ENTRY
    if ( iSocket )
        {
        if ( iConnected )
            {
            iSocket->CancelAll();
            // Return value may be ignored
            iSocket->Shutdown( RSocket::EImmediate );
            }
        delete iSocket;
        iSocket = NULL;
        iConnected = EFalse;
        if ( iObserver )
            {
            iObserver->HandleDisconnectedFromHs( KErrNone );
            }

        }

    TRACE_FUNC_EXIT
    }

EXPORT_C void CHsRemoteController::ReqTurnOnHs( const TDesC& aPluginCod,
        const TDesC& aPluginSdp, const TDesC& aPluginProfile )
    {
    TRACE_FUNC_ENTRY

    __ASSERT_ALWAYS( iConnected,
            User::Panic(KHSRemoteControllerNotConnectedPanicMsg, KErrNotReady));

    RBuf buf;
    TRAPD(err, buf.CreateL( aPluginCod.Length() + aPluginSdp.Length()
                    + aPluginProfile.Length() + 4 ) );
    if ( err == KErrNone )
        {
        TBuf <2> sep;
        CnvUtfConverter::ConvertToUnicodeFromUtf8( sep,
                KHsRemoteRequestParamSeparator );

        buf.Copy( aPluginCod );
        buf.Append( sep );
        buf.Append( aPluginSdp );
        buf.Append( sep );
        buf.Append( aPluginProfile );

        SendRequest( EHsTurnOn, buf );
        }

    TRACE_FUNC_EXIT
    }

EXPORT_C void CHsRemoteController::ReqTurnOffHs()
    {
    TRACE_FUNC_ENTRY

    __ASSERT_ALWAYS( iConnected,
            User::Panic(KHSRemoteControllerNotConnectedPanicMsg, KErrNotReady));

    SendRequest( EHsTurnOff );

    TRACE_FUNC_EXIT
    }

EXPORT_C void CHsRemoteController::ReqConnectWithDevAddr(
        const TBTDevAddr& aDevAddr )
    {
    TRACE_FUNC_ENTRY

    __ASSERT_ALWAYS( iConnected, 
            User::Panic(KHSRemoteControllerNotConnectedPanicMsg, KErrNotReady));

    TBuf <KDevAddrLength> devAddrBuf;
    aDevAddr.GetReadable( devAddrBuf );
    SendRequest( EHsConnectDevAddress, devAddrBuf );

    TRACE_FUNC_EXIT
    }

EXPORT_C void CHsRemoteController::ReqConnectWithDevName( 
        const TDesC& aDevName )
    {
    TRACE_FUNC_ENTRY

    __ASSERT_ALWAYS( iConnected, 
            User::Panic(KHSRemoteControllerNotConnectedPanicMsg, KErrNotReady));
    SendRequest( EHsConnectName, aDevName );

    TRACE_FUNC_EXIT
    }

EXPORT_C void CHsRemoteController::ReqConnectWithLastConnected()
    {
    TRACE_FUNC_ENTRY

    __ASSERT_ALWAYS( iConnected,
            User::Panic(KHSRemoteControllerNotConnectedPanicMsg, KErrNotReady));
    
    SendRequest( EHsConnectLastconnected );

    TRACE_FUNC_EXIT
    }

EXPORT_C void CHsRemoteController::ReqAcceptCall()
    {
    TRACE_FUNC_ENTRY

    __ASSERT_ALWAYS( iConnected, 
            User::Panic(KHSRemoteControllerNotConnectedPanicMsg, KErrNotReady));
    SendRequest( EHsAcceptCall );

    TRACE_FUNC_EXIT
    }

EXPORT_C void CHsRemoteController::ReqReleaseCall()
    {
    TRACE_FUNC_ENTRY

    __ASSERT_ALWAYS( iConnected, 
            User::Panic(KHSRemoteControllerNotConnectedPanicMsg, KErrNotReady));
    SendRequest( EHsReleaseCall );

    TRACE_FUNC_EXIT
    }

EXPORT_C void CHsRemoteController::ReqSetMicGain( const TDesC& aValue )
    {
    TRACE_FUNC_ENTRY

    __ASSERT_ALWAYS( iConnected, 
            User::Panic(KHSRemoteControllerNotConnectedPanicMsg, KErrNotReady));
    SendRequest( EHsSetMicVolume, aValue );

    TRACE_FUNC_EXIT
    }

EXPORT_C void CHsRemoteController::ReqSetSpeakerVolume( const TDesC& aValue )
    {
    TRACE_FUNC_ENTRY

    __ASSERT_ALWAYS( iConnected, 
            User::Panic(KHSRemoteControllerNotConnectedPanicMsg, KErrNotReady));
    
    SendRequest( EHsSetSpeakerVolume, aValue );

    TRACE_FUNC_EXIT
    }

EXPORT_C void CHsRemoteController::ReqSendAnyAt( const TDesC& aValue )
    {
    TRACE_FUNC_ENTRY

    __ASSERT_ALWAYS( iConnected, 
            User::Panic(KHSRemoteControllerNotConnectedPanicMsg, KErrNotReady));
    SendRequest( EHsSendAnyAt, aValue );

    TRACE_FUNC_EXIT
    }

EXPORT_C void CHsRemoteController::ReqDisconnectAG()
    {
    TRACE_FUNC_ENTRY

    __ASSERT_ALWAYS( iConnected, 
            User::Panic(KHSRemoteControllerNotConnectedPanicMsg, KErrNotReady));
    SendRequest( EHsDisconnectAGs );

    TRACE_FUNC_EXIT
    }

CHsRemoteController::CHsRemoteController( MHsRCObserver* aObserver ) :
    iObserver( aObserver )
    {

    }

void CHsRemoteController::ConstructL()
    {
    User::LeaveIfError( iSocketServ.Connect() );
    User::LeaveIfError( CreateBTManager() );
    }

void CHsRemoteController::SendRequest(
        const THsRemoteControlCommandType aCommandType, const TDesC& aData )
    {
    TRACE_FUNC_ENTRY

    THsRCCommandData data( KNullDesC8 );
    TInt err = CnvUtfConverter::ConvertFromUnicodeToUtf8( data, aData );
    if ( err == KErrNone )
        {
        THsRCCommand cmd( data, aCommandType );
        cmd.ToDes8( iSendDataBuffer );

        err = Send( iSendDataBuffer );
        if ( ( err == KErrNone ) && iObserver )
            {
            iObserver->HandleRequestSent( aCommandType );
            }
        }
    TRACE_FUNC_EXIT
    }

TInt CHsRemoteController::Send( const TDesC8& aData )
    {
    TRACE_FUNC_ENTRY
    TRACE_INFO( ( _L8("Data to be send: [%S]"), &aData) )

    if ( !iConnected )
        {
        TRACE_INFO( _L("Not connected to HS") )
        TRACE_FUNC_EXIT
        return KErrNotReady;
        }

    iSendDataBuffer.Copy( aData );
    if ( iSendDataBuffer.Length() > 0 )
        {
        TInt err = iSocket->Write( iSendDataBuffer );
        if ( err == KErrNone )
            {
            iSendDataBuffer.Zero();
            }

        TRACE_FUNC_EXIT
        return err;
        }

    TRACE_FUNC_EXIT

    return KErrNone;
    }

void CHsRemoteController::Receive()
    {
    TRACE_FUNC_ENTRY
    // Return value may be ignored, 
    // error will be notified to HandleReceiveCompleteL
    iSocket->RecvOneOrMore( iReceiveDataBuffer, 0, iDataLength );
    TRACE_FUNC_EXIT
    }

TInt CHsRemoteController::ConnectRemoteControlServer( const TBTDevAddr& aAddr,
        const TInt aPort )
    {
    TRACE_FUNC_ENTRY
    TInt error = KErrNone;
    if ( !iConnected )
        {

        TProtocolDesc protocolDesc;
        error = iSocketServ.FindProtocol( _L("RFCOMM"), protocolDesc );
        if ( error != KErrNone )
            {
            TRACE_INFO( ( _L("iSocketServ.FindProtocol error = %d"), error) )
            TRACE_FUNC_EXIT
            return error;
            }

        TRAP(error, iSocket = CBluetoothSocket::NewL(*this, iSocketServ,
                        protocolDesc.iSockType, protocolDesc.iProtocol));
        if ( error != KErrNone )
            {
            TRACE_INFO( ( _L("iSocket = CBluetoothSocket::NewL error = %d"), error))
            TRACE_FUNC_EXIT
            return error;
            }

        TBTSockAddr addr;
        addr.SetBTAddr( aAddr );
        addr.SetPort( aPort );
        error = iSocket->Connect( addr );

        if ( error != KErrNone )
            {
            TRACE_INFO( ( _L("iSocket->Connect error = %d"), error))
            TRACE_FUNC_EXIT
            return error;
            }
        }
    else
        {
        TRACE_INFO( _L("CHsRemoteController::Connect() - client is already connected") )
        TRACE_FUNC_EXIT
        return KErrInUse;
        }

    TRACE_FUNC_EXIT
    return KErrNone;
    }

TInt CHsRemoteController::CreateBTManager()
    {
    TInt err = KErrNone;

    if ( !iBTManager )
        {
        TRAP(err, iBTManager = CHsRCBTManager::NewL(iSocketServ, this));
        if ( err != KErrNone )
            {
            iBTManager = NULL;
            }
        return err;
        }
    else
        {
        return KErrAlreadyExists;
        }

    }

void CHsRemoteController::HandleConnectCompleteL( TInt aErr )
    {
    TRACE_FUNC_ENTRY
    TRACE_INFO( ( _L("aErr = %d"), aErr) )

    if ( aErr == KErrNone )
        {
        TRACE_INFO(_L("Connect completed"))
        iConnected = ETrue;
        Receive();
        }
    if ( iObserver )
        {
        iObserver->HandleConnectedToHs( aErr );
        }
    TRACE_FUNC_EXIT
    }

void CHsRemoteController::HandleAcceptCompleteL( TInt /*aErr*/)
    {
    }

void CHsRemoteController::HandleShutdownCompleteL( TInt /*aErr*/)
    {
    }

void CHsRemoteController::HandleSendCompleteL( TInt aErr )
    {
    TRACE_FUNC_ENTRY
    TRACE_INFO( ( _L("aErr = %d"), aErr) )

    if ( aErr == KErrNone )
        {
        if ( ( iSendDataBuffer.Length() > 0 ) && ( ( iSocket->Write(
                iSendDataBuffer ) ) == KErrNone ) )
            {
            iSendDataBuffer.Zero();
            }
        }
    Receive();
    TRACE_FUNC_EXIT
    }

void CHsRemoteController::HandleReceiveCompleteL( TInt aErr )
    {
    TRACE_FUNC_ENTRY
    TRACE_INFO( ( _L("aErr = %d"), aErr) )

    if ( aErr == KErrNone )
        {
        if ( ( iSendDataBuffer.Length() > 0 ) && ( ( iSocket->Write(
                iSendDataBuffer ) ) == KErrNone ) )
            {
            iSendDataBuffer.Zero();
            }
        Receive();
        }
    else
        {
        TRACE_INFO(_L("ControlServer cancelled listening"));
        DisconnectFromHs();
        }
    }

void CHsRemoteController::HandleIoctlCompleteL( TInt /*aErr*/)
    {
    }

void CHsRemoteController::HandleActivateBasebandEventNotifierCompleteL(
        TInt /*aErr*/, TBTBasebandEventNotification& /*aEventNotification*/)
    {
    }

void CHsRemoteController::HandleDesiredDevFound( const TDesC& aDevName,
        const TBTDevAddr& aDevAddr, const TInt aPort )
    {
    TRACE_FUNC_ENTRY
    //value ignored
    TInt err = ConnectRemoteControlServer( aDevAddr, aPort );

    TRACE_INFO((_L("err = %d"), err))

    if ( iObserver && err != KErrNone )
        {
        iObserver->HandleConnectedToHs( err );
        }
    TRACE_FUNC_EXIT
    }

void CHsRemoteController::HandleDesiredDevNotFound( TInt aErr )
    {
    TRACE_FUNC_ENTRY

    if ( iObserver )
        {
        iObserver->HandleConnectedToHs( aErr );
        }

    TRACE_FUNC_EXIT
    }