// Copyright (c) 2008-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:

// @file

// @internalComponent

// System Includes

// 

//

#include<ss_glob.h>

#include <ecom/ecom.h>

#include <appprotintf/app_protintf_msgs.h>

#include <comms-infras/ss_nodemessages.h>

#include <comms-infras/ss_nodemessages_factory.h>

//Local Includes

#include "genericcontainer.h"

using namespace ESock;

using namespace Messages;

CAppProtIntfFactoryContainer* CAppProtIntfFactoryContainer::NewL ( )

	{

	CAppProtIntfFactoryContainer *factContainer = new ( ELeave ) CAppProtIntfFactoryContainer (  );

	CleanupStack::PushL(factContainer);

	factContainer->ConstructL();

	CleanupStack::Pop(factContainer);

	return factContainer;

	}

CAppProtIntfFactoryContainer::CAppProtIntfFactoryContainer ( )

	{

	}

void CAppProtIntfFactoryContainer::ConstructL()

	{

	TUid destroyUid;

	if(!iAppProtIntfFactory)

		{

		iAppProtIntfFactory = reinterpret_cast<CFactory*>( REComSession::CreateImplementationL(TUid::Uid( KAppProtIntfFactoryUid ), destroyUid ));

		iAppProtIntfFactory->iDestroyUid = destroyUid;	

		}

	}

void CAppProtIntfFactoryContainer::ReceivedL ( const TRuntimeCtxId& aSender, const TNodeId& /*aRecipient*/, TSignatureBase& aMessage )

	{

	CFactoryObject* myFactoryObject = NULL;	

	const TCFFactory::TFindOrCreatePeer& msg = message_cast<const TCFFactory::TFindOrCreatePeer> ( aMessage );

	if ( iAppProtIntfFactory )

		{

		myFactoryObject = iAppProtIntfFactory->FindOrCreateFactoryObjectL ( *(msg.iQuery) );

		}

	RClientInterface::OpenPostMessageClose ( NodeId (), aSender, TCFFactory::TPeerFoundOrCreated ( myFactoryObject->Id () ).CRef() ); 

	}

CFactory::CFactory()

	{

	}

CFactory::~CFactory ()

	{

	if (iDestroyUid.iUid)

		{

		REComSession::DestroyedImplementation(iDestroyUid);

		}

	iObjectsList.ResetAndDestroy();

	}

CFactoryObject* CFactory::FindFactoryObject ( Factories::MFactoryQuery& aFactoryQuery )

	{

	const TAppProtIntfQuery& query = static_cast < const TAppProtIntfQuery& > ( aFactoryQuery );

	TInt count = iObjectsList.Count();

	CFactoryObject* obj = NULL;

	for ( TInt ind = 0; ind < count; ind++ )

		{

		if (iObjectsList[ind]->ProtocolType() == query.iProtocol )

    		obj = iObjectsList[ind];

		}

	return obj;

	}

CFactoryObject* CFactory::FindOrCreateFactoryObjectL ( Factories::MFactoryQuery& aFactoryQuery )

	{

	CFactoryObject* myFactoryObj = FindFactoryObject ( aFactoryQuery );

	return myFactoryObj ? myFactoryObj : CreateFactoryObjectL ( aFactoryQuery );

	}

CFactoryObject* CFactory::CreateFactoryObjectL ( Factories::MFactoryQuery& aFactoryQuery )

	{

	CFactoryObject* myFactoryObj = DoCreateFactoryObjectL ( aFactoryQuery );	

	CleanupStack::PushL ( myFactoryObj );

	iObjectsList.Append(myFactoryObj);

	CleanupStack::Pop ( myFactoryObj );

	return myFactoryObj;	

	}

CFactoryObject::CFactoryObject( TInt aProtocolType) : iProtocolFlag(aProtocolType)

	{

	}

TInt CFactoryObject::ProtocolType()

	{

	return iProtocolFlag;

	}

CFactoryObject::~CFactoryObject()

	{

	}