// 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:
// SHIMCPRFACTORY.H
// 
//

#include <ecom/ecom.h>
#include <implementationproxy.h>
#include "shimcprfactory.h"	// for CConnectionProviderFactoryShim

#include "connectionSelectorShim.h"
#include "shimcpr.h"
#include "shimnifmansconn.h"
#include "idquerynetmsg.h"
#include <nifman.h>
#ifdef SYMBIAN_NETWORKING_UMTSR5
#include <esockmessages.h>
#endif // #ifdef SYMBIAN_NETWORKING_UMTSR5	


const TUint KShimConnectionProviderImplementationUid = 0x102070FF;
/**
Data required for instantiating ECOM Plugin
*/
const TImplementationProxy ImplementationTable[] = 
	{
	IMPLEMENTATION_PROXY_ENTRY(KShimConnectionProviderImplementationUid, CConnectionProviderFactoryShim::NewL),
	};


/**
ECOM Implementation Factory
*/
EXPORT_C const TImplementationProxy* ImplementationGroupProxy(TInt& aTableCount)
    {
    aTableCount = sizeof(ImplementationTable) / sizeof(TImplementationProxy);

    return ImplementationTable;
    }

CConnectionProviderFactoryShim* CConnectionProviderFactoryShim::NewL(TAny* aConstructionParameters)
	{
	CConnectionProviderFactoryShim* ptr = new (ELeave) CConnectionProviderFactoryShim(KShimConnectionProviderFactoryId, *(reinterpret_cast<CConnectionFactoryContainer*>(aConstructionParameters)));
	CleanupStack::PushL(ptr);
	ptr->ConstructL();
	CleanupStack::Pop(ptr);
	return ptr;
	}
   
void CConnectionProviderFactoryShim::ConstructL()
	{//create a provider session for global tasks (enumerate connections/all interface notification....)
    iNifmanSession = Nif::NewConnectionL(this, 0);
    iNifmanSession->AllInterfaceNotificationL();
	}
// Destructor
CConnectionProviderFactoryShim::~CConnectionProviderFactoryShim()
	{
	delete iNifmanSession;
	}
   
// Constructor
CConnectionProviderFactoryShim::CConnectionProviderFactoryShim(TUint aFactoryId, CConnectionFactoryContainer& aParentContainer) :
	CConnectionProviderFactoryBase( aFactoryId, aParentContainer )
	{
	}

#ifdef SYMBIAN_NETWORKING_UMTSR5
// Sets the IAP lock status
void CConnectionProviderFactoryShim::SetIAPLockStatus(TBool aLockStatus, TInt aLockedIAP)
	{
	iIsIAPLocked = aLockStatus;
	iLockedIAP = aLockedIAP;
	}
// Gets the IAP lock status
void CConnectionProviderFactoryShim::GetIAPLockStatus(TBool &aLockStatus, TInt &aLockedIAP)
	{
	aLockStatus = iIsIAPLocked;
	aLockedIAP = iLockedIAP;
	}
	
#endif // #ifdef SYMBIAN_NETWORKING_UMTSR5	

CConnectionProviderBase* CConnectionProviderFactoryShim::DoCreateProviderL()
	{
#ifdef SYMBIAN_NETWORKING_UMTSR5	
	CConnectionProviderShim * shimProv = CConnectionProviderShim::NewL(*this);
	shimProv->SetFactoryIfactory(this);
	return shimProv;
#else
	return CConnectionProviderShim::NewL(*this);
#endif // #ifdef SYMBIAN_NETWORKING_UMTSR5		
	}
   
MProviderSelector* CConnectionProviderFactoryShim::DoSelectProvider( Meta::SMetaData& aPreferences, ISelectionNotify& aSelectionNotify, const RMessagePtr2* aMessage )
	{
	//create self-destructing object
	CConnectionSelectorShim* selector = new CConnectionSelectorShim(aSelectionNotify);
	if (!selector)
		{
		aSelectionNotify.SelectComplete(NULL,KErrNoMemory);
		aSelectionNotify.Detach();
		}
	else 
		{
		#ifdef SYMBIAN_NETWORKING_UMTSR5	
		selector->SetFactoryIface(this);	
		#endif
		if ( selector->Select(aPreferences, aMessage) != KErrNone )
			{
			selector = NULL;
			}	
		}
		
		
	return selector;
	}
   
MProviderSelector* CConnectionProviderFactoryShim::DoSelectNextLayerProvider( Meta::SMetaData& /*aPreferences*/, ISelectionNotify& /*aSelectionNotify*/, const RMessagePtr2* /*aMessage*/ )
	{	
	return NULL;
	}
	
void CConnectionProviderFactoryShim::DoEnumerateConnectionsL(RPointerArray<TConnectionInfo>& aConnectionInfoPtrArray)
	{
    iNifmanSession->EnumerateConnectionsL(aConnectionInfoPtrArray);
	}

//MConnectionNotify interface to catch the global events
void CConnectionProviderFactoryShim::SelectionComplete(TInt /*aError*/, const TDesC8& /*aSelectionInfo*/)
	{
	
	ASSERT(NULL);//it's never to happen
	}
	
void CConnectionProviderFactoryShim::ConnectionError(TInt /*aError*/)
	{
	ASSERT(NULL);//it's never to happen
	}
	
void CConnectionProviderFactoryShim::LinkLayerOpen(TInt /*aError*/)
	{
	ASSERT(NULL);//it's never to happen
	}
	
void CConnectionProviderFactoryShim::LinkLayerClosed(TInt /*aError*/)
	{
	ASSERT(NULL);//it's never to happen
	}
	
void CConnectionProviderFactoryShim::ProgressNotification(TInt /*aStage*/, TInt /*aError*/)
	{
	ASSERT(NULL);//it's never to happen
	}
	
void CConnectionProviderFactoryShim::ProgressNotification(TSubConnectionUniqueId /*aSubConnectionUniqueId*/, TInt /*aStage*/, TInt /*aError*/)
	{
	ASSERT(NULL);//it's never to happen
	}
	
void CConnectionProviderFactoryShim::ServiceChangeNotification(TUint32 /*aId*/, const TDesC& /*aType*/)
	{
	ASSERT(NULL);//it's never to happen
	}
	
void CConnectionProviderFactoryShim::InterfaceStateChangeNotification(TDesC8& aInfo)
	{
	TInt count = iConnectionFactoryNotify.Count();
	for (TInt n = 0; n < count; n++)
		{
		iConnectionFactoryNotify[n].InterfaceStateChange(aInfo);
		}
	}
	
void CConnectionProviderFactoryShim::NotifyDataSent(TSubConnectionUniqueId /*aSubConnectionUniqueId*/, TUint /*aUplinkVolume*/)
	{
	ASSERT(NULL);//it's never to happen
	}
	
void CConnectionProviderFactoryShim::NotifyDataReceived(TSubConnectionUniqueId /*aSubConnectionUniqueId*/, TUint /*aDownlinkVolume*/)
	{
	ASSERT(NULL);//it's never to happen
	}
	
void CConnectionProviderFactoryShim::SubConnectionEvent(const TSubConnectionEvent& /*aSubConnectionEvent*/)
	{
	ASSERT(NULL);//it's never to happen
	}
	

/**
Define the factory query to find out particular CSubConnectionLinkShimClient object based on CConnection address 
*/

class XShimFactoryQuery : public MCommsFactoryQuery
	{
	friend class CConnectionProviderFactoryShim;
	
public:
	explicit XShimFactoryQuery( NetMessages::CTypeIdQuery& aQuery ) :
		iQuery(aQuery),
		iClient(NULL)
		{
		}

protected:
	NetMessages::CTypeIdQuery& iQuery;
	CSubConnectionLinkShimClient* iClient;

public:
	virtual TMatchResult Match( TFactoryObjectInfo& aInfo );
	};

//This method is called for each instance of particular class being managed by CommsFactory framework
MCommsFactoryQuery::TMatchResult XShimFactoryQuery::Match( TFactoryObjectInfo& aInfo )
	{
	CConnectionProviderShim* connectionProvider = static_cast<CConnectionProviderShim*>(aInfo.iInfo.iFactoryObject);
	ASSERT(connectionProvider);
	//call the CNifManSubConnectionShim interface to do the job
	iClient = connectionProvider->QuerySubSessions(iQuery.iTypeId, reinterpret_cast<CConnection*> (iQuery.iHandle));
	
	return iClient ? MCommsFactoryQuery::EMatch : MCommsFactoryQuery::EContinue;
	}
	
/**	Handles incoming messages

@param aNetMessage Messsge reference
@return KErrNone|KErrNotFound|KErrNotSupported
@return if object found passes its pointer to the aNetMessasge object
*/
TInt CConnectionProviderFactoryShim::DoReceiveMessage( NetMessages::CMessage& aNetMessage )
{
STypeId tid = STypeId::CreateSTypeId(NetMessages::KInterfaceUid, NetMessages::ETypeIdQueryId);
NetMessages::CTypeIdQuery& query = static_cast<NetMessages::CTypeIdQuery&>(aNetMessage);
TInt ret = KErrNotSupported;
if (aNetMessage.GetTypeId() == tid && query.iUid == KShimCommsUid)
	{
	XShimFactoryQuery q(query);
	ret = FindObject(q) ? KErrNone : KErrNotFound;
	//carry the result back
	query.iHandle = (TInt)(static_cast<MShimControlClient*>(q.iClient));
	}
return ret;
}