/*

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

#include "T_BTUtil.h"

/*@{*/

//Constant Literals used.

_LIT(KNamedProtocol,							"named_protocol");

_LIT(KCmdRSocketServerConnect,					"RSocketServerConnect");

_LIT(KCmdRSocketServerClose,					"RSocketServerClose");

_LIT(KCmdRSocketOpen,							"RSocketOpen");

_LIT(KCmdRSocketClose,							"RSocketClose");

_LIT(KCmdInfo,									"Info");

// Other

_LIT_SECURITY_POLICY_C2(KProcPolicy, ECapabilityNetworkServices, ECapabilityNetworkControl);

/*@}*/

CT_RSocketData* CT_RSocketData::NewL()

	{

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

	return ret;

	}

CT_RSocketData::CT_RSocketData()

	{

	}

CT_RSocketData::~CT_RSocketData()

	{

	}

TBool CT_RSocketData::DoCommandL(const TTEFFunction& aCommand, const TTEFSectionName& aSection, const TInt /*aAsyncErrorIndex*/)

	{

	TBool								retVal=ETrue;

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

	// RSocket (This class is not a full test suite just a helper to test CBluetoothSocket)

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

	if (aCommand==KCmdRSocketServerConnect)

		{

		CloseSocketServer();				

		User::LeaveIfError(iSocketServer.Connect());			

		}

	else if (aCommand==KCmdRSocketServerClose)

		{

		CloseSocketServer();

		}

	else if (aCommand==KCmdRSocketOpen)

		{	

		RSocketOpen(aSection);	

		}

	else if (aCommand==KCmdRSocketClose)

		{

		iRSocket.Close();

		}

	else if (aCommand==KCmdInfo)

		{

		Info(aSection);

		}		

	else

		{

		retVal=EFalse;

		}

	return retVal;

	}

TAny* CT_RSocketData::GetObject()

	{

	return &iRSocket;

	}

void CT_RSocketData::CloseSocketServer()

	{

	if(iSocketServer.Handle())

		{

		iSocketServer.Close();

		}	

	}	

void CT_RSocketData::RSocketOpen(const TDesC& aSection)

	{	

	TPtrC	namedProtocol;

	if( GetStringFromConfig(aSection, KNamedProtocol(), namedProtocol))

		{

		INFO_PRINTF2(_L("Opening RSocket with: %S protocol"), &namedProtocol);			

		TProtocolDesc pInfo;

		User::LeaveIfError(iSocketServer.FindProtocol(namedProtocol,pInfo));		

		iRSocket.Open(iSocketServer, pInfo.iAddrFamily, pInfo.iSockType, pInfo.iProtocol);

		iRSocket.SetOpt(KSOEnableTransfer, KSOLSocket, KProcPolicy().Package());

		}

	else

		{

		ERR_PRINTF1(_L("GetStringFromConfig failed"));

		SetBlockResult(EFail);	

		}	

	}

void CT_RSocketData::Info(const TDesC& /*aSection*/)	

	{

	TProtocolDesc protocolDesc;

	TInt err = iRSocket.Info(protocolDesc);

	SetError(err);

	}