// Copyright (c) 2006-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 "ss_apiext_register.h"
#include <ecom/ecom.h>
#include <comms-infras/ss_thread.h>
#include <ss_glob.h>
#include <comms-infras/ss_api_ext.h>


#ifdef _DEBUG
// Panic category for "absolutely impossible!" vanilla ASSERT()-type panics from this module
// (if it could happen through user error then you should give it an explicit, documented, category + code)
_LIT(KSpecAssert_ESockSSockspxtrg, "ESockSSockspxtrg");
#endif

using namespace ESock;
using namespace Messages;

TCommsApiExtTable::TCommsApiExtTable(TInt aExtensionId, const Meta::STypeId& aMsgImplTid)
:	iExtensionId(aExtensionId),
	iMsgImplTid(aMsgImplTid),
	iMsgPluginInfo(NULL)
	{
	}

//static
void TCommsApiExtTable::DeregisterInterfaceOnCleanup(TAny* aTid)
	{
	Meta::STypeId* tid = static_cast<Meta::STypeId*>(aTid);
	TlsGlobals::Get().DeregisterInterface(tid->iUid);
	}

void TCommsApiExtTable::AddClientL(TSubSessionUniqueId aClientId, CGlobals& aGlobals)
	{
	__ASSERT_DEBUG(iMsgImplTid.iUid.iUid!=0, User::Panic(KSpecAssert_ESockSSockspxtrg, 1));
	User::LeaveIfError(iClients.FindInOrder(aClientId)!=KErrNotFound? KErrAlreadyExists : KErrNone);

	//For the first client we need to register messages
	TBool isFirst = iClients.Count()==0;
	if (isFirst)
		{
		__ASSERT_DEBUG(iMsgPluginInfo==NULL, User::Panic(KSpecAssert_ESockSSockspxtrg, 2));
		iMsgPluginInfo = CExtItfMsgPluginInfo::NewInstanceL(iMsgImplTid);
		CleanupStack::PushL(iMsgPluginInfo);

		aGlobals.RegisterInterfaceL(iMsgImplTid.iUid, iMsgPluginInfo->ImplementationProxyTableSize(), iMsgPluginInfo->ImplementationProxy());
		CleanupStack::PushL(TCleanupItem(&TCommsApiExtTable::DeregisterInterfaceOnCleanup, (TAny*)&iMsgImplTid));
		}

	iClients.InsertInOrderL(aClientId);

	if (isFirst)
		{
		CleanupStack::Pop(); //DeregisterInterfaceOnCleanup
		CleanupStack::Pop(iMsgPluginInfo);
		}
	}

//If aClientId==0 we will remove all interfaces for all clients!
TBool TCommsApiExtTable::RemoveClient(TSubSessionUniqueId aClientId, CGlobals& aGlobals)
	{
	TInt index = KErrNotFound;
	if (aClientId!=0)
		{
		index = iClients.FindInOrder(aClientId);
		if(index!=KErrNotFound)
			{
			iClients.Remove(index);
			}
		}
	else
		{
		iClients.Reset();
		}

	//If no clients, deregister messages
	if (iClients.Count()==0)
		{
		iClients.Close();
		aGlobals.DeregisterInterface(iMsgImplTid.iUid);
		delete iMsgPluginInfo;
		iMsgPluginInfo = NULL;
		index = 0;
		}

	if (index != KErrNotFound && index < iClients.Count())
		{
		return iClients[index];
		}

	return EFalse;
	}


TCommsApiExtRegister::TCommsApiExtRegister(CGlobals& aGlobals)
:	iGlobals(aGlobals)
	{
	}

TCommsApiExtRegister::~TCommsApiExtRegister()
	{
	//We should not have anything to cleanup here, if we do, some interface hasn't been closed properly
	__ASSERT_DEBUG(iApiExtList.Count()==0, User::Panic(KSpecAssert_ESockSSockspxtrg, 3)); //Panic in debug
	for (TInt i = iApiExtList.Count() - 1; i >= 0; --i)
		{
		TCommsApiExtTable& ref = iApiExtList[i];
		if (!ref.RemoveClient(0, iGlobals))
			{
			iApiExtList.Remove(i);
			}
		}
	iApiExtList.Close();
	}

TInt TCommsApiExtRegister::FindApiExtClientsTable(TInt aExtItfId)
	{
	TCommsApiExtTable entry(aExtItfId, Meta::STypeId::CreateSTypeId());
	return iApiExtList.FindInUnsignedKeyOrder(entry);
	}

void TCommsApiExtRegister::RegisterInterfaceL(TInt aExtItfId, const Meta::STypeId& aMsgImplTid, TSubSessionUniqueId aClientId)
	{
	TInt index = FindApiExtClientsTable(aExtItfId);
	if (index!=KErrNotFound)
		{
		TCommsApiExtTable& ref = iApiExtList[index];
		ref.AddClientL(aClientId, iGlobals);
		}
	else
		{
		TCommsApiExtTable entry(aExtItfId, aMsgImplTid);
		entry.AddClientL(aClientId, iGlobals);
		if (iApiExtList.InsertInUnsignedKeyOrder(entry)!=KErrNone)
			{
			entry.RemoveClient(aClientId, iGlobals);
			}
		}
	}

TSubSessionUniqueId TCommsApiExtRegister::FirstClient(TInt aExtItfId)
	{
	TCommsApiExtTable entry(aExtItfId, Meta::STypeId::CreateSTypeId());
	TInt index = iApiExtList.FindInUnsignedKeyOrder(entry);
	TSubSessionUniqueId firstClient = 0;
	if (index!=KErrNotFound)
		{
		TCommsApiExtTable& ref = iApiExtList[index];
		__ASSERT_DEBUG(ref.iClients.Count(), User::Panic(KSpecAssert_ESockSSockspxtrg, 4)); //Would not be here otherwise
		firstClient = ref.iClients[0];
		}
	return firstClient;
	}

//If aClientId==0 we will deregister this itf for all all clients!
TSubSessionUniqueId TCommsApiExtRegister::DeRegisterInterface(TInt aExtItfId, TSubSessionUniqueId aClientId)
	{
	TCommsApiExtTable entry(aExtItfId, Meta::STypeId::CreateSTypeId());
	TInt index = iApiExtList.FindInUnsignedKeyOrder(entry);
	TSubSessionUniqueId nextClient = 0;
	if (index!=KErrNotFound)
		{
		TCommsApiExtTable& ref = iApiExtList[index];
		nextClient = ref.RemoveClient(aClientId, iGlobals);
		if (nextClient==0)
			{
			iApiExtList.Remove(index);
			}
		}
	return nextClient;
	}