// 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 <e32std.h>

#include "PopsDele.h"

#include "POPS.H"

#include "POPSOP.H" // CImPop3Dele

#include <msventry.h>

#include <popsmtm.h>

#include "POPSMBX.H"

#include "POPS.PAN" // imrc's own panic codes

#include "mobilitytestmtmapi.h"

//  Panic function

GLREF_C void Panic(TPopsPanic aPanic);

CImPop3Delete::CImPop3Delete(CMsvServerEntry& aRemoteEntry, CImPop3Session* aPop3Session, TMsvId aServiceId)

	: CMsgActive( KMsgPop3RefreshMailboxPriority ),iRemoteEntry(aRemoteEntry) ,iPopSession(aPop3Session), iServiceId(aServiceId)

	{

	__DECLARE_NAME(_S("CImPop3Delete"));

	}

CImPop3Delete* CImPop3Delete::NewL(CMsvServerEntry& aRemoteEntry, const CMsvEntrySelection& aMsvSelection, CImPop3Session* aPop3Session, TMsvId aServiceId)

	{

	CImPop3Delete* self = new (ELeave) CImPop3Delete(aRemoteEntry, aPop3Session, aServiceId);

	CleanupStack::PushL(self);

	self->ConstructL(aMsvSelection);

	CleanupStack::Pop();

	return self;

	}

void CImPop3Delete::ConstructL( const CMsvEntrySelection& aMsvSelection)

	{

	// make our copy of aMsvSelection

	iSource = aMsvSelection.CopyL();

	iPopDelete=CImPop3Dele::NewL(iPopSession);

	CActiveScheduler::Add(this);	  // Add CImPop3Delete to scheduler's queue

	iCancelToMigrate = EFalse;

	}

CImPop3Delete::~CImPop3Delete()

	{

	// delete everything here

	Cancel();

	delete iSource;

	delete iPopDelete;

	}

//

// Cancel any current operation

//

void CImPop3Delete::DoCancel()

	{

	if (!iMigratingToNewBearer)

		{

		iPopSession->SetOpNotPending();

		}

	iPopDelete->Cancel();

	CMsgActive::DoCancel();

	}

//

// Start me up

//

void CImPop3Delete::Start(TRequestStatus& aStatus)

	{

	iMsgCtr=0;

	iProgress.iTotalMsgs=iSource->Count();

	iProgress.iMsgsToProcess=iProgress.iTotalMsgs;

	if(iSource->Count())

		{

		DoDelete();

		Queue(aStatus);

		}

	else

		{

		aStatus = KRequestPending;

		TRequestStatus* pS=&aStatus;

		User::RequestComplete(pS,KErrNone);

		}

	}

// ****************************************************************************************** 

// Resume function called by the POP Server MTM, once it has completed Migrating to new bearer

// 

// ******************************************************************************************	

void CImPop3Delete::ResumeL(CImPop3Session* aPopSession, TRequestStatus& aStatus)

	{

	iMigratingToNewBearer = EFalse;

	iPopSession = aPopSession;

	delete iPopDelete;

	iPopDelete = NULL;

	iPopDelete = CImPop3Dele::NewL(iPopSession);

	if(iSource->Count())

		{

		DoDelete();

		Queue(aStatus);

		}

	else

		{

		aStatus = KRequestPending;

		TRequestStatus* pS = &aStatus;

		User::RequestComplete(pS,KErrNone);

		}

	}	

//

// Result of last active call

//

void CImPop3Delete::DoRunL()

    {

	//  No really good error handling can occur below.

	TInt err = iRemoteEntry.DeleteEntry(iSource->At(iMsgCtr));

	//DMC __ASSERT_DEBUG(err == KErrNone, Panic(EPopFailedDebugAssert));

	iMsgCtr++;

	iProgress.iMsgsToProcess--;

	// Decrement iMtmData3 attribute of the service entry - count of messages on POP3 server

	// NB our handle to the CMsvServerEntry must always be set to the service entry

	// prior to call to CImPop3Delete::NewL.

	TMsvEntry serviceEntry  = iRemoteEntry.Entry();

	serviceEntry.SetMtmData3(serviceEntry.MtmData3()-1);

	err = iRemoteEntry.ChangeEntry(serviceEntry);

	if(iMsgCtr<iSource->Count())

		{

		// If we are migrating halt the operation here

		if (iMigratingToNewBearer)

			{			

			// If we don't SetActive, the RunL will complete the request

			return;

			}

		else

			{

			DoDelete();

			}

		}

	else

		{

		iProgress.iMsgsToProcess=0;

		}

    }

//

// Fire off the delete process

//

void CImPop3Delete::DoDelete()

	{

	TMsvId msgId=iSource->At(iMsgCtr);

//DMC

	if (iPopDelete->SetMessage(msgId))

 		{

		iPopDelete->Start(iStatus);

		// activate ourselves

		SetActive();

		MOBILITY_TEST_MTM_STATE(iServiceId, KMobilityTestMtmStatePopDeleting);

		}

	else

		{

		SetActive();

		iStatus = KRequestPending;

		TRequestStatus* pS=&iStatus;

		User::RequestComplete(pS,KErrNone);

		}

	}

//

// Report the refreshing news back to the UI

//

TPop3Progress CImPop3Delete::Progress()

	{

	return iProgress;

	}

// ****************************************************************************************** 

// This is called by the POP Server MTM when it starts Migrating Bearer

// 

// ******************************************************************************************

void CImPop3Delete::Pause()

	{

	// Set the Migration flag

	iMigratingToNewBearer = ETrue;

	}

// ****************************************************************************************** 

// This is called by the POP Server MTM when it starts Migrating Bearer

// 

// ******************************************************************************************	

void CImPop3Delete::CancelAllowResume()

	{

	iMigratingToNewBearer = ETrue;

	// Cancel the deletion of the current message  and decrement counters 

	// so we can restart from this message onwards when we have migrated.

	// Use the normal cancel, as we really need to cancel here.

	Cancel();		

	}