// Copyright (c) 2006-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 "cimapcompoundsyncservice.h"

#include <imapset.h>

#include "cimapfolder.h"

#include "cimapsession.h"

#include "cimapmailstore.h" 

#include "cimapofflinecontrol.h"

#include "cimapsyncmanager.h"

#include "cimapfolder.h"

#include "cimaplogger.h"

#include "cimapcompoundcopyfromlocal.h"

#include "cimapcompoundcopytolocal.h"

#include "cimapcompoundcopywithinservice.h"

#include "cimapcompoundcreate.h"

#include "cimapcompounddelete.h"

#include "cimapcompounddeletefolder.h"

#include "cimapcompounddisconnect.h"

#include "cimapcompoundrename.h"

#include "cimapcompoundselect.h"

#include "cimapsessionconsts.h"

#include "imappaniccodes.h"

#include "cimapofflinecontrol.h"

#include "imappaniccodes.h"

#include "cimapsyncdownloadrules.h"

#include "mobilitytestmtmapi.h"

CImapCompoundSyncService::CImapCompoundSyncService(CImapSyncManager& aSyncManager, CMsvServerEntry& aServerEntry, CImapSettings& aImapSettings, CImapMailStore& aImapMailStore, CImapOfflineControl& aImapOfflineControl ,TBool aDoLateDeletes)

 : CImapCompoundBase(aSyncManager, aServerEntry, aImapSettings), iImapOfflineControl(aImapOfflineControl), iImapMailStore(aImapMailStore), iDoLateDeletes(aDoLateDeletes)

	{

	// Set default progress values here so that any progress request before

	// the operation is started returns valid information.

	if(aDoLateDeletes)

		{

		iProgressState = TImap4GenericProgress::EBusy;

		iSyncProgressState=TImap4SyncProgress::EDeleting;

		}

	else

		{

		iProgressState = TImap4GenericProgress::ESyncing;

		iSyncProgressState=TImap4SyncProgress::ESyncInbox;

		}

	}

CImapCompoundSyncService::~CImapCompoundSyncService()

	{

	delete iOutstandingOps;

	delete iOutstandingMoveTypeDeletes;

	delete iOutstandingLocalDeletes;

	delete iImapCompound;

	delete iDoNotFetchSel;

	}

CImapCompoundSyncService* CImapCompoundSyncService::NewL(CImapSyncManager& aSyncManager, CMsvServerEntry& aServerEntry, CImapSettings& aImapSettings, CImapMailStore& aImapMailStore, CImapOfflineControl& aImapOfflineControl ,TBool aDoLateDeletes)

	{

	CImapCompoundSyncService* self = new (ELeave) CImapCompoundSyncService(aSyncManager, aServerEntry, aImapSettings, aImapMailStore, aImapOfflineControl,aDoLateDeletes);

	CleanupStack::PushL(self);

	self->ConstructL();

	CleanupStack::Pop(self);

	return self;

	}

void CImapCompoundSyncService::ConstructL()

	{

	iOutstandingMoveTypeDeletes = new (ELeave) CArrayFixFlat<TMsvId>(4);

	iOutstandingLocalDeletes = new (ELeave) CArrayFixFlat<TMsvId>(4);

	iPerformDeletes = !(iImapSettings.DeleteEmailsWhenDisconnecting());

	CActiveScheduler::Add(this);

	}

void CImapCompoundSyncService::StartOperation(TRequestStatus& aStatus, CImapSession& aSession)

	{

	iSession = &aSession;

	__LOG_TEXT(iSession->LogId(), "CImapCompoundSyncService::StartOperation()");

	if(iDoLateDeletes)

		{

		iNextStep = EInboxLateDeletes;

		}

	else

		{

		iNextStep = ESyncService;

		}

	Queue(aStatus);

	CompleteSelf();

	}

/**

Handles the compound operation state machine

@return ETrue if compound operation is completed, 

		EFalse otherwise (will be called again, unless active)

*/

TBool CImapCompoundSyncService::DoRunLoopL()

	{

	SetCurrentStep();

	switch (iCurrentStep)

		{

		case ESyncService:  // synchronous

			{

			// Starts the full sync process by synching the inbox

			iNextFolderSync = 0;

			__LOG_TEXT(iSession->LogId(), "CImapCompoundSyncService::DoRunLoopL : Starting the full Sync steps.");

			CImapFolder* inbox = iSyncManager.Inbox();

			if(inbox != NULL)

				{

				iNextStep = EInboxSync;

				__LOG_TEXT(iSession->LogId(), "CImapCompoundSyncService::DoRunLoopL : Processing offline for the inbox.");

					// Deal with operations in the array

				if (RefreshOutstandingOpsL(inbox->MailboxId()))

					{

					iNextStep = EInboxCheckPendingOps;

					}

				}

			else

				{

				iNextStep = ESyncTree;

				}

			CompleteSelf();

			}

			break;

		case EInboxDoneOps: // synchronous

			{

			__LOG_TEXT(iSession->LogId(), "CImapCompoundSyncService::DoRunLoopL : Performing the current offline op for the inbox.");

			iNextStep = EInboxCheckPendingOps;

			DonePendingOpL();

			CompleteSelf();

			}

			break;

		case EInboxCheckPendingOps: // synchronous

			{

			iSyncProgressState=TImap4SyncProgress::EProcessingPendingOps;

			__LOG_TEXT(iSession->LogId(), "CImapCompoundSyncService::DoRunLoopL : Find the next offline op for the inbox.");

			if (NextPendingOpL())

				{

				iNextStep = EInboxSync;

				DonePendingOpL();

				CompleteSelf();

				}

			else

				{

				iNextStep = EInboxDoneOps;

				// As there is a next pending op, we should be active so that the

				// operation can go ahead. However under some circumstances (such

				// as a missing shadow ID), the operation will not happen so we need

				// to ensure the state machine does not lock up.

				if (!IsActive())

					{

					CompleteSelf();

					}

				}

			}

			break;

		case EInboxEarlyDeletes: // async, SELECTing the inbox prior to EXPUNGE. 

			{

			__LOG_TEXT(iSession->LogId(), "CImapCompoundSyncService::DoRunLoopL : Performing early deletes for the inbox.");

			iSyncProgressState=TImap4SyncProgress::EDeleting;

			// get rid of the FromLocal message sources

			CImapFolder* inbox = iSyncManager.Inbox();

			if(inbox)

				{

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

					{

					TMsvId id = (*iOutstandingLocalDeletes)[i];

					__LOG_FORMAT((iSession->LogId(), "CImapCompoundSyncService::DoRunLoopL : Removing message %d.", id));

					inbox->DeleteMessageL(id);

					}

				iOutstandingLocalDeletes->Reset();

				// then do the inbox deletes

				if (ProcessPendingDeleteOpsL(inbox->MailboxId(), !iPerformDeletes))

					{

					MOBILITY_TEST_MTM_STATE(iImapSettings.ServiceId(), KMobilityTestMtmImapSyncEInboxEarlyDeletes);

					iNextStep = EInboxEarlyExpunge;

					inbox->SelectL(iStatus, *iSession);

					SetActive();

					return EFalse;

					}

				}

			else

				{

				iOutstandingLocalDeletes->Reset();

				}

			iNextStep = ESyncTree;

			CompleteSelf();

			}

	  		break;

		case EInboxEarlyExpunge: // async - sync deletes performed by the folder object, STORE /deleted and EXPUNGE

			{

			iSyncProgressState=TImap4SyncProgress::EDeleting;

			iNextStep = ESyncTree;

			if (iStatus.Int() == KErrImapNo)

				{

				iFoldersNotFound++;

				}

			else

				{

				// expunge the folder

				iFolder = iSyncManager.Inbox();

				if(iFolder)

					{

					MOBILITY_TEST_MTM_STATE(iImapSettings.ServiceId(), KMobilityTestMtmImapSyncEInboxEarlyExpunge);

					__LOG_FORMAT((iSession->LogId(), "CImapCompoundSyncService::DoRunLoopL : Expunge the folder %S.", &(iFolder->FullFolderPathL())));

					iFolder->SyncDeletesL(iStatus, *iSession);

					SetActive();

					return EFalse;

					}

				}

			CompleteSelf();

			}

			break;

		case EInboxSync: // async

			{

			__LOG_TEXT(iSession->LogId(), "CImapCompoundSyncService::DoRunLoopL : Calling the Syncmanger step for synching the inbox.");

			// suspend operation if stop for migrate has been requested

			if (iStopForMigrate)

				{

				__LOG_TEXT(iSession->LogId(), "CImapCompoundSyncService::Stopped for migrate");

				iCurrentStep = ESuspendedForMigrate;

				iNextStep = EInboxSync;

				Complete(KErrNone);

				return ETrue;

				}

			// Call the SyncManager inbox sync

			MOBILITY_TEST_MTM_STATE(iImapSettings.ServiceId(), KMobilityTestMtmImapSyncEInboxSync);			

			iSyncProgressState=TImap4SyncProgress::ESyncInbox;

			iSyncManager.SynchroniseInboxL(iStatus, *iSession);

			iNextStep = EInboxEarlyDeletes;

			}

			break;

		case ESyncTree:  // async

			{

			// suspend operation if stop for migrate has been requested

			if (iStopForMigrate)

				{

				__LOG_TEXT(iSession->LogId(), "CImapCompoundSyncService::Stopped for migrate");

				iCurrentStep = ESuspendedForMigrate;

				iNextStep = ESyncTree;

				Complete(KErrNone);

				return ETrue;

				}

			iNextStep = ESyncSubscriptions;

			// skip folder tree sync if disabled.

			if (iImapSettings.FolderSyncDisabled())

				{

				__LOG_TEXT(iSession->LogId(), "CImapCompoundSyncService::DoRunLoopL : Folder Tree Sync Disabled....");

				return EFalse;

				}

			__LOG_TEXT(iSession->LogId(), "CImapCompoundSyncService::DoRunLoopL : Calling the Syncmanger step to sync the folder tree.");

			// Synching the remote folders tree to local

			MOBILITY_TEST_MTM_STATE(iImapSettings.ServiceId(), KMobilityTestMtmImapSyncESyncTree);			

			iSyncProgressState=TImap4SyncProgress::ESyncFolderTree;

			iSyncManager.SynchroniseFolderTreeL(iStatus, *iSession);

			}

			break;

		case ESyncSubscriptions:  // async

			{

			__LOG_TEXT(iSession->LogId(), "CImapCompoundSyncService::DoRunLoopL : Calling the Syncmanger step to sync the folders subscriptions.");

			// Synching the remote folders tree to local

			MOBILITY_TEST_MTM_STATE(iImapSettings.ServiceId(), KMobilityTestMtmImapSyncESyncSubscriptions);

			iSyncProgressState=TImap4SyncProgress::ECheckRemoteSubscription;

			iSyncManager.SynchroniseFolderSubscriptionsL(iStatus, *iSession);

			iNextStep = ESelectSyncFolder;

			}

			break;	

		case EFolderDoneOps:  // synchronous

			{

			if(iNextFolderSync > 0)

				{

				__LOG_TEXT(iSession->LogId(), "CImapCompoundSyncService::DoRunLoopL : Calling DonePendingOp.");

				iNextStep = EFolderCheckPendingOPs;

				DonePendingOpL();

				}

			else

				{

				// All folders are done.

				iNextStep = ESyncInboxAutoFetch;

				}

			CompleteSelf();

			}

			break;

		case EFolderCheckPendingOPs: // synchronous

			{

			iSyncProgressState=TImap4SyncProgress::EProcessingPendingOps;

			if(NextPendingOpL())

				{

				__LOG_TEXT(iSession->LogId(), "CImapCompoundSyncService::DoRunLoopL : All offline ops are done, calling folder sync.");

				iNextStep = ESyncFolder;

				DonePendingOpL();

				CompleteSelf();

				}

			else

				{

				__LOG_TEXT(iSession->LogId(), "CImapCompoundSyncService::DoRunLoopL : Got a pending offline op, now do it.");

				iNextStep = EFolderDoneOps;

				// As there is a next pending op, we should be active so that the

				// operation can go ahead. However under some circumstances (such

				// as a missing shadow ID), the operation will not happen so we need

				// to ensure the state machine does not lock up.

				if (!IsActive())

					{

					CompleteSelf();

					}

				}

			}

			break;

		case EFolderEarlyDeletes: // asynchronous

			{

			iSyncProgressState=TImap4SyncProgress::EDeleting;

			CImapFolder* currentFolder = iSyncManager.GetFolderL(iNextFolderSync);

			if (currentFolder)

				{

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

					{

					TMsvId id = (*iOutstandingLocalDeletes)[i];

					__LOG_FORMAT((iSession->LogId(), "CImapCompoundSyncService::DoRunLoopL : Removing message %d.", id));

					currentFolder->DeleteMessageL(id);

					}

				iOutstandingLocalDeletes->Reset();

				// if we are doing deletes on connection then all deletes will

				// be marked Delete

				if (ProcessPendingDeleteOpsListL(!iPerformDeletes))

					{

					__LOG_FORMAT((iSession->LogId(), "CImapCompoundSyncService::DoRunLoopL : Selecting the folder %S for expunge.", &(currentFolder->FullFolderPathL())));

					MOBILITY_TEST_MTM_STATE(iImapSettings.ServiceId(), KMobilityTestMtmImapSyncEFolderEarlyDeletes);

					currentFolder->SelectL(iStatus, *iSession);

					iNextStep = EFolderEarlyExpunge;

					SetActive();

					return EFalse;

					}

				}

			else

				{

				iOutstandingLocalDeletes->Reset();

				}

			iNextStep = ESelectSyncFolder;

			CompleteSelf();

			}

			break;

		case EFolderEarlyExpunge: // asynchronous

			{

			iSyncProgressState=TImap4SyncProgress::EDeleting;

			iNextStep = ESelectSyncFolder;

			if (iStatus.Int() == KErrImapNo)

				{

				++iFoldersNotFound;

				}

			else

				{

				iFolder = iSyncManager.GetFolderL(iNextFolderSync);

				if(iFolder)

					{

					// expunge the folder

					__LOG_FORMAT((iSession->LogId(), "CImapCompoundSyncService::DoRunLoopL : Expunge the folder %S.", &(iFolder->FullFolderPathL())));

					MOBILITY_TEST_MTM_STATE(iImapSettings.ServiceId(), KMobilityTestMtmImapSyncEFolderEarlyExpunge);

					iFolder->SyncDeletesL(iStatus, *iSession);

					SetActive();

					return EFalse;

					}

				}

			CompleteSelf();

			}

			break;

		case ESelectSyncFolder: // synchronous

			{

			__LOG_TEXT(iSession->LogId(), "CImapCompoundSyncService::ESelectSyncFolder()");

			// suspend operation if stop for migrate has been requested

			if (iStopForMigrate)

				{

				__LOG_TEXT(iSession->LogId(), "CImapCompoundSyncService::Stopped for migrate");

				iCurrentStep = ESuspendedForMigrate;

				iNextStep = ESelectSyncFolder;

				Complete(KErrNone);

				return ETrue;

				}

			// Call for the first time will not be active

			iSyncManager.NextSubscribedFoldersL(iNextFolderSync);

			iSyncProgressState=TImap4SyncProgress::ESyncOther;

			if(iNextFolderSync > 0)

				{

				// Perform the pending offline operations first

				iNextStep = ESyncFolder;

				if(RefreshOutstandingOpsL(iNextFolderSync))

					{

					iNextStep = EFolderCheckPendingOPs;	

					}

				}

			else

				{

				// All folders are done.

				iNextStep = ESyncInboxAutoFetch;

				}

			CompleteSelf();

			}

			break;

		case ESyncFolder: // async

			{

			if(iNextFolderSync > 0)

				{

				// Now sync the folder

				MOBILITY_TEST_MTM_STATE(iImapSettings.ServiceId(), KMobilityTestMtmImapSyncESyncFolder);

				iSyncManager.SynchroniseSubscribedFoldersL(iStatus, *iSession, iNextFolderSync);

				iNextStep = EFolderEarlyDeletes;

				}

			else

				{

				// All folders are done.

				iNextStep = ESyncInboxAutoFetch;

				CompleteSelf();

				}

			}

			break;	

		case EInboxLateDeletes: // async

			{

			iNextFolderSync = 0;

			iSyncProgressState=TImap4SyncProgress::EDeleting;

			CImapFolder* inbox = iSyncManager.Inbox();

			if (inbox)

				{

				if (ProcessPendingDeleteOpsL( inbox->MailboxId(), EFalse ))

					{

					MOBILITY_TEST_MTM_STATE(iImapSettings.ServiceId(), KMobilityTestMtmImapEInboxLateDeletes);

					inbox->SelectL(iStatus, *iSession);

					iNextStep = EInboxLateExpunge;

					SetActive();

					return EFalse;

					}

				}

			iNextStep = EFolderLateDeletes;

			CompleteSelf();

			}

			break;	

		case EInboxLateExpunge: // async

			{

			iNextStep = EFolderLateDeletes;

			if (iStatus.Int() == KErrImapNo)

				{

				iFoldersNotFound++;

				}

			else

				{

				// expunge the folder

				iFolder = iSyncManager.Inbox();

				if(iFolder)

					{

					MOBILITY_TEST_MTM_STATE(iImapSettings.ServiceId(), KMobilityTestMtmImapSyncESyncFolder);

					__LOG_FORMAT((iSession->LogId(), "CImapCompoundSyncService::DoRunLoopL : Late Expunge the folder %S.", &(iFolder->FullFolderPathL())));

					iFolder->SyncDeletesL(iStatus, *iSession);

					SetActive();

					return EFalse;

					}

				}

			CompleteSelf();

			}

			break;

		case EFolderLateDeletes: // async

			{

			iSyncProgressState=TImap4SyncProgress::EDeleting;

			// Call for the first time will not be active

			iSyncManager.NextSubscribedFoldersL(iNextFolderSync);

			if(iNextFolderSync > 0)

				{

				if (ProcessPendingDeleteOpsListL( EFalse ) )

					{

					iNextStep = EFolderLateExpunge;

					}		

				else

					{

					CImapFolder* currentFolder = iSyncManager.GetFolderL(iNextFolderSync);

					if(currentFolder)

						{

						__LOG_FORMAT((iSession->LogId(), "CImapCompoundSyncService::DoRunLoopL : Selecting the folder %S for expunge.", &(currentFolder->FullFolderPathL())));