// Copyright (c) 1999-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 <e32test.h>

#include <e32uid.h>

#include <e32std.h>

#include <smuthdr.h>

#include <smscmds.h>

#include "t_smsbiofication.h"

#include <txtrich.h>

#include <biouids.h>

RTest test(_L("T_SmsBiofication Testrig"));

CTrapCleanup* theCleanup;

_LIT(KBioficationScript, "biofication.script");

_LIT(KSmsTestFolderDetails, "Test folder");

_LIT(KSmsTestFolderDescription, "Copied or moved message folder");

CSmsBioficationTest* CSmsBioficationTest::NewLC(CSmsTestUtils& aSmsTest, const TDesC& aScriptFile, TInt& aNextTest)

	{

	CSmsBioficationTest* self = new (ELeave) CSmsBioficationTest(aSmsTest, aScriptFile, aNextTest);

	CleanupStack::PushL(self);

	self->ConstructL();

	return self;

	}

CSmsBioficationTest::~CSmsBioficationTest()

	{

	delete iTestSelection;

	iSocket.Close();

	iSocketServ.Close();

	}

CSmsBioficationTest::CSmsBioficationTest(CSmsTestUtils& aSmsTest, const TDesC& aScriptFile, TInt& aNextTest)

: CSmsTestBase(aSmsTest, aScriptFile, aNextTest), iState(EStateIdle)

	{

	}

void CSmsBioficationTest::ConstructL()

	{

	SetTestNameL(KSmsBioficationTestName);

	iSmsTest.SetLogToFile();

	iSelection = new (ELeave) CMsvEntrySelection();

	iTestSelection = new (ELeave) CMsvEntrySelection();

	iTimer = CTestTimer::NewL();

	User::LeaveIfError(iSocketServ.Connect());

	TProtocolDesc protoinfo;

	TProtocolName protocolname(KSmsDatagram);

	User::LeaveIfError(iSocketServ.FindProtocol(protocolname,protoinfo));

	User::LeaveIfError(iSocket.Open(iSocketServ,protoinfo.iAddrFamily,protoinfo.iSockType,protoinfo.iProtocol));

	TSmsAddr smsaddr;

	smsaddr.SetSmsAddrFamily(ESmsAddrSendOnly);

	User::LeaveIfError(iSocket.Bind(smsaddr));

	CActiveScheduler::Add(this);

	}

void CSmsBioficationTest::RunL()

	{

	CActiveScheduler::Stop();

	iSmsTest(iStatus.Int() == KErrNone);

	iSmsTest.SetProgressL(*iOperation);

	switch (iState)

		{

		case EStateEnumerating:

			{

			RunEnumerateL();

			break;

			}

		case EStateCopyingToPhoneStore:

			{

			RunCopyToPhoneStoreL();

			break;

			}

		case EStateCopyingFromPhoneStore:

		case EStateMovingFromPhoneStore:

		case EStateDeletingFromPhoneStore:

			{

			RunCopyMoveDeleteFromPhoneStoreL();

			break;

			}

		case EStateSending:

			{

			ChangeMtmUidsL(*iSelection);

			break;

			}

		default:

			break;

		}

	iState=EStateIdle;

	}

void CSmsBioficationTest::DoCancel()

	{

	if (iOperation)

		{

		iOperation->Cancel();

		iSmsTest.Printf(_L("Operation Cancelled!\n"));

		}

	else

		{

		iSmsTest.Printf(_L("No operation to cancel!\n"));

		}

	delete iOperation;

	iOperation = NULL;

	}

void CSmsBioficationTest::TestSetupL()

	{

	iSmsTest.Test().Next(_L("Test Setup"));

	iState=EStateSettingUp;

	TFullName name;

	TFindProcess find(_L("watcher*"));

	while (find.Next(name)==KErrNone)

		{

		RProcess process;

		process.Open(find);

		process.Terminate(KErrGeneral);

		process.Close();

		}

	//  Create test folder

	MsvEntry().SetEntryL(KMsvDraftEntryId);

	TMsvEntry entry;

	entry.iServiceId = iSmsTest.iSmsServiceId;

	entry.SetVisible(ETrue);

	entry.iMtm = KUidMsgTypeSMS;

	entry.iDate.HomeTime();

	entry.iType = KUidMsvFolderEntry;

	entry.iDetails.Set(KSmsTestFolderDetails);

	entry.iDescription.Set(KSmsTestFolderDescription);

	MsvEntry().CreateL(entry);

	iTestFolderId=MsvEntry().EntryId();

	TTime now;

	now.HomeTime();

	iSmsTest.ReadScriptL(iScriptFile, KMsvNullIndexEntryId, *iSelection, now);

	ChangeMtmUidsL(*iSelection);

	iState=EStateIdle;

	/*

	User::LeaveIfError(iSocketServ.Connect());

	TProtocolDesc protoinfo;

	TProtocolName protocolname(KSmsDatagram);

	User::LeaveIfError(iSocketServ.FindProtocol(protocolname,protoinfo));

	User::LeaveIfError(iSocket.Open(iSocketServ,protoinfo.iAddrFamily,protoinfo.iSockType,protoinfo.iProtocol));

	TSmsAddr smsaddr;

	smsaddr.SetSmsAddrFamily(ESmsAddrSendOnly);

	User::LeaveIfError(iSocket.Bind(smsaddr));

	*/

	}

void CSmsBioficationTest::TestEnumerateL()

	{

	iSmsTest.Test().Next(_L("Enumerate Phone Stores"));

	iState = EStateEnumerating;

	iTestSelection->Reset();

	iTestSelection->AppendL(iSmsTest.iSmsServiceId);

	delete iOperation;

	iOperation = NULL;

	iOperation = Session().TransferCommandL(*iTestSelection, ESmsMtmCommandEnumeratePhoneStores, TPtrC8(), iStatus);

	SetActive();

	CActiveScheduler::Start();

	}

void CSmsBioficationTest::TestCopyToPhoneStoreL()

	{

	iSmsTest.Test().Next(_L("Copy To Phone Store"));

	iState = EStateCopyingToPhoneStore;

	delete iTestSelection;

	iTestSelection=iSelection->CopyL();

	iTestSelection->InsertL(0,iSmsTest.iSmsServiceId);

	delete iOperation;

	iOperation = NULL;

	iOperation = Session().TransferCommandL(*iTestSelection, ESmsMtmCommandCopyToPhoneStore, TPtrC8(), iStatus);

	SetActive();

	CActiveScheduler::Start();

	}

void CSmsBioficationTest::TestCopyFromPhoneStoreL()

	{

	iSmsTest.Test().Next(_L("Copy From Phone Store"));

	iState = EStateCopyingFromPhoneStore;

	DeleteEntriesFromTestFolderL();

	MsvEntry().SetEntryL(iEnumerationFolderId);

	delete iTestSelection;

	iTestSelection = MsvEntry().ChildrenL();

	iTestSelection->InsertL(0,iSmsTest.iSmsServiceId);

	TPckgBuf<TMsvId> pkg(iTestFolderId);

	delete iOperation;

	iOperation = NULL;

	iOperation = Session().TransferCommandL(*iTestSelection, ESmsMtmCommandCopyFromPhoneStore, pkg, iStatus);

	SetActive();

	CActiveScheduler::Start();

	}

void CSmsBioficationTest::TestMoveFromPhoneStoreL()

	{

	iSmsTest.Test().Next(_L("Move From Phone Store"));

	iState = EStateMovingFromPhoneStore;

	DeleteEntriesFromTestFolderL();

	MsvEntry().SetEntryL(iEnumerationFolderId);

	delete iTestSelection;

	iTestSelection = MsvEntry().ChildrenL();

	iTestSelection->InsertL(0,iSmsTest.iSmsServiceId);

	TPckgBuf<TMsvId> pkg(iTestFolderId);

	delete iOperation;

	iOperation = NULL;

	iOperation = Session().TransferCommandL(*iTestSelection, ESmsMtmCommandMoveFromPhoneStore, pkg, iStatus);

	SetActive();

	CActiveScheduler::Start();

	}

void CSmsBioficationTest::TestDeleteFromPhoneStoreL()

	{

	iSmsTest.Test().Next(_L("Delete From SIM"));

	iState = EStateDeletingFromPhoneStore;

	MsvEntry().SetEntryL(iEnumerationFolderId);

	delete iTestSelection;

	iTestSelection = MsvEntry().ChildrenL();

	iTestSelection->InsertL(0,iSmsTest.iSmsServiceId);

	delete iOperation;

	iOperation = NULL;

	iOperation = Session().TransferCommandL(*iTestSelection, ESmsMtmCommandDeleteFromPhoneStore, TPtrC8(), iStatus);

	SetActive();

	CActiveScheduler::Start();

	}

void CSmsBioficationTest::TestSendL()

	{

	iSmsTest.Test().Next(_L("Send"));

	iState = EStateSending;

	iSmsTest.Test().Next(_L("Test Send Entry\n"));

	DeleteEntriesFromTestFolderL();

	for (TInt i=iSelection->Count()-1; i>=0; i--)

		{

		MsvEntry().SetEntryL(iSelection->At(i));

		TMsvEntry entry=MsvEntry().Entry();

		if (entry.Parent()!=KMsvGlobalOutBoxIndexEntryId)

			iSelection->Delete(i);

		else

			{

			entry.iMtm=KUidMsgTypeSMS;

			MsvEntry().ChangeL(entry);

			MsvEntry().SetEntryL(KMsvGlobalOutBoxIndexEntryId);

			MsvEntry().CopyL(iSelection->At(i),iTestFolderId);

			}

		}

	MsvEntry().SetEntryL(iTestFolderId);

	delete iTestSelection;

	iTestSelection = MsvEntry().ChildrenL();

	delete iOperation;

	iOperation = NULL;

	iOperation = MsvEntry().CopyL(*iTestSelection, iSmsTest.iSmsServiceId, iStatus);

	SetActive();

	CActiveScheduler::Start();

	}

void CSmsBioficationTest::TestDeleteEnumerationFolderL()

	{

	iSmsTest.Test().Next(_L("Test Delete Enumeration Folder\n"));

	iTestSelection->Reset();

	CMsvOperationWait* wait = CMsvOperationWait::NewLC();

	wait->Start();

	iSmsTest.SetEntryL(iEnumerationFolderId);

	iSmsTest.SetEntryL(iSmsTest.Entry().Parent());

	CMsvOperation* op = iSmsTest.iMsvEntry->DeleteL(iEnumerationFolderId, wait->iStatus);

	CleanupStack::PushL(op);

	CActiveScheduler::Start();

	iSmsTest.Printf(_L("Remote DeleteL() completed with %d\n"), wait->iStatus.Int());

	User::LeaveIfError(wait->iStatus.Int());

	iSmsTest.SetProgressL(*op);

	iSmsTest.Printf(_L("Operation completed with %d, msg count %d\n"), iSmsTest.iProgress.iError, iSmsTest.iProgress.iMsgCount);

	User::LeaveIfError(iSmsTest.iProgress.iError);

	CleanupStack::PopAndDestroy(2); //wait, op

	iState = EStateIdle;

	}

void CSmsBioficationTest::RunAutoL()

	{

	iSmsTest.SetLogToConsole(ETrue);

	iSmsTest.TestStart(++iNextTest, _L("Test 1 - Setup"));

	TestSetupL();

	User::LeaveIfError(iStatus.Int());

	iSmsTest.TestFinish(iNextTest, KErrNone);

	iSmsTest.TestStart(++iNextTest, _L("Test 1 - Enumerate"));

	TestEnumerateL();

	User::LeaveIfError(iStatus.Int());

	iSmsTest.TestFinish(iNextTest, KErrNone);

	if (iTestSelection->Count())

		{

		iSmsTest.TestStart(++iNextTest, _L("Test 1 - Delete From Phone Store"));

		TestDeleteFromPhoneStoreL();

		User::LeaveIfError(iStatus.Int());

		iSmsTest.TestFinish(iNextTest, KErrNone);

		}

	iSmsTest.TestStart(++iNextTest, _L("Test 1 - Enumerate"));

	TestEnumerateL();

	User::LeaveIfError(iStatus.Int());

	test(iTestSelection->Count()==0);

	iSmsTest.TestFinish(iNextTest, KErrNone);

	const TInt KWaitAfterEnum = 10;

	const TInt KWaitAfterSend = 10;

	iSmsTest.Printf(_L("Waiting %d seconds after enum...\n"), KWaitAfterEnum);

	User::After(KWaitAfterEnum * 1000000);

	iSmsTest.Printf(_L("Finished waiting\n"));

	iSmsTest.TestStart(++iNextTest, _L("Test 2 - Copy to Phone Store"));

	TestCopyToPhoneStoreL();

	User::LeaveIfError(iStatus.Int());

	iSmsTest.TestFinish(iNextTest, KErrNone);

	iSmsTest.TestStart(++iNextTest, _L("Test 2 - Enumerate"));

	TestEnumerateL();

	User::LeaveIfError(iStatus.Int());

	test(CompareSelectionsL(*iSelection,*iTestSelection));

	iSmsTest.TestFinish(iNextTest, KErrNone);

	iSmsTest.TestStart(++iNextTest, _L("Test 2 - Copy From Phone Store"));

	TestCopyFromPhoneStoreL();

	User::LeaveIfError(iStatus.Int());

	test(CompareSelectionsL(*iSelection,*iTestSelection));

	iSmsTest.TestFinish(iNextTest, KErrNone);

	iSmsTest.TestStart(++iNextTest, _L("Test 2 - Delete From Phone Store"));

	TestDeleteFromPhoneStoreL();

	User::LeaveIfError(iStatus.Int());

	iSmsTest.TestFinish(iNextTest, KErrNone);

	iSmsTest.TestStart(++iNextTest, _L("Test 2 - Enumerate"));

	TestEnumerateL();

	User::LeaveIfError(iStatus.Int());

	test(iTestSelection->Count()==0);

	iSmsTest.TestFinish(iNextTest, KErrNone);

	iSmsTest.TestStart(++iNextTest, _L("Test 3 - Send"));

	TestSendL();

	User::LeaveIfError(iStatus.Int());

	iSmsTest.TestFinish(iNextTest, KErrNone);

	iSmsTest.Printf(_L("Waiting %d seconds after send...\n"), KWaitAfterSend);

	User::After(KWaitAfterSend * 1000000);

	iSmsTest.Printf(_L("Finished waiting\n"));

	iSmsTest.TestStart(++iNextTest, _L("Test 2 - Enumerate"));

	TestEnumerateL();

	User::LeaveIfError(iStatus.Int());

	test(CompareSelectionsL(*iSelection,*iTestSelection));

	iSmsTest.TestFinish(iNextTest, KErrNone);

	iSmsTest.TestStart(++iNextTest, _L("Test 3 - Move from Phone Store"));

	TestMoveFromPhoneStoreL();

	User::LeaveIfError(iStatus.Int());

	test(CompareSelectionsL(*iSelection,*iTestSelection));

	iSmsTest.TestFinish(iNextTest, KErrNone);

	iSmsTest.TestStart(++iNextTest, _L("Test 2 - Enumerate"));

	TestEnumerateL();

	User::LeaveIfError(iStatus.Int());

	test(iTestSelection->Count()==0);

	iSmsTest.TestFinish(iNextTest, KErrNone);

	iSmsTest.TestStart(++iNextTest, _L("Test 2 - Delete Enumeration Folder"));

	TestDeleteEnumerationFolderL();

	User::LeaveIfError(iStatus.Int());

	iSmsTest.TestFinish(iNextTest, KErrNone);

	}

void CSmsBioficationTest::ShowMenuL()

	{

	}

void CSmsBioficationTest::DeleteEntriesFromTestFolderL()

	{

	MsvEntry().SetEntryL(iTestFolderId);

	delete iTestSelection;

	iTestSelection = MsvEntry().ChildrenL();

	if (iTestSelection->Count())

		{

		CMsvOperationWait* wait = CMsvOperationWait::NewLC();

		wait->Start();

		CMsvOperation* op=MsvEntry().DeleteL(*iTestSelection,wait->iStatus);

		CleanupStack::PushL(op);

		CActiveScheduler::Start();

		User::LeaveIfError(wait->iStatus.Int());

		iSmsTest.SetProgressL(*op);

		User::LeaveIfError(iSmsTest.iProgress.iError);

		CleanupStack::PopAndDestroy(2); //wait, op

		iTestSelection->Reset();

		}

	}

void CSmsBioficationTest::ChangeMtmUidsL(CMsvEntrySelection& aSelection)

	{

	for (TInt i=0; i<aSelection.Count(); i++)

		{

		MsvEntry().SetEntryL(aSelection[i]);

		TMsvEntry entry=MsvEntry().Entry();

		if (entry.iBioType!=EBioMsgIdUnknown)

			{

			entry.iMtm=KUidBIOMessageTypeMtm;  //  The test utils do not set the correct MTM uid for BIO messages

			MsvEntry().ChangeL(entry);

			}

		}

	}

TBool CSmsBioficationTest::CompareSelectionsL(const CMsvEntrySelection& aSelection1,const CMsvEntrySelection& aSelection2)

	{

	TInt count1=aSelection1.Count();

	TInt count2=aSelection2.Count();

	iSmsTest.Printf(_L("Comparing selections, 1st msg count %d, 2nd msg count %d\n"), count1,count2);

	TBool thesame=count1==count2;

	for (TInt i=0; thesame && (i<count1); i++)

		{

		CMsvEntrySelection* selection2=aSelection2.CopyLC();

		thesame=EFalse;

		for (TInt j=0; (!thesame) && (j<count2); j++)

			{

			thesame=CompareEntriesL(aSelection1[i],selection2->At(j));

			if (thesame)

				selection2->Delete(j);

			}

		CleanupStack::PopAndDestroy();

		}

	return thesame;

	}

TBool CSmsBioficationTest::CompareEntriesL(TMsvId aId1, TMsvId aId2)

	{

	TBool thesame=iSmsTest.AreMessagesSameTextL(aId1,aId2);

	if (thesame)

		{

		MsvEntry().SetEntryL(aId1);

		TMsvEntry entry1=MsvEntry().Entry();

		MsvEntry().SetEntryL(aId2);

		TMsvEntry entry2=MsvEntry().Entry();

		thesame=(entry1.iBioType==entry2.iBioType) && (entry1.iMtm==entry2.iMtm);

		}

	return thesame;

	}

void CSmsBioficationTest::RunEnumerateL()

	{

	TInt err = iStatus.Int();

	if (err == KErrNone)

		{

		err = iSmsTest.iProgress.iError;