/*

* Copyright (c) 2005-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:

*

*/

#include "t_data_rgavdp.h"

#include "T_BTUtil.h"

#include <e32des8.h>

using namespace SymbianBluetoothAV;

/*@{*/

//Parameters

_LIT(KFldSocketServ,						"socketserv");

_LIT(KFldBTDevAddr,							"btdevaddr");

_LIT(KFldSEPInfo,							"avdtpsepinfo");

_LIT(KFldServiceCapability,					"avdtpservicecapability");

_LIT(KFldSecurityData,						"securitydata");

_LIT(KFldSEPsCount,							"expected_sepcount");

_LIT(KFldRemoteSEPs,						"remotesep_%d");

_LIT(KFldServiceCategory,					"servicecategory");

_LIT(KFldRemoteCaps,						"expected_remotecap_%d");

_LIT(KFldSEID,								"seid");

_LIT(KFldLocalSEID,							"localseid");

_LIT(KFldRemoteSEID,						"remoteseid");

_LIT(KFldIgnored1,							"ignored1");

_LIT(KFldIgnored2,							"ignored2");

_LIT(KFldSendData,							"senddata");

_LIT(KFldExpectedData,						"expecteddata");

_LIT(KFldExpectedEvents,					"expectedevents");

_LIT(KFldExpectedResponseData,				"expectedresponsedata");

_LIT(KFldExpectedMaxLength,					"expectedmaxlength");

_LIT(KFldExistRemoteSEPs,					"exist_remote_sep");

_LIT(KFldConfigReturnCode,					"config_return_code");

_LIT(KFldConfigEndReturnCode,				"config_end_return_code");

_LIT(KEGAVDP_NoneEvent,						"EGAVDP_NoneEvent");

_LIT(KEGAVDP_ConnectConfirm,				"EGAVDP_ConnectConfirm");

_LIT(KEGAVDP_SEPDiscovered,					"EGAVDP_SEPDiscovered");

_LIT(KEGAVDP_SEPDiscoveryComplete,			"EGAVDP_SEPDiscoveryComplete");

_LIT(KEGAVDP_SEPCapability,					"EGAVDP_SEPCapability");

_LIT(KEGAVDP_SEPCapabilityComplete,			"EGAVDP_SEPCapabilityComplete");

_LIT(KEGAVDP_AbortStreamConfirm,			"EGAVDP_AbortStreamConfirm");

_LIT(KEGAVDP_StartStreamsConfirm,			"EGAVDP_StartStreamsConfirm");

_LIT(KEGAVDP_SuspendStreamsConfirm,			"EGAVDP_SuspendStreamsConfirm");

_LIT(KEGAVDP_SecurityControlConfirm,		"EGAVDP_SecurityControlConfirm");

_LIT(KEGAVDP_ConfigurationConfirm,			"EGAVDP_ConfigurationConfirm");

_LIT(KEGAVDP_ConfigurationStartIndication,	"EGAVDP_ConfigurationStartIndication");

_LIT(KEGAVDP_ConfigurationIndication,		"EGAVDP_ConfigurationIndication");

_LIT(KEGAVDP_ConfigurationEndIndication,	"EGAVDP_ConfigurationEndIndication");

_LIT(KEGAVDP_StartIndication,				"EGAVDP_StartIndication");

_LIT(KEGAVDP_SuspendIndication,				"EGAVDP_SuspendIndication");

_LIT(KEGAVDP_SecurityControlIndication,		"EGAVDP_SecurityControlIndication");

_LIT(KEGAVDP_AbortIndication,				"EGAVDP_AbortIndication");

_LIT(KEGAVDP_ReleaseIndication,				"EGAVDP_ReleaseIndication");

_LIT(KEGAVDP_BearerReady,					"EGAVDP_BearerReady");

_LIT(KEGAVDP_Error,							"EGAVDP_Error");

//Commands

_LIT(KCmdDestructorGeneral,					"~");

_LIT(KCmdDestructor,						"~RGavdp");

_LIT(KCmdConstructor,						"new");

_LIT(KCmdOpen,								"Open");

_LIT(KCmdListen,							"Listen");

_LIT(KCmdConnect,							"Connect");

_LIT(KCmdClose,								"Close");

_LIT(KCmdCancel,							"Cancel");

_LIT(KCmdDiscoverRemoteSEPs,				"DiscoverRemoteSEPs");

_LIT(KCmdGetRemoteSEPCapabilities,			"GetRemoteSEPCapabilities");

_LIT(KCmdRegisterSEP,						"RegisterSEP");

_LIT(KCmdBeginConfiguringRemoteSEP,			"BeginConfiguringRemoteSEP");

_LIT(KCmdBeginConfiguringLocalSEP,			"BeginConfiguringLocalSEP");

_LIT(KCmdAddSEPCapability,					"AddSEPCapability");

_LIT(KCmdCommitSEPConfiguration,			"CommitSEPConfiguration");

_LIT(KCmdStartStream,						"StartStream");

_LIT(KCmdSuspendStream,						"SuspendStream");

_LIT(KCmdAbortStream,						"AbortStream");

_LIT(KCmdSendSecurityControl,				"SendSecurityControl");

_LIT(KCmdCreateBearerSockets,				"CreateBearerSockets");

_LIT(KCmdMaxSecurityControlLength,			"MaxSecurityControlLength");

_LIT(KCmdShutdown,							"Shutdown");

//Utility

_LIT(KCmdIncOutstanding,					"IncOutstanding");

_LIT(KCmdRead,								"Read");

_LIT(KCmdSend,								"Send");

_LIT(KCmdCloseBearerSockets,				"CloseBearerSockets");

///	Logging

_LIT(KLogInfoCmdConstructor,				"execute new RGavdp::RGavdp()");

_LIT(KLogInfoCmdOpen,						"execute RGavdp::Open()");

_LIT(KLogInfoCmdDestructor1,				"execute ~RGavdp()");

_LIT(KLogInfoCmdClose,						"execute RGavdp::Close()");

_LIT(KLogInfoCmdListen,						"execute RGavdp::Listen()");

_LIT(KLogInfoCmdCancel,						"execute RGavdp::Cancel()");

_LIT(KLogInfoCmdConnnect,        			"execute RGavdp::Connect()");

_LIT(KLogInfoCmdDiscoverRemoteSEPs,			"execute RGavdp::DiscoverRemoteSEPs()");

_LIT(KLogInfoCmdGetRemoteSEPCapabilities,	"execute RGavdp::GetRemoteSEPCapabilities()");

_LIT(KLogInfoCmdRegisterSEP,				"execute RGavdp::RegisterSEP()");

_LIT(KLogInfoCmdBeginConfiguringRemoteSEP,	"execute RGavdp::BeginConfiguringRemoteSEP()");

_LIT(KLogInfoCmdBeginConfiguringLocalSEP,	"execute RGavdp::BeginConfiguringLocalSEP()");

_LIT(KLogInfoCmdAddSEPCapability,			"execute RGavdp::AddSEPCapability()");

_LIT(KLogInfoCmdCommitSEPConfiguration,		"execute RGavdp::CommitSEPConfiguration()");

_LIT(KLogInfoCmdStartStream,				"execute RGavdp::StartStream()");

_LIT(KLogInfoCmdSuspendStream,				"execute RGavdp::SuspendStream()");

_LIT(KLogInfoCmdAbortStream,				"execute RGavdp::AbortStream()");

_LIT(KLogInfoCmdSendSecurityControl,		"execute RGavdp::SendSecurityControl()");

_LIT(KLogInfoCmdCreateBearerSockets1,		"execute RGavdp::CreateBearerSockets(TSEID)");

_LIT(KLogInfoCmdCreateBearerSockets2,		"execute RGavdp::CreateBearerSockets(TSEID, TBool, TBool)");

_LIT(KLogInfoCmdMaxSecurityControlLength1,	"execute RGavdp::MaxSecurityControlLength()");

_LIT(KLogInfoCmdShutdown,					"execute RGavdp::Shutdown()");

_LIT(KLogInfoReading,						"Start reading");

_LIT(KLogInfoSending,						"Start sending");

_LIT(KLogInfoCmdMaxSecurityControlLength2,	"RGavdp::MaxSecurityControlLength = %d");

_LIT(KLogErrMissingParameter,				"Missing parameter '%S'");

_LIT(KLogErrCmdConstructor,					"**** RGavdp Constructor failed with error %d");

_LIT(KLogErrCmdOpen,						"**** RGavdp Open failed with error %d");

_LIT(KLogErrCmdListen,						"**** RGavdp Listen failed with error %d");

_LIT(KLogErrCmdRegisterSEP,					"**** RGavdp RegisterSEP failed with error %d");

_LIT(KLogErrCmdBeginConfiguringRemoteSEP,	"**** RGavdp BeginConfiguringRemoteSEP failed with error %d");

_LIT(KLogErrCmdBeginConfiguringLocalSEP,	"**** RGavdp BeginConfiguringLocalSEP failed with error %d");

_LIT(KLogErrCmdAddSEPCapability,			"**** RGavdp AddSEPCapability failed with error %d");

_LIT(KLogErrCmdCreateBearerSockets,			"**** RGavdp CreateBearerSockets failed with error %d");

_LIT(KLogErrCmdShutdown,					"**** RGavdp Shutdown failed with error %d");

//call back

_LIT(KLogInfoConnectConfirm,				"MGavdpUser::GAVDP_ConnectConfirm() call back");

_LIT(KLogInfoSEPDiscovered,					"MGavdpUser::GAVDP_SEPDiscovered() call back");

_LIT(KLogInfoSEPDiscoveryComplete,			"MGavdpUser::GAVDP_SEPDiscoveryComplete() call back.");

_LIT(KLogInfoSEPCapability,					"MGavdpUser::GAVDP_SEPCapability() call back.");

_LIT(KLogInfoSEPCapabilityComplete,			"MGavdpUser::GAVDP_SEPCapabilityComplete() call back.");

_LIT(KLogInfoAbortStreamConfirm,			"MGavdpUser::GAVDP_AbortStreamConfirm() call back.");

_LIT(KLogInfoStartStreamsConfirm,			"MGavdpUser::GAVDP_StartStreamsConfirm() call back.");

_LIT(SuspendStreamsConfirm,					"MGavdpUser::GAVDP_SuspendStreamsConfirm() call back.");

_LIT(KLogInfoSecurityControlConfirm,		"MGavdpUser::GAVDP_SecurityControlConfirm() call back");

_LIT(KLogInfoConfigurationConfirm,			"MGavdpUser::GAVDP_ConfigurationConfirm() call back.");

_LIT(KLogInfoConfigurationStartIndication,	"MGavdpUser::GAVDP_ConfigurationStartIndication() call back");

_LIT(KLogInfoConfigurationIndication1,		"MGavdpUser::GAVDP_ConfigurationIndication() call back");

_LIT(KLogInfoConfigurationIndication2,		"Category = %d");

_LIT(KLogInfoConfigurationEndIndication,	"MGavdpUser::GAVDP_ConfigurationEndIndication() call back.");

_LIT(KLogInfoStartIndication,				"MGavdpUser::GAVDP_StartIndication() call back");

_LIT(KLogInfoSuspendIndication,				"MGavdpUser::GAVDP_SuspendIndication() call back");

_LIT(KLogInfoSecurityControlIndication,		"MGavdpUser::GAVDP_SecurityControlIndication() call back");

_LIT(KLogInfoAbortIndication,				"MGavdpUser::GAVDP_AbortIndication() call back");

_LIT(KLogInfoReleaseIndication,				"MGavdpUser::GAVDP_ReleaseIndication() call back");

_LIT(KLogInfoBearerReady,					"MGavdpUser::GAVDP_BearerReady() call back");

_LIT(KLogInfoError1,						"MGavdpUser::GAVDP_Error() call back");

_LIT(KLogInfoError2,						"aError: %d, aErrorData: %s");

_LIT(KLogInfoSEPValue,						"SEID: %d");

_LIT(KLogInfoMediaTypeAudio,				"Audio");

_LIT(KLogInfoMediaTypeVideo,				"Video");

_LIT(KLogInfoMediaTypeMultimedia,			"Multimedia");

_LIT(KLogInfoAvdtpSink,						"Sink");

_LIT(KLogInfoAvdtpSource,					"Source");

_LIT(KLogInfoAvdtpInUse,					"[In use]");

_LIT(KLogInfoServiceCategoryMediaTransport,	"Category = EServiceCategoryMediaTransport");

_LIT(KLogInfoServiceCategoryReporting,		"Category = EServiceCategoryReporting");

_LIT(KLogInfoServiceCategoryRecovery,		"Category = EServiceCategoryRecovery");

_LIT(KLogInfoServiceCategoryContentProtection, "Category = EServiceCategoryContentProtection");

_LIT(KLogInfoBearerTypeEMedia,				"EMedia");

_LIT(KLogInfoBearerTypeEReporting,			"EReporting");

_LIT(KLogInfoBearerTypeERecovery,			"ERecovery");

_LIT(KLogInfoSendSucess,					"Send successfully");

_LIT(KLogInfoReceived,						"Recevied Data :%S");

_LIT(KLogErrCallback,						"Called function is not as expected");

_LIT(KLogErrLocalSEID,						"SEID used for call back is not as expected, expected_SEID=%d actual_SEID=%d");

_LIT(KLogErrConnect,						"Remote device address is not as expected");

_LIT(KLogErrCapability,						"Received capability is not as expected");

_LIT(KLogErrExpectedEvents,					"Given expected events (%S) is invalid");

_LIT(KLogErrExpectedResponseData,			"Response security data is not as expected");

_LIT(KLogErrReceivedSecurityData,			"Received security data is not as expected");

_LIT(KLogErrExpectedMaxLength,				"MaxSecurityControlLength is not as expected");

_LIT(KLogErrExistRemoteSEPs,				"Given exist remote SEPs are invalid");

_LIT(KLogErrDiscoverRemoteSEPsCount,		"Discover remote SEPs fail expected_count=%d actual_count=%d");

_LIT(KLogErrReadData,						"Not received expected data");

_LIT(KLogErrSocket,							"Socket Error= %d");

//SecurityData

_LIT(KLogInfoSecurityDataUnchanged,			"Security data not changed");

_LIT(KLogInfoSecurityDataChanged,			"Have changed security data to: %S");

_LIT(KLogDataFixed,							"Do not change me");

_LIT(KLogDataChange,						"Change me");

_LIT(KLogDataChanged,						"Changed data");

/*@}*/

//////////////////////////////////////////////////////////////////////

// Construction/Destruction

//////////////////////////////////////////////////////////////////////

CT_DataRGavdp* CT_DataRGavdp::NewL()

	{

	CT_DataRGavdp*	ret=new	(ELeave) CT_DataRGavdp();

	CleanupStack::PushL(ret);

	ret->ConstructL();

	CleanupStack::Pop(ret);

	return ret;

	}

CT_DataRGavdp::CT_DataRGavdp()

:	iRGavdp(NULL),

	iRemoteAddr(NULL),

	iExpectedEventCount(0),

	iEventCount(0),

	iExpectedSEPsCount(0),

	iDiscoverdSEPsCount(0),

	iSrvCategory(EServiceCategoryNull),

	iReadBuffer(NULL),

	iReadBufferDes(NULL, NULL),

	iReadExpectBuffer(NULL),

	iSendBuffer(NULL),

	iExpectedResponseSecurityData(NULL),

	iActive(NULL),

	iCmdIndex(0),

	iConfigReturnCode(0),

	iConfigEndReturnCode(0)

	{

	}

void CT_DataRGavdp::ConstructL()

	{

	iActive = CActiveCallback::NewL(*this);

	}

CT_DataRGavdp::~CT_DataRGavdp()

	{

	DestroyData();

	delete iActive;

	iActive = NULL;

	}

void CT_DataRGavdp::SetObjectL(TAny* aAny)

	{

	DestroyData();

	iRGavdp	= static_cast<RGavdp*> (aAny);

	}

void CT_DataRGavdp::DisownObjectL()

	{

	iRGavdp	= NULL;

	}

void CT_DataRGavdp::DestroyData()

	{

	DoCmdDestructor();

	iRemoteAddr=NULL;

	iExpectedEvent.Close();

	iExpectedEventCount=0;

	iEventCount=0;

	iExistRemoteSEIDs.Close();

	iExpectedSEPsCount=0;

	iDiscoverdSEPsCount=0;

	iRemoteSEPs.Close();

	iRemoteCapabilities.Close();

	iSrvCategory=EServiceCategoryNull;

	delete iReadBuffer;

	iReadBuffer = NULL;

	delete iReadExpectBuffer;

	iReadExpectBuffer = NULL;

	delete iExpectedResponseSecurityData;

	iExpectedResponseSecurityData = NULL;

	delete iSendBuffer;

	iSendBuffer = NULL;

	iConfigReturnCode = 0;

	iConfigEndReturnCode = 0;

	}

inline TCleanupOperation CT_DataRGavdp::CleanupOperation()

	{

	return CleanupOperation;

	}

void CT_DataRGavdp::CleanupOperation(TAny* aAny)

	{

	RGavdp* gavdp=static_cast<RGavdp*>(aAny);

	gavdp->Close();

	delete gavdp;

	}

/**

test script	command	entry point

@internalAll

@return	ETrue if syncronous	command	otherwise EFalse

@param aParam1 descriptor containing the command value

@param aParam2 descriptor containing the command parameter

@pre N/A

@post N/A

*/

TBool CT_DataRGavdp::DoCommandL(const TTEFFunction& aCommand, const TTEFSectionName& aSection, const TInt aAsyncErrorIndex)

	{

	TBool	ret=ETrue;

	if ( aCommand==KCmdDestructorGeneral || aCommand==KCmdDestructor )

		{

		DoCmdDestructor();

		}

	else if ( aCommand==KCmdConstructor )

		{

		DoCmdConstructor();

		}

	else if( aCommand==KCmdOpen )

		{

		DoCmdOpen(aSection);

		}

	else if( aCommand==KCmdListen )

		{

		DoCmdListen(aSection, aAsyncErrorIndex);

		}

	else if( aCommand==KCmdClose )

		{

		DoCmdClose();

		}

	else if( aCommand==KCmdCancel )

		{

		DoCmdCancel();

		}

	else if( aCommand==KCmdConnect )

		{

		DoCmdConnect(aSection, aAsyncErrorIndex);

		}

	else if( aCommand==KCmdDiscoverRemoteSEPs )

		{

		DoCmdDiscoverRemoteSEPs(aSection, aAsyncErrorIndex);

		}

	else if( aCommand==KCmdGetRemoteSEPCapabilities )

		{

		DoCmdGetRemoteSEPCapabilities(aSection, aAsyncErrorIndex);

		}

	else if( aCommand==KCmdRegisterSEP )

		{

		DoCmdRegisterSEP(aSection);

		}

	else if( aCommand==KCmdBeginConfiguringRemoteSEP )

		{

		DoCmdBeginConfiguringRemoteSEP(aSection);

		}

	else if( aCommand==KCmdBeginConfiguringLocalSEP )

		{

		DoCmdBeginConfiguringLocalSEP(aSection);

		}

	else if( aCommand==KCmdAddSEPCapability )

		{

		DoCmdAddSEPCapability(aSection);

		}

	else if( aCommand==KCmdCommitSEPConfiguration )

		{

		DoCmdCommitSEPConfiguration(aSection, aAsyncErrorIndex);

		}

	else if( aCommand==KCmdStartStream )

		{

		DoCmdStartStream(aSection, aAsyncErrorIndex);

		}

	else if( aCommand==KCmdSuspendStream )

		{

		DoCmdSuspendStream(aSection, aAsyncErrorIndex);

		}

	else if( aCommand==KCmdAbortStream )

		{

		DoCmdAbortStream(aSection, aAsyncErrorIndex);

		}

	else if( aCommand==KCmdSendSecurityControl )

		{

		DoCmdSendSecurityControl(aSection, aAsyncErrorIndex);

		}

	else if( aCommand==KCmdCreateBearerSockets )

		{

		DoCmdCreateBearerSockets(aSection, aAsyncErrorIndex);

		}

	else if( aCommand==KCmdMaxSecurityControlLength )

		{

		DoCmdMaxSecurityControlLength(aSection);

		}

	else if( aCommand==KCmdShutdown )

		{

		DoCmdShutdown();

		}

	else if( aCommand==KCmdRead )

		{

		Read(aSection, aAsyncErrorIndex);

		}

	else if( aCommand==KCmdSend )

		{

		Send(aSection, aAsyncErrorIndex);

		}

	else if( aCommand==KCmdCloseBearerSockets)

		{

		CloseBearerSockets();

		}

	else if( aCommand==KCmdIncOutstanding )

		{

		IncreaseOutstanding(aSection, aAsyncErrorIndex);

		}

	else

		{

		ret=EFalse;

		}

	return ret;

	}

void CT_DataRGavdp::DoCmdDestructor()

	{

	if (iRGavdp) 

		{

		INFO_PRINTF1(KLogInfoCmdDestructor1);

		delete iRGavdp;

		iRGavdp = NULL;

		}

	}

void CT_DataRGavdp::DoCmdConstructor()

	{

	DestroyData();

	INFO_PRINTF1(KLogInfoCmdConstructor);

	TRAPD(err,	iRGavdp = new (ELeave) RGavdp());

	if(err	!= KErrNone)

		{

		ERR_PRINTF2(KLogErrCmdConstructor, err);

		SetError(err);

		}

	}

void CT_DataRGavdp::DoCmdOpen(const TTEFSectionName& aSection)

	{

	TBool	dataOk=ETrue;

	RSocketServ* socketServ;

	if ( !CT_BTUtil::GetSocketServL(*this, aSection, KFldSocketServ, socketServ) )

		{

		dataOk=EFalse;

		ERR_PRINTF2(KLogErrMissingParameter, &KFldSocketServ());

		SetBlockResult(EFail);		

		}

	TInt err = KErrNone;

	if ( dataOk )

		{

		INFO_PRINTF1(KLogInfoCmdOpen);

		err = iRGavdp->Open(*this,*socketServ);

		}

	if(err != KErrNone)

		{

		ERR_PRINTF2(KLogErrCmdOpen, err);

		SetError(err);

		}

	}

void CT_DataRGavdp::DoCmdListen(const TTEFSectionName& aSection, const TInt aAsyncErrorIndex)

	{

	INFO_PRINTF1(KLogInfoCmdListen);

	if(!GetIntFromConfig(aSection, KFldConfigReturnCode(), iConfigReturnCode))

		{

		iConfigReturnCode=KErrNone;

		}

	if(!GetIntFromConfig(aSection, KFldConfigEndReturnCode(), iConfigEndReturnCode))

		{

		iConfigEndReturnCode=KErrNone;

		}

	if (!ReadExpectedEventsFromConfig(aSection))

		{

		SetBlockResult(EFail);

		}

	else

		{

		SetEventOutstanding();

		iCmdIndex = aAsyncErrorIndex;

		TInt err = iRGavdp->Listen();

		if(err != KErrNone)

			{

			ERR_PRINTF2(KLogErrCmdListen, err);

			SetError(err);

			}

		}

	}

void CT_DataRGavdp::DoCmdClose()

	{

	INFO_PRINTF1(KLogInfoCmdClose);

	iRGavdp->Close();

	}

void CT_DataRGavdp::DoCmdCancel()

	{

	INFO_PRINTF1(KLogInfoCmdCancel);

	iRGavdp->Cancel();

	}

void CT_DataRGavdp::DoCmdConnect(const TTEFSectionName& aSection, const TInt aAsyncErrorIndex)

	{

	TBool dataOk = ETrue;

	TPtrC		objectName;

	if (!GetStringFromConfig(aSection, KFldBTDevAddr(), objectName) )

		{

		dataOk = EFalse;

		ERR_PRINTF2(KLogErrMissingParameter, &KFldBTDevAddr());

		SetBlockResult(EFail);

		}

	if (!ReadExpectedEventsFromConfig(aSection))

		{

		dataOk = EFalse;

		SetBlockResult(EFail);

		}

	if (dataOk)

		{

		iRemoteAddr = static_cast<TBTDevAddr*>(GetDataObjectL(objectName));

		INFO_PRINTF1(KLogInfoCmdConnnect);