// 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:

// IPProto Connection Provider factory class definition.

// 

//

/**

 @file

 @internalComponent

*/

#include "ItfInfoConfigExt.h"

#include "IPProtoCPRFactory.h"

#include "IPProtoCPR.h"

#include <in_sock.h>

#include <elements/nm_interfaces.h>

#include <comms-infras/ss_legacyinterfaces.h>

#include <comms-infras/ss_msgintercept.h>

using namespace Messages;

using namespace ESock;

using namespace Factories;

//-=========================================================

//

// CIPProtoConnectionProviderFactory methods

//

//-=========================================================

CIPProtoConnectionProviderFactory* CIPProtoConnectionProviderFactory::NewL(TAny* aParentContainer)

    {

    return new (ELeave) CIPProtoConnectionProviderFactory(TUid::Uid(CIPProtoConnectionProviderFactory::iUid), *reinterpret_cast<ESock::CConnectionFactoryContainer*>(aParentContainer));

    }

CIPProtoConnectionProviderFactory::CIPProtoConnectionProviderFactory(TUid aFactoryId, ESock::CConnectionFactoryContainer& aParentContainer)

:	ESock::CConnectionProviderFactoryBase(aFactoryId, aParentContainer),

	TIfStaticFetcherNearestInHierarchy(this)

    {

    }

class TEnumerateConnectionsQuery : public MFactoryQuery

	{

public:

    TEnumerateConnectionsQuery(RPointerArray<TSourcedConnectionInfo>& aConnectionInfoPtrArray)

    :iConnectionInfoPtrArray(aConnectionInfoPtrArray)

    {}

	virtual TMatchResult Match(TFactoryObjectInfo& aObjectInfo);

	inline TInt Error() {return iError;}

private:

    RPointerArray<TSourcedConnectionInfo>& iConnectionInfoPtrArray;

    TInt iError;

	};

MFactoryQuery::TMatchResult TEnumerateConnectionsQuery::Match(TFactoryObjectInfo& aObjectInfo)

    {

    //This is a legacy feature

	CIPProtoConnectionProvider* prov = static_cast<CIPProtoConnectionProvider*>(aObjectInfo.iInfo.iFactoryObject);

	iError = KErrNone;

	if (prov)

    	{

        RNodeInterface* dc = prov->GetFirstClient<TDefaultClientMatchPolicy>(TClientType(TCFClientType::EData, TCFClientType::EDefault));

    	if (dc && /*dc->Flags() & RNodeInterface::EStarted &&*/

    	        !(dc->Flags() & TClientType::ELeaving))

    		{

    		const TItfInfoConfigExt* ext = static_cast<const TItfInfoConfigExt*>(prov->AccessPointConfig().FindExtension(STypeId::CreateSTypeId(KIpProtoConfigExtUid, EItfInfoConfigExt)));

    		ASSERT(ext);

            if (ext)

                {

                TSourcedConnectionInfo* copy;

                copy = new ESock::TSourcedConnectionInfo(ext->iConnectionInfo.iIapId, ext->iConnectionInfo.iNetId, EConnectionGeneric, prov->Id());

                if(copy == NULL)

                	{

                	iError = KErrNoMemory;

                	return MFactoryQuery::ECancel;

                	}

                TInt err = iConnectionInfoPtrArray.Append(copy);

				if(err != KErrNone)

					{

					delete copy;

                	iError = err;

                	return MFactoryQuery::ECancel;

					}

                }

	        }

    	}

	return MFactoryQuery::EContinue;

    }

void CIPProtoConnectionProviderFactory::EnumerateConnectionsL(RPointerArray<ESock::TSourcedConnectionInfo>& aConnectionInfoPtrArray)

    {

    TEnumerateConnectionsQuery query(aConnectionInfoPtrArray);

    Find(query);

	User::LeaveIfError(query.Error());

    }

void CIPProtoConnectionProviderFactory::ReturnInterfacePtrL(ESock::MLinkCprFactApiExt*& aInterface)

    {

    aInterface = this;

    }

NetInterfaces::TInterfaceControl* CIPProtoConnectionProviderFactory::DoFetchInterfaceControlL(TSupportedCommsApiExt aInterfaceId)

    {

    ASSERT(aInterfaceId == ESock::MLinkCprFactApiExt::KInterfaceId);

    (void)aInterfaceId;

    return this;

    }

ESock::ACommsFactoryNodeId* CIPProtoConnectionProviderFactory::DoCreateObjectL(ESock::TFactoryQueryBase& /* aQuery */)

    {

	CConnectionProviderBase* provider = CIPProtoConnectionProvider::NewL(*this);

	ESOCK_DEBUG_REGISTER_GENERAL_NODE(iUid, provider);

	return provider;

    }