/*

 * 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 "hsclient.h"

#include "hsclientobservers.h"

#include "debug.h"

CHsClient* CHsClient::NewL( CBluetoothSocket *aClient,

        MHsClientStateNotifier *aClientStateNotifier,

        MHsClientObserver *aClientDisconnectNotifier )

    {

    User::LeaveIfNull( aClient );

    CHsClient *self = CHsClient::NewLC( aClient, aClientStateNotifier,

            aClientDisconnectNotifier );

    CleanupStack::Pop( self );

    return self;

    }

CHsClient* CHsClient::NewLC( CBluetoothSocket *aClient,

        MHsClientStateNotifier *aClientStateNotifier,

        MHsClientObserver *aClientDisconnectNotifier )

    {

    User::LeaveIfNull( aClient );

    CHsClient *self = new ( ELeave ) CHsClient( *aClient, aClientStateNotifier,

            aClientDisconnectNotifier );

    CleanupStack::PushL( self );

    self->ConstructL();

    return self;

    }

CHsClient::~CHsClient()

    {

    TRACE_FUNC_ENTRY

    if ( iSocket )

        {

        iSocket->CancelAll();

        delete iSocket;

        }

    if ( iConnected )

        {

        if ( iStateNotifier )

            {

            TRAP_IGNORE( iStateNotifier->HandleClientDisconnectL(KErrNone) );

            }

        }

    TRACE_FUNC_EXIT

    }

void CHsClient::Send( const TDesC8 &aData )

    {

    TRACE_FUNC_ENTRY

    if ( iSocket && iConnected )

        {

        TRAP_IGNORE( BufferedProcessL(aData) );

        }

    TRACE_FUNC_EXIT

    }

void CHsClient::SetClientDisconnectNotfier( MHsClientObserver &aNotifier )

    {

    TRACE_FUNC_ENTRY

    iClientObserver = &aNotifier;

    TRACE_FUNC_EXIT

    }

void CHsClient::SetClientStateNotfier( MHsClientStateNotifier &aNotifier )

    {

    TRACE_FUNC_ENTRY

    iStateNotifier = &aNotifier;

    TRACE_FUNC_EXIT

    }

MHsClientStateNotifier* CHsClient::GetClientStateNotifer()

    {

    TRACE_FUNC_ENTRY

    TRACE_FUNC_EXIT

    return iStateNotifier;

    }

CHsClient::CHsClient( CBluetoothSocket &aClient,

        MHsClientStateNotifier *aClientStateNotifier,

        MHsClientObserver *aClientDisconnectNotifier )

    {

    TRACE_FUNC_ENTRY

    iSocket = &aClient;

    iStateNotifier = aClientStateNotifier;

    iState = CHsClient::EIdle;

    iConnected = ETrue;

    iClientObserver = aClientDisconnectNotifier;

    iSocket->SetNotifier( *this );

    TRACE_FUNC_EXIT

    }

void CHsClient::ConstructL()

    {

    TRACE_FUNC_ENTRY

    BufferedProcessL();

    TRACE_FUNC_EXIT

    }

void CHsClient::RawRecvL( TDes8 &aData )

    {

    TRACE_FUNC_ENTRY

    User::LeaveIfNull( iSocket );

    if ( !iConnected )

        {

        TRACE_INFO( _L(" Client is no longer connected" ) )

        User::LeaveIfError( KErrDisconnected );

        }

    iState = CHsClient::EReceiving;

    User::LeaveIfError( iSocket->RecvOneOrMore( aData, iReceiveFlag,

            iReceiveMessageLength ) );

    TRACE_FUNC_EXIT

    }

void CHsClient::RawSendL( const TDesC8 &aData )

    {

    TRACE_FUNC_ENTRY

    User::LeaveIfNull( iSocket );

    if ( !iConnected )

        {

        User::LeaveIfError( KErrDisconnected );

        }

    if ( aData.Length() == 0 )

        {

        User::Leave( KErrWrite );

        }

    iState = CHsClient::ESending;

    User::LeaveIfError( iSocket->Send( aData, iSendFlag ) );

    TRACE_FUNC_EXIT

    }

void CHsClient::BufferedProcessL( const TDesC8 &aData )

    {

    TRACE_FUNC_ENTRY

    if ( iState != CHsClient::ESending )

        {

        iTempSendBuf.Append( aData );

        SwapBuffers();

        if ( iSendBuf.Length() > 0 )

            {

            iSocket->CancelRecv();

            RawSendL( iSendBuf );

            }

        else if ( iState != CHsClient::ESending )

            {

            RawRecvL( iReceiveMessageBuffer );

            }

        }

    else

        {

        iTempSendBuf.Append( aData );

        }

    TRACE_FUNC_EXIT

    }

void CHsClient::SwapBuffers()

    {

    TRACE_FUNC_ENTRY

    iSendBuf.Copy( iTempSendBuf );

    iTempSendBuf.Zero();

    TRACE_FUNC_EXIT

    }

void CHsClient::HandleConnectCompleteL( TInt aErr )

    {

    TRACE_FUNC_ENTRY

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

    TRACE_FUNC_EXIT

    }

void CHsClient::HandleAcceptCompleteL( TInt aErr )

    {

    TRACE_FUNC_ENTRY

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

    TRACE_FUNC_EXIT

    }

void CHsClient::HandleShutdownCompleteL( TInt aErr )

    {

    TRACE_FUNC_ENTRY

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

    TRACE_FUNC_EXIT

    }

void CHsClient::HandleSendCompleteL( TInt aErr )

    {

    TRACE_FUNC_ENTRY

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

    iState = CHsClient::EIdle;

    iSendBuf.Zero();

    if ( aErr != KErrDisconnected )

        {

        BufferedProcessL( KNullDesC8 );

        }

    if ( iStateNotifier )

        {

        if ( aErr != KErrDisconnected )

            {

            iStateNotifier->HandleClientSendCompleteL( aErr );

            }

        else

            {

            iConnected = EFalse;

            iStateNotifier->HandleClientDisconnectL( aErr );

            iClientObserver->HandleClientDisconnect( this, aErr );

            }

        }

    TRACE_FUNC_EXIT

    }

void CHsClient::HandleReceiveCompleteL( TInt aErr )

    {

    TRACE_FUNC_ENTRY

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

    iState = CHsClient::EIdle;

    if ( iStateNotifier )

        {

        if ( aErr == KErrNone )

            {

            TRAP_IGNORE( iStateNotifier->HandleClientReceiveCompleteL(

                            iReceiveMessageBuffer, aErr ) );

            }

        else

            {

            iConnected = EFalse;

            iStateNotifier->HandleClientDisconnectL( aErr );

            iClientObserver->HandleClientDisconnect( this, aErr );

            }

        }

    if ( aErr == KErrNone )

        {

        BufferedProcessL( KNullDesC8 );

        }

    TRACE_FUNC_EXIT

    }

void CHsClient::HandleIoctlCompleteL( TInt aErr )

    {

    TRACE_FUNC_ENTRY

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

    TRACE_FUNC_EXIT

    }

void CHsClient::HandleActivateBasebandEventNotifierCompleteL( TInt aErr,

        TBTBasebandEventNotification& aEventNotification )

    {

    TRACE_FUNC_ENTRY

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

    TRACE_FUNC_EXIT

    }