/*

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

#include "hsclientobservers.h"

#include "debug.h"

CHsServer* CHsServer::NewL( RSocketServ &aSocketServ )

    {

    CHsServer* self = CHsServer::NewLC( aSocketServ );

    CleanupStack::Pop( self );

    return self;

    }

CHsServer* CHsServer::NewLC( RSocketServ &aSocketServ )

    {

    CHsServer* self = new ( ELeave ) CHsServer( aSocketServ );

    CleanupStack::PushL( self );

    self->ConstructL();

    return self;

    }

CHsServer::~CHsServer()

    {

    TRACE_FUNC_ENTRY

    if ( iSocketServer )

        {

        delete iSocketServer;

        }

    if ( iBlankSocket )

        {

        delete iBlankSocket;

        }

    TRACE_FUNC_EXIT

    }

TInt CHsServer::Listen()

    {

    TRACE_FUNC_ENTRY

    TInt error = KErrNone;

    TProtocolDesc protDesc;

    TBTSockAddr addr;

    TProtocolName protName( KRFCOMMDesC );

    if ( iListen )

        {

        TRACE_FUNC_EXIT

        return KErrAlreadyExists;

        }

    error = iSServ.FindProtocol( protName, protDesc );

    if ( error != KErrNone )

        {

        TRACE_FUNC_EXIT

        return error;

        }

    TRAP(error, iSocketServer = CBluetoothSocket::NewL(*this, iSServ, 

            protDesc.iSockType, protDesc.iProtocol));

    if ( error != KErrNone )

        {

        TRACE_FUNC_EXIT

        return error;

        }

    error = iSocketServer->GetOpt( KRFCOMMGetAvailableServerChannel,

            KSolBtRFCOMM, iPort );

    if ( error != KErrNone )

        {

        TRACE_FUNC_EXIT

        return error;

        }

    addr.SetPort( iPort );

    addr.SetSecurity( iServerSecurity );

    error = iSocketServer->Bind( addr );

    if ( error != KErrNone )

        {

        TRACE_FUNC_EXIT

        return error;

        }

    error = iSocketServer->Listen( KListenQueueSize );

    if ( error != KErrNone )

        {

        TRACE_FUNC_EXIT

        return error;

        }

    if ( !iBlankSocket )

        {

        TRAP(error, iBlankSocket=CBluetoothSocket::NewL(*this, iSServ));

        }

    if ( error != KErrNone )

        {

        TRACE_FUNC_EXIT

        return error;

        }

    error = iSocketServer->Accept( *iBlankSocket );

    iListen = ETrue;

    TRACE_INFO( ( _L("Returned value = %d"), error) );

    TRACE_FUNC_EXIT

    return error;

    }

TBool CHsServer::IsReady()

    {

    return iListen;

    }

void CHsServer::Shutdown()

    {

    TRACE_FUNC_ENTRY

    if ( iSocketServer )

        {

        if ( iListen )

            {

            iSocketServer->CancelAccept();

            iListen = EFalse;

            }

        // Return value may be ignored

        iSocketServer->Shutdown( RSocket::EImmediate );

        delete iSocketServer;

        iSocketServer = NULL;

        }

    else

        {

        TRAP_IGNORE( HandleShutdownCompleteL(KErrNone) );

        }

    TRACE_FUNC_EXIT

    }

void CHsServer::SetNewClientObserver(

        MHsAcceptNewClientObserver &aNewClientObserv )

    {

    iNewClientObserver = &aNewClientObserv;

    }

TInt CHsServer::GetPort()

    {

    return iPort;

    }

void CHsServer::GetSocketAndTryToConnectL( const TBTSockAddr &aAddr )

    {

    TRACE_FUNC_ENTRY

    TBTSockAddr sockaddr( aAddr );

    TProtocolName protocolName( KRFCOMMDesC );

    TProtocolDesc protocolDesc;

    if ( iBlankSocket2 != NULL )

        {

        delete iBlankSocket2;

        iBlankSocket2 = NULL;

        }

    User::LeaveIfError( iSServ.FindProtocol( protocolName, protocolDesc ) );

    iBlankSocket2 = CBluetoothSocket::NewL( *this, iSServ,

            protocolDesc.iSockType, protocolDesc.iProtocol );

    User::LeaveIfError( iBlankSocket2->Connect( sockaddr ) );

    TRACE_FUNC_EXIT

    }

CHsServer::CHsServer( RSocketServ &aSocketServ ) :

    iSServ( aSocketServ )

    {

    iServerSecurity.SetUid( TUid::Uid( 0x10ff ) );

    iServerSecurity.SetAuthentication( EFalse );

    iServerSecurity.SetAuthorisation( EFalse );

    iServerSecurity.SetEncryption( EFalse );

    }

void CHsServer::ConstructL()

    {

    }

void CHsServer::HandleConnectCompleteL( TInt aErr )

    {

    TRACE_FUNC_ENTRY

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

    iNewClientObserver->HandleNewClientL( aErr == KErrNone ? iBlankSocket2

            : NULL, aErr );

    if ( aErr != KErrNone )

        {

        delete iBlankSocket2;

        }

    iBlankSocket2 = NULL;

    TRACE_FUNC_EXIT

    }

void CHsServer::HandleAcceptCompleteL( TInt aErr )

    {

    TRACE_FUNC_ENTRY

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

    if ( iNewClientObserver )

        {

        iNewClientObserver->HandleNewClientL( iBlankSocket, aErr );

        }

    else

        {

        iNewClientObserver->HandleNewClientL( NULL, KErrBadHandle );

        delete iBlankSocket;

        }

    iBlankSocket = NULL;

    iBlankSocket = CBluetoothSocket::NewL( *this, iSServ );

    User::LeaveIfError( iSocketServer->Accept( *iBlankSocket ) );

    TRACE_FUNC_EXIT

    }

void CHsServer::HandleShutdownCompleteL( TInt /** aErr */)

    {

    TRACE_FUNC_ENTRY

    if ( iBlankSocket )

        {

        delete iBlankSocket;

        iBlankSocket = NULL;

        }

    if ( iSocketServer )

        {

        delete iSocketServer;

        iSocketServer = NULL;

        }

    iListen = EFalse;

    TRACE_FUNC_EXIT

    }

void CHsServer::HandleSendCompleteL( TInt /** aErr */)

    {

    }

void CHsServer::HandleReceiveCompleteL( TInt /** aErr */)

    {

    }

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

    {

    }

void CHsServer::HandleActivateBasebandEventNotifierCompleteL( TInt /** aErr */,

        TBTBasebandEventNotification& /** aEventNotification */)

    {

    }