// Copyright (c) 2007-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:
// SIP SubConnection Provider states/transitions
// 
//

/**
 @file
 @internalComponent
*/

#include "sipdeftscpr.h"
#include "sipscpr.h"
#include "sipscprstates.h"



using namespace ESock;
using namespace NetStateMachine;
using namespace SipSCpr;
using namespace SipSCprStates;


//===========================================
//
//	SIP Sub Connection Provider States
//
//===========================================
namespace SipSCprStates
{

//===================================================================================
//
// StartConnection Activity
//
//====================================================================================

DEFINE_SMELEMENT(TNoTagOrAlreadyStarted,NetStateMachine::MStateFork, SipSCprStates::TContext)
DEFINE_SMELEMENT(TStartSession, NetStateMachine::MStateTransition, SipSCprStates::TContext)
DEFINE_SMELEMENT(TAwaitingSessionEstablished,NetStateMachine::MState, SipSCprStates::TContext)

	
TInt TNoTagOrAlreadyStarted::TransitionTag()
	{
	if(iContext.Node().iStage == SipSCpr::EActive)
		{
		return CoreNetStates::KAlreadyStarted;
		}
	return MeshMachine::KNoTag;
	}

void TStartSession::DoL()
	{
	//check error conditions before starting sip session
	TInt stage = iContext.Node().iStage;
	const Messages::TNodeId& self = iContext.Node().NodeId();
	if(stage != SipSCpr::EFresh)
		{
		switch(stage)
			{
			case SipSCpr::EStopped:
				__CFLOG_VAR((KSipSCprTag, KSipSCprSubTag, _L8("Cannot start stopped subconnection")));				
				
            	Messages::RClientInterface::OpenPostMessageClose(self,Messages::TNodeCtxId(ECFActivityStart,self),TSipSCprMessages::TSipSessionEstablished(KErrAbort).CRef());	
				break;
			case SipSCpr::EStopping:
				__CFLOG_VAR((KSipSCprTag, KSipSCprSubTag, _L8("Cannot start stopping subconnection")));				
            	Messages::RClientInterface::OpenPostMessageClose(self,Messages::TNodeCtxId(ECFActivityStart,self),TSipSCprMessages::TSipSessionEstablished(KErrAbort).CRef());	
				break;
			}
		}		
	
	//In the case of SIP SubConnection, the session params should be be set before we start a call.
	TSipParams& sipParams = iContext.Node().iSipSm->GetSipParams();
	// Check should be made only to non-incoming request. For incoming request the 
	// sipParams won't be set in SIP SCPR. The incoming params will be saved in iParameterBundle
	TInt err;		
	if(!(iContext.Node().iAwaitingSubConnection) && sipParams.iRequest == TSipHLConsts::ERequestNone)
		{
		__CFLOG_VAR((KSipSCprTag, KSipSCprSubTag, _L8("Cannot start SIP subconnection if Params are notset")));
		err = KErrNotSupported;		
		}
		else
		{				
		if (iContext.Node().subconType == RSubConnection::EWaitIncoming)
        	{    	
    		__CFLOG_VAR((KSipSCprTag, KSipSCprSubTag, _L8("appears to be an incoming call subconection, accepting")));
        	err = iContext.Node().iSipSm->AcceptCall();        
        	}
        	else
        	{        
        	err = iContext.Node().iSipSm->StartCall();			        	
        	}		
		}
			
	if (KErrNone != err)
     	{
     	__CFLOG_VAR((KSipSCprTag, KSipSCprSubTag, _L8("Cannot start SIP subconnection if Params are notset")));       	
       	Messages::RClientInterface::OpenPostMessageClose(self,Messages::TNodeCtxId(ECFActivityStart,self),TSipSCprMessages::TSipSessionEstablished(err).CRef());	
		}
	//Expect Response
	iContext.Node().iActivityAwaitingResponse = iContext.iNodeActivity->ActivityId();       
    iContext.iNodeActivity->SetPostedTo(iContext.Node().NodeId());
	iContext.Node().iStage = SipSCpr::EStarting;
	}	

TBool TAwaitingSessionEstablished::Accept()
	{
	if(iContext.iMessage.IsMessage<TSipSCprMessages::TSipSessionEstablished>())	
		{
		TSipSCprMessages::TSipSessionEstablished* msg = Messages::message_cast<TSipSCprMessages::TSipSessionEstablished>(&iContext.iMessage);
		if (msg->iValue == KErrNone)
			{
			// This means we have a successful session
			iContext.Node().iStage = SipSCpr::EActive;
			return ETrue;
			}
			else
			{
			//session start failed
			//Set the error for activity and will be cleared using TClearError
			TInt error = msg->iValue;
			iContext.iNodeActivity->SetError(error);
			return ETrue;							
			}
		}
	
	return EFalse;
	}

//========================================================================================================
//
// Stop Activiity
//
//========================================================================================================

DEFINE_SMELEMENT(TNoTagOrAlreadyStopped, NetStateMachine::MStateFork, SipSCprStates::TContext)
DEFINE_SMELEMENT(TStopSession, NetStateMachine::MStateTransition, SipSCprStates::TContext)
DEFINE_SMELEMENT(TAwaitingSessionTerminated,NetStateMachine::MState, SipSCprStates::TContext)


TInt TNoTagOrAlreadyStopped::TransitionTag()
	{

	//iStage defined only for non-deft SCPR
	TInt stage = iContext.Node().iStage;
	if (iContext.Node().iStage && iContext.Node().iStage >= SipSCpr::EStopping)
		{
		return CoreNetStates::KAlreadyStopped;	
		}
		return MeshMachine::KNoTag;
	}

void TStopSession::DoL()
	{
	__CFLOG_VAR((KSipSCprTag, KSipSCprSubTag, _L8("AStopSession::DoL")));		

	//there's no need to check message type before casting as it should've been checked
	//by the State::Accept() => cast & assert if not the desired type
	iContext.Node().iStopCode = Messages::message_cast<TCFServiceProvider::TStop>(iContext.iMessage).iValue;
	TInt err;	
	
	if (iContext.Node().iStage == SipSCpr::EFresh)
	{
		err = KErrNotReady;
	}
	//If this is an incoming call that hasn't been accepted yet. We should
	//reject it. Otherwise we should just stop it.
	else if (iContext.Node().iAwaitingSubConnection && iContext.Node().iStage == SipSCpr::EStarting)
        {
    	err = iContext.Node().iSipSm->RejectCall();
        }
    else
        {
    	err = iContext.Node().iSipSm->StopCall();
        }
    
    if (KErrNone != err)
     	{
     	__CFLOG_VAR((KSipSCprTag, KSipSCprSubTag, _L8("Cannot stop SIP subconnection if Params are notset")));
       	const Messages::TNodeId& self = iContext.Node().NodeId();
       	Messages::RClientInterface::OpenPostMessageClose(self,Messages::TNodeCtxId(ECFActivityStop,self),TSipSCprMessages::TSipSessionTerminated(err).CRef());	
		}
		
    iContext.Node().iActivityAwaitingResponse = iContext.iNodeActivity->ActivityId();    
    iContext.iNodeActivity->SetPostedTo(iContext.Node().NodeId());
    iContext.Node().iStage = SipSCpr::EStopping;
	}
	
TBool TAwaitingSessionTerminated::Accept()
	{		
	if(iContext.iMessage.IsMessage<TSipSCprMessages::TSipSessionTerminated>())	
		{
		TSipSCprMessages::TSipSessionTerminated* msg = Messages::message_cast<TSipSCprMessages::TSipSessionTerminated>(&iContext.iMessage);
		if (msg->iValue == KErrNone)
			{							
			iContext.Node().iStage = SipSCpr::EStopped;
			return ETrue;
			}		
		else
			{
			//Set the error for activity and will be cleared using TClearError
			TInt error = msg->iValue;
			iContext.iNodeActivity->SetError(error);
			return ETrue;			
			}		
	}
	return EFalse;
	}	


//=================================================================================================
//
//Set Params
//
//==================================================================================================

DEFINE_SMELEMENT(TSetParameters,NetStateMachine::MStateTransition, SipSCprStates::TContext)
void TSetParameters::DoL()
    {	
	TRAPD(err, iContext.Node().DoParametersAboutToBeSetL(iContext.Node().iParameterBundle));
	if(KErrNone != err)
		{
		__CFLOG_VAR((KSipSCprTag, KSipSCprSubTag, _L8("call to DoParemetersAboutToBeSet failed in ASetParameters::DoL() [error=%d]"), err));
		User::Leave(err);
		}
#ifdef SYMBIAN_ADAPTIVE_TCP_RECEIVE_WINDOW
    iContext.PostToSender(TCFScpr::TSetParamsResponse(iContext.Node().iParameterBundle).CRef());
#else
    iContext.PostToSender(TCFScpr::TParamsResponse(iContext.Node().iParameterBundle).CRef());
#endif //SYMBIAN_ADAPTIVE_TCP_RECEIVE_WINDOW
    }



DEFINE_SMELEMENT(TStoreProvision, NetStateMachine::MStateTransition, SipSCprStates::TContext)
void TStoreProvision::DoL()
	{
	__CFLOG_VAR((KSipSCprTag, KSipSCprSubTag, _L8("AStoreProvision::DoL()")));
	PRStates::TStoreProvision storeProvision(iContext);
	storeProvision.DoL();	
	  		
	const TSipCprProvisionInfo* ext = static_cast<const TSipCprProvisionInfo*>(iContext.Node().AccessPointConfig().FindExtension(STypeId::CreateSTypeId(TSipCprProvisionInfo::EUid, TSipCprProvisionInfo::ETypeId)));
	if (ext)
    	{
    	iContext.Node().iTransitionEngine = ext->iTransitionEngine;    	
    	iContext.Node().iFromField = ext->iFromField;
    	
    	// Set the falg for WaitForIncoming connection   	
    	if (iContext.Node().iAwaitingSubConnection)
    		{
    		iContext.Node().iActivityAwaitingResponse = iContext.ActivityId();
    		}    	    	
    	// Create the SIP state machine
    	iContext.Node().CreateStateMachineL();
    	__CFLOG_VAR((KSipSCprTag, KSipSCprSubTag, _L8("CSipSubConnectionProvider::TStoreProvision() [this=%08x]\t -- SIP State Machine created "), this));
    		
        }
	}   
}//namespace SipSCprStates