/*

* Copyright (c) 2002-2009 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:  Server-side sub-session of Accessory BT Control

*

*/

// INCLUDE FILES

#include "AccSrvSubBTControl.h"

#include "acc_debug.h"

#include "AccPolGenericIDArray.h"

#include "AccPolGenericIDArrayAccessor.h"

#include "AccSrvServerModel.h"

#include "AccPolGenericIDAccessor.h"

#include "AccPolicyDB.h"

#include "AccPolAccessoryPolicy.h"

#include "AccPolCapabilityStorage.h"

// EXTERNAL DATA STRUCTURES

// EXTERNAL FUNCTION PROTOTYPES  

// CONSTANTS

// MACROS

// LOCAL CONSTANTS AND MACROS

// MODULE DATA STRUCTURES

// LOCAL FUNCTION PROTOTYPES

// FORWARD DECLARATIONS

// ============================= LOCAL FUNCTIONS ===============================

// ============================ MEMBER FUNCTIONS ===============================

// -----------------------------------------------------------------------------

// CAccSrvSubBTControl::CAccSrvSubBTControl

// C++ default constructor can NOT contain any code, that

// might leave.

// -----------------------------------------------------------------------------

//

CAccSrvSubBTControl::CAccSrvSubBTControl( 

    CASYProxyAPI* aProxy,

    CAccSrvConnectionController* aConnectionController,

    CAccSrvServerModel* aServerModel )

    : CAccSrvSubControl ( aProxy, aConnectionController,aServerModel ),

    iAudioLinkOpenCancelFlagResetCalledTwice( EFalse ),

    iAudioLinkCloseCancelFlagResetCalledTwice( EFalse )

    {

    COM_TRACE_2( "[AccFW:AccServer] CAccSrvSubBTControl::CAccSrvSubBTControl(0x%x, 0x%x)", aProxy, &aConnectionController );

    COM_TRACE_( "[AccFW:AccServer] CAccSrvSubBTControl::CAccSrvSubBTControl - return void" );

    }

// -----------------------------------------------------------------------------

// CAccSrvSubBTControl::ConstructL

// Symbian 2nd phase constructor can leave.

// -----------------------------------------------------------------------------

//

void CAccSrvSubBTControl::ConstructL()

    {

    COM_TRACE_( "[AccFW:AccServer] CAccSrvSubBTControl::ConstructL()" );  

    CAccSrvSubControl::ConstructL();

    COM_TRACE_( "[AccFW:AccServer] CAccSrvSubBTControl::ConstructL- return void" ); 

    }

// -----------------------------------------------------------------------------

// CAccSrvSubBTControl::NewL

// Two-phased constructor.

// -----------------------------------------------------------------------------

//

CAccSrvSubBTControl* CAccSrvSubBTControl::NewL( 

    CASYProxyAPI* aProxy,

    CAccSrvConnectionController* aConnectionController,

    CAccSrvServerModel* aServerModel )

    {

    COM_TRACE_2( "[AccFW:AccServer] CAccSrvSubBTControl::NewL(0x%x, 0x%x)", aProxy, &aConnectionController );

    __ASSERT_ALWAYS( aProxy, User::Leave( KErrArgument ) );

    CAccSrvSubBTControl* self = new (ELeave) CAccSrvSubBTControl( aProxy, 

                                                                  aConnectionController,

                                                                  aServerModel );

    CleanupStack::PushL( self );

    self->ConstructL();

    CleanupStack::Pop( self );

    COM_TRACE_1( "[AccFW:AccServer] CAccSrvSubBTControl::NewL - return 0x%x", self );

    return self;

    }

// Destructor

CAccSrvSubBTControl::~CAccSrvSubBTControl()

    {

    COM_TRACE_( "[AccFW:AccServer] CAccSrvSubBTControl::~CAccSrvSubBTControl()" );

    RMessage2 dummy;

    CAccSrvSubBTControl::CancelConnectAccessory( dummy );//For iConnectBluetoothAccessoryMsg

    CAccSrvSubBTControl::CancelNotifyBluetoothAudioLinkCloseReq( dummy );//For iNotifyBluetoothAudioLinkCloseReqMsg

    CAccSrvSubBTControl::CancelNotifyBluetoothAudioLinkOpenReq( dummy );//For iNotifyBluetoothAudioLinkOpenReqMsg

    if ( iServerModel )

        {

        iServerModel->SetAudioLinkOpenCancelled( EFalse );

        iServerModel->SetAudioLinkCloseCancelled( EFalse );

        }

    COM_TRACE_( "[AccFW:AccServer] CAccSrvSubBTControl::~CAccSrvSubBTControl - return" );

    }

// -----------------------------------------------------------------------------

// CAccSrvSubBTControl::BluetoothConnectAccessoryL

// -----------------------------------------------------------------------------

//

void CAccSrvSubBTControl::BluetoothConnectAccessoryL( const RMessage2& aMessage )

    {

    COM_TRACE_( "[AccFW:AccServer] CAccSrvSubBTControl::BluetoothConnectAccessoryL()" );

    TBTDevAddr              BTDevAddr;

    TPckg<TBTDevAddr>       BTDevAddrPckg( BTDevAddr );

    TUint                   callerThreadID( 0 );

    TPckg<TUint>            callerThreadIDPckg( callerThreadID );

    TBuf8<KGIDIntMaxLength> GIDIntEmpty( KNullDesC8 );

    aMessage.ReadL( KAccServParamPosFirst, BTDevAddrPckg );

    aMessage.ReadL( KAccServParamPosSecond, callerThreadIDPckg );

    // A new GenericID for connection made without GenericID.

    // Rest of it is filled after supported profiles has been queried from BT-ASY

    // (see CAccSrvConnectionHandler::ResolveGenericIDL() ).

    TAccPolGenericID genericID;

    TAccPolGenericIDAccessor::SetDeviceAddress( genericID, 

                                                MakeTUint64( BTDevAddr ) );

    TAccPolGenericIDAccessor::SetFeatureAttributeL( genericID, 

                                                    KAccPolPCPhysicalConnection, 

                                                    KPCBluetooth );

    iServerModel->CapabilityStorage().GenerateUniqueId( genericID );

    iServerModel->CapabilityStorage().NewCapabilityListL( genericID );

    // Pass handling to Connection Controller.

    // If Leave occurs, aMessage is completed with error code.

    iConnectionController->HandleConnectL( genericID, callerThreadID, EFalse, EFalse );

    // Add this subsession to "ConnectAccessory"-queue for later i completion

    iConnectionController->NotificationQueue().RegisterControlMessage( EConnectAccessory,

                                                                       this );

    iConnectBluetoothAccessoryMsg = aMessage;//Store RMessage2 for future completion

    COM_TRACE_( "[AccFW:AccServer] CAccSrvSubBTControl::BluetoothConnectAccessoryL - return void" ); 

    }

// -----------------------------------------------------------------------------

// CAccSrvSubBTControl::BluetoothDisconnectAccessoryL

// -----------------------------------------------------------------------------

//

void CAccSrvSubBTControl::BluetoothDisconnectAccessoryL( const RMessage2& aMessage )

	{

    COM_TRACE_( "[AccFW:AccServer] CAccSrvSubBTControl::BluetoothDisconnectAccessoryL()" ); 

    TInt                  index( KErrNotFound );

    TAccPolGenericID      genericId;

    TAccPolGenericIDArray genericIdArray;

    TBTDevAddr            BTDevAddr;

    TPckg<TBTDevAddr>     BTDevAddrPckg( BTDevAddr );

    aMessage.ReadL( KAccServParamPosFirst, BTDevAddrPckg );

    //Find the GenericID in question

    iServerModel->CurrentConnectionStatusL( genericIdArray );//Fill the array	

    index = TAccPolGenericIDArrayAccessor::FindWithDeviceAddressL(

                                                genericIdArray,

                                                MakeTUint64( BTDevAddr ) );

    if ( index < 0 )

        {

        User::Leave( KErrArgument );        

        }

    //Pass handling to Connection Controller   

    iConnectionController->HandleDisconnectL( genericIdArray.GetGenericIDL( index ) );

    Write( aMessage, KAccSrvDisconnectBTAccessoryBit );

    COM_TRACE_( "[AccFW:AccServer] CAccSrvSubBTControl::BluetoothDisconnectAccessoryL - return void" );	

	}

// -----------------------------------------------------------------------------

// CAccSrvSubBTControl::BluetoothAudioLinkOpenRespL

// -----------------------------------------------------------------------------

//

void CAccSrvSubBTControl::BluetoothAudioLinkOpenRespL( const RMessage2& aMessage )

	{

    COM_TRACE_( "[AccFW:AccServer] CAccSrvSubBTControl::BluetoothAudioLinkOpenRespL()" );

    TInt              index( KErrNotFound );

    TInt              uniqueID( KErrNotFound );

    TBTDevAddr        BTDevAddr;

   	TPckg<TBTDevAddr> BTDevAddrPckg( BTDevAddr );

   	TInt              response( 0 );

    TPckg<TInt>       responsePckg( response );

    aMessage.ReadL( KAccServParamPosFirst, BTDevAddrPckg );

    aMessage.ReadL( KAccServParamPosSecond, responsePckg ); 

	//Find the GenericID in question	

    index = iServerModel->FindWithDeviceAddressL( 

                                MakeTUint64( BTDevAddr ),

                                uniqueID /*Unique DB id of the found accessory*/ );

    if ( index < 0 )

        {

        User::Leave( KErrArgument );        

        }

    if ( iServerModel->AudioLinkOpenCancelled() )

        {

        //AccessoryAudioLinkOpen() request was cancelled before this response was received.

        //This response can be completed with error code.

        ResetAudioLinkOpenCancelFlag( response );

        User::Leave( KErrCancel ); 

        }

    else

        {

   	    iConnectionController->NotificationQueue().CompleteControlMessageL( 

            EAccessoryAudioLinkOpen, response, uniqueID );

        }

    COM_TRACE_( "[AccFW:AccServer] CAccSrvSubBTControl::BluetoothAudioLinkOpenRespL - return void" );

	}

// -----------------------------------------------------------------------------

// CAccSrvSubBTControl::BluetoothAudioLinkCloseRespL

// -----------------------------------------------------------------------------

//

void CAccSrvSubBTControl::BluetoothAudioLinkCloseRespL( const RMessage2& aMessage )

	{

    COM_TRACE_( "[AccFW:AccServer] CAccSrvSubBTControl::BluetoothAudioLinkCloseRespL()" );

    TInt              index( KErrNotFound );

    TInt              uniqueID( KErrNotFound );

    TBTDevAddr        BTDevAddr;

   	TPckg<TBTDevAddr> BTDevAddrPckg( BTDevAddr );

   	TInt              response( 0 );

    TPckg<TInt>       responsePckg( response );

    aMessage.ReadL( KAccServParamPosFirst, BTDevAddrPckg );

    aMessage.ReadL( KAccServParamPosSecond, responsePckg ); 

	//Find the GenericID in question	

    index = iServerModel->FindWithDeviceAddressL( 

                                MakeTUint64( BTDevAddr ),

                                uniqueID /*Unique DB id of the found accessory*/ );

    if ( index < 0 )

        {

        User::Leave( KErrArgument );        

        }

    if ( iServerModel->AudioLinkCloseCancelled() )

        {

        //AccessoryAudioLinkClose() request was cancelled before this response was received.

        //This response can be completed with error code.

        ResetAudioLinkCloseCancelFlag( response );

        User::Leave( KErrCancel ); 

        }

    else

        {

   	    iConnectionController->NotificationQueue().CompleteControlMessageL( 

            EAccessoryAudioLinkClose, response, uniqueID );

        }

    COM_TRACE_( "[AccFW:AccServer] CAccSrvSubBTControl::BluetoothAudioLinkCloseRespL - return void" );	

	}

// -----------------------------------------------------------------------------

// CAccSrvSubBTControl::BluetoothAudioLinkOpenedNotifyL

// -----------------------------------------------------------------------------

//

void CAccSrvSubBTControl::BluetoothAudioLinkOpenedNotifyL( const RMessage2& aMessage )

	{

    COM_TRACE_( "[AccFW:AccServer] CAccSrvSubBTControl::BluetoothAudioLinkOpenedNotifyL()" );

    TInt                 index( KErrNotFound );

    TInt                 uniqueID( KErrNotFound );

    TInt                 currentAccessoryModeUniqueID = iServerModel->UniqueID();//Preferred audio output status is assigned for this uniqueID

    TBTDevAddr           BTDevAddr;

   	TPckg<TBTDevAddr>    BTDevAddrPckg( BTDevAddr );

   	TAccAudioType        audioType( EAccMonoAudio ); // Initialization value

    TAccSrvAudioTypePckg audioTypePckg( audioType );		

    aMessage.ReadL( KAccServParamPosFirst, BTDevAddrPckg );

    aMessage.ReadL( KAccServParamPosSecond, audioTypePckg );

    //Find the GenericID in question	

    index = iServerModel->FindWithDeviceAddressL( 

                                MakeTUint64( BTDevAddr ),

                                uniqueID /*Unique id of the found accessory*/ );               

    if ( index < 0 )

        {

        User::Leave( KErrArgument );        

        }

    if ( iServerModel->AudioLinkOpenCancelled() )

        {

        //AccessoryAudioLinkOpen() request was cancelled before this response was received.

        //This response can be completed with error code.

        ResetAudioLinkOpenCancelFlag( KErrNone );

        User::Leave( KErrCancel ); 

        }

    else

        {

        iServerModel->SetAudioType( audioType );//Notice, This works for single client (Server model can store only one value)            

        iConnectionController->NotificationQueue().CompleteControlMessageL( 

            EAccessoryAudioLinkOpened, KErrNone, uniqueID );

        }

    COM_TRACE_( "[AccFW:AccServer] CAccSrvSubBTControl::BluetoothAudioLinkOpenedNotifyL - return void" );	

	}

// -----------------------------------------------------------------------------

// CAccSrvSubBTControl::BluetoothAudioLinkClosedNotify

// -----------------------------------------------------------------------------

//

void CAccSrvSubBTControl::BluetoothAudioLinkClosedNotifyL( const RMessage2& aMessage )

	{

    COM_TRACE_( "[AccFW:AccServer] CAccSrvSubBTControl::BluetoothAudioLinkClosedNotifyL()" );

    TInt                 index( KErrNotFound );

    TInt                 uniqueID( KErrNotFound );

    TBTDevAddr           BTDevAddr;

   	TPckg<TBTDevAddr>    BTDevAddrPckg( BTDevAddr );

   	TAccAudioType        audioType( EAccMonoAudio ); // Initialization value

    TAccSrvAudioTypePckg audioTypePckg( audioType );		

    aMessage.ReadL( KAccServParamPosFirst, BTDevAddrPckg );

    aMessage.ReadL( KAccServParamPosSecond, audioTypePckg );

    //Find the GenericID in question

    index = iServerModel->FindWithDeviceAddressL( 

                                MakeTUint64( BTDevAddr ),

                                uniqueID /*Unique id of the found accessory*/ );

    if ( index < 0 )

        {

        User::Leave( KErrArgument );        

        }

    if ( iServerModel->AudioLinkCloseCancelled() )

        {

        //AccessoryAudioLinkClose() request was cancelled before this response was received.

        //This response can be completed with error code.

        ResetAudioLinkCloseCancelFlag( KErrNone );

        User::Leave( KErrCancel ); 

        }

    else

        {

        iServerModel->SetAudioType( audioType );//Notice, This works for single client (Server model can store only one value)            

   	    iConnectionController->NotificationQueue().CompleteControlMessageL( 

            EAccessoryAudioLinkClosed, KErrNone, uniqueID );

        }

    COM_TRACE_( "[AccFW:AccServer] CAccSrvSubBTControl::BluetoothAudioLinkClosedNotifyL - return void" );	

	}

// -----------------------------------------------------------------------------

// CAccSrvSubBTControl::NotifyBluetoothAudioLinkOpenReqL

// -----------------------------------------------------------------------------

//

void CAccSrvSubBTControl::NotifyBluetoothAudioLinkOpenReqL( 

    const RMessage2& aMessage )

	{

    COM_TRACE_( "[AccFW:AccServer] CAccSrvSubBTControl::NotifyBluetoothAudioLinkOpenReqL()" );

    iNotifyBluetoothAudioLinkOpenReqMsg = aMessage;//Store RMessage2 for future completion

    iConnectionController->NotificationQueue().RegisterControlMessage( 

        EBluetoothAudioLinkOpenReq, this );    

    if ( iServerModel->BluetoothAudioLinkOpenReqPostponed() )

        {        

        //Complete notification immediately if audio link open is still in progress

        if ( !iServerModel->AudioLinkOpenCancelled() &&

              iConnectionController->NotificationQueue().ControlMessagesWaiting( EAccessoryAudioLinkOpen ) > 0 )

            {

        	TInt              uniqueID( KErrNotFound );

            TBTDevAddr        BTDevAddr;

            TPckg<TBTDevAddr> BTDevAddrPckg( BTDevAddr );

            aMessage.ReadL( KAccServParamPosFirst, BTDevAddrPckg );

			// coverity[check_return]

			// coverity[unchecked_value]

            iServerModel->FindWithDeviceAddressL( MakeTUint64( BTDevAddr ), uniqueID );

            iConnectionController->NotificationQueue().CompleteControlMessageL(

                EBluetoothAudioLinkOpenReq, KErrNone, uniqueID );

            }

        }

    iServerModel->SetBluetoothAudioLinkOpenReqPostponed( EFalse );//Postpone is not needed anymore

    COM_TRACE_( "[AccFW:AccServer] CAccSrvSubBTControl::NotifyBluetoothAudioLinkOpenReqL - return void" );	

	}

// -----------------------------------------------------------------------------

// CAccSrvSubBTControl::NotifyBluetoothAudioLinkCloseReqL

// -----------------------------------------------------------------------------

//

void CAccSrvSubBTControl::NotifyBluetoothAudioLinkCloseReqL( 

    const RMessage2& aMessage )

	{

    COM_TRACE_( "[AccFW:AccServer] CAccSrvSubBTControl::NotifyBluetoothAudioLinkCloseReqL()" );

    iNotifyBluetoothAudioLinkCloseReqMsg = aMessage;//Store RMessage2 for future completion

    iConnectionController->NotificationQueue().RegisterControlMessage( 

        EBluetoothAudioLinkCloseReq, this );

    COM_TRACE_( "[AccFW:AccServer] CAccSrvSubBTControl::NotifyBluetoothAudioLinkCloseReqL - return void" );	

	}

// -----------------------------------------------------------------------------

// CAccSrvSubBTControl::NotifyBTAccessoryValueChangedTBoolL

// -----------------------------------------------------------------------------

//

void CAccSrvSubBTControl::NotifyBTAccessoryValueChangedTBoolL( 

    const RMessage2& aMessage )

    {

    COM_TRACE_( "[AccFW:AccServer] CAccSrvSubBTControl::NotifyBTAccessoryValueChangedTBoolL()" );

    TInt                         index( KErrNotFound );

    TAccPolGenericIDArray        genericIdArray;

    TAccPolGenericID             genericID;

    TBTDevAddr                   BTDevAddr;

   	TPckg<TBTDevAddr>            BTDevAddrPckg( BTDevAddr );

    TAccPolNameRecord            nameRecord;

    TAccSrvNameRecordPckg        nameRecordPckg( nameRecord );

    TAccSrvValueTypeTBoolPckgBuf valuePckgBuf;

    aMessage.ReadL( KAccServParamPosFirst, BTDevAddrPckg );

    aMessage.ReadL( KAccServParamPosSecond, nameRecordPckg );

    aMessage.ReadL( KAccServParamPosThird, valuePckgBuf );

    //Find the GenericID in question

    iServerModel->CurrentConnectionStatusL( genericIdArray );//Fill the array

    index = TAccPolGenericIDArrayAccessor::FindWithDeviceAddressL(

                                                genericIdArray,

                                                MakeTUint64( BTDevAddr ) );

    if ( index < 0 )

        {

        User::Leave( KErrArgument );        

        }

    genericID = genericIdArray.GetGenericIDL( index );

    //Check is the capability assigned for this accessory

	TUint32 name;

	nameRecord.GetName( name );

    CCapValue * value = iServerModel->CapabilityStorage().GetCapability( genericID, name );

    if ( !value ) 

        {

        User::Leave( KErrArgument );

        }

    //Store a new value

    value->SetValueL( valuePckgBuf().iValue );

    //Store Value Data for AccessoryValueChanged notification

    TAccValueTypeTInt dummyTIntValue = { 0 };

    TAccValueTypeObject dummyObjectValue( TPtr8( NULL, 0, 0 ) );

    iServerModel->SetValueData( genericID,

    	                        nameRecord,

    	                        dummyTIntValue, /*Not used*/

    	                        valuePckgBuf(),

    	                        dummyObjectValue/*Not used*/ ); 

    //complete possible pending notifications about change of accessory value    		        

    iConnectionController->NotificationQueue().CompleteControlMessageL(

        EAccessoryValueChangedTBool, KErrNone, genericID.UniqueID() );

    //Update Connection status and Accessory mode (if changed)

    iConnectionController->HandleConnectionChangeValidationL( genericID );

    COM_TRACE_( "[AccFW:AccServer] CAccSrvSubBTControl::NotifyBTAccessoryValueChangedTBoolL - return void" );

    }

// -----------------------------------------------------------------------------

// CAccSrvSubBTControl::NotifyBTAccessoryValueChangedTIntL

// -----------------------------------------------------------------------------

//

void CAccSrvSubBTControl::NotifyBTAccessoryValueChangedTIntL( 

    const RMessage2& aMessage )

    {

    COM_TRACE_( "[AccFW:AccServer] CAccSrvSubBTControl::NotifyBTAccessoryValueChangedTIntL()" );

    TInt                         index( KErrNotFound );

    TAccPolGenericIDArray        genericIdArray;

    TAccPolGenericID             genericID;

    TBTDevAddr                   BTDevAddr;

   	TPckg<TBTDevAddr>            BTDevAddrPckg( BTDevAddr );

    TAccPolNameRecord            nameRecord;

    TAccSrvNameRecordPckg        nameRecordPckg( nameRecord );

    TAccSrvValueTypeTIntPckgBuf  valuePckgBuf;

    aMessage.ReadL( KAccServParamPosFirst, BTDevAddrPckg );

    aMessage.ReadL( KAccServParamPosSecond, nameRecordPckg );

    aMessage.ReadL( KAccServParamPosThird, valuePckgBuf );

    //Find the GenericID in question