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

// This is part of an ECOM plug-in

// 

//

#include "IPProtoTierManagerSelector.h"

#include "IPProtoTierManagerFactory.h"

#include "IPProtoMCpr.h"

#include <comms-infras/ss_log.h>

#include <ss_glob.h>

#include <comms-infras/ss_tiermanagerutils.h>

#include <commsdattypesv1_1.h> // CommsDat

#include <es_connpref.h>	//TConnIdList

#include <commdbconnpref.h>	//TCommDbConnPref & TCommDbConnPrefMulti

#include <comms-infras/esock_params_internal.h>  //TConnCSRParams

#include <comms-infras/ss_mcprnodemessages.h> //RConnPrefList and Iterator

#include <comms-infras/esock_params.h>

#include <comms-infras/ss_metaconnprov_internal.h>

#include <comms-infras/simpleselectorbase.h>

#include <commsdattypesv1_1_partner.h>

#ifdef _DEBUG

#define KIpProtoTierMgrTag KESockMetaConnectionTag

_LIT8(KIpProtoTierMgrSubTag, "ipprototiermgr");

#endif

using namespace ESock;

using namespace CommsDat;

const TInt KCommsdatLinkFlag    =  0x80000000;

//Panic codes

_LIT(KIpProtoSelectorPanic, "IpProtoSelector");

enum TIpProtoSelectorPanic

	{

	EExpectedAccessPointAwareSystem = 0,

	EUnExpectedSelectionPreferences = 1,

	EUnExpectedNumberOfAccessPoints = 2

    };

TUint FindIPProtoAccessPointForIAPL(TUint aIap, CMDBSession* aDbs)

	{

	CCDAccessPointRecord* apRec = static_cast<CCDAccessPointRecord*>(CCDTierRecord::RecordFactoryL(KCDTIdAccessPointRecord));

	CleanupStack::PushL(apRec);

	apRec->iCprConfig = aIap;

	apRec->iTier = CIPProtoTierManagerFactory::iUid | KCommsdatLinkFlag;

	TUint ap = 0;

	TBool found = apRec->FindL(*aDbs);

	if (found)

		{

		ap = apRec->iRecordTag;

		}

	else

		{

		ap = TierManagerUtils::ReadDefaultAccessPointL(TUid::Uid(CIPProtoTierManagerFactory::iUid), *aDbs);

		}

	CleanupStack::PopAndDestroy(apRec);

	return ap;

	}

CMetaConnectionProviderBase* AIpProtoSelectorBase::FindOrCreateProviderL(TUint aIapToFind, TUint aAccessPointToCreate)

	{

	//Find factory

	TUid mCprUid = TierManagerUtils::ReadMCprUidL(aAccessPointToCreate,*iDbs);

	CMetaConnectionProviderFactoryBase* factory = static_cast<CMetaConnectionProviderFactoryBase*>(iMetaContainer.FindOrCreateFactoryL(mCprUid));

	//Create the provider

	TUid tierId = TUid::Uid(iTierRecord->iRecordTag);

	TUid tierImplUid = TUid::Uid(iTierRecord->iTierImplUid);

	TProviderInfo providerInfo(tierId,aIapToFind);

	TMetaConnectionFactoryQuery query(providerInfo,tierImplUid);

	CMetaConnectionProviderBase* provider = static_cast<CMetaConnectionProviderBase*>(factory->Find(query));

	if (provider==NULL)

		{

		//If this is an attach selection, the provider must be found, so leave with an error

		if (iSelectionPrefs.Scope()&TSelectionPrefs::ESelectFromExisting)

	    	{

			//For legacy reasons only, we need to return KErrCouldNotConnect instead of KErrNotFound

			//for leagcy attach (legacy attach uses EConnPrefCommDb).

			User::Leave(iSelectionPrefs.Prefs().ExtensionId() == TConnPref::EConnPrefCommDb ? KErrCouldNotConnect : KErrNotFound);

	       	}

       	//For construction of IpProto providers (construction only) we use the instance field of TProviderInfo

       	//to carry the IAP id. The IAP id is necessary fo the provider to initialise itself from the database.

       	TMetaConnectionFactoryQuery query(TProviderInfo(tierId,aAccessPointToCreate,(TAny*)aIapToFind),tierImplUid);

       	provider = static_cast<CMetaConnectionProviderBase*>(factory->CreateObjectL(query));

   		}

	if (!(iSelectionPrefs.Scope()&TSelectionPrefs::ESelectFromExisting))

		{

		CIPProtoMetaConnectionProvider *ipprotomcpr = static_cast<CIPProtoMetaConnectionProvider *>(provider);

		TSecureId sid;

		ASubSessionPlatsecApiExt platsecext(iSelectionPrefs.SubSessionUniqueId());

		if (platsecext.SecureId(sid) == KErrNone)

			{

			}

		}

	provider->IncrementBlockingDestroy();

	return provider;

	}

//

//CIpProtoProviderSelector

void CIpProtoProviderSelector::RunL()

	// The dialogue has been presented.

	// Normally completes with KErrNone or KErrCancel

	// Could, however, complete with another system error e.g. KErrOutOfMemory

	{

	TInt error = iStatus.Int();

	__CFLOG_VAR((KIpProtoTierMgrTag, KIpProtoTierMgrSubTag, _L8("CIpProtoProviderSelector %08x::\tRunL() Err%d Ap%d"),this, error, SelectedIAP()));

    User::LeaveIfError(error);

    ASSERT(SelectedIAP()); //Should not be 0 now.

    TConnPref& pref = iSelectionPrefs.Prefs();

    const TConnIdList& list = static_cast<const TConnIdList&>(pref);

    TUint accessPoint = list.Get(0);

    //finish the selection which the prompt was for

    CMetaConnectionProviderBase* ipprotoMCPr = FindOrCreateProviderL(SelectedIAP(), FindIPProtoAccessPointForIAPL(SelectedIAP(), iDbs));

    TLayerSelectionInfo* selectionInfo = const_cast<TLayerSelectionInfo*>(

            static_cast<const TLayerSelectionInfo*>(ipprotoMCPr->AccessPointConfig().FindExtension(

            		STypeId::CreateSTypeId(TLayerSelectionInfo::EUid, TLayerSelectionInfo::ETypeId))));

    __ASSERT_ALWAYS(selectionInfo, User::Panic(_L("ipproto"), CorePanics::KPanicUnexpectedExecutionPath));

    if ((TUint)-1 == selectionInfo->CustomSelectionPolicy())

    	{

    	/*

		 * This means that the default IPProto AP is used from the meshpreface.cfg file,

		 * which has a -1 as the CustomSelectionPolicy (the reason for that is that we don't know

		 * which will be the default IAP, default Link level AP, so that's why we prompted for that).

		 * This is the place and time we know how to overwrite the AccessPoint information of the MCPr

		 * meaning we know the selected IAP. So the -1 value can be overwritten with the selected recordID,

		 * or tagID of the Link level AP.

		 */

		selectionInfo->iCustomSelectionPolicy = SelectedIAP();

    	selectionInfo->iCprConfig = SelectedIAP();

    	}

    iSelectionNotify.SelectComplete(this,ipprotoMCPr);

	//iSelectionNotify.SelectComplete(this,FindOrCreateProviderL(SelectedIAP(), FindIPProtoAccessPointForIAPL(SelectedIAP(), iDbs)));

    //store the information that we have already prompted the user

    TPromptingSelectionPrefsExt* promptingExt = const_cast<TPromptingSelectionPrefsExt*>(

            static_cast<const TPromptingSelectionPrefsExt*>(iNetworkMCpr->AccessPointConfig().FindExtension(

                    TPromptingSelectionPrefsExt::TypeId())));

	if (promptingExt == NULL)

		{

		/*

		 * the extension is not existing yet on the AccessPointConfig of the NetMCPr. Append a new one

		 * to indicate that we have already prompted the user. So if the configuration contains 2

		 * ConnectionPreferences record without any default IAP and with PROPTING dialog preference then

		 * the prompt dialog won't be invoked in the 2nd time but only during the re-selection, if it's needed.

		 */

	    RMetaExtensionContainer mec;

	    mec.Open(iNetworkMCpr->AccessPointConfig());

	    CleanupClosePushL(mec);

	    TConnIdList dummyList;

		TPromptingSelectionPrefsExt* ext = new (ELeave) TPromptingSelectionPrefsExt(TUid::Uid(iTierRecord->iRecordTag),dummyList); //it's an empty list

		CleanupStack::PushL(ext);

		mec.AppendExtensionL(ext);

        CleanupStack::Pop(ext);

		iNetworkMCpr->AccessPointConfig().Close();

		iNetworkMCpr->AccessPointConfig().Open(mec);

		CleanupStack::PopAndDestroy(&mec);

		}

	else if (!promptingExt->iPromptingInProgress)

	    {

	    promptingExt->iPromptingInProgress = ETrue;

	    }

	else

		{

		/* the extension is existing already on the AccessPointConfig of the NetMCPr.

		 * This means that this is was the 2nd time we have prompted. Mark the extension

		 * to indicate that we don't have any more choices...

		 */

		promptingExt->iPromptingInProgress = EFalse;

		}

	//Complete the selection request

	iSelectionNotify.SelectComplete(this,NULL);

	}

TInt CIpProtoProviderSelector::RunError(TInt aError)

	{

	iSelectionNotify.Error(this,aError);

	return KErrNone;

	}

void CIpProtoProviderSelector::InvokeDialogL(ISelectionNotify& aSelectionNotify,

		                                     TUint aCprConfig)

	{

	TConnectionPrefs prefsForPromt;

	TierManagerUtils::GetPrefsFromConnPrefRecL(aCprConfig, *iDbs, prefsForPromt);

	PromptUserL(aSelectionNotify, prefsForPromt);

	}

void CIpProtoProviderSelector::SelectL(ISelectionNotify& aSelectionNotify)

	{

	ASSERT(iDbs);

	ASSERT(iTierRecord);

	TUint32 defaultAccessPoint = iTierRecord->iDefaultAccessPoint;

	//Must be set

	__ASSERT_DEBUG(defaultAccessPoint!=0,User::Panic(KIpProtoSelectorPanic,EExpectedAccessPointAwareSystem));

	User::LeaveIfError(defaultAccessPoint!=0? KErrNone : KErrCorrupt);

	TConnPref& pref = iSelectionPrefs.Prefs();

	//This selector receives only EConnPrefIdList at this layer

	__ASSERT_DEBUG(pref.ExtensionId() == TConnPref::EConnPrefIdList, User::Panic(KIpProtoSelectorPanic,EUnExpectedSelectionPreferences));

	__CFLOG_VAR((KIpProtoTierMgrTag, KIpProtoTierMgrSubTag, _L8("CIpProtoProviderSelector %08x::\tSelectL() Using TConnIdList"),this));

	const TConnIdList& list = static_cast<const TConnIdList&>(pref);

	TUint apElemId = 0;

	TUint cprConfig = 0;

	TUint custSelPol = 0;

	TInt count = list.Count();

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

		{

		TUint accessPoint = list.Get(i);

		cprConfig  = TierManagerUtils::ReadCprConfigL(accessPoint, *iDbs);

		custSelPol = TierManagerUtils::ReadCustomSelectionPolicyIdL(accessPoint, *iDbs);

		if ( (KCDTIdConnectionPrefsRecord == (KCDMaskShowRecordType & cprConfig)) ||

			 ((TUint)-1 == custSelPol) )

			{

			/* 1.)

			 * There is a full TMDBelementID in the cprConfig field of the given AP. 

			 * This means that the related ConnPref record is a prompting record so

			 * this AP is a so-called 'prompring AP. Invoke a dialog prompt.

			 * 

			 * 2.)

			 * The default IPProto AP is used form the meshpreface.cfg file, where

			 * there isn't any connectionPrefs record in the database. We should invoke

			 * a dialog in this case too to get back the tagID of the Linke level AP, which

			 * is the same as recordID of the used IAP.

			 * 

			 */

		    TPromptingSelectionPrefsExt* promptingExt = const_cast<TPromptingSelectionPrefsExt*>(

		            static_cast<const TPromptingSelectionPrefsExt*>(iNetworkMCpr->AccessPointConfig().FindExtension(

		                    TPromptingSelectionPrefsExt::TypeId())));

		    if (promptingExt)

				{

				/* our NetMCPr has a prompting extension already. This can mean 2 things:

				 * 1.) We are still in the selection process and we have 2 prompting APs on

				 * 	   the IPProto level. In this case now (2nd time) don't invoke any further

				 *     dialog but store the information in the NetMCPr that we have still 1

				 *     possibility for the re-selection scenario.

				 * 2.) This is the re-selection scenario, so we have to invoke the prompt

				 *     dialog.

				 */

				if (!iReselection)

					{

					//the 1.) paragraph is true

					TConnIdList list;

					list.Append(accessPoint);

					promptingExt->iPrefs = list;

					promptingExt->iTierId = TUid::Uid(iTierRecord->iRecordTag);

					promptingExt->iPromptingInProgress = ETrue;

					}

				else

					{

					//the 2.) paragraph is true

					//invoke a dialog

					InvokeDialogL(aSelectionNotify, cprConfig);

					return; //selection will continue in the RunL

					}

				}

			else

				{

				//invoke a dialog

				InvokeDialogL(aSelectionNotify, cprConfig);

				return; //selection will continue in the RunL

				}

			}

		else

			{

			/*

			 * business as usual

			 */

			TPromptingSelectionPrefsExt* promptingExt = const_cast<TPromptingSelectionPrefsExt*>(

                static_cast<const TPromptingSelectionPrefsExt*>(iNetworkMCpr->AccessPointConfig().FindExtension(

                    TPromptingSelectionPrefsExt::TypeId())));

    		if (promptingExt != NULL)

				{

				/* There is a prompting extension in the AccessPointConfig of our

				 * Network MCPr. This means that there are 2 ConnPref records in the

				 * database. The first one is a prompting one (that's why the extension is there

				 * - to indicate that we have already prompted). But the 2nd record is

				 * not a prompting record, so the mapped IPProto AP is _NOT_ a prompting AP.

				 * Continue the selection as usual, and mark the extension - it's not

				 * needed anymore because if there will be a re-selection we can't use

				 * the extension as the 2nd IPProto AP is not a promting one.

				 */

				promptingExt->iPromptingInProgress = EFalse;

				}

			//apElemId = TierManagerUtils::ReadCustomSelectionPolicyIdL(accessPoint,*iDbs);

			apElemId = TierManagerUtils::ReadCprConfigL(accessPoint,*iDbs);

			aSelectionNotify.SelectComplete(this,FindOrCreateProviderL(apElemId,accessPoint));

			}

		} //for

	//Complete the selection request

	aSelectionNotify.SelectComplete(this,NULL);

	}

//

//CIpProtoProviderSelectorConnPrefList

CIpProtoProviderSelectorConnPrefList::CIpProtoProviderSelectorConnPrefList(const ESock::RConnPrefList& aSelectionPreferences)

	:	AIpProtoSelectorBase()

	,	iSelectionPrefList(aSelectionPreferences)

	,	iTierId(TUid::Uid(CIPProtoTierManagerFactory::iUid))

	,	iLastAccessPoint(0)

		{

		}

void CIpProtoProviderSelectorConnPrefList::RunL()

	// The dialogue has been presented.

	// Normally completes with KErrNone or KErrCancel

	// Could, however, complete with another system error e.g. KErrOutOfMemory

	{

	TInt error = iStatus.Int();

	__CFLOG_VAR((KIpProtoTierMgrTag, KIpProtoTierMgrSubTag, _L8("CIpProtoProviderSelector %08x::\tRunL() Err%d Ap%d"),this, error, SelectedIAP()));

    User::LeaveIfError(error);

    ASSERT(SelectedIAP()); //Should not be 0 now.

    //finish the selection which the prompt was for

	iSelectionNotify.SelectComplete(this,FindOrCreateProviderL(SelectedIAP(), iLastAccessPoint));

    //--------------------------------------------------

    //continue the loop which we started in the SelectL

    //--------------------------------------------------

    ESock::RConnPrefList::TIter<TConnAPPref> iterAP = iSelectionPrefList.getIter<TConnAPPref>();

	CCDAccessPointRecord* apRec;

	TUid tierId;

	TInt cprConfig = 0;

//This iterator runs through all the instances of TConnAPPref

	while(!iterAP.IsEnd())

		{

		//Access point is retrived from preference

		TUint accessPoint = iterAP->GetAP();

		//The record relating to this access point is retrived

		apRec = TierManagerUtils::LoadAccessPointRecordL(accessPoint,*iDbs);

		//A check is done to confirm the access point is related to this tier

		//tierId = TUid::Uid(apRec->iTier);

		tierId = TierManagerUtils::MapElementIdToTagId(apRec->iTier, *iDbs);

		delete apRec;

		if(iTierId == tierId)

			{

			//The iap related to the access point is retrived from the record

			//This iap must be created at the link layer, within the method

			//FindOrCreateProviderL the provider created is provisioned with this

			//iap, this means when the next tier is created the appropriate iap will

			//be created

			cprConfig =  TierManagerUtils::ReadCprConfigL(accessPoint,*iDbs);

			if (KCDTIdConnectionPrefsRecord == (KCDMaskShowRecordType & cprConfig))

				{

				/* There is a full TMDBelementID in the cprConfig field of the given AP.

				 * This means that the related ConnPref record is a prompting record so

				 * this AP is a so-called 'prompring AP. As we are in the RunL method

				 * this means that we've invoked already a dilog prompt so here we cannot

				 * invoke another one. Instead store the information that we have still

				 * possibilies in the case of a reconnection.

				 */

				TConnIdList list;

				list.Append(accessPoint);

				RMetaExtensionContainer mec;

				mec.Open(iNetworkMCpr->AccessPointConfig());

				CleanupClosePushL(mec);

				TPromptingSelectionPrefsExt* ext = new (ELeave) TPromptingSelectionPrefsExt(TUid::Uid(iTierRecord->iRecordTag),list); //it's an empty list

				CleanupStack::PushL(ext);

				mec.AppendExtensionL(ext);

				CleanupStack::Pop(ext);

				iNetworkMCpr->AccessPointConfig().Close();

				iNetworkMCpr->AccessPointConfig().Open(mec);

				CleanupStack::PopAndDestroy(&mec);

				}

			else

				{

				iSelectionNotify.SelectComplete(this,FindOrCreateProviderL(cprConfig, accessPoint));

				}

			//The peference is no longer needed so is deleted and removed

			delete iterAP.Remove();

			}

		else

			{

			iterAP++;

			}

		}

	iSelectionNotify.SelectComplete(this,NULL);

	}

TInt CIpProtoProviderSelectorConnPrefList::RunError(TInt aError)

	{

	iSelectionNotify.Error(this,aError);

	return KErrNone;

	}

void CIpProtoProviderSelectorConnPrefList::SelectL(ISelectionNotify& aSelectionNotify)

	{

	iDbs = CMDBSession::NewL(KCDVersion1_2);

	iTierRecord = TierManagerUtils::LoadTierRecordL(iTierId,*iDbs);

	ASSERT(iTierRecord);

	CCDAccessPointRecord* apRec;

	TUid tierId;

	ESock::RConnPrefList::TIter<TConnCSRPref> iterCSR = iSelectionPrefList.getIter<TConnCSRPref>();

	ASSERT(iterCSR[0] != NULL || iterCSR[1] == NULL );

	iSelectionPrefs.SetScope(iterCSR[0]->Scope());

	iSelectionPrefs.SetFlags(iterCSR[0]->Flags());

	iSelectionPrefs.SetSubSessionUniqueId(iterCSR[0]->SubSessionUniqueId());

	TInt cprConfig = 0;

	ESock::RConnPrefList::TIter<TConnAPPref> iterAP = iSelectionPrefList.getIter<TConnAPPref>();

	//This iterator runs through all the instances of TConnAPPref

	while(!iterAP.IsEnd())

		{

		//Access point is retrived from preference

		TUint accessPoint = iterAP->GetAP();

		//The record relating to this access point is retrived

		apRec = TierManagerUtils::LoadAccessPointRecordL(accessPoint,*iDbs);

		//A check is done to confirm the access point is related to this tier

		//tierId = TUid::Uid(apRec->iTier);

		tierId = TierManagerUtils::MapElementIdToTagId(apRec->iTier, *iDbs);

		delete apRec;

		if(iTierId == tierId)

			{

			//The iap related to the access point is retrived from the record

			//This iap must be created at the link layer, within the method

			//FindOrCreateProviderL the provider created is provisioned with this

			//iap, this means when the next tier is created the appropriate iap will

			//be created

			cprConfig =  TierManagerUtils::ReadCprConfigL(accessPoint,*iDbs);

			if (KCDTIdConnectionPrefsRecord == (KCDMaskShowRecordType & cprConfig))

				{

				/* There is a full TMDBelementID in the cprConfig field of the given AP.

				 * This means that the related ConnPref record is a prompting record so

				 * this AP is a so-called 'prompring AP. Invoke a dialog prompt.

				 */

				//invoke a dialog

				TConnectionPrefs prefsForPromt;

				TierManagerUtils::GetPrefsFromConnPrefRecL(cprConfig, *iDbs, prefsForPromt);

				PromptUserL(aSelectionNotify, prefsForPromt);

				/* Remove the last processed preference so the loop in the

				 * RunL can continue from the beginning of the list

				 */

				delete iterAP.Remove();

				iLastAccessPoint = accessPoint;

				return; //selection will continue in the RunL

				}

			else

				{

				aSelectionNotify.SelectComplete(this,FindOrCreateProviderL(cprConfig, accessPoint));

				}

			//The peference is no longer needed so is deleted and removed

			delete iterAP.Remove();

			}

		else

			{

			iterAP++;

			}

		}

	aSelectionNotify.SelectComplete(this,NULL);

	}

//

//CLinkPrefsSelector