/*

* 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:  Harvester message plugin

*

*/

//  INCLUDES 

#include <e32base.h>

#include <mtclreg.h>

#include <mmsclient.h>

#include <smsclnt.h>

#include <smuthdr.h>

#include <smsclnt.h>

#include <smut.h>

#include <gsmuelem.h>

#include <msventry.h>

#include <msvuids.h>

#include <mmsconst.h>

#include "cmessageharvester.h"

// ============================ MEMBER FUNCTIONS ===============================

// ---------------------------------------------------------------------------

// CMessageHarvester::NewL

// ---------------------------------------------------------------------------

//

CMessageHarvester* CMessageHarvester::NewL(  CMessagePlugin& aMessagePlugin, CMsvSession& aSession )

	{

	CMessageHarvester* self = new (ELeave) CMessageHarvester(  aMessagePlugin, aSession );

	return self;

	}

// ---------------------------------------------------------------------------

// CMessageHarvester::~CMessageHarvester

// ---------------------------------------------------------------------------

//

CMessageHarvester::~CMessageHarvester()

	{   

	Cancel();  

    delete iChildren;

    iToBeSearchedFolders.Close();

	}

// ---------------------------------------------------------------------------

// CMessageHarvester::CMessageHarvester

// ---------------------------------------------------------------------------

//

CMessageHarvester::CMessageHarvester( CMessagePlugin& aMessagePlugin, CMsvSession& aSession  ) :

	CActive(CActive::EPriorityIdle),

	iMessagePlugin( aMessagePlugin ),

	iMsvSession( aSession ),

	iState(EStateIdle)

	{

	CActiveScheduler::Add( this );

	}

// ---------------------------------------------------------------------------

// CMessageHarvester::StartHarvesting

// ---------------------------------------------------------------------------

//	

void CMessageHarvester::StartHarvestingL()

	{

	// First, get message folders

	GetMessageFoldersL();

	// Then, harvest them

	iState = EStateNextFolder;

	HandleNextRequest();

	}

// ---------------------------------------------------------------------------

// CMessageHarvester::AddFolderWithSubFoldersL

// ---------------------------------------------------------------------------

//		

void CMessageHarvester::AddFolderWithSubFoldersL( const TMsvId& aFolderId )

	{

	// Add a folder to the search list

	User::LeaveIfError(iToBeSearchedFolders.Append(aFolderId));	

	CMsvEntry* folderEntry = CMsvEntry::NewL(iMsvSession, aFolderId, TMsvSelectionOrdering(KMsvGroupByStandardFolders, EMsvSortByDetails, EFalse));

	CleanupStack::PushL(folderEntry);	

	ListSubFoldersL(*folderEntry);

	CleanupStack::PopAndDestroy(folderEntry);

	}

// ---------------------------------------------------------------------------

// CMessageHarvester::ListSubFoldersL

// ---------------------------------------------------------------------------

//	

void CMessageHarvester::ListSubFoldersL(  const CMsvEntry& aFolderEntry ) 

	{

	// Only list "folder" children

    CMsvEntrySelection* children = aFolderEntry.ChildrenL();

	CleanupStack::PushL( children );

	for ( TInt i=0; i < children->Count(); i++ )

		{

		TMsvId& childId = ( *children )[i];

		const TMsvEntry& childEntry ( aFolderEntry.ChildDataL( childId ) );

		if ( ( childEntry.iType == KUidMsvServiceEntry ) || 

    		 ( childEntry.iType == KUidMsvFolderEntry ) )

		    {

		    // Add this folder to search list

            AddFolderWithSubFoldersL( childId );		

		    }

		}

	CleanupStack::PopAndDestroy();  // children

	}

// ---------------------------------------------------------------------------

// CMessageHarvester::GetMessageFoldersL

// ---------------------------------------------------------------------------

//

void CMessageHarvester::GetMessageFoldersL()

    {

    // Get list of folders

    CMsvEntry* rootEntry;

    rootEntry = CMsvEntry::NewL( iMsvSession, KMsvRootIndexEntryIdValue,

    TMsvSelectionOrdering( KMsvGroupByStandardFolders, EMsvSortByDetails, EFalse ) );

    CleanupStack::PushL( rootEntry );

	ListSubFoldersL( *rootEntry);

	CleanupStack::PopAndDestroy( rootEntry );

    }

// ---------------------------------------------------------------------------

// CMessageHarvester::GetNextFolderL

// ---------------------------------------------------------------------------

//		

void CMessageHarvester::GetNextFolderL()

    {

    if ( iToBeSearchedFolders.Count() > 0 )

    	{

    	// Open the new folder

        CMsvEntry* folder = CMsvEntry::NewL(

	                            iMsvSession, 

	                            iToBeSearchedFolders[0],

	                            TMsvSelectionOrdering( KMsvGroupByStandardFolders, EMsvSortByDetails ));

        iCurrentFolder = iToBeSearchedFolders[0];

        // Get the message items from the folder

        CleanupStack::PushL(folder);        

        iChildren = folder->ChildrenWithTypeL( KUidMsvMessageEntry );

        CleanupStack::PopAndDestroy( folder );

        // Remove current folder from the queue

        iToBeSearchedFolders.Remove(0);

        iState = EStateNextMessage;

        HandleNextRequest();

        }

    else

        {

        // No more folders in the queue

        iState = EStateIdle;

        HandleNextRequest();      

        }

    }

// ---------------------------------------------------------------------------

// CMessageHarvester::GetMessageId

// ---------------------------------------------------------------------------

//		    

void CMessageHarvester::GetMessageIdL()

    { 

    if (iChildren && iChildren->Count() > 0)

        {

        // Take first item from list of message items, and give it for indexing

        iMessagePlugin.MessageItemL((*iChildren)[0], ECPixAddAction, iCurrentFolder);

        // Delete the item from list

        iChildren->Delete( 0 );   

        if ( iChildren->Count() > 0 )

            {

            // Get the next message

            iState = EStateNextMessage;

            HandleNextRequest();      

            }

        else 

            {

            // No messages in this folder

            iState = EStateNextFolder;

            HandleNextRequest();      

            }

        }

    else 

        {

        // Current folder dosen't contain any message items so change folder

        iState = EStateNextFolder;

        HandleNextRequest();      

        }

    }

// -----------------------------------------------------------------------------

// CMessageHarvester::DoCancel

// -----------------------------------------------------------------------------

//   

void CMessageHarvester::DoCancel()

	{

	}

// -----------------------------------------------------------------------------

// CMessageHarvester::RunL

// -----------------------------------------------------------------------------

//   

void CMessageHarvester::RunL()	

	{

	 // Simple Round-Robin scheduling.

    Deque();

    CActiveScheduler::Add( this );

	switch (iState)

		{

	       case EStateIdle:

	            {

	            // Delete current folder items

	            delete iChildren; 

	            iChildren = NULL;

	            // Started idling, close the folders

	            iToBeSearchedFolders.Reset();

	            // Update harvester status

	            iMessagePlugin.HarvestingCompleted(KErrNone);	            

	            break; 

	    	    }    

		    case EStateNextMessage:

		        {

		        // Get the next message

		        GetMessageIdL();	

		        break;	        

		        }

	        case EStateNextFolder:

	            {

	            // Delete current folder items

	            delete iChildren; 

	            iChildren = NULL;

	            // Start harvesting folders. 

	            GetNextFolderL();	         

				break;

	            }

		}

	}

// -----------------------------------------------------------------------------

// CMessageHarvester::RunError

// -----------------------------------------------------------------------------

//   

TInt CMessageHarvester::RunError( TInt aError )	

	{

	iState = EStateIdle;

    iMessagePlugin.HarvestingCompleted(aError);

	return KErrNone;

	}

// ---------------------------------------------------------------------------

// SetNextRequest

// ---------------------------------------------------------------------------

//

void CMessageHarvester::HandleNextRequest()

    {

    if (!IsActive())

        {

        SetActive();

        TRequestStatus* status = &iStatus;

        User::RequestComplete( status, KErrNone );

        }

    }

// End of File