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

#ifndef SYMBIAN_SS_SUBCONNSTATES_H
#define SYMBIAN_SS_SUBCONNSTATES_H

#include <comms-infras/ss_esockstates.h>
#include <comms-infras/ss_esockactivities.h>
#include <comms-infras/ss_corepractivities.h>
#include <comms-infras/sockmes.h>
#include "ss_subconn.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_ESocks_sbcnsts, "ESocks_sbcnsts.");
#endif

//-=========================================================
//
//Activities
//
//-=========================================================
namespace SubConnActivities
{
class CSubConnBindingActivityBase : public SubSessActivities::CESockClientActivityBase, public CoreActivities::ABindingActivity,
                public ITFHIERARCHY_LINK_1(CSubConnBindingActivityBase, SubSessActivities::CESockClientActivityBase, CoreActivities::ABindingActivity)
	{
public:
	typedef ITFHIERARCHY_LINK_1(CSubConnBindingActivityBase, SubSessActivities::CESockClientActivityBase, CoreActivities::ABindingActivity) TIfStaticFetcherNearestInHierarchy;

public:
    static MeshMachine::CNodeActivityBase* NewL(const MeshMachine::TNodeActivity& aActivitySig, MeshMachine::AMMNodeBase& aNode);
	virtual ~CSubConnBindingActivityBase() {}

    void ReturnInterfacePtrL(CoreActivities::ABindingActivity*& aInterface)
        {
        aInterface = this;
        }

    void CompleteMessage();

protected:
	CSubConnBindingActivityBase( const MeshMachine::TNodeActivity& aActivitySig, MeshMachine::AMMNodeBase& aNode )
	:	SubSessActivities::CESockClientActivityBase(aActivitySig, aNode),
		CoreActivities::ABindingActivity(aNode.Id()),
	    TIfStaticFetcherNearestInHierarchy(this)
		{
		}
	};


//-=========================================================
//CNoBearer
//-=========================================================
/**
@internalComponent
*/
class CNoBearer : public CSubConnBindingActivityBase
	{
public:
	typedef ITFHIERARCHY_LINK_1(CNoBearer, SubSessActivities::CESockClientActivityBase, CoreActivities::ABindingActivity) TIfStaticFetcherNearestInHierarchy;

public:
    static MeshMachine::CNodeActivityBase* NewL(const MeshMachine::TNodeActivity& aActivitySig, MeshMachine::AMMNodeBase& aNode);
	virtual ~CNoBearer();

    inline ESock::RCFParameterFamilyBundleC& GetFlowRequestParameters()
    	{return iFlowRequestBundle;}

    void SetFlowRequestParameters(const ESock::RCFParameterFamilyBundleC& aParams);
		
    void ReturnInterfacePtrL(CoreActivities::ABindingActivity*& aInterface)
        {aInterface = this;}

DECLARE_SMELEMENT_HEADER( TStoreFlowParams, MeshMachine::TStateTransition<TContext>, NetStateMachine::MStateTransition, TContext )
	virtual void DoL();
DECLARE_SMELEMENT_FOOTER( TStoreFlowParams )

protected:
	CNoBearer( const MeshMachine::TNodeActivity& aActivitySig, MeshMachine::AMMNodeBase& aNode )
	:	CSubConnBindingActivityBase(aActivitySig, aNode)
		{
		}
private:
    ESock::RCFParameterFamilyBundleC iFlowRequestBundle;
	};


//-=========================================================
//CBuildStack
//-=========================================================
class CBuildStack : public MeshMachine::CNodeActivityBase, public CoreActivities::ABindingActivity,
	public ITFHIERARCHY_1(CBuildStack, CoreActivities::ABindingActivity)
	{
public:
	typedef ITFHIERARCHY_1(CBuildStack, CoreActivities::ABindingActivity) TIfStaticFetcherNearestInHierarchy;

    void ReturnInterfacePtrL(CoreActivities::ABindingActivity*& aInterface)
        {
        aInterface = this;
        }

public:
    static MeshMachine::CNodeActivityBase* NewL(const MeshMachine::TNodeActivity& aActivitySig, MeshMachine::AMMNodeBase& aNode);
	virtual ~CBuildStack();

protected:
	CBuildStack(const MeshMachine::TNodeActivity& aActivitySig, MeshMachine::AMMNodeBase& aNode);

public:
typedef MeshMachine::TNodeContext<ESock::CSubConnection, SubSessStates::TContext> TContext;
DECLARE_SMELEMENT_HEADER( TSendBuildStackResponse, MeshMachine::TStateTransition<TContext>, NetStateMachine::MStateTransition, TContext )
	virtual void DoL();
DECLARE_SMELEMENT_FOOTER( TSendBuildStackResponse )

DECLARE_SMELEMENT_HEADER( TAwaitingBuildStack, MeshMachine::TState<TContext>, NetStateMachine::MState, TContext )
	virtual TBool Accept();
DECLARE_SMELEMENT_FOOTER( TAwaitingBuildStack )

DECLARE_SMELEMENT_HEADER( TRequestServiceProviderFromCPR, MeshMachine::TStateTransition<TContext>, NetStateMachine::MStateTransition, TContext )
	virtual void DoL();
DECLARE_SMELEMENT_FOOTER( TRequestServiceProviderFromCPR )

private:
	void RequestServiceProviderFromCPRL(TContext& aContext);
};


//-=========================================================
//CCreate
//-=========================================================
class CCreate : public CSubConnBindingActivityBase
	{
public:
	typedef ITFHIERARCHY_LINK_1(CCreate, SubSessActivities::CESockClientActivityBase, CoreActivities::ABindingActivity) TIfStaticFetcherNearestInHierarchy;

public:
    static MeshMachine::CNodeActivityBase* NewL(const MeshMachine::TNodeActivity& aActivitySig, MeshMachine::AMMNodeBase& aNode);
	virtual ~CCreate();

protected:
	CCreate(const MeshMachine::TNodeActivity& aActivitySig, MeshMachine::AMMNodeBase& aNode)
	:	CSubConnBindingActivityBase(aActivitySig, aNode),
	    iSubConnectionNode(aNode.Id())
		{
		}
private:
	//We are taking ownership of the sub session for the duration of this activity
	//If something goes wrong, we need to destroy this subsession.
    Messages::TNodeId iSubConnectionNode;
	};

//-=========================================================
//CRejoin
//-=========================================================
class ESock::CSubConnection;
class CRejoin : public SubSessActivities::CESockClientActivityBase
/*

*/
	{
public:
    static MeshMachine::CNodeActivityBase* NewL(const MeshMachine::TNodeActivity& aActivitySig, MeshMachine::AMMNodeBase& aNode);
	virtual ~CRejoin();
	const Messages::TNodeId& OldOwner()
    	{
    	__ASSERT_DEBUG(!iOldOwner.IsNull(), User::Panic(KSpecAssert_ESocks_sbcnsts, 1));
    	return iOldOwner;
    	}

	const Messages::TNodeId& NewOwner()
    	{
    	__ASSERT_DEBUG(!iNewOwner.IsNull(), User::Panic(KSpecAssert_ESocks_sbcnsts, 2));
    	return iNewOwner;
    	}

  	const Messages::TNodeId& TheOtherOwner()
    	{
    	__ASSERT_DEBUG(!iOldOwner.IsNull() && !iNewOwner.IsNull(), User::Panic(KSpecAssert_ESocks_sbcnsts, 3));
    	return iMessage.Function() == ESCAddSocket ? iOldOwner : iNewOwner;
    	}

	const Messages::TNodeId& Flow()
    	{
    	__ASSERT_DEBUG(!iFlow.IsNull(), User::Panic(KSpecAssert_ESocks_sbcnsts, 4));
    	return iFlow;
    	}

	void InitialiseL(ESock::CSubConnection& aSC);

    void SetOldOwnerIntf(Messages::RNodeInterface * aIntf)
        {
        iOldOwnerIntf = aIntf;
        }
	
	Messages::RNodeInterface* OldOwnerIntf()
	    {
        __ASSERT_DEBUG(iOldOwnerIntf != NULL, User::Panic(KSpecAssert_ESocks_sbcnsts, 1));
        return iOldOwnerIntf;
	    }

protected:
	CRejoin( const MeshMachine::TNodeActivity& aActivitySig, MeshMachine::AMMNodeBase& aNode )
	:	SubSessActivities::CESockClientActivityBase(aActivitySig, aNode)
		{
		}


private:
    Messages::TNodeId iOldOwner;
    Messages::TNodeId iNewOwner;
    Messages::TNodeId iFlow;
	
	Messages::RNodeInterface * iOldOwnerIntf;
	};

//-=========================================================
//CSetParameters
//-=========================================================
class CSetParameters : public SubSessActivities::CESockClientActivityBase
/*

*/
	{
public:
	typedef MeshMachine::TNodeContext<ESock::CSubConnection, SubSessStates::TContext> TContext;
    static MeshMachine::CNodeActivityBase* NewL(const MeshMachine::TNodeActivity& aActivitySig, MeshMachine::AMMNodeBase& aNode);
	virtual ~CSetParameters();

    ESock::RCFParameterFamilyBundleC& GetParameterBundleL();
    void CompleteMessage();

protected:
	CSetParameters( const MeshMachine::TNodeActivity& aActivitySig, MeshMachine::AMMNodeBase& aNode )
	:	SubSessActivities::CESockClientActivityBase(aActivitySig, aNode)
		{
		}
private:
	void StoreParametersInSubConn(TContext& aContext);

    ESock::RCFParameterFamilyBundleC iParameterBundle;

public:
DECLARE_SMELEMENT_HEADER( TCompleteClient, MeshMachine::TStateTransition<TContext>, NetStateMachine::MStateTransition, TContext )
 	virtual void DoL();
DECLARE_SMELEMENT_FOOTER( TCompleteClient )

DECLARE_SMELEMENT_HEADER( TStoreNewParams, MeshMachine::TStateTransition<TContext>, NetStateMachine::MStateTransition, TContext )
	virtual void DoL();
DECLARE_SMELEMENT_FOOTER( TStoreNewParams )

	};

//-=========================================================
//CEventNotification
//-=========================================================
class CEventNotification : public SubSessActivities::CESockClientActivityBase
/*

*/
	{
public:
    static MeshMachine::CNodeActivityBase* NewL(const MeshMachine::TNodeActivity& aActivitySig, MeshMachine::AMMNodeBase& aNode);
	virtual ~CEventNotification();

    void RequestEventNotificationSetupL();
    void RequestAllEventNotificationsL();
    TBool FillInEvent(const CSubConNotificationEvent& aEvent);

protected:
	CEventNotification( const MeshMachine::TNodeActivity& aActivitySig, MeshMachine::AMMNodeBase& aNode )
	:	SubSessActivities::CESockClientActivityBase(aActivitySig, aNode)
		{
		}
private:
	RSubConnection::TEventFilter iEventUidFilterList[KMaxUidFilterListLen];
	TUint		                 iEventUidFilterListLength;
	};

} //namespace SubConnActivities


//-=========================================================
//
//States
//
//-=========================================================
namespace SubConnStates
{
typedef MeshMachine::TNodeContext<ESock::CSubConnection, SubSessStates::TContext> TContext;

//-=========================================================
//Create
//-=========================================================
DECLARE_SMELEMENT_HEADER( TNoTagOrWaitForIncoming, MeshMachine::TStateFork<TContext>, NetStateMachine::MStateFork, TContext )
 	virtual TInt TransitionTag();
DECLARE_SMELEMENT_FOOTER( TNoTagOrWaitForIncoming )

DECLARE_SMELEMENT_HEADER( TJoinCPR, SubSessStates::TECABStateTransitionBase<TContext>, NetStateMachine::MStateTransition, TContext )
	virtual void DoL();
DECLARE_SMELEMENT_FOOTER( TJoinCPR )

DECLARE_SMELEMENT_HEADER( TRequestServiceProvider, SubSessStates::TECABStateTransitionBase<TContext>, NetStateMachine::MStateTransition, TContext )
	virtual void DoL();
DECLARE_SMELEMENT_FOOTER( TRequestServiceProvider )

DECLARE_SMELEMENT_HEADER( TLeaveCPR, SubSessStates::TECABStateTransitionBase<TContext>, NetStateMachine::MStateTransition, TContext )
	virtual void DoL();
DECLARE_SMELEMENT_FOOTER( TLeaveCPR )

DECLARE_SMELEMENT_HEADER( TNoTagOrAttachToDefaultOrWaitForIncoming, MeshMachine::TStateFork<TContext>, NetStateMachine::MStateFork, TContext )
 	virtual TInt TransitionTag();
DECLARE_SMELEMENT_FOOTER( TNoTagOrAttachToDefaultOrWaitForIncoming )

//-=========================================================
//Rejoin
//-=========================================================
DECLARE_SMELEMENT_HEADER( TJoinTheOtherOwner, SubSessStates::TECABStateTransitionBase<TContext>, NetStateMachine::MStateTransition, TContext )
	virtual void DoL();
DECLARE_SMELEMENT_FOOTER( TJoinTheOtherOwner )

DECLARE_SMELEMENT_HEADER( TLeaveTheOtherOwner, SubSessStates::TECABStateTransitionBase<TContext>, NetStateMachine::MStateTransition, TContext )
	virtual void DoL();
DECLARE_SMELEMENT_FOOTER( TLeaveTheOtherOwner )

DECLARE_SMELEMENT_HEADER( TSendRejoinDataClientRequestToOldOwner, SubSessStates::TECABStateTransitionBase<TContext>, NetStateMachine::MStateTransition, TContext )
	virtual void DoL();
DECLARE_SMELEMENT_FOOTER( TSendRejoinDataClientRequestToOldOwner )

DECLARE_SMELEMENT_HEADER( TSendApplyToOldOwner, SubSessStates::TECABStateTransitionBase<TContext>, NetStateMachine::MStateTransition, TContext )
	virtual void DoL();
DECLARE_SMELEMENT_FOOTER( TSendApplyToOldOwner )

DECLARE_SMELEMENT_HEADER( TSendApplyToNewOwner, SubSessStates::TECABStateTransitionBase<TContext>, NetStateMachine::MStateTransition, TContext )
	virtual void DoL();
DECLARE_SMELEMENT_FOOTER( TSendApplyToNewOwner )

DECLARE_SMELEMENT_HEADER( TSendCancelToOldOwner, SubSessStates::TECABStateTransitionBase<TContext>, NetStateMachine::MStateTransition, TContext )
	virtual void DoL();
DECLARE_SMELEMENT_FOOTER( TSendCancelToOldOwner )

//-=========================================================
//Get/Set Params
//-=========================================================
DECLARE_SMELEMENT_HEADER( TSendParamsToServiceProvider, SubSessStates::TECABStateTransitionBase<TContext>, NetStateMachine::MStateTransition, TContext )
	virtual void DoL();
DECLARE_SMELEMENT_FOOTER( TSendParamsToServiceProvider )

DECLARE_SMELEMENT_HEADER( TStoreParams, SubSessStates::TECABStateTransitionBase<TContext>, NetStateMachine::MStateTransition, TContext )
	virtual void DoL();
DECLARE_SMELEMENT_FOOTER( TStoreParams )

DECLARE_AGGREGATED_TRANSITION2(
    TStoreParamsAndSendApply,
	SubConnStates::TStoreParams,
	CoreNetStates::TSendApplyRequest
	)

DECLARE_SMELEMENT_HEADER( TSendParamRequest, SubSessStates::TECABStateTransitionBase<TContext>, NetStateMachine::MStateTransition, TContext )
	virtual void DoL();
DECLARE_SMELEMENT_FOOTER( TSendParamRequest )

DECLARE_SMELEMENT_HEADER( TNoTagOrParamsPresent, MeshMachine::TStateFork<TContext>, NetStateMachine::MStateFork, TContext )
	virtual TInt TransitionTag();
DECLARE_SMELEMENT_FOOTER( TNoTagOrParamsPresent )

DECLARE_SMELEMENT_HEADER( TWriteSubConnParamsLength, SubSessStates::TECABStateTransitionBase<TContext>, NetStateMachine::MStateTransition, TContext )
	virtual void DoL();
DECLARE_SMELEMENT_FOOTER( TWriteSubConnParamsLength )

DECLARE_SMELEMENT_HEADER( TWriteSubConnParams, SubSessStates::TECABStateTransitionBase<TContext>, NetStateMachine::MStateTransition, TContext )
	virtual void DoL();
DECLARE_SMELEMENT_FOOTER( TWriteSubConnParams )

DECLARE_SERIALIZABLE_STATE(
	TNoTagOrParamsPresentBlockedBySetParams,
	MeshMachine::TActivityIdMutex<ESock::ECFActivityParamRequest>,
	SubConnStates::TNoTagOrParamsPresent
	)

//-=========================================================
//Events
//-=========================================================
DECLARE_SMELEMENT_HEADER( TAwaitingEventNotificationSubscription, MeshMachine::TState<TContext>, NetStateMachine::MState, TContext )
	virtual TBool Accept();
DECLARE_SMELEMENT_FOOTER( TAwaitingEventNotificationSubscription )

DECLARE_SMELEMENT_HEADER( TNoTagOrAllNotifications, MeshMachine::TStateFork<TContext>, NetStateMachine::MStateFork, TContext )
	virtual TInt TransitionTag();
DECLARE_SMELEMENT_FOOTER( TNoTagOrAllNotifications )

DECLARE_SMELEMENT_HEADER( TSetupFilteredEventNotification, SubSessStates::TECABStateTransitionBase<TContext>, NetStateMachine::MStateTransition, TContext )
	virtual void DoL();
DECLARE_SMELEMENT_FOOTER( TSetupFilteredEventNotification )

DECLARE_SMELEMENT_HEADER( TSetupAllEventNotification, SubSessStates::TECABStateTransitionBase<TContext>, NetStateMachine::MStateTransition, TContext )
	virtual void DoL();
DECLARE_SMELEMENT_FOOTER( TSetupAllEventNotification )

DECLARE_SMELEMENT_HEADER( TFillInEvent, SubSessStates::TECABStateTransitionBase<TContext>, NetStateMachine::MStateTransition, TContext )
	virtual void DoL();
DECLARE_SMELEMENT_FOOTER( TFillInEvent )

DECLARE_SMELEMENT_HEADER( TEnqueueEvent, SubSessStates::TECABStateTransitionBase<TContext>, NetStateMachine::MStateTransition, TContext )
	virtual void DoL();
	protected:
    void CreateOrUpdateBundleL(CSubConGenEventParamsGranted* aEvent);
DECLARE_SMELEMENT_FOOTER( TEnqueueEvent )

DECLARE_SMELEMENT_HEADER( TNoTagOrActiveWhenEventEnqued, MeshMachine::TStateFork<TContext>, NetStateMachine::MStateFork, TContext )
	virtual TInt TransitionTag();
DECLARE_SMELEMENT_FOOTER( TNoTagOrActiveWhenEventEnqued )



//-=========================================================
//Start/Stop SubConnection
//-=========================================================
DECLARE_SMELEMENT_HEADER( TStartSubConnection, SubSessStates::TECABStateTransitionBase<TContext>, NetStateMachine::MStateTransition, TContext )
	virtual void DoL();
DECLARE_SMELEMENT_FOOTER( TStartSubConnection )

DECLARE_SMELEMENT_HEADER( TStopSubConnection, SubSessStates::TECABStateTransitionBase<TContext>, NetStateMachine::MStateTransition, TContext )
	virtual void DoL();
DECLARE_SMELEMENT_FOOTER( TStopSubConnection )

//-=========================================================
//Close
//-=========================================================
DECLARE_SMELEMENT_HEADER( TDetachControlProvider, SubSessStates::TECABStateTransitionBase<TContext>, NetStateMachine::MStateTransition, TContext )
	virtual void DoL();
DECLARE_SMELEMENT_FOOTER( TDetachControlProvider )

DECLARE_AGGREGATED_TRANSITION2(
	TProcessClose,
	SubSessStates::TProcessClose,
	TDetachControlProvider
	)

//-=========================================================
// Build stack
//-=========================================================

DECLARE_SMELEMENT_HEADER( TAwaitingBuildStackResponse, MeshMachine::TState<TContext>, NetStateMachine::MState, TContext )
	virtual TBool Accept();
DECLARE_SMELEMENT_FOOTER( TAwaitingBuildStackResponse )

DECLARE_SMELEMENT_HEADER( TSendBuildStack, MeshMachine::TStateTransition<TContext>, NetStateMachine::MStateTransition, TContext )
	virtual void DoL();
DECLARE_SMELEMENT_FOOTER( TSendBuildStack )

} //namespace SubConnStates


#endif
// SYMBIAN_SS_SUBCONNSTATES_H