// 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:
// THIS API IS INTERNAL TO NETWORKING AND IS SUBJECT TO CHANGE AND NOT FOR EXTERNAL USE
// 
//

/**
 @file
 @internalTechnology
 @prototype
*/

#define SYMBIAN_NETWORKING_UPS

#include "netmcprstates.h"
#ifndef SYMBIAN_NETWORKING_UPS
#include "IPMessages.h"
#endif


using namespace NetMCprStates;
using namespace ESock;
using namespace Messages;

#ifdef DUMMY_MOBILITY_MCPR


DEFINE_SMELEMENT(TAwaitingMigrationRejectedOrMigrationAccepted, NetStateMachine::MState, TContext);
TBool TAwaitingMigrationRejectedOrMigrationAccepted::Accept()
	{
	return(iContext.iMessage.IsMessage<TCFMobilityProvider::TMigrationAccepted>() ||
		   iContext.iMessage.IsMessage<TCFMobilityProvider::TMigrationRejected>());
	}

DEFINE_SMELEMENT(TAwaitingMigrationRequestedOrMigrationRejected, NetStateMachine::MState, TContext);
TBool TAwaitingMigrationRequestedOrMigrationRejected::Accept()
	{
	return(iContext.iMessage.IsMessage<TCFMobilityProvider::TMigrationRequested>() ||
		   iContext.iMessage.IsMessage<TCFMobilityProvider::TMigrationRejected>());
	}

DEFINE_SMELEMENT(TMigrationRequestedOrMigrationRejected, NetStateMachine::MStateFork, TContext);
TInt TMigrationRequestedOrMigrationRejected::TransitionTag()
	{
	if (iContext.iMessage.IsMessage<TCFMobilityProvider::TMigrationRequested>())
		return KMigrationRequested;
	else
		return KMigrationRejected;
	}

DEFINE_SMELEMENT(TSendMigrationAvailable, NetStateMachine::MStateTransition, TContext);
void TSendMigrationAvailable::DoL()
	{
	ASSERT(iContext.iMessage.iPeer);
	TCFMessage::TMigrationAvailable msg(iContext.Node()(), KActivityNull, 0xdeadbeef);
	msg.PostTo(iContext.iMessage.iSender);
	}

DEFINE_SMELEMENT(TSendMigrateToAccessPoint, NetStateMachine::MStateTransition, TContext);
void TSendMigrateToAccessPoint::DoL()
	{
	TCFMessage::TMigrateToAccessPoint msg(iContext.Node()(), KActivityNull, 0xdeadbeef);
	msg.PostTo(iContext.iMessage.iSender);
	}

DEFINE_SMELEMENT(TProcessPolicyParams, NetStateMachine::MStateTransition, TContext)
void TProcessPolicyParams::DoL()
    {
	iContext.Node().ProcessPolicyParamsL(message_cast<TCFIPMessage::TPolicyParams>(iContext.iMessage));
    }

#endif // DUMMY_MOBILITY_MCPR

DEFINE_SMELEMENT(TAwaitingPolicyParams, NetStateMachine::MState, TContext)
TBool TAwaitingPolicyParams::Accept()
    {
	return iContext.iMessage.IsMessage<TCFIPMessage::TPolicyParams>();
    }

#ifdef SYMBIAN_NETWORKING_UPS
DEFINE_SMELEMENT(TAwaitingUPSStatusChange, NetStateMachine::MState, TContext)
TBool TAwaitingUPSStatusChange::Accept()
	{
	return iContext.iMessage.IsMessage<UpsMessage::TUPSStatusChange>();
	}
#endif

DEFINE_SMELEMENT(TProcessPolicyParams, NetStateMachine::MStateTransition, TContext)
void TProcessPolicyParams::DoL()
    {
	TCFIPMessage::TPolicyParams& qosPolicyParams = message_cast<TCFIPMessage::TPolicyParams>(iContext.iMessage);

	iContext.Node().ProcessPolicyParamsL(iContext.iSender, qosPolicyParams);
    }

#ifdef SYMBIAN_NETWORKING_UPS

using namespace ESock;

//
// Support for User Prompt Service (UPS)
//

// UPS States

DEFINE_NETMCPR_STATE(NetMCprStates, TAwaitingNoBearerNotFromSelf);

TBool TAwaitingNoBearerNotFromSelf::Accept()
/**
Accept a TNoBearer which has not been self posted from this node.
*/
    {
	if (iContext.iMessage.IsMessage<TCFControlProvider	::TNoBearer>()) 
		{
		// Left hand side must be TRuntimeCtxId to invoke TRuntimeCtxId::operator==(...).
		// Also, there is no TRuntimeCtxId::operator!=(...).
		// @TODO EC120 - we want to compare node ids - is this safe??
		// Do we want to ensure that iContext.iSender is at least as derived as a TNodeId,
		// to avoid comparison of TRuntimeCtxId against TNodeId and not taking into account
		// the node id?
		return (!(iContext.iSender == iContext.Node().Id()));
		}
	else
		{
		return EFalse;
		}
    }

DEFINE_NETMCPR_STATE(NetMCprStates, TAwaitingBindToCompleteOrCancel);

TBool TAwaitingBindToCompleteOrCancel::Accept()
/**
Accept a TNoBearer which has not been self posted from this node.
*/
    {
    CoreNetStates::TAwaitingBindToComplete state(iContext);
    if (state.Accept())
    	{
    	return ETrue;
    	}
    else
	if (iContext.iMessage.IsMessage<TEBase::TCancel>()) 
		{
		iContext.iNodeActivity->SetError(KErrCancel);
		iContext.iMessage.ClearMessageId();		
		}
	return EFalse;
    }

// UPS Transitions

DEFINE_NETMCPR_TRANSITION(NetMCprStates, TSendNoBearerToSelf);

void TSendNoBearerToSelf::DoL()
/**
Self post a TNoBearer
*/
    {
    const TNodeId& self = iContext.Node().Id();
    
	iContext.Activity()->PostRequestTo(self, TCFControlProvider::TNoBearer().CRef());
    }

#endif // SYMBIAN_NETWORKING_UPS