// 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 <s32file.h>

#include <e32test.h>

const TInt KTestCleanupStack=0x20;

// This is a path specification and should not be used as is

_LIT(KFileLocationSpec, "Z:\\STOR-TST\\T_EMBED.DAT");

const TUint8* KTestData=_S8("0123456789ABCDEFGHIJKLMNOPQRSTUVWXYZ");

const TInt KTestLength=36;

const TInt KTestTotal=KTestLength*(KTestLength+1);

const TPtrC8 KTestDes(KTestData,KTestLength);

LOCAL_D CTrapCleanup* TheTrapCleanup;

LOCAL_D RTest test(_L("t_storembed"));

LOCAL_D RFs TheFs;

LOCAL_D TStreamId TheTempId;

LOCAL_D TBuf8<KTestLength+1> TheBuf;

/**

@SYMTestCaseID          SYSLIB-STORE-CT-1192

@SYMTestCaseDesc	    Writing to a store test

@SYMTestPriority 	    High

@SYMTestActions  	    Write a test data to a stream.

@SYMTestExpectedResults Test must not fail

@SYMREQ                 REQ0000

*/

LOCAL_C void testWriteL(CPersistentStore& aStore)

	{

	test.Next(_L(" @SYMTestCaseID:SYSLIB-STORE-CT-1192 Writing... "));

	RStoreWriteStream out;

	TStreamId id=out.CreateLC(aStore);

	for (TInt i=0;i<=KTestLength;++i)

		{

		out.WriteL(KTestDes,i);

		out.WriteL(&KTestData[i],KTestLength-i);

		}

	out.CommitL();

	out.Close();

	aStore.SetRootL(out.CreateL(aStore));

	out<<KTestDes;

	out<<id;

	out.CommitL();

	CleanupStack::PopAndDestroy();

	}

/**

@SYMTestCaseID          SYSLIB-STORE-CT-1193

@SYMTestCaseDesc	    Reading from a stream test

@SYMTestPriority 	    High

@SYMTestActions  	    Attempt for reading from stream for a specific length of data

@SYMTestExpectedResults Test must not fail

@SYMREQ                 REQ0000

*/

LOCAL_C void testReadL(RReadStream& aStream)

	{

	test.Next(_L(" @SYMTestCaseID:SYSLIB-STORE-CT-1193 "));

	for (TInt i=KTestLength;i>=0;--i)

		{

		aStream.ReadL(TheBuf,i);

		test(TheBuf.Length()==i);

		TheBuf.SetMax();

		aStream.ReadL(&TheBuf[i],KTestLength-i);

		TheBuf.SetLength(KTestLength);

		test(TheBuf==KTestDes);

		}

	}

/**

@SYMTestCaseID          SYSLIB-STORE-CT-1194

@SYMTestCaseDesc	    Reading from a persistent store test

@SYMTestPriority 	    High

@SYMTestActions  	    Tests for reading from a stream

@SYMTestExpectedResults Test must not fail

@SYMREQ                 REQ0000

*/

LOCAL_C void testReadL(const CPersistentStore& aStore)

	{

	test.Next(_L(" @SYMTestCaseID:SYSLIB-STORE-CT-1194 Reading... "));

	RStoreReadStream in;

	in.OpenLC(aStore,aStore.Root());

	in>>TheBuf;

	TStreamId id;

	in>>id;

	in.Close();

	in.OpenL(aStore,id);

	testReadL(in);

	CleanupStack::PopAndDestroy();

	}

/**

@SYMTestCaseID          SYSLIB-STORE-CT-1195

@SYMTestCaseDesc	    Copying from one stream to another stream test

@SYMTestPriority 	    High

@SYMTestActions  	    Attempt for copying two streams

@SYMTestExpectedResults Test must not fail

@SYMREQ                 REQ0000

*/

LOCAL_C void testCopyL(RWriteStream& aWriteStream,RReadStream& aReadStream)

	{

	test.Next(_L(" @SYMTestCaseID:SYSLIB-STORE-CT-1195 Copying "));

	for (TInt i=KTestLength;i>=0;--i)

		{

		aWriteStream.WriteL(aReadStream,i);

		aReadStream.ReadL(aWriteStream,KTestLength-i);

		}

	}

/**

@SYMTestCaseID          SYSLIB-STORE-CT-1196

@SYMTestCaseDesc	    Writing to a write once file store created using CEmbeddedStore test

@SYMTestPriority 	    High

@SYMTestActions  	    Attempt for writing to a newly created store and a temporary store.

@SYMTestExpectedResults Test must not fail

@SYMREQ                 REQ0000

*/

LOCAL_C void testWriteL()

	{

	test.Next(_L(" @SYMTestCaseID:SYSLIB-STORE-CT-1196 Replacing host file "));

	TParsePtrC parse(KFileLocationSpec);

	CFileStore* file=CPermanentFileStore::ReplaceLC(TheFs,parse.NameAndExt(),EFileWrite);

	file->SetTypeL(file->Layout());

//

	test.Next(_L("Writing root store"));

	RStoreWriteStream stream;

	TStreamId root=stream.CreateLC(*file);

	stream.WriteL(_L8(" root"));

	CleanupStack::Pop();

	CEmbeddedStore* store=CEmbeddedStore::NewL(stream);

	CleanupStack::PushL(store);

	testWriteL(*store);

	store->CommitL();

	CleanupStack::PopAndDestroy();

	file->SetRootL(root);

//

	test.Next(_L("Writing temp store"));

	TheTempId=stream.CreateLC(*file);

	stream.WriteL(_L8(" temp"));

	CleanupStack::Pop();

	store=CEmbeddedStore::NewLC(stream);

	testWriteL(*store);

	store->CommitL();

	CleanupStack::PopAndDestroy();

//

	file->CommitL();

	CleanupStack::PopAndDestroy();

	}

/**

@SYMTestCaseID          SYSLIB-STORE-CT-1197

@SYMTestCaseDesc	    Reading from a file buffer test

@SYMTestPriority 	    High

@SYMTestActions  	    Tests for reading from root and temporary store.

@SYMTestExpectedResults Test must not fail

@SYMREQ                 REQ0000

*/

LOCAL_C void testReadL()

	{

	test.Next(_L(" @SYMTestCaseID:SYSLIB-STORE-CT-1197 Opening host file "));

	TParsePtrC parse(KFileLocationSpec);

	CFileStore* file=CFileStore::OpenLC(TheFs,parse.NameAndExt(),EFileRead);

//

	test.Next(_L("Reading from root store"));

	TStreamId root=file->Root();

	RStoreReadStream stream;

	stream.OpenLC(*file,root);

	TBuf8<5> b;

	stream.ReadL(b);

	test(b==_L8(" root"));

	testReadL(*store);

	CleanupStack::PopAndDestroy();

//

	test.Next(_L("Reading from temp store"));

	stream.OpenLC(*file,TheTempId);

	stream.ReadL(b);

	test(b==_L8(" temp"));

	CleanupStack::Pop();

	store=CEmbeddedStore::FromLC(stream);

	testReadL(*store);

//

	CleanupStack::PopAndDestroy(2);

	}

/**

@SYMTestCaseID          SYSLIB-STORE-CT-1198

@SYMTestCaseDesc	    Copying in a single file store test.

@SYMTestPriority 	    High

@SYMTestActions  	    Tests for copying using different buffer sizes

@SYMTestExpectedResults Test must not fail

@SYMREQ                 REQ0000

*/

LOCAL_C void testCopyL()

	{

	test.Next(_L(" @SYMTestCaseID:SYSLIB-STORE-CT-1198 Opening host file "));

	TParsePtrC parse(KFileLocationSpec);

	CFileStore* file=CFileStore::OpenLC(TheFs,parse.NameAndExt(),EFileRead|EFileWrite);

//

	test.Next(_L("Opening source (root) store"));

	TStreamId root=file->Root();

	RStoreReadStream src;

	src.OpenLC(*file,root);

	TBuf8<5> b;

	src.ReadL(b);

	test(b==_L8(" root"));

	CleanupStack::Pop();

	CEmbeddedStore* source=CEmbeddedStore::FromLC(src);

//

	test.Next(_L("Duplicating source store"));

	RStoreWriteStream trg;

	trg.CreateLC(*file);

	MStreamBuf* host=source->Host();

	TStreamPos pos=CEmbeddedStore::Position(source->Root());

	host->SeekL(host->ERead,EStreamBeginning);

	RReadStream stream(host);

	trg.WriteL(stream,pos.Offset());

	stream>>TheBuf;

	TStreamId id;

	stream>>id;

	test(host->TellL(host->ERead).Offset()==host->SizeL());

	trg<<TheBuf;

	trg<<id;

	trg.CommitL();

	source->Detach();

	host->Release();

	source->Reattach(trg.Sink());

	CleanupStack::Pop();

	testReadL(*source);

//

	test.Next(_L("Creating target store"));

	trg.CreateLC(*file);

	trg.WriteL(_L8(" target"));

	CleanupStack::Pop();

	CEmbeddedStore* target=CEmbeddedStore::NewLC(trg);

//

	test.Next(_L("Copying using small transfers"));

	RStoreReadStream in;

	in.OpenL(*source,source->Root());

	in>>TheBuf;

	TStreamId copyId;

	in>>copyId;

	in.Close();

	in.OpenL(*source,copyId);

	RStoreWriteStream out;

	id=out.CreateL(*target);

	testCopyL(out,in);

	out.CommitL();

	out.Close();

	in.Close();

	in.OpenL(*target,id);

	testReadL(in);

	in.Close();

//

	test.Next(_L("Copying using a single big transfer"));

	in.OpenL(*source,copyId);

	id=out.CreateL(*target);

	in.ReadL(out,KTestTotal);

	out.CommitL();

	out.Close();

	in.Close();

	in.OpenL(*target,id);

	testReadL(in);

	in.Close();

	in.OpenL(*source,copyId);

	id=out.CreateL(*target);

	out.WriteL(in,KTestTotal);

	out.CommitL();

	out.Close();

	in.Close();

	in.OpenL(*target,id);

	testReadL(in);

	in.Close();

//

	CleanupStack::PopAndDestroy(3);

	}

//

// Prepare the test directory.

//

LOCAL_C void setupTestDirectory()

    {

	TInt r=TheFs.Connect();

	test(r==KErrNone);

//

	TDriveUnit drive(static_cast<TUint>(RFs::GetSystemDrive()));	

	TParse parse;

	parse.Set(drive.Name(), &KFileLocationSpec, NULL);

	r=TheFs.MkDir(parse.DriveAndPath());

	test(r==KErrNone||r==KErrAlreadyExists);

	r=TheFs.SetSessionPath(parse.DriveAndPath());

	test(r==KErrNone);

	}

//

// Initialise the cleanup stack.

//

LOCAL_C void setupCleanup()

    {

	TheTrapCleanup=CTrapCleanup::New();

	test(TheTrapCleanup!=NULL);

	TRAPD(r,\

		{\

		for (TInt i=KTestCleanupStack;i>0;i--)\

			CleanupStack::PushL((TAny*)0);\

		CleanupStack::Pop(KTestCleanupStack);\

		});

	test(r==KErrNone);

	}

LOCAL_C void DeleteDataFile(const TDesC& aFullName)

	{

	RFs fsSession;

	TInt err = fsSession.Connect();

	if(err == KErrNone)

		{

		TEntry entry;

		if(fsSession.Entry(aFullName, entry) == KErrNone)

			{

			RDebug::Print(_L("Deleting \"%S\" file.\n"), &aFullName);

			err = fsSession.SetAtt(aFullName, 0, KEntryAttReadOnly);

			if(err != KErrNone)

				{

				RDebug::Print(_L("Error %d changing \"%S\" file attributes.\n"), err, &aFullName);

				}

			err = fsSession.Delete(aFullName);

			if(err != KErrNone)

				{

				RDebug::Print(_L("Error %d deleting \"%S\" file.\n"), err, &aFullName);

				}

			}

		fsSession.Close();

		}

	else

		{

		RDebug::Print(_L("Error %d connecting file session. File: %S.\n"), err, &aFullName);

		}

	}

//

// Test streaming conversions.

//

GLDEF_C TInt E32Main()

    {

	test.Title();

	setupTestDirectory();

	setupCleanup();

	__UHEAP_MARK;

//

	test.Start(_L("Test direct file store"));

	TRAPD(r,testWriteL());

	test(r==KErrNone);

	TRAP(r,testReadL());

	test(r==KErrNone);

	TRAP(r,testCopyL());

	test(r==KErrNone);

	//deletion of data files must be before call to .End() - DEF047652

	TDriveUnit drive(static_cast<TUint>(RFs::GetSystemDrive()));	

	TParse parse;

	parse.Set(drive.Name(), &KFileLocationSpec, NULL);

	::DeleteDataFile(parse.FullName());

	test.End();

//

	__UHEAP_MARKEND;

	delete TheTrapCleanup;

	TheFs.Close();

	test.Close();

	return 0;

    }