// 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 __UPNPSERVICESCPRACTIVITIES_H
#define __UPNPSERVICESCPRACTIVITIES_H

// System Include
#include <comms-infras/corescpractivities.h>

// User Include
#include "upnpservicescpr.h"

using namespace ESock;
using namespace MeshMachine;

namespace UPnPServiceSCprActivities
	{
	DECLARE_ACTIVITY_MAP(activityMap)
	
		
	//-------------------New Service Registration using SCRP----------------------------
	class CUpnpServiceRegistrationActivity: public CNodeActivityBase
		{
	public:
		static CNodeActivityBase* NewL ( const TNodeActivity& aActivitySig, AMMNodeBase& aNode );
		~CUpnpServiceRegistrationActivity ( );
				
	private:
		CUpnpServiceRegistrationActivity ( const TNodeActivity& aActivitySig, AMMNodeBase& aNode );			
		
		void GenerateServiceIdL ( CStringPoolManager& aStringPoolMgr, const TDesC8& aUri, RBuf8& aServiceId );
		void CreateRelativeUrlL ( const TDesC8& aServiceId, const TDesC8& aUri, RBuf8& aResultUrl );
		
	private:
		CUPnPServiceRegisterParamSet*	iParamSet;
		CUPnPServiceInfo*				iServiceInfo; // Dont delete ownership will be passed to CPR		
		
	public:			
		typedef TNodeContext<CUPnPServiceSubConnectionProvider, CoreStates::TContext> TContext;
	
		// States
		typedef TAwaitingMessageState<TUpnpMessage::TServiceRegistration> TAwaitingServiceRegistration;
				
		
		//Transitions
		DECLARE_SMELEMENT_HEADER ( TRequestServiceJoin, TStateTransition<TContext>, NetStateMachine::MStateTransition, TContext )
			void DoL ( );
		DECLARE_SMELEMENT_FOOTER ( TRequestServiceJoin )
		
		DECLARE_SMELEMENT_HEADER ( TBuildPublishAndServiceInfo, TStateTransition<TContext>, NetStateMachine::MStateTransition, TContext )
			void DoL ( );
		DECLARE_SMELEMENT_FOOTER ( TBuildPublishAndServiceInfo )
		
		DECLARE_SMELEMENT_HEADER ( TRegisterServiceInfoWithCPR, TStateTransition<TContext>, NetStateMachine::MStateTransition, TContext )
			void DoL ( );
		DECLARE_SMELEMENT_FOOTER ( TRegisterServiceInfoWithCPR )
		
		DECLARE_SMELEMENT_HEADER ( TSendPublishRequest, TStateTransition<TContext>, NetStateMachine::MStateTransition, TContext )
			void DoL ( );
		DECLARE_SMELEMENT_FOOTER ( TSendPublishRequest )
		
		DECLARE_SMELEMENT_HEADER ( TRegisterSsdpInfoWithServer, TStateTransition<TContext>, NetStateMachine::MStateTransition, TContext )
			void DoL ( );
		DECLARE_SMELEMENT_FOOTER ( TRegisterSsdpInfoWithServer )
				
		DECLARE_SMELEMENT_HEADER ( TInitiateTcpFlowCreation, TStateTransition<TContext>, NetStateMachine::MStateTransition, TContext )
			void DoL ( );
		DECLARE_SMELEMENT_FOOTER ( TInitiateTcpFlowCreation )
				
		};
			
	
	//-------------------New Device Registration using SCRP----------------------------
	class CUpnpDeviceRegistrationActivity: public CNodeActivityBase			
		{
	public:
		static CNodeActivityBase* NewL ( const TNodeActivity& aActivitySig, AMMNodeBase& aNode );
		~CUpnpDeviceRegistrationActivity ( );
				
	private:
		CUpnpDeviceRegistrationActivity ( const TNodeActivity& aActivitySig, AMMNodeBase& aNode );		

	private:
		CUPnPDeviceRegisterParamSet *iParamSet;
		CUPnPDevice*				iDeviceInfo; // Dont delete ownership will be passed to CPR
		RBuf8						iIconUrl;
		TInt						iIconUrlIdx;
	public:
		typedef TNodeContext<CUPnPServiceSubConnectionProvider, CoreStates::TContext> TContext;
	
		// States 		
		typedef TAwaitingMessageState<TUpnpMessage::TDeviceRegistration> TAwaitingDeviceRegistration;
		
		// Transitions
		DECLARE_SMELEMENT_HEADER ( TRequestDeviceJoin, TStateTransition<TContext>, NetStateMachine::MStateTransition, TContext )
			void DoL ( );
		DECLARE_SMELEMENT_FOOTER ( TRequestDeviceJoin )
		
		DECLARE_SMELEMENT_HEADER ( TBuildPublishAndDeviceInfo, TStateTransition<TContext>, NetStateMachine::MStateTransition, TContext )
			void DoL ( );
		DECLARE_SMELEMENT_FOOTER ( TBuildPublishAndDeviceInfo )
		
		DECLARE_SMELEMENT_HEADER ( TRegisterDeviceInfoWithCPR, TStateTransition<TContext>, NetStateMachine::MStateTransition, TContext )
			void DoL ( );
		DECLARE_SMELEMENT_FOOTER ( TRegisterDeviceInfoWithCPR )
		
		DECLARE_SMELEMENT_HEADER ( TSendPublishRequest, TStateTransition<TContext>, NetStateMachine::MStateTransition, TContext )
			void DoL ( );
		DECLARE_SMELEMENT_FOOTER ( TSendPublishRequest )
		
		DECLARE_SMELEMENT_HEADER ( TRegisterSsdpInfoWithServer, TStateTransition<TContext>, NetStateMachine::MStateTransition, TContext )
			void DoL ( );
			void RegisterForMSearchL ( const TDesC8& aSearchTarget );
		DECLARE_SMELEMENT_FOOTER ( TRegisterSsdpInfoWithServer )	
		
		DECLARE_SMELEMENT_HEADER ( TCreateIconFlow, TStateTransition<TContext>, NetStateMachine::MStateTransition, TContext )
			void DoL ();
		DECLARE_SMELEMENT_FOOTER ( TCreateIconFlow )
				
		// StateForks
		DECLARE_SMELEMENT_HEADER ( TIconCreateOrNoTag, TStateFork<TContext>, NetStateMachine::MStateFork, TContext )
			TInt TransitionTag ();
		DECLARE_SMELEMENT_FOOTER ( TIconCreateOrNoTag )
		
		DECLARE_SMELEMENT_HEADER ( TIconOrNoTag, TStateFork<TContext>, NetStateMachine::MStateFork, TContext )
			TInt TransitionTag ();
		DECLARE_SMELEMENT_FOOTER ( TIconOrNoTag )
		};
							
	
	//-------------------TCP ( Get/Subscribe/UnSubscribe ) Response Activity----------------------------
	class CUpnpSPRequestInfoActivity: public CNodeActivityBase
		{
	public:
		static CNodeActivityBase* NewL ( const TNodeActivity& aActivitySig, AMMNodeBase& aNode );
		
		~CUpnpSPRequestInfoActivity ( );
			
	private:
		CUpnpSPRequestInfoActivity::CUpnpSPRequestInfoActivity ( const TNodeActivity& aActivitySig, AMMNodeBase& aNode )
		: CNodeActivityBase ( aActivitySig, aNode )
		{  }
				
		TInt HandleSubscribeRequestL ( CRequest& aRequest, TSubsribeResponseInfo& aSubscribeResponse, CUPnPPublishInfoElement& aPublishInfo );
		void ProcessCallBackUrlL ( const TDesC8& aUrl, CUPnPSubscribeInfoElement* aSubscribeElement );
		
		TInt HandleResubscribeRequestL ( CRequest& aRequest, TSubsribeResponseInfo& aSubscribeResponse, CUPnPPublishInfoElement& aPublishInfo );			
		TInt GetHeaderValue ( CRequest& aRequest, TInt aFieldIndex, THTTPHdrVal& aFieldVal, const TStringTable& aTable );
			
	private: // Context
		typedef TNodeContext<CUPnPServiceSubConnectionProvider, CoreStates::TContext> TContext;								

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

		DECLARE_SMELEMENT_HEADER ( TSendSubscribeResponse, TStateTransition<TContext>, NetStateMachine::MStateTransition, TContext )
			void DoL ( );
			TBool IsFirstSubscription ( );		
		DECLARE_SMELEMENT_FOOTER ( TSendSubscribeResponse )
		
		DECLARE_SMELEMENT_HEADER ( TSendUnsubscribeResponse, TStateTransition<TContext>, NetStateMachine::MStateTransition, TContext )
			void DoL ( );
			TBool IsLastSubscription ( );		
		DECLARE_SMELEMENT_FOOTER ( TSendUnsubscribeResponse )				
		};
		
		
	class CNotifyFlowFinder: public CNodeParallelActivityBase
		{
	public:
		static CNodeActivityBase* NewL ( const TNodeActivity& aActivitySig, AMMNodeBase& aNode );
		~CNotifyFlowFinder ( );
		
	private:
		CNotifyFlowFinder ( const TNodeActivity& aActivitySig, AMMNodeBase& aNode, TUint aActivityCount );
		
	private:
		CUPnPSubscribeInfoElement*	iSubscribeInfo; // don't delete, not owned
	
		// Context
		typedef TNodeContext<CUPnPServiceSubConnectionProvider, CoreStates::TContext> TContext;
	
	public:
		// States
		typedef TAwaitingMessageState<TUpnpMessage::TCreateNotifyFlow> TAwaitingFlowCreationRequest;
	
		// Transitions
		DECLARE_SMELEMENT_HEADER ( TFindOrCreateFlow, TStateTransition<TContext>, NetStateMachine::MStateTransition, CNotifyFlowFinder::TContext )
			void DoL ( );
		DECLARE_SMELEMENT_FOOTER ( TFindOrCreateFlow )
	
		DECLARE_SMELEMENT_HEADER ( TProcessDataClient, TStateTransition<TContext>, NetStateMachine::MStateTransition, CNotifyFlowFinder::TContext )
			void DoL ( );
		DECLARE_SMELEMENT_FOOTER ( TProcessDataClient )
		};
		
		
	class CUpnpEventNotificationActivity: public CNodeParallelActivityBase
		{
	public:
		static CNodeActivityBase* NewL ( const TNodeActivity& aActivitySig, AMMNodeBase& aNode );
		~CUpnpEventNotificationActivity ( ) 
		{ }
		
	private:
		CUpnpEventNotificationActivity ( const TNodeActivity& aActivitySig, AMMNodeBase& aNode, TUint aActivityCount );
		
	private:		
		// Context
		typedef TNodeContext<CUPnPServiceSubConnectionProvider, CoreStates::TContext> TContext;
		
	public: 
		// States
		typedef TAwaitingMessageState<TUpnpMessage::TNotifyRequest> TAwaitingNotifyRequest;
		typedef TAwaiting2MessagesState<TEBase::TError, TUpnpMessage::TResponse> TAwaitingErrorOrResponse;
			
		// Transitions		
		DECLARE_SMELEMENT_HEADER ( TSendRequest, TStateTransition<TContext>, NetStateMachine::MStateTransition, CUpnpEventNotificationActivity::TContext )
			void DoL ( );
		DECLARE_SMELEMENT_FOOTER ( TSendRequest )			
		};	
	}

#endif // UPNPSERVICESCPRACTIVITIES_H