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

/**
Standard 2-phase constructor.
@param aObserverRequestStatus Request status of the observer to be completed when the operation completes.
@param aSession Handle to an opened session with the message server.
@param aEntryId The entry id for the message for the IR operation.
@return Pointer to the newly created object.
*/
CIRCancelObserver* CIRCancelObserver::NewL(TRequestStatus& aObserverRequestStatus, CMsvSession& aSession, TMsvId aEntryId)
	{
	CIRCancelObserver* me = new(ELeave) CIRCancelObserver(aObserverRequestStatus, aSession, aEntryId);
	return me;
	}

CIRCancelObserver::CIRCancelObserver(TRequestStatus& aObserverRequestStatus, CMsvSession& aSession, TMsvId aEntryId)
	:CMsvOperation(aSession, EPriorityStandard, aObserverRequestStatus), iEntryId(aEntryId)
	{
	CActiveScheduler::Add(this);
	iObserverRequestStatus = KRequestPending;
	SetActive();
	}

/**
Default destructor.
*/
CIRCancelObserver::~CIRCancelObserver()
	{
	Cancel();
	delete iMsvOperation;
	}

void CIRCancelObserver::RunL()
	{
	// The operation has completed, relay the status completion to the observer
	TRequestStatus* observerStatus = &iObserverRequestStatus;
	User::RequestComplete(observerStatus, iStatus.Int());
	}

TInt CIRCancelObserver::RunError(TInt /*aError*/)
	{
	// The RunL does not leave
	return KErrNone;
	}

void CIRCancelObserver::DoCancel()
	{
	// This is an explicit cancel from the user, cancel the operation and complete the client
	if( iMsvOperation!=NULL )
		iMsvOperation->Cancel();
	TRequestStatus* st = &iObserverRequestStatus;
	User::RequestComplete(st, KErrCancel);

	// If the operation is queued, clean up the entries
	if(!iOperationStarted)
		CleanupEntry();
	}
	
void CIRCancelObserver::CleanupEntryL() const
	{
	// Delete the entry
	CMsvEntry* entry = iMsvSession.GetEntryL(iEntryId);
	CleanupStack::PushL(entry);
	entry->DeleteL(iEntryId);
	CleanupStack::PopAndDestroy(entry);
	}

void CIRCancelObserver::CleanupEntry() const
	{
	// Call leaving version of CleanupEntry and ignore any errors
	TRAPD(err, CleanupEntryL());
	}

void CIRCancelObserver::SetOperation(CMsvOperation* aMsvOperation)
	{
	__ASSERT_DEBUG(iMsvOperation==NULL, User::Invariant());

	// Initialise the members now that we have the operation
	iMsvOperation = aMsvOperation;
	iMtm = iMsvOperation->Mtm();
	iService = iMsvOperation->Service();
	}

TRequestStatus& CIRCancelObserver::Status()
	{
	return iStatus;
	}

const TDesC8& CIRCancelObserver::ProgressL()
	{
	__ASSERT_DEBUG(iMsvOperation!=NULL, User::Invariant());

	// This call will leave if the operation is queued
	const TDesC8& progressDes = iMsvOperation->ProgressL();
	
	// Will only get to here when the operation has started so updated the flag if not already done
	if(!iOperationStarted)
		iOperationStarted = ETrue;

	return progressDes;

	}

const TDesC8& CIRCancelObserver::FinalProgress()
	{
	__ASSERT_DEBUG(iMsvOperation!=NULL, User::Invariant());

	return iMsvOperation->FinalProgress();
	}