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

/**
 @file
 @internalComponent
*/

#include <comms-infras/corescpractivities.h>
#include <comms-infras/ss_coreprstates.h>
#include "ipscprstates.h"
#include "ipscprlog.h"

using namespace Messages;
using namespace ESock;
using namespace IpSCprStates;
using namespace MeshMachine;
using namespace CorePanics;

#if _DEBUG
_LIT(KIpSCprPanic, "IpSCprPanic");
#endif

//-=========================================================
//
// Activities
//
//-=========================================================

//-=========================================================
//
//States
//
//-=========================================================
DEFINE_SMELEMENT(TAwaitingJoinComplete, NetStateMachine::MState, IpSCprStates::TContext)
TBool TAwaitingJoinComplete::Accept()
    {
	__IPCPRLOG(IpCprLog::Printf(_L("TAwaitingJoinComplete::Accept [%08x]"), this));
	return iContext.iMessage.IsMessage<TCFPeer::TJoinComplete>();
    }
//-=========================================================
//
//State Forks
//
//-=========================================================

DEFINE_SMELEMENT(TNoTagOrSendApplyResponseOrErrorTag, NetStateMachine::MStateFork, IpSCprStates::TContext)
TInt TNoTagOrSendApplyResponseOrErrorTag::TransitionTag()
	{
	__IPCPRLOG(IpCprLog::Printf(_L("TNoTagSendApplyResponseOrErrorTag::TransitionTag [%08x]"), this));

	RIPDataClientNodeInterface* client = static_cast<RIPDataClientNodeInterface*>(
	    iContext.Node().GetFirstClient<TDefaultClientMatchPolicy>(TClientType(TCFClientType::EData, TCFClientType::EJoining)));

	if (!client)
    	{
    	return SCprActivities::Apply::ESendApplyResponse;
    	}

	TInt err = iContext.Node().AddressCompletionValidation(*client);
	if( KErrNone == err )
		{
		return KNoTag;
		}
	
	iContext.iNodeActivity->SetError(err);
	
    return KErrorTag;
	}

DEFINE_SMELEMENT(TNoTagOrSendApplyResponse, NetStateMachine::MStateFork, IpSCprStates::TContext)
TInt TNoTagOrSendApplyResponse::TransitionTag()
	{
	__IPCPRLOG(IpCprLog::Printf(_L("TNoTagOrSendApplyResponse::TransitionTag [%08x]"), this));

	if (iContext.Node().GetFirstClient<TDefaultClientMatchPolicy>(TClientType(TCFClientType::EData, TCFClientType::EJoining)) == NULL)
    	{
    	return SCprActivities::Apply::ESendApplyResponse;
    	}

    return KNoTag;
	}

DEFINE_SMELEMENT(TNoTagOrDoNothingTag, NetStateMachine::MStateFork, IpSCprStates::TContext)
TInt TNoTagOrDoNothingTag::TransitionTag()
	{
	__IPCPRLOG(IpCprLog::Printf(_L("TNoTagOrNoBearerOrDoNothingTag::TransitionTag [%08x]"), this));

	RIPDataClientNodeInterface* client =
	    static_cast<RIPDataClientNodeInterface*>(iContext.iPeer);

	if(!(client->Flags() & TCFClientType::EJoining)
		&& (KErrNone == iContext.Node().AddressCompletionValidation(*client)) )
		{
		return KNoTag;
		}

	return KDoNothingTag;
	}

DEFINE_SMELEMENT(TDoNothingTag, NetStateMachine::MStateFork, IpSCprStates::TContext)
TInt TDoNothingTag::TransitionTag()
	{
	return KDoNothingTag;
	}

DEFINE_SMELEMENT(TNoTagOrAlreadyStarted, NetStateMachine::MStateFork, IpSCprStates::TContext)
TInt TNoTagOrAlreadyStarted::TransitionTag()
    {
    __ASSERT_DEBUG(iContext.iPeer || iContext.iSender == iContext.NodeId(), User::Panic(KIpSCprPanic,KPanicPeerMessage));
	if (iContext.Node().GetFirstClient<TDefaultClientMatchPolicy>(TClientType(TCFClientType::EServProvider, TCFClientType::EStarted)) != NULL)
		{
		// check Params
		RCFParameterFamilyBundleC& bundle = iContext.Node().GetOrCreateParameterBundleL();
		TInt num,i;
        num = bundle.CountParameterSets();
        STypeId typeId = STypeId::CreateSTypeId( CSubConIPAddressInfoParamSet::EUid,
                                                CSubConIPAddressInfoParamSet::ETypeId );
        for(i=0; i<num; i++)
            {
            RParameterFamily family = bundle.GetFamilyAtIndex(i);
            if (family.IsNull())
                {
                continue;
                }
            else if(family.FindParameterSet(typeId,RParameterFamily::ERequested)!= NULL)
                {
                return CoreNetStates::KAlreadyStarted;
                }
            }
		}
	
    return MeshMachine::KNoTag;
    }
//-=========================================================
//
//Transitions
//
//-=========================================================

#ifndef SYMBIAN_ADAPTIVE_TCP_RECEIVE_WINDOW
DEFINE_SMELEMENT(TSendParamsToServiceProvider, NetStateMachine::MStateTransition, IpSCprStates::TContext)
void TSendParamsToServiceProvider::DoL()
	{
	__IPCPRLOG(IpCprLog::Printf(_L("TSendParamsToServiceProvider::DoL [%08x]"), this));

	iContext.iNodeActivity->PostRequestTo(*iContext.Node().ServiceProvider(),
	    TCFScpr::TParamsRequest(iContext.Node().iParameterBundle).CRef());
	}
#endif // SYMBIAN_ADAPTIVE_TCP_RECEIVE_WINDOW

DEFINE_SMELEMENT(TSendSelfStart, NetStateMachine::MStateTransition, IpSCprStates::TContext)
void TSendSelfStart::DoL()
	{
	__IPCPRLOG(IpCprLog::Printf(_L("TSendSelfStart::DoL [%08x]"), this));

	__ASSERT_DEBUG(iContext.iNodeActivity, User::Panic(KIpSCprPanic, KPanicNoActivity));
    iContext.iNodeActivity->PostRequestTo(iContext.NodeId(),
    	TCFServiceProvider::TStart().CRef());
	}

DEFINE_SMELEMENT(TSetJoiningFlag, NetStateMachine::MStateTransition, IpSCprStates::TContext)
void TSetJoiningFlag::DoL()
	{
	RIPDataClientNodeInterface* client =
	    static_cast<RIPDataClientNodeInterface*>(iContext.iPeer);

	ASSERT(client);

	client->SetFlags(TCFClientType::EJoining);
   }

DEFINE_SMELEMENT(TClearJoiningFlag, NetStateMachine::MStateTransition, IpSCprStates::TContext)
void TClearJoiningFlag::DoL()
	{
	RIPDataClientNodeInterface* client = static_cast<RIPDataClientNodeInterface*>(
	    iContext.Node().GetFirstClient<TDefaultClientMatchPolicy>(TClientType(TCFClientType::EData, TCFClientType::EJoining)));

	ASSERT(client);

	client->ClearFlags(TCFClientType::EJoining);
   }

DEFINE_SMELEMENT(TPrepareToAddClientToQosChannel, NetStateMachine::MStateTransition, IpSCprStates::TContext)
void TPrepareToAddClientToQosChannel::DoL()
	{
	RIPDataClientNodeInterface* client =
	    static_cast<RIPDataClientNodeInterface*>(iContext.iPeer);

	if (client && !(client->Flags() & TCFClientType::EJoining))
	   {
	   client->SetFlags(TCFClientType::EJoining);

	   IpSCprStates::TAddClientToQosChannel addToChannel(iContext);
	   TRAPD(err, addToChannel.DoL();)

	   client->ClearFlags(TCFClientType::EJoining);

	   User::LeaveIfError(err);
	   }
   }

DEFINE_SMELEMENT(TAddClientToQosChannel, NetStateMachine::MStateTransition, IpSCprStates::TContext)
void TAddClientToQosChannel::DoL()
	{
	__IPCPRLOG(IpCprLog::Printf(_L("TAddClientToQosChannel::DoL [%08x]"), this));

	RIPDataClientNodeInterface* clientToBeAdded = static_cast<RIPDataClientNodeInterface*>(
	    iContext.Node().GetFirstClient<TDefaultClientMatchPolicy>(TClientType(TCFClientType::EData, TCFClientType::EJoining)));
	ASSERT(clientToBeAdded);


	if (KErrNone == iContext.Node().AddressCompletionValidation(*clientToBeAdded) )
		{
		CSubConIPAddressInfoParamSet* IPAdressInfoParamSet = iContext.Node().InitBundleL();

		if(IPAdressInfoParamSet)
			{
			// add Param info
			IPAdressInfoParamSet->AddParamInfo(CSubConIPAddressInfoParamSet::TSubConIPAddressInfo(clientToBeAdded->iCliSrcAddr, clientToBeAdded->iCliDstAddr, clientToBeAdded->iProtocolId, CSubConIPAddressInfoParamSet::TSubConIPAddressInfo::EAdd));
			__IPCPRLOG(IpCprLog::Printf(_L("SubConIPAddressParamInfo is added")));
			}
		else
			{
			// InitBundleL is already solving this
			User::Leave(KErrArgument);
			}

		// kick start
		ASSERT(iContext.iNodeActivity);
		iContext.iNodeActivity->PostRequestTo(iContext.NodeId(), TCFServiceProvider::TStart().CRef());

		__IPCPRLOG(IpCprLog::Printf(_L("TPrepareToAddClientToQosChannel::DoL [%08x], ActivityId=[%08x]"), this, iContext.iNodeActivity->ActivityId()));
		}

	}

DEFINE_SMELEMENT(TCreateAddressInfoBundle, NetStateMachine::MStateTransition, IpSCprStates::TContext)
void TCreateAddressInfoBundle::DoL()
	{
	RIPDataClientNodeInterface* dataClient =
	    static_cast<RIPDataClientNodeInterface*>(iContext.iPeer);

	ASSERT(dataClient);

	CSubConIPAddressInfoParamSet* IPAdressInfoParamSet = iContext.Node().InitBundleL();

	if(IPAdressInfoParamSet)
		{
		// add Param info
		IPAdressInfoParamSet->AddParamInfo(CSubConIPAddressInfoParamSet::TSubConIPAddressInfo(dataClient->iCliSrcAddr, dataClient->iCliDstAddr, dataClient->iProtocolId, CSubConIPAddressInfoParamSet::TSubConIPAddressInfo::EAdd));
		__IPCPRLOG(IpCprLog::Printf(_L("SubConIPAddressParamInfo is added")));
		}
	}

DEFINE_SMELEMENT(TCreateAddressInfoBundleFromJoiningClient, NetStateMachine::MStateTransition, IpSCprStates::TContext)
void TCreateAddressInfoBundleFromJoiningClient::DoL()
	{
	RIPDataClientNodeInterface* clientToBeAdded = static_cast<RIPDataClientNodeInterface*>(
	    iContext.Node().GetFirstClient<TDefaultClientMatchPolicy>(TClientType(TCFClientType::EData, TCFClientType::EJoining)));
	ASSERT(clientToBeAdded);

	CSubConIPAddressInfoParamSet* IPAdressInfoParamSet = iContext.Node().InitBundleL();

	if(IPAdressInfoParamSet)
		{
		// add Param info
		IPAdressInfoParamSet->AddParamInfo(CSubConIPAddressInfoParamSet::TSubConIPAddressInfo(clientToBeAdded->iCliSrcAddr, clientToBeAdded->iCliDstAddr, clientToBeAdded->iProtocolId, CSubConIPAddressInfoParamSet::TSubConIPAddressInfo::EAdd));
		__IPCPRLOG(IpCprLog::Printf(_L("SubConIPAddressParamInfo is added")));
		}
	}