--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/sipproviderplugins/sipprovider/sipstatemachine/src/StateSessionEstablished.cpp	Tue Feb 02 01:03:15 2010 +0200
@@ -0,0 +1,406 @@
+// Copyright (c) 2005-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:
+// CStateSessionEstablished implementation file.
+// 
+//
+
+/**
+ @file
+ @internalComponent
+*/
+ 
+#include <e32std.h>
+#include <e32base.h>
+
+#include "StateSessionEstablished.h"
+
+CStateSessionEstablished * CStateSessionEstablished::NewL( CSipStateMachine * aStateMachine )
+/**
+Instantiaion static function
+*/
+	{
+	return new(ELeave) CStateSessionEstablished (aStateMachine);
+	}
+
+CStateSessionEstablished::CStateSessionEstablished ( CSipStateMachine * aStateMachine ) :
+CSipStateBase (aStateMachine, TSipHLConsts::EStateSessionEstablished )
+/**
+Constuctor
+*/
+	{
+	iDoneUnSubscribe = EFalse;
+	// Open Logs
+	__FLOG_OPEN(_L8("SipStateMachine"), _L8("StateSessionEstablished"));
+	__FLOG_1(_L("[StateSessionEstablished]:[%x]::CStateSessionEstablished() "), this);
+	}
+
+CStateSessionEstablished::~CStateSessionEstablished ()
+/**
+Destructor
+*/	
+	{
+	// Close Logging
+	__FLOG_0(_L("[StateSessionEstablished]: CStateSessionEstablished::~CStateSessionEstablished()"));
+	__FLOG_CLOSE;
+	}
+	
+CSipStateBase * CStateSessionEstablished::ProcessClientL(TRequestStatus & aStatus)
+/**
+Function which process the request and responses from the client
+*/
+	{
+	__FLOG_1(_L("[StateSessionEstablished]:CStateSessionEstablished[%x]::ProcessClientL()"), this);
+	switch(iClientRequest)
+		{
+		case TSipHLConsts::ERequestUnRegister:
+			{
+			__FLOG_1(_L("[StateSessionEstablished]:CStateSessionEstablished[%x]::ProcessClientL() <<REQUEST UNREGISTER>>"), this);
+			TRAPD(err,iSipSM->SendUnRegisterMessageL());
+			if(err != KErrNone)
+				{
+				iSipSM->SetSIPStimulus(TSipHLConsts::EClientStimulus);
+				iSipSM->SetGeneralError(err);
+				iNext = iSipSM->GetNextState(TSipHLConsts::EStateSessionTerminated);
+				}
+			else
+				{
+				iSipSM->SetSuspendRequest(ETrue);
+				iNext = this;
+				}
+			iSipSM->GetTe()->SetTransaction(iSipSM,iSipSM->GetCommandContext().iClientTx);
+			}
+			break;
+		case TSipHLConsts::ERequestUnSubscribe:
+			{
+			__FLOG_1(_L("[StateSessionEstablished]:CStateSessionEstablished[%x]::ProcessClientL() <<REQUEST UNSUBSCRIBE>>"), this);
+			TRAPD(err,iSipSM->SendUnSubscribeMessageL());
+			if(err != KErrNone)
+				{
+				iSipSM->SetSIPStimulus(TSipHLConsts::EClientStimulus);
+				iSipSM->SetGeneralError(err);
+				iNext = iSipSM->GetNextState(TSipHLConsts::EStateSessionTerminated);
+				}
+			else
+				{
+				iSipSM->SetSuspendRequest(ETrue);
+				iNext = this;
+				}
+			iSipSM->GetTe()->SetTransaction(iSipSM,iSipSM->GetCommandContext().iClientTx);
+			}
+			break;
+		case TSipHLConsts::ERequestAck:
+			{
+			__FLOG_1(_L("[StateSessionEstablished]:CStateSessionEstablished[%x]::ProcessClientL() <<REQUEST ACK>>"), this);
+			TRAPD(err,iSipSM->SendAckForInviteL());
+			if(err != KErrNone)
+				{
+				iSipSM->SetSIPStimulus(TSipHLConsts::EClientStimulus);
+				iSipSM->SetGeneralError(err);
+				iNext = iSipSM->GetNextState(TSipHLConsts::EStateSessionTerminated);
+				}
+			else
+				{
+				iSipSM->SetSuspendRequest(ETrue);
+				iNext = this;
+				iSipSM->CallEstablishedCallback();	
+				}
+			}
+			break;
+		case TSipHLConsts::ERequestBye:
+			{
+			__FLOG_1(_L("[StateSessionEstablished]:CStateSessionEstablished[%x]::ProcessClientL() <<REQUEST BYE>>"), this);
+			TRAPD(err,iSipSM->SendByeL());
+			if(err != KErrNone)
+				{
+				iSipSM->SetSIPStimulus(TSipHLConsts::EClientStimulus);
+				iSipSM->SetGeneralError(err);
+				iNext = iSipSM->GetNextState(TSipHLConsts::EStateSessionTerminated);
+				}
+			else
+				{
+				iSipSM->GetTe()->SetTransaction(iSipSM,iSipSM->GetCommandContext().iClientTx);
+				iSipSM->SetSuspendRequest(ETrue);
+				iNext = this;					
+				}
+			}
+			break;
+		default:
+			{
+			__FLOG_1(_L("[StateSessionEstablished]:CStateSessionEstablished[%x]::ProcessClientL() <<REQUEST DEFAULT>>"), this);
+			if(iReqIdentifier == 1)
+				{
+				iSipSM->SetSuspendRequest(ETrue);
+				iNext = this;
+				}
+			}
+		}
+	TRequestStatus * stat = &aStatus;		
+	User::RequestComplete (stat, KErrNone);
+#ifdef __FLOG_ACTIVE	
+	// This indormation is required only when logging is enabled
+	TSipHLConsts::SIP_STATES	iD = (iNext != NULL)?iNext->GetStateId() : TSipHLConsts::EStateNone;
+	if(iD == TSipHLConsts::EStateNone)
+		{
+		__FLOG_1(_L("[StateSessionEstablished]:CStateSessionEstablished[%x]::ProcessClientL() <<Next State --> NULL>> "), this);
+		}
+	if(iD == TSipHLConsts::EStateSessionIdle)
+		{
+		__FLOG_1(_L("[StateSessionEstablished]:CStateSessionEstablished[%x]::ProcessClientL() <<Next State --> StateIdle>> "), this);
+		}
+	else if(iD == TSipHLConsts::EStateSessionInitiation)
+		{
+		__FLOG_1(_L("[StateSessionEstablished]:CStateSessionEstablished[%x]::ProcessClientL() <<Next State --> StateSessionInitiation>> "), this);
+		}
+	else if(iD == TSipHLConsts::EStateSessionEstablished)
+		{
+		__FLOG_1(_L("[StateSessionEstablished]:CStateSessionEstablished[%x]::ProcessClientL() <<Next State --> StateSessionEstablished>> "), this);
+		}
+	else if(iD == TSipHLConsts::EStateSessionTerminated)
+		{
+		__FLOG_1(_L("[StateSessionEstablished]:CStateSessionEstablished[%x]::ProcessClientL() <<Next State --> StateSessionTerminated>> "), this);	
+		}
+	else
+		{
+		__FLOG_1(_L("[StateSessionEstablished]:CStateSessionEstablished[%x]::ProcessClientL() <<Next State --> Unknown, its a serious error>> "), this);		
+		}
+#endif	
+	return iNext;
+	}
+
+CSipStateBase * CStateSessionEstablished::ProcessServerL( TRequestStatus & aStatus )
+/**
+Function which process the request and responses from the Serevr
+*/
+	{
+	__FLOG_1(_L("[StateSessionEstablished]:CStateSessionEstablished[%x]::ProcessServerL()"), this);
+	TSipMsgBundle SipMsgBundle = iSipSM->GetSipMessageBundle();
+	switch(iServerResponse)
+		{
+		case TSipHLConsts::EResponseNone:
+			{
+			__FLOG_1(_L("[StateSessionEstablished]:CStateSessionEstablished[%x]::ProcessServerL() <<RESPONSE NONE>>"), this);	
+			}
+			break;
+		case TSipHLConsts::EResponseUnRegister: // This means unregister over here
+			{
+			__FLOG_1(_L("[StateSessionEstablished]:CStateSessionEstablished[%x]::ProcessServerL() <<RESPONSE UNREGISTER>>"), this);	
+			if(SipMsgBundle.iStatusCode != 200)
+				{
+				iSipSM->SetSIPError(SipMsgBundle.iStatusCode);
+				}
+			iSipSM->SetSIPStimulus(TSipHLConsts::EClientStimulus);
+			iNext = iSipSM->GetNextState(TSipHLConsts::EStateSessionTerminated);
+			iNext->ResetRequestResponse();
+			}
+			break;
+		case TSipHLConsts::EResponseBye:
+			{
+			__FLOG_1(_L("[StateSessionEstablished]:CStateSessionEstablished[%x]::ProcessServerL() <<RESPONSE BYE>>"), this);	
+			if(SipMsgBundle.iStatusCode != 200)
+				{
+				iSipSM->SetSIPError(SipMsgBundle.iStatusCode);
+				}
+			iSipSM->SetSuspendRequest(EFalse);
+			iSipSM->SetSIPStimulus(TSipHLConsts::EClientStimulus);
+			iNext = iSipSM->GetNextState(TSipHLConsts::EStateSessionTerminated);
+			iNext->ResetRequestResponse();
+			}
+			break;
+		case TSipHLConsts::EResponseSubscribe:
+			{
+			__FLOG_1(_L("[StateSessionEstablished]:CStateSessionEstablished[%x]::ProcessServerL() <<RESPONSE SUBSCRIBE>>"), this);	
+			if(SipMsgBundle.iStatusCode != 200)
+				{
+				iSipSM->SetSIPError(SipMsgBundle.iStatusCode);
+				}
+			// This is For unsubscribe if comes
+			// at this stage
+			// After being unsubscribed wait for a final notify
+			iDoneUnSubscribe = ETrue;
+			iSipSM->SetSuspendRequest(ETrue);
+			iNext = this;
+			iNext->ResetRequestResponse();		
+			}
+			break;
+		default:
+			{
+			__FLOG_1(_L("[StateSessionEstablished]:CStateSessionEstablished[%x]::ProcessServerL() <<RESPONSE DEFAULT>>"), this);	
+			if(iReqIdentifier == 4)
+				{
+				iSipSM->SetSuspendRequest(ETrue);
+				iNext = this;				
+				}
+			}
+		}
+	switch (iServerRequest)
+		{
+		case TSipHLConsts::ERequestNone:
+			{
+			__FLOG_1(_L("[StateSessionEstablished]:CStateSessionEstablished[%x]::ProcessServerL() <<REQUEST NONE>>"), this);	
+			}
+			break;	
+		case TSipHLConsts::ERequestBye:
+			{
+			__FLOG_1(_L("[StateSessionEstablished]:CStateSessionEstablished[%x]::ProcessServerL() <<REQUEST BYE>>"), this);	
+			TRAPD(err,iSipSM->SendByeResponseL());
+			if(err != KErrNone)
+				{
+				iSipSM->SetGeneralError(err);
+				}
+			iSipSM->SetSIPStimulus(TSipHLConsts::EClientStimulus);
+			iNext = iSipSM->GetNextState(TSipHLConsts::EStateSessionTerminated);
+			iNext->ResetRequestResponse();
+			}
+			break;
+		case TSipHLConsts::ERequestAck:
+			{
+			__FLOG_1(_L("[StateSessionEstablished]:CStateSessionEstablished[%x]::ProcessServerL() <<REQUEST ACK>>"), this);	
+			iSipSM->CallEstablishedCallback();
+			}
+			break;
+		case TSipHLConsts::ERequestNotify:
+			{
+			__FLOG_1(_L("[StateSessionEstablished]:CStateSessionEstablished[%x]::ProcessServerL() <<REQUEST NOTIFY>>"), this);	
+			HBufC8 * notificationData = iSipSM->GenerateNotificationData();
+			TRAPD(err,iSipSM->GenerateSubscribeResponseL(iSipSM->GetCommandContext().iServerTx, TSipHLConsts::EResponse200OK));
+			if(err != KErrNone)
+				{
+				iSipSM->SetGeneralError(err);
+				iSipSM->SetSIPStimulus(TSipHLConsts::EClientStimulus);
+				iNext = iSipSM->GetNextState(TSipHLConsts::EStateSessionTerminated);
+				}
+			else
+				{
+				if (iDoneUnSubscribe)
+					{
+					iSipSM->SetSIPStimulus(TSipHLConsts::EClientStimulus);
+					iNext = iSipSM->GetNextState(TSipHLConsts::EStateSessionTerminated);
+					iNext->ResetRequestResponse();
+					}
+				else
+					{
+					iSipSM->SetSuspendRequest(ETrue);
+					iNext = this;
+					iNext->ResetRequestResponse();		
+					}
+				}
+			// we will not call notification to the client as RSubConnection::Stop() will terminate the 
+			// client and we dont have anything to call the event upon
+			// This is against the SIP functionality over here, But this is done in view of the current limitations
+			// of the rsubconnection APIs, In future this needs to be changes with evolving APIs.
+			if(!iDoneUnSubscribe)
+				{
+				iSipSM->CallNotificationCallback(*notificationData);				
+				}
+			// delete Notification Data as not required
+			delete notificationData;
+			notificationData = NULL;
+			}
+			break;
+		default:
+			{
+			__FLOG_1(_L("[StateSessionEstablished]:CStateSessionEstablished[%x]::ProcessServerL() <<REQUEST DEFAULT>>"), this);	
+			if(iReqIdentifier == 2)
+				{
+				iSipSM->SetSuspendRequest(ETrue);
+				iNext = this;					
+				}
+			}
+		}
+	TRequestStatus * stat = &aStatus;
+	User::RequestComplete(stat, KErrNone);
+#ifdef __FLOG_ACTIVE	
+	// This indormation is required only when logging is enabled
+	TSipHLConsts::SIP_STATES	iD = (iNext != NULL)?iNext->GetStateId() : TSipHLConsts::EStateNone;
+	if(iD == KErrNotFound)
+		{
+		__FLOG_1(_L("[StateSessionEstablished]:CStateSessionEstablished[%x]::ProcessServerL() <<Next State --> NULL>> "), this);
+		}
+	if(iD == TSipHLConsts::EStateSessionIdle)
+		{
+		__FLOG_1(_L("[StateSessionEstablished]:CStateSessionEstablished[%x]::ProcessServerL() <<Next State --> StateIdle>> "), this);
+		}
+	else if(iD == TSipHLConsts::EStateSessionInitiation)
+		{
+		__FLOG_1(_L("[StateSessionEstablished]:CStateSessionEstablished[%x]::ProcessServerL() <<Next State --> StateSessionInitiation>> "), this);
+		}
+	else if(iD == TSipHLConsts::EStateSessionEstablished)
+		{
+		__FLOG_1(_L("[StateSessionEstablished]:CStateSessionEstablished[%x]::ProcessServerL() <<Next State --> StateSessionEstablished>> "), this);
+		}
+	else if(iD == TSipHLConsts::EStateSessionTerminated)
+		{
+		__FLOG_1(_L("[StateSessionEstablished]:CStateSessionEstablished[%x]::ProcessServerL() <<Next State --> StateSessionTerminated>> "), this);	
+		}
+	else
+		{
+		__FLOG_1(_L("[StateSessionEstablished]:CStateSessionEstablished[%x]::ProcessServerL() <<Next State --> Unknown, its a serious error>> "), this);		
+		}
+#endif	
+	return iNext;	
+	}
+
+CSipStateBase * CStateSessionEstablished::ProcessServerErrorL(TRequestStatus & aStatus)
+/**
+Handles the Error condition for this state from the server
+*/
+	{
+	__FLOG_1(_L("[StateSessionEstablished]:StateSessionEstablished[%x]::ProcessServerErrorL()"), this);	
+	TSipMsgBundle SipMsgBundle = iSipSM->GetSipMessageBundle();
+	// Call the call back to Notify the client
+	iSipSM->SetGeneralError(SipMsgBundle.iErrCode);
+	iSipSM->SetSIPError(SipMsgBundle.iStatusCode);
+	iSipSM->CallTerminateCallback();
+	iSipSM->SetCallTerminateCallBack(EFalse);
+	// Get to The terminated state
+	iNext = iSipSM->GetNextState(TSipHLConsts::EStateSessionTerminated);
+	iSipSM->SetSIPStimulus(TSipHLConsts::EClientStimulus);
+	if(iNext)
+	{
+	    iNext->ResetRequestResponse();
+	}
+	TRequestStatus * stat = &aStatus;
+	User::RequestComplete(stat, KErrNone);
+#ifdef __FLOG_ACTIVE	
+	// This indormation is required only when logging is enabled
+	TSipHLConsts::SIP_STATES	iD = (iNext != NULL)?iNext->GetStateId() : TSipHLConsts::EStateNone;
+	if(iD == KErrNotFound)
+		{
+		__FLOG_1(_L("[StateSessionEstablished]:StateSessionEstablished[%x]::ProcessServerErrorL() <<Next State --> NULL>> "), this);
+		}
+	if(iD == TSipHLConsts::EStateSessionIdle)
+		{
+		__FLOG_1(_L("[StateSessionEstablished]:StateSessionEstablished[%x]::ProcessServerErrorL() <<Next State --> StateIdle>> "), this);
+		}
+	else if(iD == TSipHLConsts::EStateSessionInitiation)
+		{
+		__FLOG_1(_L("[StateSessionEstablished]:StateSessionEstablished[%x]::ProcessServerErrorL() <<Next State --> StateSessionInitiation>> "), this);
+		}
+	else if(iD == TSipHLConsts::EStateSessionEstablished)
+		{
+		__FLOG_1(_L("[StateSessionEstablished]:StateSessionEstablished[%x]::ProcessServerErrorL() <<Next State --> StateSessionEstablished>> "), this);
+		}
+	else if(iD == TSipHLConsts::EStateSessionTerminated)
+		{
+		__FLOG_1(_L("[StateSessionEstablished]:StateSessionEstablished[%x]::ProcessServerErrorL() <<Next State --> StateSessionTerminated>> "), this);	
+		}
+	else
+		{
+		__FLOG_1(_L("[StateSessionEstablished]:StateSessionEstablished[%x]::ProcessServerErrorL() <<Next State --> Unknown, its a serious error>> "), this);		
+		}
+#endif	
+	return iNext;
+	}
+
+