// Copyright (c) 2008-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:+
−
//+
−
+
−
+
−
/**+
−
 * HEADER FILES+
−
 */+
−
+
−
#include <s32fileiter.h>+
−
#include "cmsvversion0version1converter.h"+
−
+
−
+
−
// Literals+
−
const TInt KMsvLongestStringAllowed=KMaxTInt32; +
−
+
−
/*+
−
CMsvVersion0Version1Converter()+
−
Default Constructor+
−
 +
−
@param aDBAdapter: CMsvDbAdapter object reference.+
−
@param aDriveNum: Drive Number+
−
@return None+
−
*/	+
−
CMsvVersion0Version1Converter::CMsvVersion0Version1Converter(CMsvDBAdapter& aDBAdapter,TDriveNumber aDriveNum,TBool aConversionResume)+
−
: iDBAdapter(aDBAdapter),iDrive(aDriveNum),iResume(aConversionResume)+
−
	{+
−
	}+
−
+
−
/*+
−
NewL()+
−
Constructs and returns CMsvVersion0Version1Converter object+
−
+
−
@param aFileStore:  A reference to store object. This supports full manipulation of store contents.+
−
@param aDBAapter: A handle to db ada[ter object+
−
@param aDriveNum: The Drive number of the drive to be converted.+
−
@return : CMsvVersion0Version1Converter object+
−
*/+
−
CMsvVersion0Version1Converter* CMsvVersion0Version1Converter::NewL(CMsvDBAdapter& aDBAapter,TDriveNumber aDriveNum,TBool aConversionResume)+
−
	{+
−
	CMsvVersion0Version1Converter* self = new(ELeave) CMsvVersion0Version1Converter(aDBAapter,aDriveNum,aConversionResume);+
−
	CleanupStack::PushL(self);+
−
	self->ConstructL();+
−
	CleanupStack::Pop(self);+
−
	return self;+
−
	}+
−
+
−
/*+
−
~CMsvVersion0Version1Converter()+
−
Destructor+
−
+
−
@param : None +
−
@return: None+
−
*/+
−
CMsvVersion0Version1Converter::~CMsvVersion0Version1Converter()+
−
	{+
−
	delete iStream;+
−
	delete iDescriptionBuffer;+
−
	delete iDetailsBuffer;+
−
	}	+
−
+
−
/*+
−
ConstructL()+
−
Second phase constructor.+
−
+
−
@param aDriveNum: Drive to be converted.+
−
@param aConversionResume: Boolean flag indicating if conversion is to be resumed.+
−
@return None+
−
@internalComponent+
−
*/	+
−
void CMsvVersion0Version1Converter::ConstructL()+
−
	{+
−
	// create the stream index+
−
	iStream=new (ELeave) CArrayFixFlat<TStreamId>(KMsvStreamIndexGranularity);+
−
	}+
−
+
−
/*+
−
ConvertMessageStoreL()+
−
Starts conversion of version 0 to version 1 message store.+
−
If the conversion is to be resumed, it reads the resume status from conversion status table and starts reading entries from their.+
−
For a new conversion request, it creates the conversion status entry in the status table.+
−
+
−
@param :None+
−
@return: None+
−
@internalComponent+
−
*/+
−
void CMsvVersion0Version1Converter::ConvertMessageStoreL()+
−
	{+
−
	RFs fs;+
−
	User::LeaveIfError(fs.Connect()); +
−
	CleanupClosePushL(fs);+
−
	+
−
	TBuf<KMaxPath> filePath;+
−
	TPtrC drive = TDriveUnit(iDrive).Name();+
−
	filePath.Append(drive);+
−
	filePath.Append(KIndexFilePath);+
−
		+
−
	RFile file;+
−
	TInt error = file.Open(fs, filePath, EFileShareAny|EFileWrite);+
−
	+
−
	iIndexStore = CPermanentFileStore::FromL(file);+
−
	CleanupStack::PushL(iIndexStore);+
−
			+
−
	RestoreStreamIndexL();+
−
+
−
	// Check for ConversionStatus table+
−
	if(iResume)+
−
		{+
−
		iDBAdapter.GetConversionStatusL(iResumeStatus);+
−
		iEntryStreamIndex = iStream->Count() - iResumeStatus.remainingCount;+
−
		}+
−
	else+
−
		{+
−
		iEntryStreamIndex += 2;+
−
+
−
		iResumeStatus.lastId = 0;+
−
		iResumeStatus.mtmId.iUid = 0;+
−
		iResumeStatus.serviceId = 0;+
−
		iResumeStatus.sourceVersion = 0;+
−
		iResumeStatus.targetVersion = 1;+
−
		iResumeStatus.remainingCount = iStream->Count() - 1;+
−
		iDBAdapter.AddConversionStatusEntryL(iResumeStatus);+
−
		iResumeStatus.remainingCount --;+
−
		}+
−
+
−
	// read TMsvEntries now+
−
	while(ReadNextEntriesL())+
−
		{+
−
		}+
−
		+
−
	// update remaining visible parent id's+
−
	UpdateVisibleParentL();+
−
	// we are finished with v0-v1 conversion. Lets remove the status entry from resumestatus table+
−
	iDBAdapter.RemoveConversionStatusEntriesL();+
−
+
−
	CleanupStack::PopAndDestroy(2);  //iIndexStore,fs+
−
	file.Close();+
−
	fs.Close();+
−
	}+
−
	+
−
/*+
−
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 CMsvVersion0Version1Converter::GetPropertyValue()+
−
	{+
−
	TInt value;+
−
	TInt err = RProperty::Get(KMyPropertyCat,KMyPropertyName, value);+
−
	return value;+
−
	}+
−
/*+
−
RestoreStreamIndexL()+
−
Restores all the stream index id's (id of TMveEntry) by reading them from the index file store.+
−
These ids are than stored in an array and for each of them, its TMsvEntry restored from the file store.+
−
+
−
@param None+
−
@return: None+
−
@internalComponent+
−
*/+
−
void CMsvVersion0Version1Converter::RestoreStreamIndexL()+
−
	{+
−
	// Create a stream iterator+
−
	RPermanentFileStoreIter iter;+
−
	iter.ResetLC(*iIndexStore);+
−
+
−
	// Build the new stream index+
−
	TStreamId id;+
−
	while( (id = iter.NextL()) != KNullStreamIdValue )+
−
		{+
−
		iStream->AppendL(id);+
−
		}+
−
	CleanupStack::PopAndDestroy(&iter);+
−
	}+
−
+
−
+
−
/*+
−
ReadNextEntriesL()+
−
Prepares the index that determines how many entries will be read in each iteration+
−
It than reads the index file on the initial and final range specified.+
−
+
−
@param None+
−
@return: None+
−
@internalComponent+
−
*/+
−
TBool CMsvVersion0Version1Converter::ReadNextEntriesL()+
−
	{+
−
	if (iEntryStreamIndex<iStream->Count())+
−
		{+
−
		TInt nextIndex = Min(iEntryStreamIndex+KIndexReadGranularity, iStream->Count());+
−
		PopulateDatabaseL(iEntryStreamIndex, nextIndex);+
−
		iEntryStreamIndex = nextIndex;+
−
		return ETrue;+
−
		}+
−
	return EFalse;+
−
	}+
−
+
−
/*+
−
PopulateDatabaseL()+
−
Reads each entry information from the file stream and stores this in the database table.+
−
Also updates the conversion status table entry for each iteration = 10.+
−
+
−
@param aFirstEntry: Initial index+
−
@param aNextEntry: Final index+
−
@return:None+
−
@internalComponent+
−
*/+
−
void CMsvVersion0Version1Converter::PopulateDatabaseL(TInt aFirstEntry, TInt aNextEntry)+
−
	{+
−
	iDBAdapter.BeginTransactionL();+
−
	+
−
	TInt i=aFirstEntry;+
−
	while (i<aNextEntry)+
−
		{+
−
		RStoreReadStream readStream;+
−
		readStream.OpenLC(*iIndexStore, iStream->At(i++));+
−
+
−
		InternalizeL(readStream);		+
−
		+
−
		TMsvId visParent = -99;+
−
		// can we find parents visFlag. +
−
		TBool parentVisFlag = iDBAdapter.GetParentVisibleFlagL(iEntry.Parent());	+
−
					+
−
		if(parentVisFlag)+
−
			{+
−
			if( (iEntry.Visible()) && +
−
		    (iEntry.iType == KUidMsvFolderEntry || iEntry.iType == KUidMsvServiceEntry)+
−
		      )+
−
				{+
−
				iEntry.SetVisibleFolderFlag(ETrue);+
−
				}+
−
			else+
−
				{+
−
				iEntry.SetVisibleFolderFlag(EFalse);+
−
				}+
−
			iDBAdapter.GetVisibleParentIdL(iEntry.Parent(),visParent);				+
−
			}+
−
	+
−
		+
−
		//create the db entry+
−
		iDBAdapter.CreateIndexEntryL(iEntry,visParent);+
−
		CleanupStack::PopAndDestroy(); //  readStream+
−
		}+
−
	+
−
	//check if we have a request for cancellation+
−
	TInt cancel = GetPropertyValue();+
−
	if(cancel == KErrCancel	)+
−
		{+
−
		User::Leave(KErrCancel);+
−
		}+
−
	// commit for this iteration+
−
	iResumeStatus.lastId = iEntry.iId;+
−
	iResumeStatus.remainingCount -= 10;+
−
	iDBAdapter.UpdateConversionStatusEntryL(iResumeStatus);+
−
	iDBAdapter.CommitTransactionL();+
−
	+
−
	}+
−
+
−
/*+
−
InternalizeL()+
−
Reads TMsvEntry from the stream.+
−
+
−
@param aStream: File stream +
−
@return: None+
−
@internalComponent+
−
*/+
−
void CMsvVersion0Version1Converter::InternalizeL(RReadStream& aStream)+
−
	{+
−
	// NOTE: This has been added in case versioning is required in the future+
−
	TUint8 ver;+
−
	aStream >> ver;+
−
+
−
	aStream >> iEntry;+
−
	TInt dummy = aStream.ReadUint32L();+
−
	dummy  =  aStream.ReadUint32L();+
−
+
−
	// Get last change and creation dates+
−
	aStream >> iLastChangeDays;+
−
	aStream >> iLastChangeMinutes;+
−
	aStream >> iCreatedDays;+
−
	aStream >> iCreatedMinutes;+
−
+
−
	HBufC* des = HBufC::NewL(aStream, KMsvLongestStringAllowed);+
−
	delete iDescriptionBuffer;+
−
	iDescriptionBuffer = des;+
−
+
−
	HBufC* det = HBufC::NewL(aStream, KMsvLongestStringAllowed);+
−
	delete iDetailsBuffer;+
−
	iDetailsBuffer = det;+
−
+
−
	iEntry.iDescription.Set(*iDescriptionBuffer);+
−
	iEntry.iDetails.Set(*iDetailsBuffer);+
−
	}+
−
	+
−
/*+
−
UpdateVisibleParentL()+
−
Update ids whose visible parent was not set previously+
−
+
−
@param None: +
−
@return: None+
−
@internalComponent+
−
*/+
−
void CMsvVersion0Version1Converter::UpdateVisibleParentL()+
−
	{+
−
				+
−
	TMsvId visibleParent;;+
−
	RArray<TMsvId> idArray;+
−
	CleanupClosePushL(idArray);+
−
	+
−
	iDBAdapter.GetRemainingIdsL(idArray);+
−
	iDBAdapter.BeginTransactionL();+
−
	+
−
	for(TInt i = 0; i<idArray.Count(); i++)+
−
		{+
−
		iDBAdapter.GetVisibleParentL(idArray[i],visibleParent);+
−
		iDBAdapter.UpdateVisibleFolderIdL(idArray[i],visibleParent);+
−
		+
−
		if (i % 50 == 0 && i!=0)+
−
			{+
−
			iDBAdapter.CommitTransactionL();	+
−
			iDBAdapter.BeginTransactionL();+
−
			}+
−
		}+
−
	+
−
	iDBAdapter.CommitTransactionL();	+
−
	CleanupStack::PopAndDestroy();  //idArray+
−
	}+
−
+
−