// 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 "cbodyqueueentry16.h"
#include "cimaputils.h"
#include "cimaplogger.h"
#include <txtrich.h>

/**
Constructor.
*/
CBodyChunk16Info::CBodyChunk16Info(TInt aChunkNumber,HBufC8* aData)
:iChunkNumber(aChunkNumber),iData(aData)
	{
	}
/**
Destructor.
*/	
CBodyChunk16Info::~CBodyChunk16Info()
	{
	delete iData;
	}
/**
Constructor.
*/
CBodyQueueEntry16::CBodyQueueEntry16(TInt aTotalChunks,CImapMailStore& aParent,CMsvServerEntry& aServerEntry,CImapSettings& aImapSettings,CFetchBodyInfo& aFetchBodyInfo,TInt aLogId,MMailStoreObserver& aObserver, TBool aBinaryCap)
	: CQueueEntryBase(aFetchBodyInfo.PartId(),EBody16,aParent,aServerEntry,aObserver),
	iTotalChunks(aTotalChunks),
	iEncoding(aFetchBodyInfo.ContentTransferEncoding()),
	iCharsetId(aFetchBodyInfo.CharsetId()),
	iBodyPartRemainingSize(aFetchBodyInfo.BodyPartRemainingSize()),
	iImapSettings(aImapSettings),
	iLogId(aLogId)
#if (defined SYMBIAN_EMAIL_CAPABILITY_SUPPORT)		
	, iBinaryCap(aBinaryCap)
#endif
	{
	//to ignore compilation warnings
	aBinaryCap = aBinaryCap;
	}

/**
Destructor.
*/		
CBodyQueueEntry16::~CBodyQueueEntry16()
	{
	delete iBodyText;
	delete iCharFormatLayer;
	delete iParaFormatLayer;
	delete iStoreUtilities;
	iDataArray.Close();
	}
	
/**
Factory constructors.
*/
CBodyQueueEntry16* CBodyQueueEntry16::NewL(TInt aTotalChunks,CImapMailStore& aParent,CMsvServerEntry& aServerEntry,CImapSettings& aImapSettings,CFetchBodyInfo& aFetchBodyInfo,TInt aLogId,MMailStoreObserver& aObserver, TBool aBinaryCap)
	{
	CBodyQueueEntry16* self=new(ELeave)CBodyQueueEntry16(aTotalChunks,aParent,aServerEntry,aImapSettings,aFetchBodyInfo,aLogId,aObserver,aBinaryCap);
	CleanupStack::PushL(self);
	self->ConstructL();
	CleanupStack::Pop();
	return self;
	}

void CBodyQueueEntry16::ConstructL()
	{
	BaseConstructL();
	iParaFormatLayer=CParaFormatLayer::NewL();
	iCharFormatLayer=CCharFormatLayer::NewL(); 
	iBodyText=CRichText::NewL(iParaFormatLayer, iCharFormatLayer);
	if(iCharsetId == KUidMsvCharsetNone)
		{
		// Get the default charset
		CCnvCharacterSetConverter* characterConverter = CCnvCharacterSetConverter::NewL();
		CleanupStack::PushL(characterConverter);
		CImConvertCharconv* charConv = CImConvertCharconv::NewL(*characterConverter, CImapUtils::GetRef().Fs());
	
		iCharsetId = charConv->SystemDefaultCharset();
		delete charConv;
		CleanupStack::PopAndDestroy();//characterConverter
		}
	iStoreUtilities=CStoreUtilities::NewL(iEncoding,iCharsetId, CImapUtils::GetRef().Fs());
	}

/**
Adds a chunk of body data to the data array and sorts the array
@param aData 			the body data, ownership  is taken.
@param aChunkNumber 	the order number in which the chunk makes up the whole data.
@return 
*/		
void CBodyQueueEntry16::AddChunkL(HBufC8* aData,TInt aChunkNumber, TInt aExtraFetchRequestCount)
	{
#if (defined SYMBIAN_EMAIL_CAPABILITY_SUPPORT)		
	if(iBinaryCap)
		{
		iExtraFetchRequestCount=aExtraFetchRequestCount;
		}
#else
	//to ignore compilation warnings
	aExtraFetchRequestCount = aExtraFetchRequestCount;	
#endif
	__LOG_FORMAT((iLogId, "CBodyQueueEntry16::AddChunkL chunk number = %d",aChunkNumber));
	CleanupStack::PushL(aData);
	//make sure the chunk is within range.
	__ASSERT_DEBUG(aChunkNumber<iTotalChunks,TImapServerPanic::ImapPanic(TImapServerPanic::EMailStoreDataChunkOutOfRange));
	//append the chunk
 	CBodyChunk16Info* chunkInfo = new(ELeave) CBodyChunk16Info(aChunkNumber,aData);
 	CleanupStack::PushL(chunkInfo);
 	TLinearOrder<CBodyChunk16Info>compareChunks(CompareChunks); 	
 	iDataArray.InsertInOrderL(chunkInfo,compareChunks);
    CleanupStack::Pop(2,aData);
    
    if(!IsActive())
		{
  	  	CompleteSelf();	
		}
	}
	
/**
Used to sort chunks of data by chunk number.
@param aChunkBodyInfo1 	the first chunk in the comparision
@param aChunkBodyInfo2 	the second chunk in the comparision
@return TInt			the difference between the first chunks number and the second chunks number.
*/	
TInt CBodyQueueEntry16::CompareChunks(const CBodyChunk16Info& aChunkBodyInfo1, const CBodyChunk16Info& aChunkBodyInfo2)
	{
	return aChunkBodyInfo1.iChunkNumber-aChunkBodyInfo2.iChunkNumber;	
	}

TInt CBodyQueueEntry16::RunError(TInt aError)
	{
	iDataArray.Close();
	return CQueueEntryBase::RunError(aError);
	}
	
/**
Uses CMsvEntry to synchronousy store the requests data object.
@param 
@return
*/
void CBodyQueueEntry16::RunL()
	{
	
	//while there are contiguous chunk in the data array append the data to the CRichText object
	while(iDataArray.Count()>0 && iDataArray[0]->iChunkNumber==iNextExpectedChunk)
		{
		++iNextExpectedChunk;
		//is this the last chunk?
		TBool lastChunk=(iNextExpectedChunk==iTotalChunks);
		HBufC8* decodedData = NULL;
#if (defined SYMBIAN_EMAIL_CAPABILITY_SUPPORT)		
		if(iBinaryCap)
			{
			__LOG_FORMAT((iLogId, "CBodyQueueEntry16::RunL Decoding not required since binary capability is set..."));	
			const TPtrC8& bodyData = *(iDataArray[0]->iData);
			decodedData = HBufC8::NewL(bodyData.Length());
			// Message body is downloaded using Fetch Binary and the data is decoded by the IMAP mail server
			// Nothing to do, just copy data
			decodedData->Des().Append(bodyData);			
			}
		else
#endif
			{	
			//decode the data
			__LOG_FORMAT((iLogId, "CBodyQueueEntry16::RunL Decoding..."));
			decodedData=iStoreUtilities->DecodeL(*(iDataArray[0]->iData),lastChunk);
			}	
		__ASSERT_DEBUG(decodedData!=NULL, TImapServerPanic::ImapPanic(TImapServerPanic::EMailStoreDecodeDataNull));
		CleanupStack::PushL(decodedData); 
		//if this is the last chunk and if was a partial download then add footer
		if(iBodyPartRemainingSize && iNextExpectedChunk==iTotalChunks)
			{
			__LOG_FORMAT((iLogId, "CBodyQueueEntry16::RunL AttachFooterInfoL..."));
			iStoreUtilities->AttachFooterInfoL(iBodyPartRemainingSize,iImapSettings,decodedData);	
			}
			
		__LOG_FORMAT((iLogId, "CBodyQueueEntry16::RunL WriteToBodyL..."));
		//convert the data
		iStoreUtilities->WriteToBodyL(decodedData->Des(),iBodyText);
		
		CleanupStack::PopAndDestroy(decodedData); 
		//delete the data
		CBodyChunk16Info* chunkInfo=iDataArray[0];
		iDataArray.Remove(0);
		delete chunkInfo;
		}
		
#if (defined SYMBIAN_EMAIL_CAPABILITY_SUPPORT)				
	// if message body is downloaded using FETCH BINARY, there might be some extra fetch command
	// issued, remove these extra fetch requests from iTotalChunks.
	if(iBinaryCap && iExtraFetchRequestCount > 0)
		{
		iTotalChunks-=iExtraFetchRequestCount;
		//reset iExtraFetchRequestCount to zero
		iExtraFetchRequestCount=0;
		}
#endif
	
	//if we have appended all the chunks then store the data.
	if(iNextExpectedChunk==iTotalChunks)
		{
		__LOG_FORMAT((iLogId, "CBodyQueueEntry16::RunL Commiting body data..."));
		iServerEntry.SetEntry(iId);
		CMsvStore* store = iServerEntry.EditStoreL();
		CleanupStack::PushL(store);		
		store->StoreBodyTextL(*iBodyText);
		store->CommitL();
		CleanupStack::PopAndDestroy(store); 
		//call back to the observer as the operation is complete
		StoreComplete(KErrNone);	
		//request can be removed from the queue
		iParent.RemoveFromQueueAndDelete(this);	
		}
	}