/*

* Copyright (c) 2008-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 "ondemandao.h"

#include "mdeharvestersession.h"

#include "harvesterdata.h"

#include "harvesterlog.h"

#include "harvesterplugin.h"

#include "harvesterplugininfo.h"

#include "harvesterpluginfactory.h"

COnDemandAO::COnDemandAO() :

	CActive( CActive::EPriorityUserInput )

	{

	WRITELOG("COnDemandAO::COnDemandAO");

	}

COnDemandAO* COnDemandAO::NewLC( CMdESession& aSession, MMonitorPluginObserver& aObserver,

		CHarvesterPluginFactory& aPluginFactory, RPointerArray<CHarvesterData>* aPhArray )

	{

	WRITELOG("COnDemandAO::NewLC");

	COnDemandAO* self = new ( ELeave ) COnDemandAO();

	CleanupStack::PushL ( self);

	self->ConstructL ( aSession, aObserver, aPluginFactory, aPhArray );

	return self;

	}

COnDemandAO* COnDemandAO::NewL( CMdESession& aSession, MMonitorPluginObserver& aObserver,

		CHarvesterPluginFactory& aPluginFactory, RPointerArray<CHarvesterData>* aPhArray )

	{

	WRITELOG("COnDemandAO::NewL");

	COnDemandAO* self = COnDemandAO::NewLC ( aSession, aObserver, aPluginFactory, aPhArray );

	CleanupStack::Pop (); // self;

	return self;

	}

void COnDemandAO::ConstructL( CMdESession& aSession, MMonitorPluginObserver& aObserver,

		CHarvesterPluginFactory& aPluginFactory, RPointerArray<CHarvesterData>* aPhArray )

	{

	WRITELOG("COnDemandAO::ConstructL");

	iMdEHarvesterSession = CMdEHarvesterSession::NewL ( aSession);

	iObserver = &aObserver;

	iPluginFactory = &aPluginFactory;

	iReadyPhArray = aPhArray;

	CActiveScheduler::Add ( this ); // Add to scheduler

	}

COnDemandAO::~COnDemandAO()

	{

	WRITELOG("COnDemandAO::~COnDemandAO");

	Cancel (); // Cancel any request, if outstanding

	if( iMdEHarvesterSession )

		{

		delete iMdEHarvesterSession;

		}

	// Delete instance variables if any

	}

void COnDemandAO::DoCancel()

	{

	WRITELOG("COnDemandAO::DoCancel");

	iMdEHarvesterSession->CancelHarvestingPrioritizationObserver ();

	}

void COnDemandAO::StartL()

	{

	WRITELOG("COnDemandAO::StartL");

	// Cancel any request, just to be sure

	Cancel ();

	iMdEHarvesterSession->SetHarvestingPrioritizationChunkL ( 16384 );

	WaitHarvestingRequest ();

	}

void COnDemandAO::RunL()

	{

	WRITELOG("COnDemandAO::RunL");

	if( iStatus.Int() != KErrNotFound )

		{

		User::LeaveIfError ( iStatus.Int ());

		TInt count = iMdEHarvesterSession->HarvestingPrioritizationUriCountL();

		if( count > 0 )

			{

			RPointerArray<CHarvesterPluginInfo>& pluginInfos = iPluginFactory->GetPluginInfos();

			TInt plugins = pluginInfos.Count();

			for (TInt i = count; --i >= 0;)

				{

				HBufC* uri = iMdEHarvesterSession->HarvestingPrioritizationUriL( i );

				CleanupStack::PushL( uri );

				TBool found = EFalse;

				for ( TInt j = 0; j < plugins && !found; j++ )

					{

					RPointerArray<CHarvesterData>& queue = pluginInfos[j]->iQueue;

					TInt queueSize = queue.Count();

					for ( TInt k = 0; k < queueSize && !found; k++ )

						{				

						if ( queue[k]->Uri().CompareF( *uri ) == 0 )

							{

							WRITELOG2("COnDemandAO::RunL URI %S found in plugin %d queue", uri, j);

							CHarvesterData* hd = queue[k];

							hd->SetEventType( EHarvesterEdit );

							hd->SetObjectType( EFastHarvest );

							queue.Remove( k );

							queue.Insert( hd, 0 );

							found = ETrue;

							}							

						}

					}

				const TInt readyPhArraySize = iReadyPhArray->Count();

				for ( TInt j = 0; j < readyPhArraySize && !found; j++ )

					{

					if ( (*iReadyPhArray)[j]->Uri().CompareF( *uri ) == 0 )

						{

						WRITELOG1("COnDemandAO::RunL URI %S found in ph array", uri);

						CHarvesterData* hd = (*iReadyPhArray)[j];

						hd->SetEventType( EHarvesterEdit );

						hd->SetObjectType( EFastHarvest );

						iReadyPhArray->Remove( j );

						iReadyPhArray->Insert( hd, 0 );

						found = ETrue;

						}

					}

				if ( !found )

					{

					WRITELOG1("COnDemandAO::RunL URI %S wasn't found in placeholder queue.", uri);

					CMdESession& session = iMdEHarvesterSession->SessionRef();

					TMdEObject object;

					TRAPD( err, session.CheckObjectL( object, *uri ));

					if ( err == KErrNone && object.Placeholder() )

						{

						CHarvesterData* hd = CHarvesterData::NewL( uri );

						hd->SetEventType( EHarvesterEdit );

						hd->SetObjectType( EFastHarvest );

						iObserver->MonitorEvent( hd );

						CleanupStack::Pop( uri );

						}

					else

						{

						CleanupStack::PopAndDestroy( uri );

						}

					}

				else

					{

					CleanupStack::PopAndDestroy( uri );

					}

				}

			}

		}

	WaitHarvestingRequest();

	}

TInt COnDemandAO::RunError( TInt /*aError*/ )

	{

	return KErrNone;

	}

void COnDemandAO::WaitHarvestingRequest()

	{

	WRITELOG("COnDemandAO::WaitHarvestingRequest");

	iStatus = KRequestPending;

	iMdEHarvesterSession->AddHarvestingPrioritizationObserver( iStatus );

	// Tell scheduler a request is active

	SetActive();

	}