--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/harvester/monitorplugins/messageplugin/inc/messagescannerao.h	Mon Jan 18 20:34:07 2010 +0200
@@ -0,0 +1,80 @@
+/*
+* 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_*/