/*
* 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:
*
*/

#ifndef MESSAGESCANNER_H_
#define MESSAGESCANNER_H_

#include <e32property.h>
#include <mdequery.h>

// FORWARD DECLARATION
class CMsvSession;
class CMdESession;
class CMsvFindOperation;
class MMonitorPluginObserver;

class TMessage
	{
	public:
		TInt32 iMsvId;
		TTime iCreationDate;
		TItemId iMdeId;
	};

class CMessageScannerAO : public CActive, public MMdEQueryObserver
	{
	public:
		enum TScannerState {
			EScannerIdle,
			EScannerRunning,
			EScannerFinished
		};
	
		static CMessageScannerAO* NewL( CMsvSession* aMsvSession, CMdESession* aMdeSession, 
				MMonitorPluginObserver* aMonitorPluginObserver );
		~CMessageScannerAO();
		void StartL();
		
		void HandleQueryNewResults( CMdEQuery& aQuery, TInt aFirstNewItemIndex,
				TInt aNewItemCount );

		void HandleQueryCompleted( CMdEQuery& aQuery, TInt aError );
		
	private:
		CMessageScannerAO( CMsvSession* aMsvSession, CMdESession* aMdeSession,
				MMonitorPluginObserver* aMonitorPluginObserver );
		void ConstructL();
		void RunL();
		void DoCancel();
		TInt RunError( TInt aError );
		void ScanMessagesL( RArray<TMessage>& aMessageIds );
		void QueryAllMessagesL();
		void ProcessMessagesL( CMdEQuery& aQuery, RArray<TMessage>& aMessages );
		void Unregister();
		void Cleanup();
		
	private:
		CMsvFindOperation* 	iFindOperation;
		CMsvSession* 		iMsvSession;
		CMdESession* 		iMdeSession;
		CMdEObjectQuery* 	iObjectQuery;
		MMonitorPluginObserver* iMonitorPluginObserver;
		RProperty iProperty;
		TScannerState		iState;
	};

#endif /*MESSAGESCANNER_H_*/