// 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:

//

/**

 * HEADER FILES

 */

#include "cmsvversion1version2converter.h"

#include "cmessageconvertermanager.h"

#include "CMsvCachedStore.h"

#include "MSVUTILS.H"

#include "txtrich.h"

// constants

const TInt KArrayGranularity = 16;

const TInt KMaxImHeaderStringLength = 1000;

const TInt KMaxImMimeFieldLength	= 1000;

const TInt KDesCArrayGranularity = 8;

const TInt KMaxBufferLength = 1000;

const TInt KDBCommitCount = 50;

const TInt KMaxLengthOfRecipientField = 50;

const TInt KSmcmSmsNumberMaxNumberLength = 21;

const TInt KSmcmSmsNumberMaxNameLength = 256;							

const TUid KUidMsvSmsEmailFieldsStream	= {0x10204C9D};

const TUid KUidSMSHeaderStream = {0x10001834};

const TUid KMsvEntryFileForSms={0x10003C68};

const TUid KUidMsgFileIMailHeader	= {0x100001D8}; // mail header UID

const TUid KUidMsgFileIMailEncodedHeader = {0x101FD0E3};

const TUid KUidMsgFileMimeHeader	= {0x1000160F};		// 268441103 decimal

const TInt KMaxConverterNumber = 100;

const TInt KMaxPathConverter = 1000;

//Literals

_LIT16(KSeparator,";");

_LIT16(KComma,",");

_LIT16(KDetails,"");

_LIT16(KSpace,"");

_LIT16(KDelimiter, ";");

// Sms header fields

_LIT16(KSmsHeadearversion , "SmsHeadearversion");

_LIT16(KSmsRecipientCount , "RecipientCount");

_LIT16(KRecipients , "To");

_LIT16(KSmsFlags , "SmsFlags");

_LIT16(KTextBioMsgIdType,"BioMsgIdType");

// global function declaration

extern void ExternalizeL(const CDesC8Array& anArray,RWriteStream& aStream);

extern void InternalizeL(CDesC8Array& anArray,RReadStream& aStream);

extern void ExternalizeL(const CDesC16Array& anArray,RWriteStream& aStream);

extern void InternalizeL(CDesC16Array& anArray,RReadStream& aStream);

/**

InternalizeL()

@param anArray: A reference to an array of 16 bit descriptor arrays

@param aStream: The read stream interface

@retun None.

*/

void InternalizeL(CDesC8Array& anArray,RReadStream& aStream)

	{

	TCardinality card;

	aStream >> card;

	TInt count=card;

	anArray.Reset();

	for (TInt ii=0;ii<count;++ii)

		{

		HBufC8* buf=HBufC8::NewLC(aStream,KMaxImHeaderStringLength);

		anArray.CArrayFixBase::InsertL(ii,&buf);

		CleanupStack::Pop();

		}

	}

/**

InternalizeL()

@param anArray: A reference to an array of 16 bit descriptor arrays

@param aStream: The read stream interface

@retun None.

*/

void InternalizeL(CDesC16Array& anArray,RReadStream& aStream)

	{

	TCardinality card;

	aStream >> card;

	TInt count=card;

	anArray.Reset();

	for (TInt ii=0;ii<count;++ii)

		{

		HBufC16* buf=HBufC16::NewLC(aStream,KMaxImHeaderStringLength);

		anArray.CArrayFixBase::InsertL(ii,&buf);

		CleanupStack::Pop();

		}

	}

/**

HMsvReadBuffer()

@param aBuf: 8-bit non-modifiable descriptors

@retun None.

*/

HMsvReadBuffer::HMsvReadBuffer(const TDesC8 &aBuf)

	{ 

	TUint8* ptr=(TUint8 *)aBuf.Ptr();

	Set(ptr,ptr+aBuf.Length(),ERead);

	}	

void HMsvReadBuffer::DoRelease()

	{

	delete this;

	}

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

//              Class TImHeaderEncodingInfo Functions

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

TImHeaderEncodingInfo::TImHeaderEncodingInfo() :  

		iType(ENoEncoding), iAddSpace(EFalse), iCharsetUid(0)

	{

	}

/** 

TImHeaderEncodingInfo()

Copy constructor.

@param aFrom: Object to copy 

*/

TImHeaderEncodingInfo::TImHeaderEncodingInfo(const TImHeaderEncodingInfo& aFrom) 

	{

	SetField( aFrom.Field() );

	SetOffset( aFrom.Offset() );

	SetLength( aFrom.Length() );

	SetEncodingType( aFrom.EncodingType() );

	SetArrayValue( aFrom.ArrayValue() );

	SetCharsetUid(aFrom.CharsetUid());

	SetAddSpace( aFrom.AddSpace() ); 

	SetEncodedLength( aFrom.EncodedLength() ); 

	}

/** 

InternalizeL()

Internalises the object from the specified stream.

@param aReadStream Stream to read from */

void TImHeaderEncodingInfo::InternalizeL( RReadStream& aReadStream )

	{

	SetField( (TFieldList) aReadStream.ReadUint16L());

	SetOffset( aReadStream.ReadUint16L());

	SetLength( aReadStream.ReadUint16L());

	SetEncodingType( (TEncodingType) aReadStream.ReadUint16L());

	SetArrayValue( aReadStream.ReadUint16L());

	SetCharsetUid( aReadStream.ReadUint32L());

	SetAddSpace( aReadStream.ReadUint16L());

	SetEncodedLength( aReadStream.ReadUint8L());

	}

void TImHeaderEncodingInfo::SetField(const TFieldList aField)

	{

	iField = aField;

	}

/** 

Gets the field type.

@return Field type 

*/

TImHeaderEncodingInfo::TFieldList TImHeaderEncodingInfo::Field() const

	{

	return iField;

	}

/** 

Sets the field offset.

@param aOffset Field offset 

*/

void TImHeaderEncodingInfo::SetOffset(const TInt aOffset)

	{

	iOffset = (TUint16)aOffset;

	}

/** 

Gets the field offset.

@return Field offset 

*/

TInt TImHeaderEncodingInfo::Offset() const

	{

	return iOffset;

	}

/** 

Sets the field length.

@param aLength Field length 

*/

void TImHeaderEncodingInfo::SetLength(const TInt aLength)

	{

	iLength = (TUint16)aLength;

	}

/** 

Gets the field length.

@return Field length 

*/

TInt TImHeaderEncodingInfo::Length()  const

	{

	return iLength;

	}

/** Sets the character set UID.

@param aUid Character set UID 

*/

void TImHeaderEncodingInfo::SetCharsetUid(const TUint aUid)

	{

	iCharsetUid = aUid;

	}

/** 

Gets the character set UID.

@return Character set UID 

*/

TUint TImHeaderEncodingInfo::CharsetUid() const

	{

	return iCharsetUid;

	}

/** 

Sets the encoding type (string).

@param aChar Encoding type 

*/

void TImHeaderEncodingInfo::SetEncodingType(const TDesC8& aChar)

	{

	// If invalid, defaults to QPEncoding

	if (aChar[0] == 'b' || aChar[0] == 'B')

		iType = TImHeaderEncodingInfo::EBase64;

	else if (aChar[0] == 'q' || aChar[0] == 'Q')

		iType = TImHeaderEncodingInfo::EQP;

	else

		iType = TImHeaderEncodingInfo::ENoEncoding;

	}

/**

Sets the encoding type (enumeration).

@param aType Encoding type

*/

void TImHeaderEncodingInfo::SetEncodingType(const TEncodingType aType)

	{

	iType = aType;

	}

/** 

Gets the encoding type (enumeration).

@return Encoding type 

*/

TImHeaderEncodingInfo::TEncodingType TImHeaderEncodingInfo::EncodingType()  const

	{

	return iType;

	}

/** 

Sets the array value.

@param aValue Array value 

*/

void TImHeaderEncodingInfo::SetArrayValue(const TInt aValue)

	{

	iArrayValue = (TUint16)aValue;

	}

/** 

Gets the array value.

@return Array value 

*/

TInt TImHeaderEncodingInfo::ArrayValue()  const

	{

	return iArrayValue;

	}

/** 

Sets if a space character needs adding between two adjoining encoded-words.

@param atrueFalse True to add a space character 

*/

void TImHeaderEncodingInfo::SetAddSpace(const TBool atrueFalse)

	{

	iAddSpace = atrueFalse;

	}

/** 

Tests if the add space character flag is set.

@return True for added space characters 

*/

 TBool TImHeaderEncodingInfo::AddSpace() const

	{

	return iAddSpace;

	}

/** 

Sets the encoded length.

@param aLength Encoded length 

*/

void TImHeaderEncodingInfo::SetEncodedLength(const TInt aLength)

	{

	iEncodedLength = (TInt8) aLength;

	}

/** 

Gets the encoded length.

@return Encoded length 

*/

TInt TImHeaderEncodingInfo::EncodedLength() const

	{

	return iEncodedLength + (AddSpace() ? 1 : 0);

	}

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

//              Class CMsvVersion1Version2Converter Functions

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

/*

CMsvVersion1Version2Converter()

@param aDBAdapter: 

@param aMesasgeDBAdapter: 

@retun None.

@internalComponent

*/

CMsvVersion1Version2Converter::CMsvVersion1Version2Converter(CMsvDBAdapter& aDBAdapter,CMsvMessageDBAdapter& aMessageDBAdapter,TDriveNumber aDriveNum,TBool aConversionResume)

: iDBAdapter(aDBAdapter),iMessageDBAdapter(aMessageDBAdapter)

	{

	iResume = aConversionResume;

	iDrive = aDriveNum;

	}

/**

NewL()

@param aDBAdapter: 

@param aMesasgeDBAdapter: 

@retun None.

@internalComponent

*/

CMsvVersion1Version2Converter* CMsvVersion1Version2Converter::NewL(CMsvDBAdapter& aDBAdapter,CMsvMessageDBAdapter& aMessageDBAdapter,TDriveNumber aDriveNum,TBool aConversionResume)

	{

	CMsvVersion1Version2Converter* self = new (ELeave) CMsvVersion1Version2Converter(aDBAdapter,aMessageDBAdapter,aDriveNum,aConversionResume);

	CleanupStack::PushL(self);

	self->ConstructL();

	CleanupStack::Pop(self);

	return self;

	}

/**

~CMsvVersion1Version2Converter()

@param None: 

@retun None.

@internalComponent

*/

CMsvVersion1Version2Converter::~CMsvVersion1Version2Converter()

	{

	iConvertedMtmArray.Close();

	delete iSmsRecipientAddressFields;

	iSmsRecipientAddressFields = NULL;

	iRecipientDetails.Close();

	iEmailOverSmsAddress.Close();

	iEmailfieldPairList.ResetAndDestroy();	

	iEmailfieldPairList.Close();

	iTableFieldPairList.ResetAndDestroy();

	iTableFieldPairList.Close();

	delete iEncodingInfo;

	iEncodingInfo = NULL;

	iServiceIdArray.Close();

	}	

/**

ConstructL()

@param None: 

@retun None.

@internalComponent

*/	

void CMsvVersion1Version2Converter::ConstructL()

	{

	iResumeStatus.lastId = 0;

	iResumeStatus.mtmId.iUid = 0;

	iResumeStatus.serviceId = 0;

	iResumeStatus.sourceVersion = 1;

	iResumeStatus.targetVersion = 2;

	iResumeStatus.remainingCount = 0;

	iEncodingInfo = new (ELeave) CArrayFixFlat<TImHeaderEncodingInfo>(KArrayGranularity);

	}

/*

GetPropertyValue()

Gets the value of RProperty object. This value is used to check if cancel request is 

issued for the store conversion in progress

@param None

@return: Value of the property

@internalComponent

*/

TInt CMsvVersion1Version2Converter::GetPropertyValue()

	{

	TInt value;

	TInt err = RProperty::Get(KMyPropertyCat,KMyPropertyName, value);

	return value;

	}

/**

ConvertMessageStoreL()

Starts conversion of version 1 message store to version 2

It is responsible for the conversion of sms, imap and pop messages.

It sequentially converts the above MTM's, reading messages and inserting the same in database table

Header tables for MTM's are created only if a service entry is found for it.

It takes care of resuming conversion (RESTART), updation/removal of conversion status table entries,

creation of header tables etc.

@param None:

@retun None.

@internalComponent

*/

void CMsvVersion1Version2Converter::ConvertMessageStoreL()

	{

	// this class will take care of converting all mtms for v1 to v2

	iConvertedMtmArray.AppendL(KUidMsvSmsMtm);

	iConvertedMtmArray.AppendL(KUidMsgTypeIMAP4); // imap

	iConvertedMtmArray.AppendL(KUidMsgTypePOP3); // pop/smtpKUidMsgTypeSMTP

	iConvertedMtmArray.AppendL(KUidMsgTypeSMTP); // pop/smtpKUidMsgTypeSMTP

	TInt pos=0;

	if(iResume)

		{

		iDBAdapter.GetConversionStatusL(iResumeStatus);

		pos = iConvertedMtmArray.Find(iResumeStatus.mtmId);

		if (pos == KErrNotFound)// nothing found

			{

			pos = 0;

			iResume = EFalse;

			}		

		}

	while(pos < iConvertedMtmArray.Count())

		{

		TInt mtmId = iConvertedMtmArray[pos].iUid;

		switch(mtmId)

			{

			case 0x1000102C: // sms

				{

					/*

					1. Read TMsvIds

					2. Construct path

					3. Create header table for header part

					4. Open file and Read header part and Email over sms part

					5. Insert Header and Email Over sms part into the header table

					6  Open file and Read body part 

					7. Insert body part into the body table

					8. commit the changes.	

					*/

				iResumeStatus.mtmId.iUid = iConvertedMtmArray[pos].iUid;

				iDBAdapter.BeginTransactionL();

				if(iResume)

					{

					// Resume conversion from the last point

					iDBAdapter.GetRemainingServiceIdsL(iServiceIdArray);

					iResume = EFalse;

					}

				else

					{	

					// get all serviceIds belong to sms mtm.

					iDBAdapter.GetAllServiceIDsForMtmL(iConvertedMtmArray[pos].iUid,iServiceIdArray);

					//Lets create resume status for all the serviceids

					iResumeStatus.mtmId.iUid = iConvertedMtmArray[pos].iUid;

					for(TInt j =0; j < iServiceIdArray.Count(); j++)

						{

						iResumeStatus.lastId = 0;

						iResumeStatus.serviceId = iServiceIdArray[j];

						iResumeStatus.sourceVersion = 1;

						iResumeStatus.targetVersion = 2;

						iResumeStatus.remainingCount = iDBAdapter.GetMessageCountL(iServiceIdArray[j]);

						iDBAdapter.AddConversionStatusEntryL(iResumeStatus);

						}

					if(iServiceIdArray.Count() !=0)

						{