// Copyright (c) 2007-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:
// User Prompt Service (UPS) support.
// 
//

#define SYMBIAN_NETWORKING_UPS

#ifdef SYMBIAN_NETWORKING_UPS

#include "netmcprups.h"
#include "netmcpractivities.h"		// for NetMCprActivities::netMCprActivities
#include <comms-infras/ss_log.h>
#include <comms-infras/netups.h>
#include <comms-infras/netupsserviceid.h>

#ifdef __CFLOG_ACTIVE
#define KNetMCprTag KESockMetaConnectionTag
_LIT8(KNetMCprSubTag, "netmcpr");
#endif

using namespace ESock;

CUpsNetworkMetaConnectionProvider::CUpsNetworkMetaConnectionProvider(CMetaConnectionProviderFactoryBase& aFactory, const TProviderInfo& aProviderInfo, const MeshMachine::TNodeActivityMap& aActivityMap)
:	CNetworkMetaConnectionProvider(aFactory,aProviderInfo,aActivityMap)
	{
//	LOG_NODE_CREATE(KNetMCprTag, CNetworkMetaConnectionProvider);
	}

CUpsNetworkMetaConnectionProvider* CUpsNetworkMetaConnectionProvider::NewL(CMetaConnectionProviderFactoryBase& aFactory, const TProviderInfo& aProviderInfo)
	{
	__CFLOG_VAR((KNetMCprTag, KNetMCprSubTag, _L8("CUpsNetworkMetaConnectionProvider:\tNewL()")));

	CUpsNetworkMetaConnectionProvider* self = new (ELeave) CUpsNetworkMetaConnectionProvider(aFactory,aProviderInfo,NetMCprActivities::netMCprActivities::Self());
	CleanupStack::PushL(self);
	self->ConstructL();
	CleanupStack::Pop(self);
	return self;
	}

CUpsNetworkMetaConnectionProvider::~CUpsNetworkMetaConnectionProvider()
	{
	FreeApName();
	CloseNetUps();
	
	iUpsClientHandleRefCount.ResetAndDestroy();
	iUpsClientHandleRefCount.Close();
	}

void CUpsNetworkMetaConnectionProvider::ConstructL()
	{
	CNetworkMetaConnectionProvider::ConstructL();
	
	if (!NetUps::CNetUps::UpsDisabled(NetUps::EIpServiceId))
		{
		RMetaExtensionContainer mec;
		mec.Open(AccessPointConfig());
		CleanupClosePushL(mec);
		//
		// UPS is enabled - provision the UPS specific Access Point Config extension to the layer
		//
		CUPSAccessPointConfigExt* accessPointConfigExt = CUPSAccessPointConfigExt::NewL(ETSockAddress);
		CleanupStack::PushL(accessPointConfigExt);
		// set UPS specific ServiceId	
		accessPointConfigExt->SetServiceId(NetUps::EIpServiceId);
		mec.AppendExtensionL(accessPointConfigExt);
		CleanupStack::Pop(accessPointConfigExt);
		
		AccessPointConfig().Close();
		AccessPointConfig().Open(mec);
		CleanupStack::PopAndDestroy(&mec);
		}
	else
		{
		// UPS is disabled.
		SetUpsDisabled(ETrue);
		}
	} 

void CUpsNetworkMetaConnectionProvider::ShowAccessPointRecordL(CommsDat::CMDBSession* /*aSession*/, CommsDat::CCDAccessPointRecord* aApRec)
/**
Called from base class during reading of Access Point Record.

Store away the Access Point Name locally.
*/
	{
	SetApNameL(aApRec->iRecordName);
	}

void CUpsNetworkMetaConnectionProvider::CloseNetUps()
	{
	delete NetUps();
	SetNetUps(NULL);
	}

void  CUpsNetworkMetaConnectionProvider::AddUpsClientCommsIdL(const Messages::TNodeId& aCommsId)
	{
	TInt32 index = 0;
	TInt32 count = 0;	
	TBool found = FindUpsClientHandle(aCommsId, index, count);
	
	if (found == EFalse)
		{
		TUpsClientHandleRefCount* upsClientHandleRefCount = new (ELeave) TUpsClientHandleRefCount(aCommsId, 0);
		CleanupStack::PushL(upsClientHandleRefCount);
		iUpsClientHandleRefCount.AppendL(upsClientHandleRefCount);
		CleanupStack::Pop(upsClientHandleRefCount);
		}		
	}

TBool CUpsNetworkMetaConnectionProvider::FindUpsClientHandle(const Messages::TNodeId& aCommsId, TInt32& aIndex, TInt32& aCount)
	{
	TBool found = EFalse;
	for (TInt i = iUpsClientHandleRefCount.Count() - 1; i >=0; --i)
		{
		if (iUpsClientHandleRefCount[i]->iCommsId == aCommsId)
			{
			aIndex = i;
			aCount = iUpsClientHandleRefCount[i]->iCount;
			found = ETrue;
			break;
			}
		}
	return found;	
	}

void CUpsNetworkMetaConnectionProvider::IncrementUpsClientHandle(const Messages::TNodeId& aCommsId)
	{
	TInt32 index = 0;
	TInt32 count = 0;
	TBool found = FindUpsClientHandle(aCommsId, index, count);
		
	if (found == EFalse)
		{
		// TODO: ADD a panic code User::Panic(KNetMCprPanic, KPanicNoConnectionHandle);
		User::Panic(KNetMCprPanic, KPanicNoConnectionHandle);
		}
	else
		{
		++(iUpsClientHandleRefCount[index]->iCount);
		}				
	}

void CUpsNetworkMetaConnectionProvider::DecrementUpsClientHandle(const Messages::TNodeId& aCommsId, TBool& aAllHandlesDeleted)
	{
	TInt32 index = 0;
	TInt32 count = 0;	
	TBool found = FindUpsClientHandle(aCommsId, index, count);
	
	if (found == EFalse)
		{		
		User::Panic(KNetMCprPanic, KPanicNoConnectionHandle);
		}
	else
		{
		iUpsClientHandleRefCount[index]->iCount--;
		if (iUpsClientHandleRefCount[index]->iCount == 0)
			{
			delete iUpsClientHandleRefCount[index];
			iUpsClientHandleRefCount.Remove(index);
			}
		}
	aAllHandlesDeleted = (iUpsClientHandleRefCount.Count() == 0) ? ETrue : EFalse;
	}

#endif //SYMBIAN_NETWORKING_UPS