// Copyright (c) 2007-2010 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:

//

#include <elements/mm_activities.h>

#include <elements/mm_states.h>

#include "MMExample1states.h"

#include "MMExample1nodes.h"

_LIT8(KLoggingTag, "MMExample1");

enum TMMExample1ActivityIds

	{

	ETimerActivity = 1,

	ETrafficLightActivity = 2,

	ETrafficLightControllerActivity = 3

	};

namespace ClockActivities

{

DECLARE_DEFINE_CUSTOM_NODEACTIVITY(ETimerActivity, Timer, TWait, Clock::CTimerActivity::NewL)

    FIRST_NODEACTIVITY_ENTRY(MeshMachine::TAwaitingMessageState<TWait>, MeshMachine::TNoTag)

    NODEACTIVITY_ENTRY(MeshMachine::KNoTag, Clock::TKickOffTimer, MeshMachine::TAwaitingMessageState<TGo>, MeshMachine::TNoTag)

    LAST_NODEACTIVITY_ENTRY(MeshMachine::KNoTag, MeshMachine::TForwardMessageToOriginators)

NODEACTIVITY_END()

}

DECLARE_DEFINE_ACTIVITY_MAP(ClockActivityMap)

    ACTIVITY_MAP_ENTRY(ClockActivities, Timer)

ACTIVITY_MAP_END()

CClock::CClock() : MeshMachine::AMMNodeBase(ClockActivityMap::iSelf, Messages::ANodeId::Id())

	{

	NM_LOG_NODE_CREATE(KLoggingTag, CClock);

	}

void CClock::ReceivedL(const Messages::TRuntimeCtxId& aSender, const Messages::TNodeId& aRecipient, Messages::TSignatureBase& aCFMessage)

	{

	Messages::TNodeSignal::TMessageId noPeerIds[] = { Messages::TNodeSignal::TMessageId() };

	MeshMachine::TNodeContext<CClock> ctx(*this, aCFMessage, aSender, aRecipient);

	MeshMachine::AMMNodeBase::Received(noPeerIds, ctx);

	MeshMachine::AMMNodeBase::PostReceived(ctx);

	User::LeaveIfError(ctx.iReturn);

	}

namespace TrafficLightActivities

{

DECLARE_DEFINE_NODEACTIVITY(ETrafficLightActivity, TrafficLight, TGoGreen)

    FIRST_NODEACTIVITY_ENTRY(MeshMachine::TAwaitingMessageState<TGoGreen>, MeshMachine::TNoTag)

    NODEACTIVITY_ENTRY(MeshMachine::KNoTag, TrafficLightStates::TGoAmber, MeshMachine::TAwaitingMessageState<TGo>, MeshMachine::TNoTag)

    NODEACTIVITY_ENTRY(MeshMachine::KNoTag, TrafficLightStates::TGoGreen, MeshMachine::TAwaitingMessageState<TGo>, MeshMachine::TNoTag)

    NODEACTIVITY_ENTRY(MeshMachine::KNoTag, TrafficLightStates::TGoAmber, MeshMachine::TAwaitingMessageState<TGo>, MeshMachine::TNoTag)

    LAST_NODEACTIVITY_ENTRY(MeshMachine::KNoTag, TrafficLightStates::TGoRedAndSendGoneRed)

NODEACTIVITY_END()

}

DECLARE_DEFINE_ACTIVITY_MAP(TrafficLightActivityMap)

    ACTIVITY_MAP_ENTRY(TrafficLightActivities, TrafficLight)

ACTIVITY_MAP_END()

CTrafficLight::CTrafficLight(CConsoleBase* aConsole, const TDesC& aPositionText) : MeshMachine::AMMNodeBase(TrafficLightActivityMap::iSelf, Messages::ANodeId::Id()), iConsole(aConsole), iPositionText(aPositionText)

	{

	NM_LOG_NODE_CREATE(KLoggingTag, CTrafficLight);

	SetColour(ERed);

	}

void CTrafficLight::ReceivedL(const Messages::TRuntimeCtxId& aSender, const Messages::TNodeId& aRecipient, Messages::SignatureBase& aCFMessage)

	{

	Messages::TNodeSignal::TMessageId noPeerIds[] = { Messages::TNodeSignal::TMessageId() };

	MeshMachine::TNodeContext<CTrafficLight> ctx(*this, aCFMessage, aSender, aRecipient);

	MeshMachine::AMMNodeBase::Received(noPeerIds, ctx);

	MeshMachine::AMMNodeBase::PostReceived(ctx);

	User::LeaveIfError(ctx.iReturn);

	}

void CTrafficLight::SetColour(TColour aColour)

	{

	iColour = aColour;

	switch (aColour)

		{

		case ERed:

			iConsole->Printf(_L("%S set to RED\n"), &iPositionText);

			break;

		case EAmber:

			iConsole->Printf(_L("%S set to AMBER\n"), &iPositionText);

			break;

		case EGreen:

			iConsole->Printf(_L("%S set to GREEN\n"), &iPositionText);

			break;

		}

	}

namespace ControllerActivities

{

DECLARE_DEFINE_NODEACTIVITY(ETrafficLightControllerActivity, TrafficLightController, TGo)

    FIRST_NODEACTIVITY_ENTRY(MeshMachine::TAwaitingMessageState<TGo>, MeshMachine::TNoTag)

    NODEACTIVITY_ENTRY(ControllerStates::KStart, ControllerStates::TEastAndWestGreen, ControllerStates::TAwaitingAllRed, MeshMachine::TNoTag)

    NODEACTIVITY_ENTRY(MeshMachine::KNoTag, ControllerStates::TNorthAndSouthGreen, ControllerStates::TAwaitingAllRed, MeshMachine::TTag<ControllerStates::KStart|NetStateMachine::EBackward>)

NODEACTIVITY_END()

}

DECLARE_DEFINE_ACTIVITY_MAP(ControllerActivityMap)

    ACTIVITY_MAP_ENTRY(ControllerActivities, TrafficLightController)

ACTIVITY_MAP_END()

CController::CController() : MeshMachine::AMMNodeBase(ControllerActivityMap::iSelf, Messages::ANodeId::Id())

	{

	NM_LOG_NODE_CREATE(KLoggingTag, CController);

	}

void CController::ReceivedL(const Messages::TRuntimeCtxId& aSender, const Messages::TNodeId& aRecipient, Messages::TSignatureBase& aCFMessage)

	{

	Messages::TNodeSignal::TMessageId noPeerIds[] = { TGo::Id(), Messages::TNodeSignal::TMessageId() };

	MeshMachine::TNodeContext<CController> ctx(*this, aCFMessage, aSender, aRecipient);

	MeshMachine::AMMNodeBase::Received(noPeerIds, ctx);

	MeshMachine::AMMNodeBase::PostReceived(ctx);

	User::LeaveIfError(ctx.iReturn);

	}