// Copyright (c) 2006-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:

//

#define _MSVAPI_DONT_INCLUDE_FLOGGER_

#include <e32std.h>

#include "POPSMTM.H"

#include "POPSMBX.H"

#include "POPS.H"

#include "POPSOFFL.H"

#include <iapprefs.h>

// panics

#include "POPS.PAN"

#include <pop3set.h>

#include <miutset.h>	// internet mail settings

#include <miuthdr.h>

#include <offop.h>

#include <commdb.h>

#include <pop3cmds.h>

#include <imcvutil.h>

#include <cemailaccounts.h>

#include <tmsvsystemprogress.h>

#include "msventry.h"	// CMsvServerEntry

#include "POPSMTM.H"

#include "POPS.H"

#include "POPSOFFL.H"

#include "IAPPrefs.h"

#include "PopsDele.h"

#include "POPSRFSH.h"

#include "PopsCpMv.h"

#include "PopsTopPop.h"

#include "cpopsessionmanager.h"

#include "imutcon.h"

#include "cimmobilitymanager.h"

#include "mobilitytestmtmapi.h"

const TUid KUidPop3ServerMtm = {0x10003C77};

#if (defined SYMBIAN_USER_PROMPT_SERVICE) 

#include "cpopupsresponsewaiter.h"

#endif

//

// factory function

//

EXPORT_C CImppServerMtm* CImppServerMtm::NewL(CRegisteredMtmDll& aPopServerMtmDll,

											  CMsvServerEntry* aEntry) 

	{

	CImppServerMtm* popServerMtm=new CImppServerMtm(aPopServerMtmDll, aEntry);

	if (popServerMtm==NULL)

		{

		aPopServerMtmDll.ReleaseLibrary();

		User::Leave(KErrNoMemory);

		}

	CleanupStack::PushL(popServerMtm);

	popServerMtm->ConstructL();

	CleanupStack::Pop();

	return popServerMtm;

	}

	//

void CImppServerMtm::CopyFromLocalL(const CMsvEntrySelection& /*aSelection*/, TMsvId/* aDestination*/, TRequestStatus& /*aStatus*/)

	{

	User::Leave(KErrNotSupported);

	}

//

// IMPPCPMV

//

void CImppServerMtm::CopyToLocalL(const CMsvEntrySelection& aSelection,

                                  TMsvId aDestination,

                                  TRequestStatus& aStatus)

	{

	if (AcceptingOfflineOperationsL(aSelection))

		{

		AddOfflineOperationL(aSelection, aDestination, CImOffLineOperation::EOffLineOpCopyToLocal, aStatus);

		}

	else if (iMigrationState!=ENotMigrating && !iState.iRunningOfflineOperations)

		{

		// do not accept new operations if currently migrating

		User::Leave(KErrServerBusy);

		}

	else

		{

		DoCopyMoveL( aSelection, aDestination, aStatus, EImppCopy);

		}

	}

void CImppServerMtm::MoveToLocalL(const CMsvEntrySelection& aSelection,TMsvId aDestination, TRequestStatus& aStatus)

	{

	if (AcceptingOfflineOperationsL(aSelection))

		{

		AddOfflineOperationL(aSelection, aDestination, CImOffLineOperation::EOffLineOpMoveToLocal, aStatus);

		}

	else if (iMigrationState!=ENotMigrating && !iState.iRunningOfflineOperations)

		{

		// do not accept new operations if currently migrating

		User::Leave(KErrServerBusy);

		}

	else

		{

		DoCopyMoveL( aSelection, aDestination, aStatus, EImppMove);

		}

	}

//

// IMPPDELE

//

void CImppServerMtm::DeleteAllL(const CMsvEntrySelection& aSelection, TRequestStatus& aStatus)

	{

	if (iMigrationState!=ENotMigrating && !iState.iRunningOfflineOperations)

		{

		// do not accept new operations if currently migrating

		User::Leave(KErrServerBusy);

		}

	if (PruneMessages(aSelection, aStatus))

		{

		// Was this call to DeleteAllL an instruction to delete local parts of a message ?

		// If so then we don't need to continue.

		return;

		}

	if (iPopSettings == 0)

		{

		GetPopDetailsL(aSelection);

		}

	if ((iPopSettings->DisconnectedUserMode()) && (!iState.iQuitting))

		// If we are in disconnected mode (although not necessarily disconnected)

		// and we are not quitting then add the delete as an offline operation.

		{

		AddOfflineOperationL(aSelection, 0, CImOffLineOperation::EOffLineOpDelete, aStatus);

		}

	else

		// If we are not in disconnected mode or we are quitting then do the delete now.

		{

		__ASSERT_DEBUG(iConnectedToPopMbox, Panic(EPopNotConnectedToMbox));

		if(iConnectedToPopMbox==EFalse)

			{

			TRAP_IGNORE( DoShowMessagesL( EFalse ) );

			User::Leave(KErrDisconnected);

			}

		__ASSERT_DEBUG(iState.iCurrentOperation==EPopConnectedAndIdle,Panic(EImppAlreadyActive));

		if(iState.iCurrentOperation!=EPopConnectedAndIdle)

			{

			User::Leave(KErrInUse);

			}

		iReportStatus=&aStatus;

		Cancel();

		ResetProgress();

		__ASSERT_ALWAYS(iServerEntry, Panic(EPopNullPointer));

		// make sure iServerEntry is set to the service entry

		User::LeaveIfError(iServerEntry->SetEntry(iServiceId));

		CMsvEntrySelection* sel=StripInvalidEntriesLC(aSelection);

		// set selected entries invisible (hopefully so they wont be selected twice)

		TInt err=iServerEntry->ChangeAttributes( *sel, 0, KMsvVisibilityAttribute);

		if (err)

			{

			iServerEntry->ChangeAttributes( *sel,KMsvVisibilityAttribute,0);

			User::Leave(err);

			}

		delete iPopDelete;

		iPopDelete=NULL;

		iPopDelete=CImPop3Delete::NewL(*iServerEntry,*sel,iPopSession, iServiceId);

		CleanupStack::PopAndDestroy(); //sel

		iPopDelete->Start(iStatus);

		SetActive();

		aStatus = KRequestPending;

		iOperationActive=ETrue;

		iState.iCurrentOperation=EPopDeleting;

		}

	}

void CImppServerMtm::CopyWithinServiceL(const CMsvEntrySelection& aSelection,TMsvId aDestination, TRequestStatus& aStatus)

	{

	if (aDestination == iServiceId)

		// If the service id is given as the destination then the message selection is populated.

		{

		if (AcceptingOfflineOperationsL(aSelection))

			{

			AddOfflineOperationL(aSelection, aDestination, CImOffLineOperation::EOffLineOpCopyWithinService, aStatus);

			}

		else if (iMigrationState!=ENotMigrating && !iState.iRunningOfflineOperations)

			{

			// do not accept new operations if currently migrating

			User::Leave(KErrServerBusy);

			}

		else

			{

			DoCopyMoveL( aSelection, 0 /*ignored when populating*/, aStatus, EImppPopulate);	

			}

		}

	else

		{

		User::Leave(KErrNotSupported);	

		}

	}

void CImppServerMtm::CreateL(TMsvEntry/* aNewEntry*/, TRequestStatus& /*aStatus*/)

	{

	User::Leave(KErrNotSupported);

	}

void CImppServerMtm::ChangeL(TMsvEntry aNewEntry, TRequestStatus& aStatus)

	{

	__ASSERT_ALWAYS(iServerEntry, Panic(EPopNullPointer));

	User::LeaveIfError(iServerEntry->SetEntry( aNewEntry.Id() ));

	User::LeaveIfError(iServerEntry->ChangeEntry( aNewEntry ));

	TRequestStatus* status = &aStatus;

	User::RequestComplete(status, KErrNone);

	}

void CImppServerMtm::MoveFromLocalL(const CMsvEntrySelection& /*aSelection*/,TMsvId /*aDestination*/, TRequestStatus& /*aStatus*/)

	{

	User::Leave(KErrNotSupported);

	}

void CImppServerMtm::MoveWithinServiceL(const CMsvEntrySelection& /*aSelection*/,TMsvId /*aDestination*/, TRequestStatus& /*aStatus*/)

	{

	User::Leave(KErrNotSupported);

	}

//

// Connect and refresh mailbox or quit 

//

void CImppServerMtm::StartCommandL(CMsvEntrySelection& aSelection, TInt aCommand, const TDesC8& aParameter, TRequestStatus& aStatus)

	{

	if (iMigrationState!=ENotMigrating && aCommand!=KPOP3MTMDisconnect && !iState.iRunningOfflineOperations)

		{

		// do not accept new operations (except disconnect) if currently migrating

		User::Leave(KErrServerBusy);

		}

	switch(aCommand)

		{

	case KPOP3MTMConnect: // KPop3MtmConnectUID

		MOBILITY_TEST_MTM_STATE(iServiceId, KMobilityTestMtmStatePopConnecting);

		break;

	case KPOP3MTMDisconnect:

		DoQuitL(aStatus);

		break;

	case KPOP3MTMCancelOfflineOperations:

		if (iPopSettings == 0)

			{

			GetPopDetailsL(aSelection);

			}

		MOBILITY_TEST_MTM_STATE(iServiceId, KMobilityTestMtmStatePopCancellingOfflineOps);

		CancelOfflineOperationsL(aSelection, aStatus);

		break;

	case KPOP3MTMPopulate:

		{

		GetPopDetailsL(aSelection);

		// unpackage the destination from aParameter

		TImPop3PopulateOptions info;

		TImPop3PopulateOptions::UnpackL(aParameter,info);			

		DoTopPopulateL(aSelection,info.PopulationLimit(),aStatus);

		}

		break;

	case KPOP3MTMIsConnected:

	default:

		User::Leave(KErrNotSupported);

		break;

		}

	}

//

//

//

	{

	__ASSERT_ALWAYS(iServerEntry, Panic(EPopNullPointer));

	if(IsActive())

		{

		User::Leave(KErrPop3ServerAlreadyConnected);

		}

	iNotConnectToPopMailBox = EFalse ;	

	// set this here so progress can be set

#if (defined SYMBIAN_USER_PROMPT_SERVICE) 	

	iState.iCurrentOperation = EPopAuthoriseAndConnect;

#else

	iState.iCurrentOperation = EPopConnecting;

#endif	

	ResetProgress();

	// POP3 settings

	// attempt to open POP3 service settings leave if we cant

	GetPopDetailsL(aSelection);

	delete iMessagesToKeep;

	iMessagesToKeep = NULL;

	iMessagesToKeep = aSelection.CopyL();

	iReportStatus=&aStatus;

	// Clear the new attribute on all entries if we are connecting

	User::LeaveIfError(iServerEntry->SetEntry(iServiceId));

	CMsvEntrySelection* selection = new (ELeave) CMsvEntrySelection;

	CleanupStack::PushL(selection);

	User::LeaveIfError(iServerEntry->GetChildren(*selection));  

	User::LeaveIfError(iServerEntry->ChangeAttributes(*selection, 0, KMsvNewAttribute));

	CleanupStack::PopAndDestroy(); // selection

	// create session manager

	if (!iSessionManager)

		{

		iSessionManager = CPopSessionManager::NewL();

		}

#if (defined SYMBIAN_USER_PROMPT_SERVICE) 	

	// Connect to UPS server and check if connection to remote server is permitted.

	iWaiter->AuthoriseAndConnectL(iPopSettings, iClientThreadId, iHasCapability, iStatus);

#else

	// obtain a connected pop session

	iSessionManager->GetSessionL(*iPopSettings, *iIAPPreferences, iPopSession, iStatus);

#endif

	iOperationActive=ETrue;

	SetActive();

	aStatus = KRequestPending;

	}

void CImppServerMtm::ResetProgress()

	{

	iPopProgress.iTotalMsgs=0;

	iPopProgress.iMsgsToProcess=0;

	iPopProgress.iBytesDone=0;

	iPopProgress.iTotalBytes=0;

	iPopProgress.iErrorCode=KErrNone;

	iPopProgressBuf.Zero();

	}

// utlity method - check state of mailbox and make sure it's raeady

void CImppServerMtm::CheckMailboxStateL()

	{

	__ASSERT_DEBUG(iConnectedToPopMbox, Panic(EPopNotConnectedToMbox));

	if(!iConnectedToPopMbox)

		{

		TRAP_IGNORE( DoShowMessagesL( EFalse ) );

		User::Leave(KErrDisconnected);

		}

	__ASSERT_DEBUG(iState.iCurrentOperation==EPopConnectedAndIdle,Panic(EImppAlreadyActive));

	if(iState.iCurrentOperation!=EPopConnectedAndIdle)

		{

		User::Leave(KErrInUse);

		}

	}

//

// Do the refresh

//

void CImppServerMtm::DoRefreshL()

	{

	__ASSERT_ALWAYS(iServerEntry, Panic(EPopNullPointer));

	ResetProgress();

	delete iMsvIdArray;

	iMsvIdArray=NULL;

	iMsvIdArray=new(ELeave)CArrayFixFlat<TMsvId>(8);

	// context of entry should be set to service entry

	User::LeaveIfError(iServerEntry->SetEntry(iServiceId));

	delete iPopRefreshMailbox;

	iPopRefreshMailbox=NULL;

	iPopRefreshMailbox = CImPop3RefreshMailBox::NewL(*iServerEntry, *iPopSession, iServerEntry->FileSession());

	iPopRefreshMailbox->SetMessagesToKeepL(iMessagesToKeep);

	iPopRefreshMailbox->Start(iStatus,iMsvIdArray);

	iOperationActive=ETrue;

	SetActive();

	iState.iCurrentOperation=EPopRefreshing;

	MOBILITY_TEST_MTM_STATE(iServiceId, KMobilityTestMtmStatePopRefreshing);

	}

void CImppServerMtm::DoCopyMoveL(const CMsvEntrySelection& aSelection, TMsvId aDestination, TRequestStatus& aStatus, TImppCopyMethod aCopyMethod)

	{

	__ASSERT_ALWAYS(iServerEntry, Panic(EPopNullPointer));

	CheckMailboxStateL();

	Cancel();

	iReportStatus=&aStatus;

	ResetProgress();

	User::LeaveIfError(iServerEntry->SetEntry(iServiceId));

	CMsvEntrySelection* sel=StripInvalidEntriesLC(aSelection);

	if( aCopyMethod == EImppMove)

		{

		// set selected entries invisible (hopefully so they wont be selected twice)

		TInt err=iServerEntry->ChangeAttributes(*sel, 0, KMsvVisibilityAttribute);

		if (err)

			{

			iServerEntry->ChangeAttributes(*sel,KMsvVisibilityAttribute,0);

			User::Leave(err);

			}

		}

	delete iPopCopyMove;

	iPopCopyMove=NULL;

	if (aCopyMethod == EImppPopulate)

		{

		iPopCopyMove = CImPop3CopyMove::NewL(*sel,*iServerEntry,iPopSession,ETrue,iServerEntry->FileSession(), iLogMessage, iPopSettings->DisconnectedUserMode());

		}

	else

		{

		iPopCopyMove = CImPop3CopyMove::NewL(*sel,*iServerEntry,iPopSession,(aCopyMethod == EImppCopy),iServerEntry->FileSession(),aDestination, iLogMessage, iPopSettings->DisconnectedUserMode());

		}

	CleanupStack::PopAndDestroy(); //sel

	switch (aCopyMethod)

		{

		case EImppCopy:

			iState.iCurrentOperation = EPopCopying;

			MOBILITY_TEST_MTM_STATE(iServiceId, KMobilityTestMtmStatePopCopying);

			break;

		case EImppMove:

			iState.iCurrentOperation = EPopMoving;

			MOBILITY_TEST_MTM_STATE(iServiceId, KMobilityTestMtmStatePopMoving);

			break;

		case EImppPopulate:

			iState.iCurrentOperation = EPopPopulating;

			MOBILITY_TEST_MTM_STATE(iServiceId, KMobilityTestMtmStatePopPopulating);

			break;

		default:

			User::Leave(KErrNotSupported);

			break;

		};

	iPopCopyMove->StartL(iStatus);

	SetActive();

	aStatus = KRequestPending;

	iOperationActive = ETrue;

	}

void CImppServerMtm::DoTopPopulateL(const CMsvEntrySelection& aSelection, TInt aLimit, TRequestStatus& aStatus)

	{

	// Deletion of service entry from entrySelection which is added at client

	CMsvEntrySelection* sel=StripInvalidEntriesLC(aSelection);

	if(sel->At(0) == iServiceId)

		{

		sel->Delete(0);

		}

	if ( aLimit==KErrNotFound )

		{

		// A full populate is required

		DoCopyMoveL(*sel,sel->At(0),aStatus,EImppPopulate);

		CleanupStack::PopAndDestroy(sel);

		return;

		}

	CheckMailboxStateL();

	Cancel();

	iReportStatus=&aStatus;

	ResetProgress();

	__ASSERT_ALWAYS(iServerEntry, Panic(EPopNullPointer));

	User::LeaveIfError(iServerEntry->SetEntry(iServiceId));

	RArray<TUint> sizes;

	CleanupClosePushL(sizes);

	TInt count=sel->Count();

	for(TInt i=0;i<count;i++)

		{

		User::LeaveIfError(sizes.Append(iPopRefreshMailbox->RemoteMessageSizeL(sel->At(i))));

		}

	delete iPopTopPop;

	iPopTopPop=NULL;

	iPopTopPop = CImPop3TopPopulate::NewL(*sel,*iServerEntry,aLimit,iPopSession,iServerEntry->FileSession(), iLogMessage, iPopSettings->DisconnectedUserMode(),sizes);

	CleanupStack::Pop(&sizes);

	CleanupStack::PopAndDestroy(sel);

	iState.iCurrentOperation = EPopTopPopulating;

	MOBILITY_TEST_MTM_STATE(iServiceId, KMobilityTestMtmStatePopTopPopulating);

	iPopTopPop->StartL(iStatus);

	SetActive();

	aStatus = KRequestPending;

	iOperationActive = ETrue;

	}

//

// quit

//

void CImppServerMtm::DoQuitL(TRequestStatus& aStatus)

	{

	__ASSERT_ALWAYS(iServerEntry, Panic(EPopNullPointer));