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

//

/**

 @file

 @internal

 @released

*/

#if !defined(POLICYREQUESTSTATES_H)

#define POLICYREQUESTSTATES_H

#include <comms-infras/ss_nodemessages.h>

#include <comms-infras/ss_coreprstates.h>

#include <comms-infras/ss_corepractivities.h>

#include "policyrequest.h"

namespace PolicyRequestStates

{

typedef MeshMachine::TNodeContext<CPolicyRequest, CoreStates::TContext> TContext;

//

//Default self generated error handling for request transitions

template<class TCONTEXT>

NONSHARABLE_CLASS(TPolicyRequestTransitionBase) : public MeshMachine::TStateTransition<TCONTEXT>

    {

public:

    explicit TPolicyRequestTransitionBase(TCONTEXT& aContext)

    :	MeshMachine::TStateTransition<TCONTEXT>(aContext) {}

	virtual void Error(TInt aError)

	    {

        this->iContext.iReturn = aError;

       	this->iContext.Node().iError = aError;

        MeshMachine::TStateTransition<TCONTEXT>::Error(aError);

        }

    };

//

// Default Cancel and Error handling for states of CESockClientActivityBase Activities

// Intended for ECAB'isation of an otherwise normal state

// Not intended to be used as the first ECAB state (no TransitionTag handling) which

// is never actually desired (specific Accept must be present for the first state of ECAB)

template<class TSTATE>

NONSHARABLE_CLASS(TPolicyRequestState) : public TSTATE

    {

public:

	NETSM_TPL_DECLARE_CTR(TPolicyRequestState, NetStateMachine::MState, TContext)

    explicit TPolicyRequestState(TContext& aContext)

    :	TSTATE(aContext)

        {

        }

	virtual TBool Accept()

    	{

    	Messages::TEBase::TError* msg = Messages::message_cast<Messages::TEBase::TError>(&this->iContext.iCFMessageSig);

    	if(msg)

	    	{

			// save error in activity so it will be forwarded on to originator when the node is destroyed.

	    	CPolicyRequest& fr = static_cast<CPolicyRequest&>(this->iContext.Node());

	    	fr.iError = msg->iValue;

	    	// Error handling has to clean-up node properly, including leaving the client nodes. Done through an

	    	// explicit error handling activity that we trigger by forwarding the message to ourself: we can't

	    	// let it get originated by a client because their subsequent leave will abort the activity

			Messages::TNodeId selfId(this->iContext.Node()());

	    	if(this->iContext.iSender != selfId)

	    		{

	    		Messages::RClientInterface::OpenPostMessageClose(selfId, selfId, *msg);

	    		}

    		this->iContext.iCFMessageSig.ClearMessageId();

    		return EFalse;

    		}

    	return TSTATE::Accept();

    	}

	virtual void Cancel()

        {

        // We're handling our own abort sequence

        this->iContext.iCFMessageSig.iReturn = KErrNone;

        }

    };

//

// States

//

DECLARE_SMELEMENT_HEADER( TAwaitingBinderResponse, MeshMachine::TState<TContext>, NetStateMachine::MState, TContext )

	virtual TBool Accept();

DECLARE_SMELEMENT_FOOTER( TAwaitingBinderResponse )

DECLARE_SMELEMENT_HEADER( TAwaitingConnPolicyRequest, MeshMachine::TState<TContext>, NetStateMachine::MState, TContext )

	virtual TBool Accept();

DECLARE_SMELEMENT_FOOTER( TAwaitingConnPolicyRequest )

DECLARE_SMELEMENT_HEADER( TAwaitingCancelError, MeshMachine::TState<TContext>, NetStateMachine::MState, TContext )

	virtual TBool Accept();

DECLARE_SMELEMENT_FOOTER( TAwaitingCancelError )

//

// Activities

//

DECLARE_SMELEMENT_HEADER( TSendQoSParamsToNewSCpr, PolicyRequestStates::TPolicyRequestTransitionBase<TContext>, NetStateMachine::MStateTransition, TContext )

	virtual void DoL();

DECLARE_SMELEMENT_FOOTER( TSendQoSParamsToNewSCpr )

DECLARE_SMELEMENT_HEADER( TJoinReceivedSCpr, PolicyRequestStates::TPolicyRequestTransitionBase<TContext>, NetStateMachine::MStateTransition, TContext )

	virtual void DoL();

DECLARE_SMELEMENT_FOOTER( TJoinReceivedSCpr )

DECLARE_SMELEMENT_HEADER( TRequestCommsBinderFromSCpr, PolicyRequestStates::TPolicyRequestTransitionBase<TContext>, NetStateMachine::MStateTransition, TContext )

	virtual void DoL();

DECLARE_SMELEMENT_FOOTER( TRequestCommsBinderFromSCpr )

DECLARE_SMELEMENT_HEADER( TAwaitingError, MeshMachine::TState<TContext>, NetStateMachine::MState, TContext )

	virtual TBool Accept();

DECLARE_SMELEMENT_FOOTER( TAwaitingError )

DECLARE_SMELEMENT_HEADER( TJoinCpr, PolicyRequestStates::TPolicyRequestTransitionBase<TContext>, NetStateMachine::MStateTransition, TContext )

	virtual void DoL();

DECLARE_SMELEMENT_FOOTER( TJoinCpr )

DECLARE_SMELEMENT_HEADER( TLeaveCpr, PolicyRequestStates::TPolicyRequestTransitionBase<TContext>, NetStateMachine::MStateTransition, TContext )

	virtual void DoL();

DECLARE_SMELEMENT_FOOTER( TLeaveCpr )

DECLARE_SMELEMENT_HEADER( TSendBindToComplete, PolicyRequestStates::TPolicyRequestTransitionBase<TContext>, NetStateMachine::MStateTransition, TContext )

	virtual void DoL();

DECLARE_SMELEMENT_FOOTER( TSendBindToComplete )

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

//Rejoin

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

DECLARE_SMELEMENT_HEADER( TJoinTheDeftSCPr, PolicyRequestStates::TPolicyRequestTransitionBase<TContext>, NetStateMachine::MStateTransition, TContext )

	virtual void DoL();

DECLARE_SMELEMENT_FOOTER( TJoinTheDeftSCPr )

DECLARE_SMELEMENT_HEADER( TLeaveTheDeftSCPr, PolicyRequestStates::TPolicyRequestTransitionBase<TContext>, NetStateMachine::MStateTransition, TContext )

	virtual void DoL();

DECLARE_SMELEMENT_FOOTER( TLeaveTheDeftSCPr )

DECLARE_SMELEMENT_HEADER( TSendRejoinDataClientRequestToDeftSCPr, PolicyRequestStates::TPolicyRequestTransitionBase<TContext>, NetStateMachine::MStateTransition, TContext )

	virtual void DoL();

DECLARE_SMELEMENT_FOOTER( TSendRejoinDataClientRequestToDeftSCPr )

DECLARE_SMELEMENT_HEADER( TSendApplyToDeftSCPr, PolicyRequestStates::TPolicyRequestTransitionBase<TContext>, NetStateMachine::MStateTransition, TContext )

	virtual void DoL();

DECLARE_SMELEMENT_FOOTER( TSendApplyToDeftSCPr )

DECLARE_SMELEMENT_HEADER( TSendApplyToNewSCPr, PolicyRequestStates::TPolicyRequestTransitionBase<TContext>, NetStateMachine::MStateTransition, TContext )

	virtual void DoL();

DECLARE_SMELEMENT_FOOTER( TSendApplyToNewSCPr )

DECLARE_SMELEMENT_HEADER( TSendCancelToDeftSCPr, PolicyRequestStates::TPolicyRequestTransitionBase<TContext>, NetStateMachine::MStateTransition, TContext )

	virtual void DoL();

DECLARE_SMELEMENT_FOOTER( TSendCancelToDeftSCPr )

DECLARE_SMELEMENT_HEADER( TIgnoreAndCloseSubConEvent, PolicyRequestStates::TPolicyRequestTransitionBase<TContext>, NetStateMachine::MStateTransition, TContext )

	virtual void DoL();

DECLARE_SMELEMENT_FOOTER( TIgnoreAndCloseSubConEvent )

//

//SCpr specific

/*DECLARE_SMELEMENT_NAMESPACE_HEADER( TJoinSCpr, PolicyRequestStates, PolicyRequestTransitionBase<TContext>, NetStateMachine::MStateTransition, TContext )

	virtual void DoL();

DECLARE_SMELEMENT_FOOTER( TJoinSCpr )*/

} //namespace PolicyRequestStates

namespace PolicyRequestActivities

{

NONSHARABLE_CLASS(CPolicyRequestActivity) : public MeshMachine::CNodeActivityBase, public CoreActivities::ABindingActivity,

											public ITFHIERARCHY_1(CPolicyRequestActivity, CoreActivities::ABindingActivity)

	{

public:

	typedef ITFHIERARCHY_1(CPolicyRequestActivity, CoreActivities::ABindingActivity) TIfStaticFetcherNearestInHierarchy;

public:

    static MeshMachine::CNodeActivityBase* NewL(const MeshMachine::TNodeActivity& aActivitySig, MeshMachine::AMMNodeBase& aNode)

    	{

		return new (ELeave) CPolicyRequestActivity(aActivitySig,aNode,static_cast<const CPolicyRequest&>(aNode));

    	}

	void ReturnInterfacePtrL(CoreActivities::ABindingActivity*& aInterface)

		{

		aInterface = this;

		}

protected:

	CPolicyRequestActivity(const MeshMachine::TNodeActivity& aActivitySig, MeshMachine::AMMNodeBase& aNode, const CPolicyRequest& aPolicyRequest)

	:MeshMachine::CNodeActivityBase(aActivitySig, aNode),

	 ABindingActivity(aNode.Id()),

	 TIfStaticFetcherNearestInHierarchy(this),

	 iPolicyRequest(&aPolicyRequest)

		{

		}

	virtual ~CPolicyRequestActivity()

		{

		ASSERT(iPolicyRequest);

		if (iPolicyRequest->CountAllActivities()==0)

			{

			delete iPolicyRequest;

			}

		SetError(KErrNone);	// any bad news we're carrying gets passed to the client through the request

		}

private:

	const CPolicyRequest* iPolicyRequest;

	};

} //namespace PolicyRequestActivities

#endif

// QOSPOLICYREQUESTSTATES_H