/*
* Copyright (c) 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:
*
*/
#include "CdlChangeObserver.h"
#include "CCdlEngine.h"

const TInt KCdlGranularity = 4;


//
// CCdlChangeMonitor
//

CCdlChangeMonitor::CCdlChangeMonitor(RCdlSession& aServer, CCdlEngine* aEngine)
: CActive(EPriorityStandard), iServer(aServer), iEngine(aEngine)
	{
	CActiveScheduler::Add(this);
	Queue();
	}

CCdlChangeMonitor::~CCdlChangeMonitor()
	{
	Cancel();
	}

void CCdlChangeMonitor::Queue()
	{
	iServer.NotifyChange(iStatus, iChange);
	SetActive();
	}

void CCdlChangeMonitor::RunL()
	{
	if (iStatus == KErrNone)
		Queue();

	TRAP_IGNORE(ProcessL());
	}

void CCdlChangeMonitor::ProcessL()
	{
	switch (iChange().iType)
		{
		case SCdlServerChange::EGlobalCustomisation:
			iEngine->HandleGlobalCustomisationChangeL(iChange().iSize);
			break;

		case SCdlServerChange::EAvailableRefs:
			iEngine->HandleAvailableRefsChangeL();
			break;

		default:
			Panic(ECdlEngPanic_BadChangeType);
			break;
		}
	}

void CCdlChangeMonitor::DoCancel()
	{
	iServer.CancelNotifyChange();
	}


//
// CCdlChangeObserver
//

CCdlChangeObserver* CCdlChangeObserver::NewLC(MCdlChangeObserver* aObserver, TUid aUid)
	{
	CCdlChangeObserver* self = new(ELeave) CCdlChangeObserver;
	CleanupStack::PushL(self);
	self->iObserver = aObserver;
	self->AddUidL(aUid);
	return self;
	}

CCdlChangeObserver* CCdlChangeObserver::NewLC(MCdlChangeObserver* aObserver)
	{
	CCdlChangeObserver* self = new(ELeave) CCdlChangeObserver;
	CleanupStack::PushL(self);
	self->iObserver = aObserver;
	return self;
	}

CCdlChangeObserver::~CCdlChangeObserver()
	{
	}

MCdlChangeObserver* CCdlChangeObserver::Observer() const
	{
	return iObserver;
	}

void CCdlChangeObserver::AddUidL(TUid aUid)
	{
	iUids.AddL(aUid);
	}

void CCdlChangeObserver::HandleCustomisationChangeL(const CCdlUids& aUids)
	{
	CCdlUids* change = iUids.IntersectionLC(aUids);
	if (change->Count())
		iObserver->HandleCustomisationChangeL(*change);
	CleanupStack::PopAndDestroy(change);
	}

void CCdlChangeObserver::HandleAvailableRefsChangeL()
	{
	iObserver->HandleAvailableRefsChangeL();
	}


//
// CCdlChangeObservers
//

CCdlChangeObservers::CCdlChangeObservers()
: iObservers(KCdlGranularity)
	{
	}

CCdlChangeObservers::~CCdlChangeObservers()
	{
	iObservers.ResetAndDestroy();
	}

void CCdlChangeObservers::AddCustomisationChangeObserverL(MCdlChangeObserver* aObserver, TUid aUid)
	{
	TInt index = FindIndex(aObserver);
	if (index == KErrNotFound)
		{
		iObservers.AppendL(CCdlChangeObserver::NewLC(aObserver, aUid));
		CleanupStack::Pop();
		}
	else
		{
		iObservers[index]->AddUidL(aUid);
		}
	}

void CCdlChangeObservers::AddGeneralChangeObserverL(MCdlChangeObserver* aObserver)
	{
	TInt index = FindIndex(aObserver);
	if (index == KErrNotFound)
		{
		iObservers.AppendL(CCdlChangeObserver::NewLC(aObserver));
		CleanupStack::Pop();
		}
	}

void CCdlChangeObservers::RemoveChangeObserver(MCdlChangeObserver* aObserver)
	{
	TInt index = FindIndex(aObserver);
	if (index != KErrNotFound)
		{
		delete iObservers[index];
		iObservers.Delete(index);
		}
	}

void CCdlChangeObservers::HandleCustomisationChangeL(const CCdlUids& aUids)
	{
	TInt count = iObservers.Count();
	for (TInt ii=0; ii<count; ii++)
		{
		iObservers[ii]->HandleCustomisationChangeL(aUids);
		}
	}

void CCdlChangeObservers::HandleAvailableRefsChangeL()
	{
	TInt count = iObservers.Count();
	for (TInt ii=0; ii<count; ii++)
		{
		iObservers[ii]->HandleAvailableRefsChangeL();
		}
	}

TInt CCdlChangeObservers::FindIndex(MCdlChangeObserver* aObserver) const
	{
	TInt count = iObservers.Count();
	for (TInt ii=0; ii<count; ii++)
		{
		if (iObservers[ii]->Observer() == aObserver)
			return ii;
		}
	return KErrNotFound;
	}