/*
* Copyright (c) 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:  MDE harvester utility class
 *
*/


#include "mdeharvester.h"

// -----------------------------------------------------------------------------
// CCPixIndexerUtils::NewL()
// -----------------------------------------------------------------------------
//
CMdeHarvester* CMdeHarvester::NewL(CMdESession* aSession,
                                   MdeMEdiaObserver* aObserver,
                                   CMdeObjectQueueManager* aObjJobQueue)
    {
    CMdeHarvester* self = CMdeHarvester::NewLC(aSession,aObserver,aObjJobQueue);
    CleanupStack::Pop(self);
    return self;
    }

// -----------------------------------------------------------------------------
// CCPixIndexerUtils::NewLC()
// -----------------------------------------------------------------------------
//
CMdeHarvester* CMdeHarvester::NewLC(CMdESession* aSession,
                                    MdeMEdiaObserver* aObserver,
                                    CMdeObjectQueueManager* aObjJobQueue)
    {
    CMdeHarvester* self = new (ELeave) CMdeHarvester();
    CleanupStack::PushL(self);
    self->ConstructL(aSession,aObserver,aObjJobQueue);
    return self;
    }

// -----------------------------------------------------------------------------
// CCPixIndexerUtils::~CMdeHarvester()
// -----------------------------------------------------------------------------
//
CMdeHarvester::~CMdeHarvester()
   {
   Cancel();
   delete iWait;
   delete iQuery;
   }

// -----------------------------------------------------------------------------
// CCPixIndexerUtils::ConstructL()
// -----------------------------------------------------------------------------
//
void CMdeHarvester::ConstructL(CMdESession* aSession,
                               MdeMEdiaObserver* aObserver,
                               CMdeObjectQueueManager* aObjJobQueue)
    {
    iSession = aSession;
    iObserver = aObserver;
    iJobQueue = aObjJobQueue;
    iWait = new (ELeave) CActiveSchedulerWait;
    CActiveScheduler::Add(this);
    }

// -----------------------------------------------------------------------------
// CCPixIndexerUtils::CMdeHarvester()
// -----------------------------------------------------------------------------
//
CMdeHarvester::CMdeHarvester():CActive(CActive::EPriorityStandard)
    {
    iCurrentIndex = 0;
    }

// -----------------------------------------------------------------------------
// CCPixIndexerUtils::RunL()
// -----------------------------------------------------------------------------
//
//from CActive
void CMdeHarvester::RunL()
    {
    if(KErrNone == iStatus.Int())
      {
      HandleNextRequestL();
      }
    else
      {
      iObserver->HarvestingCompletedL(/*iStatus.Int()*/);//Introduce Error
      }
    }

// -----------------------------------------------------------------------------
// CCPixIndexerUtils::DoCancel()
// -----------------------------------------------------------------------------
//
void CMdeHarvester::DoCancel()
    {
    
    }

// -----------------------------------------------------------------------------
// CCPixIndexerUtils::RunError()
// -----------------------------------------------------------------------------
//
TInt CMdeHarvester::RunError()
    {
    //@TODO: handle next items here incrementing count index 
    return KErrNone;
    }
   

// -----------------------------------------------------------------------------
// CCPixIndexerUtils::handleQueryNewResults()
// -----------------------------------------------------------------------------
//
void CMdeHarvester::HandleQueryNewResults(CMdEQuery& aQuery,
                                          TInt aFirstNewItemIndex,
                                          TInt aNewItemCount)
    {
    
    }

// -----------------------------------------------------------------------------
// CCPixIndexerUtils::HandleQueryCOmpleted()
// -----------------------------------------------------------------------------
//
void CMdeHarvester::HandleQueryCompleted(CMdEQuery& aQuery, TInt aError)
    {
    if(aError !=KErrNone)
        {
        TInt count = aQuery.Count();
        }
    if(iWait->IsStarted()) //Complete in Handle
        iWait->AsyncStop();
    }

// -----------------------------------------------------------------------------
// CCPixIndexerUtils::DoHarvestL()
// -----------------------------------------------------------------------------
//
void CMdeHarvester::DoHarvesetL(const TDesC& aNameSpaceDef)
    {
    iCurrentIndex = 0;
    QueryAllMediaObjectsL(aNameSpaceDef);
    }
   

// -----------------------------------------------------------------------------
// CCPixIndexerUtils::QueryAllMediaObjectsL()
// -----------------------------------------------------------------------------
//
void CMdeHarvester::QueryAllMediaObjectsL(const TDesC& aNameSpaceDef)
    {
    //delete iQuery;
	iQuery->Delete(iQuery);
	iQuery = NULL;
    CMdENamespaceDef& defaultNamespaceDef = iSession->GetDefaultNamespaceDefL();
    CMdEObjectDef& audioObjDef = defaultNamespaceDef.GetObjectDefL(aNameSpaceDef);    
    // query objects with object definition "Audio" "video" "images" etc..
    iQuery = iSession->NewObjectQueryL( defaultNamespaceDef, audioObjDef, this );
    iQuery->FindL();
    iWait->Start();  //Complete in Handle
    TInt count = iQuery->Count();
    CompleteSelf();    
    }

// -----------------------------------------------------------------------------
// CCPixIndexerUtils::HandleNextRequestL()
// -----------------------------------------------------------------------------
//
void CMdeHarvester::HandleNextRequestL()
    {
    if(iCurrentIndex < iQuery->Count())
        {
        //Get the Object ID and pass to ObjectQueue manager
        CMdEObject& object = static_cast<CMdEObject&>( iQuery->ResultItem( iCurrentIndex ) );
        //@TODO: ResultId does'nt work need to check with MDS 
        //iJobQueue->AddMdeItemToQueueL(iQuery->ResultId(iCurrentIndex),ECPixAddAction);
        iJobQueue->AddMdeItemToQueueL(object.Id(),ECPixAddAction);
        iCurrentIndex++;
        CompleteSelf();
        }
    else
        {
        iObserver->HarvestingCompletedL();
        }
    }

// -----------------------------------------------------------------------------
// CCPixIndexerUtils::CompleteSelf()
// -----------------------------------------------------------------------------
//
void CMdeHarvester::CompleteSelf()
    {
    // trigger our RunL
    TRequestStatus*  caller;
    caller = &iStatus;
    iStatus = KRequestPending;
    User::RequestComplete(caller, KErrNone);
    SetActive();    
    }

//End of life