// 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 the License "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:

// This is the Cpp file which contains the utility functions to delete all children in the

// message store

// 

//

/**

 @file

*/

// User includes

#include <t_utilsdeleteallchildren.h>

// Epoc includes

#include <msvapi.h>

#include <msvuids.h>

/**

CT_MsgUtilsDeleteAllChildren()

Constructor

@param aSession

An object of CMsvSession

@param aParentId

Entry ID of whose children would be deleted

*/

EXPORT_C CT_MsgUtilsDeleteAllChildren::CT_MsgUtilsDeleteAllChildren(CMsvSession* aSession,TMsvId aParentId) 

: CActive(EPriorityNormal), iSession(aSession), iParentId(aParentId) 

	{

	CActiveScheduler::Add(this);

	}

/**

~CT_MsgUtilsDeleteAllChildren()

Destructor

*/

CT_MsgUtilsDeleteAllChildren::~CT_MsgUtilsDeleteAllChildren()

	{

	delete iEntry;

	delete iSelection;

	}

/**

StartL()

Deletes the children entries of the specified parent

@param aStatus			

*/

EXPORT_C void CT_MsgUtilsDeleteAllChildren::StartL(TRequestStatus& aStatus)

	{

	StartL(EFalse, aStatus);

	}

/**

StartL()

Deletes the children entries of the specified parent

@param aBlockDelete Delete all in one go

@param aStatus			

*/

EXPORT_C void CT_MsgUtilsDeleteAllChildren::StartL(TBool aBlockDelete, TRequestStatus& aStatus)

	{

	iRequestStatus = &aStatus;

	aStatus = KRequestPending;

	// Creates a new CMsvEntry for the specified parent entry ID nad sets the context

	// to that entry.

	if(iEntry==NULL)

	{

	iEntry = CMsvEntry::NewL(*iSession,iParentId,TMsvSelectionOrdering(KMsvNoGrouping,EMsvSortByNone,ETrue));

	}

	iEntry->SetEntryL(iParentId);

	// Gets a selection containing the IDs of children

	iSelection = iEntry->ChildrenL();

	iTotalChildren = iSelection->Count();

	// If the entry has no children entries, then signals the thread that the asynchronous request 

	// is complete.

	if (iTotalChildren == 0)

		{

		User::RequestComplete(iRequestStatus,KErrNone);

		}

	// If the entry has children entries then,delete child entries of the context

	// recursively through all the descendants

	else

		{

		if (aBlockDelete)

			{

			iOperation = iEntry->DeleteL(*iSelection ,iStatus);

			iState = EBlockDelete;

			}

		else

			{

			iOperation = iEntry->DeleteL((*iSelection)[iCurrentChild],iStatus);

			iState = EStateThisLevel;

			}

		SetActive();

		}

	}

/**

DoCancel()

Implements cancellation of an outstanding request

@see CActive::Cancel()

*/

void CT_MsgUtilsDeleteAllChildren::DoCancel()

	{

	switch (iState)

		{

		case EStateThisLevel:

		case EBlockDelete:

			iOperation->Cancel();

			break;

		case EStateNextLevel:

			iNextLevel->Cancel();

			break;

		}

	}

/**

RunL()

Handles an active object's request completion event

@see CActive::RunL()

*/

void CT_MsgUtilsDeleteAllChildren::RunL()

	{

	TInt err;

	switch (iState)

		{

		case EStateThisLevel:

			err = CT_MsgUtilsDeleteAllChildren::FinalProgressStatus(*iOperation,iStatus);

			delete iOperation;

			iOperation = NULL;

			switch (err)

				{

				case KErrAccessDenied:

					iUndeletedChildren++;

					if(iNextLevel==NULL)

					{

					iNextLevel = new (ELeave) CT_MsgUtilsDeleteAllChildren(iSession,(*iSelection)[iCurrentChild]);

					}

					iNextLevel->StartL(iStatus);

					SetActive();

					iState = EStateNextLevel;

					break;

				case KErrNone:

					if (++iCurrentChild == iTotalChildren)

						{

						User::RequestComplete(iRequestStatus,KErrNone);

						}

					else

						{

						iOperation = iEntry->DeleteL((*iSelection)[iCurrentChild],iStatus);

						SetActive();

						}

					break;

				default:

					User::RequestComplete(iRequestStatus,err);

					break;			

				}

				break;

		case EStateNextLevel:

			err = iStatus.Int();

			iUndeletedChildren += iNextLevel->Undeleted();

			delete iNextLevel;

			iNextLevel = NULL;

			switch (err)

				{

				case KErrNone:

					if (++iCurrentChild == iTotalChildren)

						{

						User::RequestComplete(iRequestStatus,KErrNone);

						}

					else

						{

						iOperation = iEntry->DeleteL((*iSelection)[iCurrentChild],iStatus);

						SetActive();

						iState = EStateThisLevel;

						}

					break;

				default:

					User::RequestComplete(iRequestStatus,err);

					break;

				}

			break;

		case EBlockDelete:

			{

			err = CT_MsgUtilsDeleteAllChildren::FinalProgressStatus(*iOperation,iStatus);

			delete iOperation;

			iOperation = NULL;

			User::RequestComplete(iRequestStatus,err);

			break;

			}

		}

	}

/**

FinalProgressStatus()

This function gets the information about a completed operation for the local entries..

@param aOperation	

Used to get progress information about the operation

@param aStatus	

@return

The error code

*/

EXPORT_C TInt CT_MsgUtilsDeleteAllChildren::FinalProgressStatus(CMsvOperation& aOperation,const TRequestStatus& aStatus)

	{

	TInt err = KErrNone;

	if (aOperation.Mtm() == KUidMsvLocalServiceMtm)

		{

		TPckgBuf<TMsvLocalOperationProgress> progress;

		progress.Copy(aOperation.FinalProgress());

		err = progress().iError;

		}

	else

		{

		if (iState == EBlockDelete)

			{

			TRAP_IGNORE(err = McliUtils::GetProgressErrorL(aOperation));

			}

		else

			{

			err = aStatus.Int();

			}

		}

	return (err);

	}