/*

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

//	Epoc includes

#include <in_sock.h>

#include <es_sock.h>

#include <es_enum.h>

#include <bt_sock.h>

#include <cs_subconevents.h>

/*@{*/

///	Constant Literals used.

_LIT(KInterfaceDownBuf,							"EInterfaceDown");

// TConnectionType

_LIT(KConnectionCSD ,							"EConnectionCSD ");

_LIT(KConnectionGPRS,							"EConnectionGPRS");

_LIT(KConnectionGPRSR97,						"EConnectionGPRSR97");

_LIT(KConnectionGPRSR99,						"EConnectionGPRSR99");

_LIT(KConnectionGPRSRel4,						"EConnectionGPRSRel4");

_LIT(KConnectionGPRSRel5,						"EConnectionGPRSRel5");

//_LIT(KConnectionCDMA,							"EConnectionCDMA");

//_LIT(KConnectionCDMA20001xRTT,					"EConnectionCDMA20001xRTT");

//_LIT(KConnectionCDMA20001xRTTDO,				"EConnectionCDMA20001xRTTDO ");

//_LIT(KConnectionCDMA20001xRTTDV,				"EConnectionCDMA20001xRTTDV");

//_LIT(KConnectionCDMA20003xRTT,					"EConnectionCDMA20003xRTT");

_LIT(KConnectionEthernet,						"EConnectionEthernet");

_LIT(KConnectionWLAN,							"EConnectionWLAN");

_LIT(KConnectionBTPAN,							"EConnectionBTPAN");

// TConnStopType

_LIT(KStopAuthoritative,						"EStopAuthoritative");

// TConnAttachType

_LIT(KAttachTypeMonitor,						"EAttachTypeMonitor");

// SockType

_LIT(KSockStreamStr,							"KSockStream");

_LIT(KSockDatagramStr,							"KSockDatagram");

// Protocol

_LIT(KProtocolInetTcpStr,						"KProtocolInetTcp");

_LIT(KProtocolInetUdpStr,						"KProtocolInetUdp");

// AddrFamily

_LIT(KAFUnspecStr,								"KAFUnspec");

_LIT(KAfInetStr,								"KAfInet");

_LIT(KAfInet6Str,								"KAfInet6");

// Capability

_LIT(ECapabilityTCBStr,							"ECapabilityTCB");

_LIT(ECapabilityCommDDStr,						"ECapabilityCommDD");

_LIT(ECapabilityPowerMgmtStr,					"ECapabilityPowerMgmt");

_LIT(ECapabilityMultimediaDDStr,				"ECapabilityMultimediaDD");

_LIT(ECapabilityReadDeviceDataStr,				"ECapabilityReadDeviceData");

_LIT(ECapabilityWriteDeviceDataStr,				"ECapabilityWriteDeviceData");

_LIT(ECapabilityDRMStr,							"ECapabilityDRM");

_LIT(ECapabilityTrustedUIStr,					"ECapabilityTrustedUI");

_LIT(ECapabilityProtServStr,					"ECapabilityProtServ");

_LIT(ECapabilityDiskAdminStr,					"ECapabilityDiskAdmin");

_LIT(ECapabilityNetworkControlStr,				"ECapabilityNetworkControl");

_LIT(ECapabilityAllFilesStr,					"ECapabilityAllFiles");

_LIT(ECapabilitySwEventStr,						"ECapabilitySwEvent");

_LIT(ECapabilityNetworkServicesStr,				"ECapabilityNetworkServices");

_LIT(ECapabilityLocalServicesStr,				"ECapabilityLocalServices");

_LIT(ECapabilityReadUserDataStr,				"ECapabilityReadUserData");

_LIT(ECapabilityWriteUserDataStr,				"ECapabilityWriteUserData");

_LIT(ECapabilityLocationStr,					"ECapabilityLocation");

_LIT(ECapabilitySurroundingsDDStr,				"ECapabilitySurroundingsDD");

_LIT(ECapabilityUserEnvironmentStr,				"ECapabilityUserEnvironment");

_LIT(ECapability_LimitStr,						"ECapability_Limit");

_LIT(ECapability_HardLimitStr,					"ECapability_HardLimit");

_LIT(ECapability_NoneStr,						"ECapability_None");

_LIT(ECapability_DeniedStr,						"ECapability_Denied");

// ProgressNotification stages

_LIT(KStartingSelectionStr,						"KStartingSelection");

_LIT(KFinishedSelectionStr,						"KFinishedSelection");

_LIT(KConnectionOpenStr,						"KConnectionOpen");

_LIT(KLinkLayerOpenStr,							"KLinkLayerOpen");

_LIT(KLinkLayerClosedStr,						"KLinkLayerClosed");

_LIT(KNonExistentStr,							"KNonExistent");

// TSubConnType

_LIT(KCreateNew,								"ECreateNew");

_LIT(KAttachToDefault,							"EAttachToDefault");

// EventGroupUid

_LIT(KSubConnGenericEventsImplUidStr,			"KSubConnGenericEventsImplUid");

// EventNotification events

_LIT(KSubConGenericEventParamsGrantedStr,		"KSubConGenericEventParamsGranted");

_LIT(KSubConGenericEventDataClientJoinedStr,	"KSubConGenericEventDataClientJoined");

_LIT(KSubConGenericEventDataClientLeftStr,		"KSubConGenericEventDataClientLeft");

_LIT(KSubConGenericEventSubConDownStr,			"KSubConGenericEventSubConDown");

_LIT(KSubConGenericEventParamsChangedStr,		"KSubConGenericEventParamsChanged");

_LIT(KSubConGenericEventParamsRejectedStr,		"KSubConGenericEventParamsRejected");

// ParameterSetType

_LIT(KAcceptable,								"EAcceptable");

_LIT(KRequested,								"ERequested");

_LIT(KGranted,									"EGranted");

/*@}*/

CT_DataCommsBase::CT_DataCommsBase()

	{

	}

CT_DataCommsBase::~CT_DataCommsBase()

	{

	}

void CT_DataCommsBase::RunL( CActive* aActive, TInt /*aIndex*/ )

	{

	ERR_PRINTF2(_L("RunL Stray signal, status = %d"), aActive->iStatus.Int());

	SetBlockResult(EFail);

	}

void CT_DataCommsBase::DoCancel( CActive* aActive, TInt /*aIndex*/ )

	{

	ERR_PRINTF2(_L("DoCancel Stray signal, status = %d"), aActive->iStatus.Int());

	SetBlockResult(EFail);

	}

void CT_DataCommsBase::MissingParamError( const TDesC& aParamName )

	{

	ERR_PRINTF2(_L("No %S"), &aParamName);

	SetBlockResult(EFail);

	}

TConnInterfaceState	CT_DataCommsBase::InterfaceNotificationState( const TDesC& aState )

	{

	TConnInterfaceState state = EInterfaceUp;

	if( aState == KInterfaceDownBuf() )

		{

		state = EInterfaceDown;

		}

	return state;

	}

TConnectionType CT_DataCommsBase::ConnectionType( const TDesC& aConnectionTypeName )

	{

	TConnectionType	connType = EConnectionGeneric;

	if( aConnectionTypeName == KConnectionCSD() )

		{

		connType = EConnectionCSD;

		}

	else if( aConnectionTypeName == KConnectionGPRS() )

		{

		connType = EConnectionGPRS;

		}

	else if( aConnectionTypeName == KConnectionGPRSR97() )

		{

		connType = EConnectionGPRSR97;

		}

	else if( aConnectionTypeName == KConnectionGPRSR99() )

		{

		connType = EConnectionGPRSR99;

		}

	else if( aConnectionTypeName == KConnectionGPRSRel4() )

		{

		connType = EConnectionGPRSRel4;

		}

	else if( aConnectionTypeName == KConnectionGPRSRel5() )

		{

		connType = EConnectionGPRSRel5;

		}

/*	else if( aConnectionTypeName == KConnectionCDMA() )

		{

		connType = EConnectionCDMA;

		}

	else if( aConnectionTypeName == KConnectionCDMA20001xRTT() )

		{

		connType = EConnectionCDMA20001xRTT;

		}

	else if( aConnectionTypeName == KConnectionCDMA20001xRTTDO() )

		{

		connType = EConnectionCDMA20001xRTTDO ;

		}

	else if( aConnectionTypeName == KConnectionCDMA20001xRTTDV() )

		{

		connType = EConnectionCDMA20001xRTTDV;

		}

	else if( aConnectionTypeName == KConnectionCDMA20003xRTT() )

		{

		connType = EConnectionCDMA20003xRTT;

		}*/

	else if( aConnectionTypeName == KConnectionEthernet() )

		{

		connType = EConnectionEthernet;

		}

	else if( aConnectionTypeName == KConnectionWLAN() )

		{

		connType = EConnectionWLAN;

		}

	else if( aConnectionTypeName == KConnectionBTPAN() )

		{

		connType = EConnectionBTPAN;

		}

	return connType;

	}

RConnection::TConnStopType CT_DataCommsBase::ConnectionStopType( const TDesC& aConnectionStopType )

	{

	RConnection::TConnStopType	stopType = RConnection::EStopNormal;

	if( aConnectionStopType == KStopAuthoritative() )

		{

		stopType = RConnection::EStopAuthoritative;

		}

	return stopType;

	}

RConnection::TConnAttachType CT_DataCommsBase::ConnectionAttachType( const TDesC& aConnectionAttachType )

	{

	RConnection::TConnAttachType	connAttachType = RConnection::EAttachTypeNormal;

	if( aConnectionAttachType == KAttachTypeMonitor() )

		{

		connAttachType = RConnection::EAttachTypeMonitor;

		}

	return connAttachType;

	}

TUint CT_DataCommsBase::ProgressNotificationExpectedStage( const TDesC& aStage)

	{

	TUint expectedStage = 0;

	if ( aStage == KStartingSelectionStr() )

		{

		expectedStage = KStartingSelection;

		}

	else if ( aStage == KFinishedSelectionStr() )

		{

		expectedStage = KFinishedSelection;

		}

	else if ( aStage == KConnectionOpenStr() )

		{

		expectedStage = KConnectionOpen;

		}

	else if ( aStage == KLinkLayerOpenStr() )

		{

		expectedStage = KLinkLayerOpen;

		}

	else if ( aStage == KLinkLayerClosedStr() )

		{

		expectedStage = KLinkLayerClosed;

		}

	else if ( aStage == KNonExistentStr() )

		{

		expectedStage = 1234;

		}

	return expectedStage;

	}

TBool CT_DataCommsBase::GetSockType( const TDesC& aSockTypeStr, TUint& aSockType )

	{

	TBool found = ETrue;

	if( aSockTypeStr == KSockStreamStr() )

		{

		aSockType = KSockStream;

		}

	else if( aSockTypeStr == KSockDatagramStr() )

		{

		aSockType = KSockDatagram;

		}

	else

		{

		found = EFalse;

		}

	return found;

	}

TBool CT_DataCommsBase::GetProtocol( const TDesC& aProtocolStr, TUint& aProtocol )

	{

	TBool found = ETrue;

	if( aProtocolStr == KProtocolInetTcpStr() )

		{

		aProtocol = KProtocolInetTcp;

		}

	else if( aProtocolStr == KProtocolInetUdpStr() )

		{

		aProtocol = KProtocolInetUdp;

		}

	else

		{

		found = EFalse;

		}

	return found;

	}

TBool CT_DataCommsBase::GetAddrFamily( const TDesC& aAddrFamilyStr, TUint& aAddrFamily )

	{

	TBool found = ETrue;

	if( aAddrFamilyStr == KAFUnspecStr() )

		{

		aAddrFamily = KAFUnspec;

		}

	else if( aAddrFamilyStr == KAfInetStr() )

		{

		aAddrFamily = KAfInet;

		}

	else if( aAddrFamilyStr == KAfInet6Str() )

		{

		aAddrFamily = KAfInet6;

		}

	else

		{

		found = EFalse;

		}

	return found;

	}

TBool CT_DataCommsBase::GetCapability( const TDesC& aCapabilityStr, TCapability& aCapability )

	{

	TBool found = ETrue;

	if( aCapabilityStr == ECapabilityTCBStr() )

		{

		aCapability = ECapabilityTCB;

		}

	else if( aCapabilityStr == ECapabilityCommDDStr() )

		{

		aCapability = ECapabilityCommDD;

		}

	else if( aCapabilityStr == ECapabilityPowerMgmtStr() )

		{

		aCapability = ECapabilityPowerMgmt;

		}

	else if( aCapabilityStr == ECapabilityMultimediaDDStr() )

		{

		aCapability = ECapabilityMultimediaDD;

		}

	else if( aCapabilityStr == ECapabilityReadDeviceDataStr() )

		{

		aCapability = ECapabilityReadDeviceData;

		}

	else if( aCapabilityStr == ECapabilityWriteDeviceDataStr() )

		{

		aCapability = ECapabilityWriteDeviceData;

		}

	else if( aCapabilityStr == ECapabilityDRMStr() )

		{

		aCapability = ECapabilityDRM;

		}

	else if( aCapabilityStr == ECapabilityTrustedUIStr() )

		{

		aCapability = ECapabilityTrustedUI;

		}

	else if( aCapabilityStr == ECapabilityProtServStr() )

		{

		aCapability = ECapabilityProtServ;

		}

	else if( aCapabilityStr == ECapabilityDiskAdminStr() )

		{

		aCapability = ECapabilityDiskAdmin;

		}

	else if( aCapabilityStr == ECapabilityNetworkControlStr() )

		{

		aCapability = ECapabilityNetworkControl;

		}

	else if( aCapabilityStr == ECapabilityAllFilesStr() )

		{

		aCapability = ECapabilityAllFiles;

		}

	else if( aCapabilityStr == ECapabilitySwEventStr() )

		{

		aCapability = ECapabilitySwEvent;

		}

	else if( aCapabilityStr == ECapabilityNetworkServicesStr() )

		{

		aCapability = ECapabilityNetworkServices;

		}

	else if( aCapabilityStr == ECapabilityLocalServicesStr() )

		{

		aCapability = ECapabilityLocalServices;

		}

	else if( aCapabilityStr == ECapabilityReadUserDataStr() )

		{

		aCapability = ECapabilityReadUserData;

		}

	else if( aCapabilityStr == ECapabilityWriteUserDataStr() )

		{

		aCapability = ECapabilityWriteUserData;

		}

	else if( aCapabilityStr == ECapabilityLocationStr() )

		{

		aCapability = ECapabilityLocation;

		}

	else if( aCapabilityStr == ECapabilitySurroundingsDDStr() )

		{

		aCapability = ECapabilitySurroundingsDD;

		}

	else if( aCapabilityStr == ECapabilityUserEnvironmentStr() )

		{

		aCapability = ECapabilityUserEnvironment;

		}

	else if( aCapabilityStr == ECapability_LimitStr() )

		{

		aCapability = ECapability_Limit;

		}

	else if( aCapabilityStr == ECapability_HardLimitStr() )

		{

		aCapability = ECapability_HardLimit;

		}

	else if( aCapabilityStr == ECapability_NoneStr() )

		{

		aCapability = ECapability_None;

		}

	else if( aCapabilityStr == ECapability_DeniedStr() )

		{

		aCapability = ECapability_Denied;

		}

	else

		{

		found = EFalse;

		}

	return found;

	}

TBool CT_DataCommsBase::SubConnectionType( const TDesC& aSubConnTypeStr, RSubConnection::TSubConnType& aSubConnType)

	{

	TBool found = ETrue;

	if( aSubConnTypeStr == KCreateNew() )

		{

		aSubConnType = RSubConnection::ECreateNew;

		}

	else if( aSubConnTypeStr == KAttachToDefault() )

		{

		aSubConnType = RSubConnection::EAttachToDefault;

		}

	else

		{

		found = EFalse;

		}

	return found;

	}

TBool CT_DataCommsBase::GetEventGroupUid(const TDesC& aEventGroupUidStr, TInt32& aEventGroupUid)

	{

	TBool found = ETrue;

	if (aEventGroupUidStr == KSubConnGenericEventsImplUidStr())

		{

		aEventGroupUid = KSubConnGenericEventsImplUid;

		}

	else

		{

		found = EFalse;

		}

	return found;

	}

TBool CT_DataCommsBase::GetEventMaskBits(const TDesC& aConstantName, TUint32& aEventMask)

	{

	TBool	ret = ETrue;

	if (aConstantName == KSubConGenericEventParamsGrantedStr())

		{

		aEventMask=KSubConGenericEventParamsGranted;

		}

	else if (aConstantName == KSubConGenericEventDataClientJoinedStr())

		{

		aEventMask=KSubConGenericEventDataClientJoined;

		}

	else if (aConstantName == KSubConGenericEventDataClientLeftStr())

		{

		aEventMask=KSubConGenericEventDataClientLeft;

		}

	else if (aConstantName == KSubConGenericEventSubConDownStr())

		{

		aEventMask=KSubConGenericEventSubConDown;

		}

	else if (aConstantName == KSubConGenericEventParamsChangedStr())

		{

		aEventMask=KSubConGenericEventParamsChanged;

		}

	else if (aConstantName == KSubConGenericEventParamsRejectedStr())

		{

		aEventMask=KSubConGenericEventParamsRejected;

		}

	else

		{

		TInt	location=aConstantName.Match(_L("*|*"));

		if( location!=KErrNotFound )

			{

			//Converting Left part of the data

			TPtrC	tempStr=aConstantName.Left(location);

			ret=GetEventMaskBits(tempStr, aEventMask);

			//Converting right data can be with another "|"

			tempStr.Set(aConstantName.Mid(location+1));

			TUint32	tmp;

			if ( GetEventMaskBits(tempStr, tmp) )

				{

				aEventMask |= tmp;

				}

			else

				{

				ret = EFalse;

				}