// Copyright (c) 2007-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:
// POPSTRAN.H
// 
//

#include "popstran.h"
#include "msventry.h"	// CMsvServerEntry
#include <txtetext.h>
#include <txtrich.h>
#include <miuthdr.h>
#include <msvutils.h>
#include <msvapi.h>

_LIT(KPop3DriveSeparator, ":");

CImPop3TransferMessage* CImPop3TransferMessage::NewL(CMsvServerEntry& aEntry)
	{
	CImPop3TransferMessage* self = new (ELeave) CImPop3TransferMessage(aEntry);
	CActiveScheduler::Add(self);
	return self;
	}

void CImPop3TransferMessage::StartL(TMsvId aSourceMessage, TMsvId aDestFolder, TImPop3TransferMethod aTransferMethod, TRequestStatus& aStatus)
	{
	iSourceMessage = aSourceMessage;
	iDestFolder = aDestFolder;
	iTransferMethod = aTransferMethod;
	iReportStatus = &aStatus;

	User::LeaveIfError(iEntry.SetEntry(aSourceMessage));
	TMsvEntry entry = iEntry.Entry();

	HBufC* details = HBufC::NewLC(entry.iDetails.Size());
	(*details) = entry.iDetails;
	HBufC* description = HBufC::NewLC(entry.iDescription.Size());
	(*description) = entry.iDescription;

	TFileName mailDirectory;
	mailDirectory.Append('a' + MessageServer::CurrentDriveL(iEntry.FileSession()));
	mailDirectory.Append(KPop3DriveSeparator);
	mailDirectory.Append(KMsvDefaultFolder2);
	
	// Get the store filename from the source message
	TFileName sourceStoreFilename = mailDirectory;
	User::LeaveIfError(iEntry.SetEntry(aSourceMessage));

	TBool storeFound = iEntry.HasStoreL();
	if (storeFound)
		{
		MsvUtils::ConstructEntryName(iEntry.Entry().iServiceId, iEntry.Entry().Id(), sourceStoreFilename, MsvUtils::EStore);	
		}

	// Create a message entry in the destination folder
	iEntry.SetEntry(aDestFolder);
	TMsvEmailEntry emailEntry(entry);
	emailEntry.SetVisible(ETrue);
	emailEntry.iDetails.Set(details->Des());
	emailEntry.iDescription.Set(description->Des());
	emailEntry.SetDisconnectedOperation(ENoDisconnectedOperations);
  
	User::LeaveIfError(iEntry.CreateEntry(emailEntry));
	iCopiedMessageId = emailEntry.Id();

	User::LeaveIfError(iEntry.SetEntry(emailEntry.Id()));
	TMsvId newEntry = emailEntry.Id();

	// Get the serviceId of the service the destination ID is located in.
	TMsvId destinationServiceId = iEntry.OwningService();

	if (storeFound)
		{
		// Get the name that the destination file should be copied to
		TFileName destinationStoreFilename = mailDirectory;
		MsvUtils::ConstructEntryName(destinationServiceId, iEntry.Entry().Id(), destinationStoreFilename, MsvUtils::EStore);
		CFileMan* fileMan = CFileMan::NewL(iEntry.FileSession());
		CleanupStack::PushL(fileMan);
		User::LeaveIfError(fileMan->Copy(sourceStoreFilename, destinationStoreFilename, CFileMan::ERecurse|CFileMan::EOverWrite));
		CleanupStack::PopAndDestroy(); // fileMan

		// This change entry isn't actually changing anything.
		// However the store contains a hidden stream created by the Message Server.
		// This is used to rebuild the index if it's corrupted
		// Calling ChangeEntry will make sure the stream is updated correctly
		iEntry.ChangeEntry(iEntry.Entry());
		}

	// Move all child entries from under the remote entry to the new entry
	User::LeaveIfError(iEntry.SetEntry(aSourceMessage));
	CMsvEntrySelection* childEntries = new (ELeave) CMsvEntrySelection;
	CleanupStack::PushL(childEntries);
	User::LeaveIfError(iEntry.GetChildren(*childEntries));
	if (childEntries->Count() > 0)
		{
		if (iTransferMethod == EImPop3CopyTransfer)
			// If we are in disconnected mode then we really want to copy the
			// entries, however if we are not then we want to move them.
			// This is because the only reason there are entries under the
			// service is because the remote server does not support the TOP
			// command.
			{
			iStatus = KRequestPending;
			iEntry.CopyEntriesL(*childEntries, newEntry, iStatus);
			SetActive();
			}
		else
			{
			iStatus = KRequestPending;
			iEntry.MoveEntriesL(*childEntries, newEntry, iStatus);
			SetActive();
			}
		}
	else
		{
		iStatus = KRequestPending;
		SetActive();
		TRequestStatus* status = &iStatus;
		User::RequestComplete(status, KErrNone);
		}

	CleanupStack::PopAndDestroy(); // childEntries

	CleanupStack::PopAndDestroy(2); // description, details

	}

void CImPop3TransferMessage::DoCancel()
	{
	iEntry.Cancel();
	
	if (iEntry.SetEntry(iDestFolder) == KErrNone)
		{
		iEntry.DeleteEntry(iCopiedMessageId);
		}
	
	User::RequestComplete(iReportStatus, KErrCancel);
	}

void CImPop3TransferMessage::RunL()
	{
	if (iStatus == KErrNone)
		{
		if (iTransferMethod == EImPop3MoveTransfer)
			// If the data under the message entry has been moved then mark it as incomplete
			{
			TInt err;
			err = iEntry.SetEntry(iSourceMessage);
			if (err == KErrNone)
				{
				TMsvEntry entry = iEntry.Entry();
				entry.SetComplete(EFalse);
				err = iEntry.ChangeEntry(entry);
				if (err != KErrNone)
					iStatus = err;
				}
			}
		}
	else
		// If the message hasn't been copied or moved correctly then
		// delete the new message.
		// The old source message is still in a valid state.
		{
		TInt err;
		err = iEntry.SetEntry(iDestFolder);
		if (err == KErrNone)
			{
			err = iEntry.DeleteEntry(iCopiedMessageId);
			if (err != KErrNone)
				iStatus = err;
			}
		}

	User::RequestComplete(iReportStatus, iStatus.Int());
	}

CImPop3TransferMessage::~CImPop3TransferMessage()
	{
	}

CImPop3TransferMessage::CImPop3TransferMessage(CMsvServerEntry& aEntry) : CActive(EPriorityStandard), iEntry(aEntry)
	{
	}