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

//

#include <comms-infras/ss_log.h>

#include "ss_glob.h"

#include "policyrequest.h"

#include "policyrequeststates.h"

#include <comms-infras/ss_mcprnodemessages.h>

#include <comms-infras/ss_coreprstates.h>

#include <comms-infras/ss_nodemessages_dataclient.h>

#include <comms-infras/ss_nodemessages_serviceprovider.h>

#include <comms-infras/ss_nodemessages_rejoiningprovider.h>

#include <comms-infras/ss_nodemessages_subconn.h>

#include <comms-infras/ss_nodemessages_scpr.h>

using namespace Messages;

using namespace MeshMachine;

using namespace ESock;

using namespace PolicyRequestStates;

using namespace CorePanics;

#ifdef _DEBUG

_LIT (KCPolicyRequestPanic,"PolicyRequestPanic");

#endif

//

// States

//

DEFINE_SMELEMENT( TAwaitingBinderResponse, NetStateMachine::MState, PolicyRequestStates::TContext)

TBool TAwaitingBinderResponse::Accept()

	{

	const TCFServiceProvider::TCommsBinderResponse* br = message_cast<TCFServiceProvider::TCommsBinderResponse>(&iContext.iMessage);

	if (br)

    	{

        iContext.Node().iNewSCprId = br->iNodeId;

        return ETrue;        

    	}

	return EFalse;

	}

DEFINE_SMELEMENT( TAwaitingConnPolicyRequest, NetStateMachine::MState, PolicyRequestStates::TContext)

TBool PolicyRequestStates::TAwaitingConnPolicyRequest::Accept()

	{

	TCFIPMessage::TPolicyRequest* PolicyReqMsg = message_cast<TCFIPMessage::TPolicyRequest>(&iContext.iMessage);

	return PolicyReqMsg && PolicyReqMsg->iValue == ESoCreateWithConnection ? ETrue : EFalse;

	}

//

// Activities

//

DEFINE_SMELEMENT( TSendQoSParamsToNewSCpr, NetStateMachine::MStateTransition, PolicyRequestStates::TContext)

void TSendQoSParamsToNewSCpr::DoL()

	{

#ifdef SYMBIAN_ADAPTIVE_TCP_RECEIVE_WINDOW

	iContext.iNodeActivity->PostRequestTo(*iContext.Node().ServiceProvider(),

	    ESock::TCFScpr::TSetParamsRequest(iContext.Node().iParamBundle).CRef());

#else

	iContext.iNodeActivity->PostRequestTo(*iContext.Node().ServiceProvider(),

	    ESock::TCFScpr::TParamsRequest(iContext.Node().iParamBundle).CRef());

#endif // SYMBIAN_ADAPTIVE_TCP_RECEIVE_WINDOW

	}

DEFINE_SMELEMENT( TJoinReceivedSCpr, NetStateMachine::MStateTransition, PolicyRequestStates::TContext)

void PolicyRequestStates::TJoinReceivedSCpr::DoL()

	{

	__ASSERT_DEBUG(iContext.iNodeActivity, User::Panic(KCPolicyRequestPanic, KPanicNoActivity));

	__ASSERT_DEBUG(iContext.iPeer == iContext.Node().ServiceProvider(), User::Panic(KCPolicyRequestPanic, KPanicExpectedNoServiceProvider));

	TCFServiceProvider::TCommsBinderResponse& br = message_cast<TCFServiceProvider::TCommsBinderResponse>(iContext.iMessage);

    iContext.Node().AddClientL(br.iNodeId, TClientType(TCFClientType::EServProvider, TCFClientType::EActive));

    iContext.iNodeActivity->PostRequestTo(br.iNodeId,

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

	}

DEFINE_SMELEMENT( TRequestCommsBinderFromSCpr, NetStateMachine::MStateTransition, PolicyRequestStates::TContext)

void PolicyRequestStates::TRequestCommsBinderFromSCpr::DoL()

	{

    __ASSERT_DEBUG(iContext.iNodeActivity, User::Panic(KCPolicyRequestPanic, KPanicNoActivity));

    RNodeInterface* sp = iContext.Node().ServiceProvider();

    __ASSERT_DEBUG(sp, User::Panic(KCPolicyRequestPanic, KPanicNoServiceProvider));

    iContext.iNodeActivity->PostRequestTo(*sp,

    	TCFServiceProvider::TCommsBinderRequest(TSubConnOpen::ECreateNew).CRef());

	}

DEFINE_SMELEMENT( TAwaitingError, NetStateMachine::MState, PolicyRequestStates::TContext)

TBool PolicyRequestStates::TAwaitingError::Accept()

	{

	return iContext.iMessage.IsMessage<TEBase::TError>();

	}

DEFINE_SMELEMENT( TAwaitingCancelError, NetStateMachine::MState, PolicyRequestStates::TContext)

TBool PolicyRequestStates::TAwaitingCancelError::Accept()

	{

	TEBase::TError* msg = message_cast<TEBase::TError>(&iContext.iMessage);

	return msg && msg->iValue == KErrCancel;

	}

//

//Cpr specific

DEFINE_SMELEMENT( TJoinCpr, NetStateMachine::MStateTransition, PolicyRequestStates::TContext)

void PolicyRequestStates::TJoinCpr::DoL()

	{

	__ASSERT_DEBUG(iContext.iNodeActivity, User::Panic(KCPolicyRequestPanic, KPanicNoActivity));

	RNodeInterface* cpr = iContext.Node().GetFirstClient<TDefaultClientMatchPolicy>(TClientType(TCFClientType::EServProvider, TCFClientType::EActive));

	//The sc has been already added

	__ASSERT_DEBUG(cpr != NULL, User::Panic(KCPolicyRequestPanic, KPanicNoServiceProvider));

	//Join the service provider

	iContext.iNodeActivity->PostRequestTo(*cpr,

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

	}

DEFINE_SMELEMENT( TLeaveCpr, NetStateMachine::MStateTransition, PolicyRequestStates::TContext)

void PolicyRequestStates::TLeaveCpr::DoL()

	{

	__ASSERT_DEBUG(iContext.iNodeActivity, User::Panic(KCPolicyRequestPanic, KPanicNoActivity));

	RNodeInterface* cpr = iContext.Node().GetFirstClient<TDefaultClientMatchPolicy>(TClientType(TCFClientType::EServProvider, TCFClientType::EActive));

	//The sc has been already added

	__ASSERT_DEBUG(cpr != NULL, User::Panic(KCPolicyRequestPanic, KPanicNoServiceProvider));

	//Leave the service provider

	iContext.iNodeActivity->PostRequestTo(*cpr,

		TEPeer::TLeaveRequest().CRef());

	cpr->SetFlags(TCFClientType::ELeaving);

	}

DEFINE_SMELEMENT( TSendBindToComplete, NetStateMachine::MStateTransition, PolicyRequestStates::TContext)

void PolicyRequestStates::TSendBindToComplete::DoL()

	{

	__ASSERT_DEBUG(iContext.iNodeActivity, User::Panic(KCPolicyRequestPanic, KPanicNoActivity));

	RNodeInterface* cpr = iContext.Node().GetFirstClient<TDefaultClientMatchPolicy>(TClientType(TCFClientType::EServProvider, TCFClientType::EActive));

	if(cpr)

		{	

		iContext.iNodeActivity->PostRequestTo(*cpr,

			TCFServiceProvider::TBindToComplete(iContext.iNodeActivity->Error()).CRef());

 		}

	}

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

//Rejoin

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

DEFINE_SMELEMENT( TJoinTheDeftSCPr, NetStateMachine::MStateTransition, PolicyRequestStates::TContext)

void PolicyRequestStates::TJoinTheDeftSCPr::DoL()

	{

	__ASSERT_DEBUG(iContext.iNodeActivity, User::Panic(KCPolicyRequestPanic,KPanicNoActivity));

	//MZTODO: activity using this transition - and possibly the whole approach - must be redesigned

	//so that all destinations are safe! (used to be: TCtrlClientJoinRequestUnsafeDst).

    iContext.Node().iDeftScprClient = iContext.Node().AddClientL(iContext.Node().iSenderSCPrNodeId, TClientType(TCFClientType::EServProvider, TCFClientType::EActive));

    iContext.iNodeActivity->PostRequestTo(iContext.Node().iSenderSCPrNodeId,

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

	}

DEFINE_SMELEMENT( TLeaveTheDeftSCPr, NetStateMachine::MStateTransition, PolicyRequestStates::TContext)

void PolicyRequestStates::TLeaveTheDeftSCPr::DoL()

	{

	__ASSERT_DEBUG(iContext.iNodeActivity, User::Panic(KCPolicyRequestPanic,KPanicNoActivity));

    RClientInterface::OpenPostMessageClose(TNodeCtxId(iContext.ActivityId(), iContext.NodeId()), iContext.Node().iSenderSCPrNodeId,

    	TEPeer::TLeaveRequest().CRef());

	iContext.Node().iDeftScprClient->SetFlags(TCFClientType::ELeaving);

	}

DEFINE_SMELEMENT( TSendRejoinDataClientRequestToDeftSCPr, NetStateMachine::MStateTransition, PolicyRequestStates::TContext)

void PolicyRequestStates::TSendRejoinDataClientRequestToDeftSCPr::DoL()

	{

	__ASSERT_DEBUG(iContext.iNodeActivity, User::Panic(KCPolicyRequestPanic,KPanicNoActivity));

    RClientInterface::OpenPostMessageClose(TNodeCtxId(iContext.ActivityId(), iContext.NodeId()), iContext.Node().iSenderSCPrNodeId,

    	TCFRejoiningProvider::TRejoinDataClientRequest(iContext.Node().iFlowNodeId, iContext.Node().iNewSCprId).CRef());

	}

DEFINE_SMELEMENT( TSendApplyToDeftSCPr, NetStateMachine::MStateTransition, PolicyRequestStates::TContext)

void PolicyRequestStates::TSendApplyToDeftSCPr::DoL()

	{

	__ASSERT_DEBUG(iContext.iNodeActivity, User::Panic(KCPolicyRequestPanic,KPanicNoActivity));

    iContext.iNodeActivity->PostRequestTo(iContext.Node().iSenderSCPrNodeId,

    	ESock::TCFScpr::TApplyRequest().CRef());

	}

DEFINE_SMELEMENT( TSendApplyToNewSCPr, NetStateMachine::MStateTransition, PolicyRequestStates::TContext)

void PolicyRequestStates::TSendApplyToNewSCPr::DoL()

	{

	__ASSERT_DEBUG(iContext.iNodeActivity, User::Panic(KCPolicyRequestPanic,KPanicNoActivity));

    iContext.iNodeActivity->PostRequestTo(iContext.Node().iNewSCprId,

    	ESock::TCFScpr::TApplyRequest().CRef());

	}

DEFINE_SMELEMENT( TSendCancelToDeftSCPr, NetStateMachine::MStateTransition, PolicyRequestStates::TContext)

void PolicyRequestStates::TSendCancelToDeftSCPr::DoL()

	{

	__ASSERT_DEBUG(iContext.iNodeActivity, User::Panic(KCPolicyRequestPanic,KPanicNoActivity));

    RClientInterface::OpenPostMessageClose(TNodeCtxId(iContext.ActivityId(), iContext.NodeId()), iContext.Node().iSenderSCPrNodeId,

    	TEBase::TCancel().CRef());

	iContext.iNodeActivity->ClearPostedTo(); // the error that comes in wont be a reply

	}

DEFINE_SMELEMENT( TIgnoreAndCloseSubConEvent, NetStateMachine::MStateTransition, PolicyRequestStates::TContext)

void PolicyRequestStates::TIgnoreAndCloseSubConEvent::DoL()

	{

	TCFSubConnControlClient::TSubConnNotification& event = message_cast<TCFSubConnControlClient::TSubConnNotification>(iContext.iMessage);

    event.iRefCountOwnedSubConNotification->Close();

	}