// 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:

// A subject for oberving requests to reduce the timers currently

// running in the simulator.

// 

//

/**

 @file

*/

#include "CSimReduceTimers.h"

/**

Factory function for creating a CSimReduceTimers object.

@return A pointer to the object created.

*/

CSimReduceTimers* CSimReduceTimers::NewL()

	{

	CSimReduceTimers* self = new(ELeave) CSimReduceTimers;

	CleanupStack::PushL(self);

	self->ConstructL();

	CleanupStack::Pop(self);

	return self;

	}

/**

Second phase constructor.  Ensures that the required Publish &

Subscribe property is defined and starts listening to any changes (or

Set() calls) made to this property.

*/

void CSimReduceTimers::ConstructL()

	{

	TInt dummy;

	TInt ret = RProperty::Get(KUidPSSimTsyCategory, KPSSimTsyTimersReduceTime, dummy);

	if (ret == KErrNone)

		{

		iPSProperty = CSimPubSub::TPubSubProperty(KUidPSSimTsyCategory,KPSSimTsyTimersReduceTime,

												KPSSimTsyTimersReduceTimeSignalKeyType);

		iSimPubSub = CSimPubSub::NewL(this,iPSProperty);

		iSimPubSub->Start();

		}

	else

		{

		User::Leave(ret);

		}

	}

/**

Default, first-phase, constructor.

*/

CSimReduceTimers::CSimReduceTimers()

	{

	// NOP

	}

/**

Default destrucor for the reduce timers subject.

*/

CSimReduceTimers::~CSimReduceTimers()

	{

	delete iSimPubSub;

	iObservers.Close();

	}

void CSimReduceTimers::SimPSEvent(const CSimPubSub::TPubSubProperty aProperty, TInt aStatus)

	{

	if (aProperty == iPSProperty && // Condition for correct property

		(aStatus == ETimerIdAllTimers)) // and correct value for signal

		{

		Notify();

		}

	else if(aProperty == iPSProperty && aStatus > 0)

		{

		Notify(aStatus);

		}

	}

void CSimReduceTimers::AttachL(MSimTimerUpdateObserver* aObserver)

	{

	User::LeaveIfError(iObservers.Append(aObserver));

	}

void CSimReduceTimers::DetachL(MSimTimerUpdateObserver* aObserver)

	{

	TInt pos = iObservers.Find(aObserver);

	User::LeaveIfError(pos);

	iObservers.Remove(pos);

	}

void CSimReduceTimers::Notify()

	{

	TInt totalItems = iObservers.Count();

	if (totalItems <= 0)

		{

		return;

		}

	TInt minTimeReduce = KMaxTInt;

	TInt num;

	for (num = 0; num < totalItems; num++)

		{

		TInt temp = iObservers[num]->GetRemainingSeconds();

		// Ensure no error is returned and check if the current itteration gives a lower time remaining.

		if (temp > 0 && temp < minTimeReduce)

			{

			minTimeReduce = temp;

			}

		}

	if (minTimeReduce == KMaxTInt)

		{

		return;

		}

	// Ensure that reducing timers by minTimeReduce does not reduce any timer to less than KTimerDelayOnReduceTimeSignal.

	minTimeReduce -= KTimerDelayOnReduceTimeSignal;

	if (minTimeReduce <= 0)

		{

		return;

		}

	for (num = 0; num < totalItems; num++)

		{

		iObservers[num]->Update(minTimeReduce);

		}

	}

void CSimReduceTimers::Notify(TInt aTimerEventId)

	{

	TInt totalItems = iObservers.Count();

	if (totalItems <= 0)

		{

		return;

		}

	//Get the index of the observer with with event id aTimerEventId

	//and the lowest remaining timer 

	TInt lowestTime = KMaxTInt;

	TInt indexOfLowest = KErrNotFound;

	TInt index;

	for(index = 0; index < totalItems; index++)

		{

		if((iObservers[index]->GetTimerEventInfo() == aTimerEventId) &&

			(iObservers[index]->GetRemainingSeconds() > 0) &&

			(iObservers[index]->GetRemainingSeconds() < lowestTime))

			{

			indexOfLowest = index;

			lowestTime = iObservers[index]->GetRemainingSeconds();

			}

		}

	if(indexOfLowest == KErrNotFound)

		{

		return;

		}

	//Check that reducing the timer of the selected observer is acceptable

	TInt reduceBy = lowestTime - KTimerDelayOnReduceTimeSignal;

	if(reduceBy >= lowestTime)

		{

		}

	else

		{

		iObservers[indexOfLowest]->Update(reduceBy);

		}

	}