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

 @internalTechnology

 @prototype

*/

#include <comms-infras/ss_log.h>

#include <ss_glob.h>

#include <commsdattypesv1_1.h>

#include <metadatabase.h>

#include "tunnelagentcpr.h"

#include "tunnelagentcprstates.h"

#include "agentmessages.h"

#include <comms-infras/ss_tiermanagerutils.h>

#include <comms-infras/ss_connprov.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_NifManAgtPrCtnlg, "NifManAgtPrCtnlg");

#endif

//#ifdef __CFLOG_ACTIVE

//#define KTunnelAgentCprTag KESockConnectionTag

//_LIT8(KTunnelAgentCprSubTag, "tunnelagentcprstates");

//#endif

_LIT (KTunnelAgentCPRPanic,"TunnelAgentCPRPanic");

using namespace TunnelAgentCprStates;

using namespace ESock;

using namespace Messages;

EXPORT_DEFINE_SMELEMENT(TJoinRealIAP, NetStateMachine::MStateTransition, TunnelAgentCprStates::TContext)

EXPORT_C void TJoinRealIAP::DoL()

	{

    //__CFLOG_VAR((KTunnelAgentCprTag, KTunnelAgentCprSubTag, _L8("TBindToRealIAP::DoL()")));

    __ASSERT_DEBUG(iContext.iNodeActivity, User::Panic(KSpecAssert_NifManAgtPrCtnlg, 1));

	// 1) Get the realIAPId

	TUint32 realIapId, myIapId,snaprecid,snapid=0;

	MQueryConnSettingsApiExt* queryItf;

	iContext.Node().ReturnInterfacePtrL(queryItf);

	CommsDat::TMDBElementId elementId = (KCDTIdRealIAP);

	TInt err = queryItf->GetInt(elementId, realIapId, NULL);

	if (err == KErrNotFound) 

	        realIapId = 0;

        CommsDat::TMDBElementId elementId2 = (KCDTIdVPNSNAPRecord);

	TInt err2 = queryItf->GetInt(elementId2, snaprecid,NULL);

	if(err2 == KErrNone)

	    {

	    CMDBSession* dbs = CMDBSession::NewLC(KCDVersion1_2);

	    snapid = TierManagerUtils::ConvertSNAPPrefToTagIdL(snaprecid,*dbs);

	    CleanupStack::PopAndDestroy(dbs);

	    }

	// compare it with MY IAP id, make sure they are different

	CommsDat::TMDBElementId myElementId = (KCDTIdIAPRecord | KCDTIdRecordTag);

	err = queryItf->GetInt(myElementId, myIapId, NULL);

	if(myIapId == realIapId)

		{

		_LIT(KPanicNoTunnelService, "No Tunnel Service");

		User::Panic(KPanicNoTunnelService, ETunnelAgentCprNoTunnelService);

		}

	// 2) Bind to the real AP

	TUint apid = realIapId ? realIapId : snapid;

	XConnectionProviderInfoQuery query(apid);

	CConnectionFactoryContainer* connectionFactories = SockManGlobals::Get()->iConnectionFactories;

	__ASSERT_DEBUG(connectionFactories, User::Panic(KSpecAssert_NifManAgtPrCtnlg, 2));

	CConnectionProviderBase* provider = static_cast<CConnectionProviderBase*>(connectionFactories->Find(query));

	TNodeId realIapNodeId = provider->Id();

	TNodeId thisNodeId = iContext.Node().NodeId();

	//SP are peers added with TClientType ((TCFClientType::EServProvider, CFClientType::EActive))

	RNodeInterface* sp = iContext.Node().AddClientL(realIapNodeId, TClientType(TCFClientType::EServProvider, TCFClientType::EActive));

	__ASSERT_DEBUG(sp != NULL, User::Panic(KTunnelAgentCPRPanic, ETunnelAgentCprNoServiceProvider));

 	iContext.iNodeActivity->PostRequestTo(

 			realIapNodeId, 

 			TCFServiceProvider::TJoinRequest(iContext.NodeId(), TClientType(TCFClientType::ECtrl)).CRef()

 			);

	}