/*

* 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 <barsc2.h>

#include <barsread2.h>

#include "CdlEcomReg.h"

void CCdlDllsWatcherBase::NewL(CCdlDllsWatcherBase*& iWatcher, RFs& aFs, MCdlDllsObserver* aObserver)

	{

	CCdlEcomWatcher* self = new(ELeave) CCdlEcomWatcher(aFs, aObserver);

	iWatcher = self;

	self->ConstructL();

	}

CCdlRefCollection* CCdlDllsWatcherBase::FileContentsLC(const TDesC& aFileName)

	{

	CCdlRefs* refs = CCdlRefs::NewLC();

	TParsePtrC parse(aFileName);

	TPtrC name(parse.Name());

	TPtrC drive(parse.Drive());

	_LIT(KRes, "%S\\resource\\cdl\\%S_cdl_detail.rsc");

	TBuf<64> fileName;

	fileName.Format(KRes, &drive, &name);

	CResourceFile* resFile = CResourceFile::NewLC(iFs, fileName, 0, 0);

	RResourceReader reader;

	reader.OpenLC(resFile, 1);

	TInt count = reader.ReadInt16L();

	for (TInt ii=0; ii<count; ii++)

		{

		TCdlRef ref;

		ref.iName = &aFileName;

		ref.iUid = TUid::Uid(reader.ReadInt32L());

		ref.iId = reader.ReadInt32L();

		refs->AppendL(ref);

		}

	CleanupStack::PopAndDestroy(2);		// reader, resFile

	return refs;

	}

CCdlEcomWatcher::CCdlEcomWatcher(RFs& aFs, MCdlDllsObserver* aObserver)

: CCdlDllsWatcherBase(aFs), iObserver(aObserver)

	{

	}

CCdlEcomWatcher::~CCdlEcomWatcher()

	{

	Cancel();

	if (iImplArray)

		iImplArray->ResetAndDestroy();

	delete iImplArray;

	if (iEcom)

		{

		iEcom->Close();

		REComSession::FinalClose();

		}

	}

void CCdlEcomWatcher::ConstructL()

	{

	iImplArray = new(ELeave) RImplInfoPtrArray;

	iEcom = &REComSession::OpenL();

	TRAP_IGNORE(GetListL());

	Queue();

	}

void CCdlEcomWatcher::DoCancel()

	{

	iEcom->CancelNotifyOnChange(iStatus);

	}

void CCdlEcomWatcher::RunL()

	{

	TRAP_IGNORE(GetListL());

	Queue();

	}

void CleanImplArray(TAny* aArray)

	{

	RImplInfoPtrArray* array = static_cast<RImplInfoPtrArray*>(aArray);

	array->ResetAndDestroy();

	delete array;

	}

TInt ImplUidLessThan(const CImplementationInformation& aLhs, const CImplementationInformation& aRhs)

	{

	return aLhs.ImplementationUid().iUid - aRhs.ImplementationUid().iUid;

	}

void CCdlEcomWatcher::GetListL()

	{

	RImplInfoPtrArray* implArray = new(ELeave) RImplInfoPtrArray;

	CleanupStack::PushL(TCleanupItem(CleanImplArray, implArray));

	REComSession::ListImplementationsL(TUid::Uid(0x101f8243), *implArray);

	implArray->Sort(&ImplUidLessThan);

	HandleNewListL(*implArray);

	iImplArray->ResetAndDestroy();

	delete iImplArray;

	iImplArray = implArray;

	CleanupStack::Pop(); // implArray

	}

void CCdlEcomWatcher::Queue()

	{

	iEcom->NotifyOnChange(iStatus);

	SetActive();

	}

void CCdlEcomWatcher::HandleNewListL(RImplInfoPtrArray& aImplArray)

	{

	RImplInfoPtrArray& implArray = *iImplArray;

	TInt ixNew = 0;

	TInt ixCur = 0;

	TInt countNew = aImplArray.Count();

	TInt countCur = implArray.Count();

	while (ixNew < countNew || ixCur < countCur)

		{

		if (ixCur == countCur)				// at end of current list, any UIDs left in new list should be added

			{

			AddNewToObserverL(*aImplArray[ixNew]);

			ixNew++;

			}

		else if (ixNew == countNew)					// at end of new list, any UIDs left in current list should be removed

			{

			RemoveCurrentFromObserverL(*implArray[ixCur]);

			ixCur++;

			}

		else if (implArray[ixCur]->ImplementationUid() == aImplArray[ixNew]->ImplementationUid())				// UIDs are the same, skip to the next one

			{

			ixNew++;

			ixCur++;

			}

		else if (implArray[ixCur]->ImplementationUid().iUid < aImplArray[ixNew]->ImplementationUid().iUid)				// current UID does not appear in new list, remove it

			{

			RemoveCurrentFromObserverL(*implArray[ixCur]);

			ixCur++;

			}

		else									// new UID does not appear in current list, add it

			{

			AddNewToObserverL(*aImplArray[ixNew]);

			ixNew++;

			}

		}

	if (iTellingObserver)

		{

		iTellingObserver = EFalse;

		iObserver->McdoChangesCompleteL();

		}

	}

void CCdlEcomWatcher::AddNewToObserverL(CImplementationInformation& aImpl)

	{

	TFileName fileName;

	ImplFileName(aImpl, fileName);

	StartTellingObserverIfNecessaryL();

	TRAP_IGNORE(iObserver->McdoFileAddedL(fileName));

	}

void CCdlEcomWatcher::RemoveCurrentFromObserverL(CImplementationInformation& aImpl)

	{

	TFileName fileName;

	ImplFileName(aImpl, fileName);

	StartTellingObserverIfNecessaryL();

	TRAP_IGNORE(iObserver->McdoFileRemovedL(fileName));

	}

void CCdlEcomWatcher::ImplFileName(CImplementationInformation& aImpl, TFileName& aFileName)

	{

	TDriveName drive = aImpl.Drive().Name();

	aFileName.Format(_L("%S%08x.dll"), &drive, aImpl.ImplementationUid());

	}

void CCdlEcomWatcher::StartTellingObserverIfNecessaryL()

	{

	if (!iTellingObserver)

		iObserver->McdoPrepareForChangesL();

	iTellingObserver = ETrue;

	}

TInt ImplArrayUidSearchPred(const TUid* aUid, const CImplementationInformation& aImpl)

	{

	return aUid->iUid - aImpl.ImplementationUid().iUid;

	}

TInt CCdlEcomWatcher::FindPlugin(const TDesC& aFileName) const

	{

	// get the implementation UID from the file name

	TParsePtrC parse(aFileName);

	TPtrC name(parse.Name());

	TLex lexer(name);

	TUint32 uidVal;

	TInt r = lexer.Val(uidVal, EHex);

	if (r!=KErrNone)

		return r;

	// Search for an implementation with the UID in the implementation array

	TUid uid = { uidVal };

	return iImplArray->FindInOrder(uid, &ImplArrayUidSearchPred);

	}

TInt CCdlEcomWatcher::IsPluginInRom(const TDesC& aFileName, TBool& aIsInRom) const

    {

    TInt index = FindPlugin(aFileName);

	if (index<=KErrNotFound)

		return index;

	// Is this implementation ROM based or not?

	aIsInRom = (*iImplArray)[index]->RomBased();

	return KErrNone;

	}

TInt CCdlEcomWatcher::PluginDrive(const TDesC& aFileName, TDriveUnit& aDrive) const

    {

    TInt index = FindPlugin(aFileName);

	if (index<=KErrNotFound)

		return index;

	// Get the drive unit

	aDrive = (*iImplArray)[index]->Drive();

	return KErrNone;

    }