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

#ifndef __UPNPCONTROLSCPRACTIVITIES_H
#define __UPNPCONTROLSCPRACTIVITIES_H

#include <comms-infras/corescpractivities.h>
#include <comms-infras/ss_nodemessages.h>
#include <comms-infras/ss_corepractivities.h>
#include <http/thttptable.h>

#include "upnpctrlscpr.h"
#include "upnp_cf_msgs.h"


using namespace ESock;
using namespace MeshMachine;

namespace UPnPControlSCprActivities
	{	
	DECLARE_ACTIVITY_MAP ( activityMap )
	}

class CUPnPActivityBase : public CNodeParallelActivityBase
	{
protected:
	CUPnPActivityBase ( const TNodeActivity& aActivitySig, AMMNodeBase& aNode, TUint aActivitiesCount )
		:CNodeParallelActivityBase ( aActivitySig, aNode, aActivitiesCount )	
		{ }
	
	~CUPnPActivityBase ( ); 	
 	virtual TBool Next ( TNodeContextBase& aContext );
 
 public:
 	TNodeId iFlowId;
 	CUPnPRequestParamSetBase* iRequestParamSet;
 
 public:
 	typedef TNodeContext<CUPnPControlSubConnectionProvider, CoreStates::TContext> TContext;
 	
 	//States
	DECLARE_SMELEMENT_HEADER ( TStopCurrentActivities, TStateTransition<TContext>, NetStateMachine::MStateTransition, CUPnPActivityBase::TContext )
    	virtual void DoL ( );    	
    DECLARE_SMELEMENT_FOOTER ( TStopCurrentActivities)    
   
	//TState Forks
	DECLARE_SMELEMENT_HEADER ( TStopActivityOrStopDataClient, TStateFork<TContext>, NetStateMachine::MStateFork, CUPnPActivityBase::TContext )
		virtual TInt TransitionTag ( );
	DECLARE_SMELEMENT_FOOTER ( TStopActivityOrStopDataClient )	

	//Transitions
	DECLARE_SMELEMENT_HEADER ( TAwaitingResponseToStopActivities, TState<TContext>, NetStateMachine::MState, CUPnPActivityBase::TContext )
		virtual TBool Accept ( );
	DECLARE_SMELEMENT_FOOTER ( TAwaitingResponseToStopActivities )

    DECLARE_AGGREGATED_TRANSITION2(
       TProcessClientLeave,
       TRemoveClient,
       CoreNetStates::TSendLeaveCompleteIfRequest
	   )
	};
//---------------------------------------Control Point Search Request Activity-------------------------------------
class CUPnPSearchActivity: public CUPnPActivityBase							 
	{
public:	    
	static CNodeActivityBase* NewL ( const TNodeActivity& aActivitySig, AMMNodeBase& aNode );
	~CUPnPSearchActivity ( );
     
private:
	CUPnPSearchActivity ( const TNodeActivity& aActivitySig, AMMNodeBase& aNode, TUint aActivitiesCount )
		:CUPnPActivityBase ( aActivitySig, aNode, aActivitiesCount )
	  	{	  	
	  	}		
		
public:
 	typedef TNodeContext<CUPnPControlSubConnectionProvider, CoreStates::TContext> TContext;
 
	//States
	typedef TAwaitingMessageState<TUpnpMessage::TSearchRequest> TAwaitingSearchRequest;

	DECLARE_SMELEMENT_HEADER ( TAwaitingReceiveSearchResponse, TState<TContext>, NetStateMachine::MState, CUPnPSearchActivity::TContext )
	virtual TBool Accept ( );
	DECLARE_SMELEMENT_FOOTER ( TAwaitingReceiveSearchResponse )
	
	typedef TAwaiting2MessagesState<TUpnpMessage::TCancelled, TUpnpMessage::TUPnPSearchResponse> TAwaitingDataClientStopResponse;

	//Transitions
    DECLARE_SMELEMENT_HEADER ( TSendSearchRequest, TStateTransition<TContext>, NetStateMachine::MStateTransition, CUPnPSearchActivity::TContext )
    	virtual void DoL ( );    	
    DECLARE_SMELEMENT_FOOTER ( TSendSearchRequest )    
	
	DECLARE_SMELEMENT_HEADER ( TProcessResponse, TStateTransition<TContext>, NetStateMachine::MStateTransition, CUPnPSearchActivity::TContext )
    	virtual void DoL ( );    	
    DECLARE_SMELEMENT_FOOTER ( TProcessResponse )    

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

	DECLARE_SMELEMENT_HEADER ( TCancelSearchRequest, TStateTransition<TContext>, NetStateMachine::MStateTransition, CUPnPSearchActivity::TContext )
    	virtual void DoL ( );
	DECLARE_SMELEMENT_FOOTER ( TCancelSearchRequest )
 	};

//---------------------------------------Control Point Register Notify Request Activity-------------------------------------
class CUPnPRegisterNotifyActivity: public CUPnPActivityBase							 
	{
public:	    
	static CNodeActivityBase* NewL ( const TNodeActivity& aActivitySig, AMMNodeBase& aNode );
	~CUPnPRegisterNotifyActivity ( );
     
private:
	CUPnPRegisterNotifyActivity ( const TNodeActivity& aActivitySig, AMMNodeBase& aNode, TUint aActivitiesCount )
		:CUPnPActivityBase ( aActivitySig, aNode, aActivitiesCount )
	  	{	  	
	  	}		
		
public:
	typedef TNodeContext<CUPnPControlSubConnectionProvider, CoreStates::TContext> TContext;
 
	//States
	typedef TAwaitingMessageState<TUpnpMessage::TRegisterNotifyRequest> TAwaitingRegisterNotifyRequest;

	DECLARE_SMELEMENT_HEADER ( TAwaitingReceiveNotifivation, TState<TContext>, NetStateMachine::MState, CUPnPRegisterNotifyActivity::TContext )
	virtual TBool Accept ( );
	DECLARE_SMELEMENT_FOOTER ( TAwaitingReceiveNotifivation )
	
	typedef TAwaitingMessageState<TCFDataClient::TStarted> TAwaitingServerStarted;
	typedef TAwaiting2MessagesState<TUpnpMessage::TCancelled, TUpnpMessage::TUPnPSearchResponse> TAwaitingDataClientStopResponse;
	
	//Transitions        
    DECLARE_SMELEMENT_HEADER ( TStartServer, TStateTransition<TContext>, NetStateMachine::MStateTransition, CUPnPRegisterNotifyActivity::TContext )
    	virtual void DoL ( );
    DECLARE_SMELEMENT_FOOTER ( TStartServer )    

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

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

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

 	DECLARE_SMELEMENT_HEADER ( TCleanupActivity, TStateTransition<TContext>, NetStateMachine::MStateTransition, CUPnPRegisterNotifyActivity::TContext )
    	virtual void DoL ( );    	
	DECLARE_SMELEMENT_FOOTER ( TCleanupActivity )
	};

//---------------------------------------Control Point Describe Request Activity-------------------------------------
class CUpnpDescribeActivity: public CUPnPActivityBase
	{
public:
	static CNodeActivityBase* NewL( const TNodeActivity& aActivitySig, AMMNodeBase& aNode );
	~CUpnpDescribeActivity();
	
private:
	CUpnpDescribeActivity( const TNodeActivity& aActivitySig, AMMNodeBase& aNode, TUint aActivityCount )
		:CUPnPActivityBase ( aActivitySig, aNode, aActivityCount )
		{ }
		
public:
	typedef TNodeContext<CUPnPControlSubConnectionProvider, CoreStates::TContext> TContext;
 
 	// States
	typedef TAwaitingMessageState<TUpnpMessage::TDescribeRequest> TAwaitingDescribeRequest;
	
	DECLARE_SMELEMENT_HEADER( TAwaitingErrorOrResponseOrCancel, TState<TContext>, NetStateMachine::MState, CUpnpDescribeActivity::TContext )
		TBool Accept();
	DECLARE_SMELEMENT_FOOTER ( TAwaitingErrorOrResponseOrCancel )

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

	// Transitions
	DECLARE_SMELEMENT_HEADER ( TSendDescribeRequest, TStateTransition<TContext>, NetStateMachine::MStateTransition, CUpnpDescribeActivity::TContext )
		void DoL();
	DECLARE_SMELEMENT_FOOTER( TSendDescribeRequest )

	DECLARE_SMELEMENT_HEADER ( TProcessResponse, TStateTransition<TContext>, NetStateMachine::MStateTransition, CUpnpDescribeActivity::TContext )
		void DoL();
		void Error( TInt aError );
	DECLARE_SMELEMENT_FOOTER ( TProcessResponse )

	DECLARE_SMELEMENT_HEADER ( TReportError, TStateTransition<TContext>, NetStateMachine::MStateTransition, CUpnpDescribeActivity::TContext )
		void DoL();
	DECLARE_SMELEMENT_FOOTER( TReportError )

	DECLARE_SMELEMENT_HEADER ( TCleanupActivity, TStateTransition<TContext>, NetStateMachine::MStateTransition, CUpnpDescribeActivity::TContext )
		void DoL();
	DECLARE_SMELEMENT_FOOTER( TCleanupActivity )

	DECLARE_SMELEMENT_HEADER ( TDataClientStop, TStateTransition<TContext>, NetStateMachine::MStateTransition, CUpnpDescribeActivity::TContext )
    	virtual void DoL ( );    	
	DECLARE_SMELEMENT_FOOTER ( TDataClientStop)    
	};


//---------------------------------------Control Point Subscribe Request Activity-------------------------------------
class CUpnpSubscribeActivity: public CUPnPActivityBase
	{
public:
	static CNodeActivityBase* NewL( const TNodeActivity& aActivitySig, AMMNodeBase& aNode );
	~CUpnpSubscribeActivity();
	
private:
	CUpnpSubscribeActivity( const TNodeActivity& aActivitySig, AMMNodeBase& aNode, TUint aActivityCount )
		:CUPnPActivityBase ( aActivitySig, aNode, aActivityCount )
		{ }
	
public :
	CSubscriptionInfo*  iSubscriptionInfo; // Not owned
	
public: // States	
	typedef TNodeContext<CUPnPControlSubConnectionProvider, CoreStates::TContext> TContext;
 
	typedef TAwaitingMessageState<TUpnpMessage::TSubscribeRequest> TAwaitingSubscribeRequest;
			
	DECLARE_SMELEMENT_HEADER ( TAwaitingErrorOrResponseOrCancel, TState<TContext>, NetStateMachine::MState, CUpnpSubscribeActivity::TContext )
		TBool Accept();
	DECLARE_SMELEMENT_FOOTER ( TAwaitingErrorOrResponseOrCancel )

public: // Transitions
	DECLARE_SMELEMENT_HEADER ( TSendSubscribeRequest, TStateTransition<TContext>, NetStateMachine::MStateTransition, CUpnpSubscribeActivity::TContext )
		void DoL();
	DECLARE_SMELEMENT_FOOTER( TSendSubscribeRequest )

	DECLARE_SMELEMENT_HEADER ( TProcessSubscribeResponse, TStateTransition<TContext>, NetStateMachine::MStateTransition, CUpnpSubscribeActivity::TContext )
		void DoL();
		void Error( TInt aError );
	DECLARE_SMELEMENT_FOOTER ( ProcessSubscribeResponse )

	DECLARE_SMELEMENT_HEADER ( TReportError, TStateTransition<TContext>, NetStateMachine::MStateTransition, CUpnpSubscribeActivity::TContext )
		void DoL();
	DECLARE_SMELEMENT_FOOTER( TReportError )
	
	DECLARE_SMELEMENT_HEADER ( TSendUnsubscribeRequest, TStateTransition<TContext>, NetStateMachine::MStateTransition, CUpnpSubscribeActivity::TContext )
		void DoL();
	DECLARE_SMELEMENT_FOOTER( TSendUnsubscribeRequest )
	
	DECLARE_SMELEMENT_HEADER ( TProcessUnsubscribeResponse, TStateTransition<TContext>, NetStateMachine::MStateTransition, CUpnpSubscribeActivity::TContext )
		void DoL();
	DECLARE_SMELEMENT_FOOTER ( TProcessUnsubscribeResponse )
	};

class CUpnpUnSubscribeActivity: public CUPnPActivityBase
	{
public:
	static CNodeActivityBase* NewL( const TNodeActivity& aActivitySig, AMMNodeBase& aNode );
	~CUpnpUnSubscribeActivity();
		
private:
	CUpnpUnSubscribeActivity( const TNodeActivity& aActivitySig, AMMNodeBase& aNode, TUint aActivityCount )
		:CUPnPActivityBase ( aActivitySig, aNode, aActivityCount )
		{ }
	
private:
	CSubscriptionInfo*  iSubscriptionInfo; // Not Owned
	
public:
	typedef TNodeContext<CUPnPControlSubConnectionProvider, CoreStates::TContext> TContext;

	// States
	DECLARE_SMELEMENT_HEADER ( TAwaitingUnSubscribeRequest, TState<TContext>, NetStateMachine::MState, CUpnpUnSubscribeActivity::TContext )
		TBool Accept();
	DECLARE_SMELEMENT_FOOTER( TAwaitingUnSubscribeRequest )
	
	typedef TAwaiting2MessagesState<TEBase::TError, TUpnpMessage::TResponse> TAwaitingErrorOrResponse;

public: // Transitions				
	DECLARE_SMELEMENT_HEADER ( TSendUnSubscribeRequest, TStateTransition<TContext>, NetStateMachine::MStateTransition, CUpnpUnSubscribeActivity::TContext )
		void DoL();
	DECLARE_SMELEMENT_FOOTER( TSendUnSubscribeRequest )

	DECLARE_SMELEMENT_HEADER ( TProcessResponse, TStateTransition<TContext>, NetStateMachine::MStateTransition, CUpnpUnSubscribeActivity::TContext )
		void DoL();		
	DECLARE_SMELEMENT_FOOTER ( TProcessResponse )
	};

	
class CUpnpNotificationActivity: public CNodeParallelActivityBase
	{
public:
	static CNodeActivityBase* NewL( const TNodeActivity& aActivitySig, AMMNodeBase& aNode );
	~CUpnpNotificationActivity();
	
private:
	CUpnpNotificationActivity( const TNodeActivity& aActivitySig, AMMNodeBase& aNode, TUint aActivityCount );
	
private:
	RBuf8	   iBodyBuf;
	TPtrC8	   iPublisherUrl;
	CTransaction* iTransaction;
	TInt		iResponseStatus;
	
private: // Context
	typedef TNodeContext<CUPnPControlSubConnectionProvider, CoreStates::TContext> TContext;

public: 
	// Transitions
	DECLARE_SMELEMENT_HEADER ( TProcessNotifyRequest, TStateTransition<TContext>, NetStateMachine::MStateTransition, CUpnpNotificationActivity::TContext )
		void DoL();
	DECLARE_SMELEMENT_FOOTER( TProcessNotifyRequest )

	DECLARE_SMELEMENT_HEADER ( TSendResponse, TStateTransition<TContext>, NetStateMachine::MStateTransition, CUpnpNotificationActivity::TContext )
		void DoL();
	DECLARE_SMELEMENT_FOOTER( TSendResponse )	
	};	
 
#endif // UPNPCONTROLSCPRACTIVITIES_H