// Copyright (c) 2004-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 <csch_cli.h>

#include "Thelpers.h"

#include <e32base.h>

#include <e32test.h>

#include <f32file.h>

#include <s32file.h>

#include "TestUtils.h"

//If suddenly all SCHSVR tests begin failing, the OOM conditions might be the reason.

//TScheduling test tries to create KNumberOfSchedulesToCreate tasks, loading enormously 

//the task scheduling server. The task scheduling server fails and stays loaded in memory

//with many scheduling tasks holding large amounts of allocated memory in this way.

//The next SCHSVR tests may fail because of OOM.

//KNumberOfSchedulesToCreate value was 100 originally. Now it is 20.

//

// Literal constants

//

_LIT(KTestName,								"TC_TSCH_SCHEDULING2");

//

// Type definitions

//

typedef CArrayFixFlat<TScheduleEntryInfo>	CSchEntryInfoArray;

typedef CArrayFixFlat<TTaskInfo>			CTaskInfoArray;

typedef CArrayFixFlat<TSchedulerItemRef>    CSchItemRefArray;

//

// Global data

//

RTest										TheTest(KTestName);

static TInt64								TheSeed;

static RScheduler							TheScheduler;

static CTrapCleanup*						TheCleanup;

static RFs									TheFsSession;

_LIT(KMinimalTaskHandler, "MinimalTaskHandler");

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

// Extract task info from the schedule server based on a schedule ID

static void GetTaskInfoL(CTaskInfoArray& aTaskInfoArray,

						TInt aScheduleId)

	{

	aTaskInfoArray.Reset();

	TTime nextTimeScheduleIsDue;

	TScheduleState state;

	CSchEntryInfoArray* entries 

		= new (ELeave) CSchEntryInfoArray(3);

	CleanupStack::PushL(entries);

	TInt res = TheScheduler.GetScheduleL(aScheduleId, 

										state, 

										*entries, 

										aTaskInfoArray, 

										nextTimeScheduleIsDue);

	TEST2(res, KErrNone);

	CleanupStack::PopAndDestroy(entries);

	}

// count the number of tasks associated with this schedule

static TInt CountTasksL(TInt aScheduleId)	

	{

	CTaskInfoArray* tasks = new (ELeave) CTaskInfoArray(3);

	CleanupStack::PushL(tasks);

	GetTaskInfoL(*tasks, aScheduleId);

	TInt ret = tasks->Count();

	CleanupStack::PopAndDestroy(tasks);

	return ret;

	}

// count the number of schedules based on a filter.

static TInt CountScheduledItemsL(TScheduleFilter aFilter, 

								RScheduler& aScheduler)

	{

	CSchItemRefArray* refs = new (ELeave) CSchItemRefArray(3);

	CleanupStack::PushL(refs);

	TInt res = aScheduler.GetScheduleRefsL(*refs, aFilter);

	TEST2(res, KErrNone);

	TInt count = refs->Count();

	CleanupStack::PopAndDestroy(); // refs

	return count;

	}

//creates a daily schedule with StartTime of aStartTime

static TInt CreateScheduleL(TSchedulerItemRef& aRef, 

							RScheduler& aScheduler, 

							const TTime& aStartTime)

	{

	CSchEntryInfoArray* entryList 

		= new (ELeave) CSchEntryInfoArray(1);

	CleanupStack::PushL(entryList);

	TScheduleEntryInfo entry1;

	entry1.iStartTime		= aStartTime;

	entry1.iInterval		= 1; // TTimeIntervalDays

	entry1.iIntervalType	= EDaily;

	entry1.iValidityPeriod	= 30; // minutes

	entryList->AppendL(entry1);

	TInt res = aScheduler.CreatePersistentSchedule(aRef, *entryList);

	CleanupStack::PopAndDestroy(); // entryList

	return res;

	}

// creates a schedule with numerous entries	

static TInt CreateSchedule1L(TSchedulerItemRef& aRef, RScheduler& aScheduler)

	{

	aRef.iName = _L("Schedule created using \"CreateSchedule1L\"");

	CSchEntryInfoArray* entryList = new (ELeave) CSchEntryInfoArray(3);

	CleanupStack::PushL(entryList);

	{

	TScheduleEntryInfo entry1;

	entry1.iStartTime		= SchSvrHelpers::TimeBasedOnOffset(20, 0); // 0m:20s from "now"

	entry1.iInterval		= 1;

	entry1.iIntervalType	= EDaily;

	entry1.iValidityPeriod	= 20;

	entryList->AppendL(entry1);

	}

	{

	TScheduleEntryInfo entry2;

	entry2.iStartTime		= SchSvrHelpers::TimeBasedOnOffset(00, 1); // 1m:00s from "now"

	entry2.iInterval		= 1;

	entry2.iIntervalType	= EDaily;

	entry2.iValidityPeriod	= 20;

	entryList->AppendL(entry2);

	}

	{

	TScheduleEntryInfo entry3;

	entry3.iStartTime		= SchSvrHelpers::TimeBasedOnOffset(0, 0, 0, 0, 0, -1); // -1 year from "now"

	entry3.iInterval		= 1;

	entry3.iIntervalType	= EDaily;

	entry3.iValidityPeriod	= 20;

	entryList->AppendL(entry3);

	}

	TInt res = aScheduler.CreatePersistentSchedule(aRef, *entryList);

	CleanupStack::PopAndDestroy(); // entryList

	return res;

	}

// creates a schedule with numerous entries	

static TInt CreateSchedule2L(TSchedulerItemRef& aRef, RScheduler& aScheduler)

	{

	CSchEntryInfoArray* entryList = new (ELeave) CSchEntryInfoArray(3);

	CleanupStack::PushL(entryList);

	aRef.iName = _L("Schedule created using \"CreateSchedule2L\"");

	{

	TScheduleEntryInfo entry1;

	entry1.iStartTime		= SchSvrHelpers::TimeBasedOnOffset(30, 2); // 2m:30s from "now"

	entry1.iInterval		= 1;

	entry1.iIntervalType	= EDaily;

	entry1.iValidityPeriod	= 20;

	entryList->AppendL(entry1);

	}

	{

	TScheduleEntryInfo entry2;

	entry2.iStartTime		= SchSvrHelpers::TimeBasedOnOffset(0, 5);  // 5m:00s from "now"

	entry2.iInterval		= 1;

	entry2.iIntervalType	= EDaily;

	entry2.iValidityPeriod	= 20;

	entryList->AppendL(entry2);

	}

	TInt res = aScheduler.CreatePersistentSchedule(aRef, *entryList);

	CleanupStack::PopAndDestroy(); // entryList

	return res;

	}

// creates a schedule with numerous entries	

static TInt CreateSchedule3L(TSchedulerItemRef& aRef, RScheduler& aScheduler)

	{

	CSchEntryInfoArray* entryList = new (ELeave) CSchEntryInfoArray(3);

	CleanupStack::PushL(entryList);

	aRef.iName = _L("Schedule created using \"CreateSchedule3L\"");

	{

	TScheduleEntryInfo entry1;

	entry1.iIntervalType	= EDaily;

	entry1.iInterval		= 1; // repeat every day

	entry1.iValidityPeriod	= 5; // valid for only 5 minutes 

	entry1.iStartTime		= SchSvrHelpers::TimeBasedOnOffset(0, 9, 0, 20); // 9mins and 20days in the future

	entryList->AppendL(entry1);

	}

	{

	TScheduleEntryInfo entry2;

	entry2.iIntervalType	= EDaily;

	entry2.iInterval		= 1;

	entry2.iValidityPeriod	= 5;

	entry2.iStartTime		= SchSvrHelpers::TimeBasedOnOffset(0, 11, 0, 20); // 11mins and 20days in the future

	entryList->AppendL(entry2);

	}

	TInt res = aScheduler.CreatePersistentSchedule(aRef, *entryList);

	CleanupStack::PopAndDestroy(); // entryList

	return res;

	}

// schedules a persistent task associated with the supplied schedule ID

static TInt SchedulePersistentTaskL(const TName& aName, 

									TInt& aNewId, 

									TInt aScheduleId, 

									TInt aRepeat, 

									RScheduler& aScheduler)

	{

	TTaskInfo taskInfo;

	taskInfo.iTaskId = aNewId;

	taskInfo.iName = aName;

	taskInfo.iPriority = 2;

	taskInfo.iRepeat = aRepeat;

	HBufC* data = _L("the data").AllocLC();

	TInt res = aScheduler.ScheduleTask(taskInfo, *data, aScheduleId);

	aNewId = taskInfo.iTaskId;

	CleanupStack::PopAndDestroy(); // data

	return res;

	}

/**

@SYMTestCaseID          SYSLIB-SCHSVR-CT-1033

@SYMTestCaseDesc	    Test 1 - verifies fix for defect:

						Registering twice with the task scheduler causes a memory leak(EDNAWIR-4FQJ6A)

@SYMTestPriority 	    High

@SYMTestActions  	    Connect to scheduler and register twice with the task scheduler.Check for memory errors,

@SYMTestExpectedResults Test must not fail

@SYMREQ                 REQ0000

*/		

static void Test1L()

	{

	TheTest.Next(_L(" @SYMTestCaseID:SYSLIB-SCHSVR-CT-1033 TheTest1: Registering with the tasks scheduler without disconnecting "));    

	__UHEAP_MARK;

	TheTest.Next(_L("Connect to Scheduler"));

	TInt res = TheScheduler.Connect();

	TEST2(res, KErrNone);

	TheTest.Next(_L("Registering Client"));

	TEST2(SchSvrHelpers::RegisterClientL(TheScheduler), KErrNone);

	TheScheduler.Close();

	__UHEAP_MARKEND;

	__UHEAP_MARK;

	TheTest.Next(_L("Connect to Scheduler again"));

	res = TheScheduler.Connect();

	TEST2(res, KErrNone);

	TheTest.Next(_L("Registering client again"));

	TEST2(SchSvrHelpers::RegisterClientL(TheScheduler), KErrNone);

	TheScheduler.__DbgMarkHeap();

	TheTest.Next(_L("Register when already registered"));

	TEST2(SchSvrHelpers::RegisterClientL(TheScheduler), KErrNone);

	TheTest.Next(_L("Cancel registering client and check for memory leak"));

	TheScheduler.__DbgMarkEnd(0);

	TheScheduler.Close();

	__UHEAP_MARKEND;

	}

/**

@SYMTestCaseID          SYSLIB-SCHSVR-CT-1034

@SYMTestCaseDesc	    Test 2 - verifies fix for defect

						Messages with "Resend" status are not sent after reboot (EDNHLJT-4TRAAE)

@SYMTestPriority 	    High

@SYMTestActions  	    Add a task to the schedule,kill the server and re-register the client,wait for one minute for task to fire

@SYMTestExpectedResults Test must not fail

@SYMREQ                 REQ0000

*/		

static void Test2L()

//

//

	{

	TheTest.Next(_L(" @SYMTestCaseID:SYSLIB-SCHSVR-CT-1034 TheTest2: Resend after hard reset (simulation) "));

	TheTest.Next(_L("Connect to Scheduler"));

	TInt res = TheScheduler.Connect();

	TEST2(res, KErrNone);

	TheTest.Next(_L("Registering Client"));

	TEST2(SchSvrHelpers::RegisterClientL(TheScheduler), KErrNone);

	// Create a schedule

	TheTest.Next(_L("Creating schedule"));

	TSchedulerItemRef scheduleHandle;

	TTime time;

	time.HomeTime();

	time += TTimeIntervalSeconds(2); //Task to go off two seconds from now

	User::LeaveIfError(CreateScheduleL(scheduleHandle, TheScheduler, time));  

	// Add a task to the schedule

	TheTest.Next(_L("Creating task for schedule"));

	{

	TTaskInfo taskInfo;

	taskInfo.iName = _L("MyTaskName");

	taskInfo.iPriority = 2;

	taskInfo.iTaskId = 0;

	taskInfo.iRepeat = 1;

	HBufC* data = _L("Task Data").AllocLC();

	TInt res = TheScheduler.ScheduleTask(taskInfo, *data, scheduleHandle.iHandle);

	CleanupStack::PopAndDestroy(); // data

	TEST2(res, KErrNone);

	}

	// Kill the server !!

	TheTest.Next(_L("Killing server"));

	// Need to turn off JIT dubugging as we are panicking server and we 

	// want test to keep running.

	TBool jit = User::JustInTime();

	User::SetJustInTime(EFalse);

	TheScheduler.__FaultServer();

	User::After(100000);

	// Turn on JIT again.

	User::SetJustInTime(jit);

	// Connect to the server again

	TheTest.Next(_L("Re-connect to Scheduler"));

	res = TheScheduler.Connect();

	TEST2(res, KErrNone);

	// Re-register

	TheTest.Next(_L("Re-register Client"));

	TEST2(SchSvrHelpers::RegisterClientL(TheScheduler), KErrNone);

	TheTest.Next(_L("Check schedule count and task count"));

	TInt scheduleCount = CountScheduledItemsL(EAllSchedules, TheScheduler);

	TEST(scheduleCount == 1);

	TInt taskCount = CountTasksL(scheduleHandle.iHandle);

	TEST(taskCount == 1);

	// Wait for task to fire... It should happen in about 2 seconds

	TheTest.Next(_L("Waiting for task to complete"));

	TEST2(STaskSemaphore::WaitL(KDefaultTimeout), KErrNone);

	CleanupHelpers::KillProcess(KMinimalTaskHandler);

	}

/**

@SYMTestCaseID          SYSLIB-SCHSVR-CT-1035

@SYMTestCaseDesc	    This test establishes that the change to RScheduler::GetScheduleL is functionally correct

@SYMTestPriority 	    High

@SYMTestActions  	    Tests changes to Schedule Server API as of Change Request document AALR-4EDG75

@SYMTestExpectedResults Test must not fail

@SYMREQ                 REQ0000

*/		

static void Test3L()

	{

	//

	//

	// Test changes to Schedule Server API as of Change Request document AALR-4EDG75

	// (GT change requests database)

	//

	//

	//

	// This test establishes that the change to...

	//

	//	RScheduler::GetScheduleL(const TInt aScheduleHandle,

	//								 TScheduleState& aState,

	//								 CArrayFixFlat<TScheduleEntryInfo>& aEntries,

	//								 CArrayFixFlat<TTaskInfo>& aTasks,

	//								 TTime& aNextDue)

	//

	// ...is functionally correct.

	// 

	//

	TheTest.Next(_L(" @SYMTestCaseID:SYSLIB-SCHSVR-CT-1035 Test change request AALR-4EDG75 implementation "));

	TheTest.Next(_L("Connect to Scheduler"));

	TInt res = TheScheduler.Connect();

	TEST2(res, KErrNone);

	TheTest.Next(_L("Registering Client"));

	TEST2(SchSvrHelpers::RegisterClientL(TheScheduler), KErrNone);

	const TDateTime KTimeToStartTask(2000, EJanuary, 10, 15, 30, 0, 0);

	TSchedulerItemRef schedulerItemReference;

	CSchEntryInfoArray* entryArray = new(ELeave) CSchEntryInfoArray(1);

	CleanupStack::PushL(entryArray);

	HBufC* taskData = _L("This is some dummy task data created for testing").AllocL();

	CleanupStack::PushL(taskData);

	// Prepare the task info - this describes the tasks that are contained within the task

	// entry array

	TTaskInfo taskInfo = SchSvrHelpers::TaskInfo(_L("A transient test task"), 100);

	// Create a schedule entry and append it to the entry array

	{

	TScheduleEntryInfo scheduleEntry = SchSvrHelpers::ScheduleEntryInfo(EDaily, TTime(KTimeToStartTask), 7, 2);

	entryArray->AppendL(scheduleEntry);

	}

	// Create the transient task

	TInt ret = TheScheduler.ScheduleTask(taskInfo, *taskData, schedulerItemReference, *entryArray);

	TEST2(ret, KErrNone);

	// Check that the task Id after scheduling the event is not 

	// the same as it was prior to the requesting the service

	TEST(taskInfo.iTaskId != -1);

	//

	// Now obtain info about the scheduled transient task...

	//

	TScheduleState scheduleState;

	TTime nextTaskDueTime;

	// Reset the schedule entry info array as the server now has copies of this and it is

	// no longer required client-side

	entryArray->Reset();

	CTaskInfoArray* taskInfoArray = new(ELeave) CTaskInfoArray(4);

	CleanupStack::PushL(taskInfoArray);

	// Request task schedule information from the server

	ret = TheScheduler.GetScheduleL(schedulerItemReference.iHandle, scheduleState, *entryArray, *taskInfoArray, nextTaskDueTime);

	TEST2(ret, KErrNone);

	// Because this is a daily task which is scheduled to occur at a specific time (but the date

	// cannot necessarily be established, we can perform a simple check to ensure that the

	// time when the task is next scheduled to run falls within the 15:30 - 17:30 bracket.

	TEST(SchSvrHelpers::IsTimeTheSame(nextTaskDueTime, TTime(KTimeToStartTask)) == (TInt) ETrue);

	// Establish and test the size of the task data for the specified task object

	TInt sizeOfTaskData = 0;

	TEST2(TheScheduler.GetTaskDataSize(taskInfo.iTaskId, sizeOfTaskData), KErrNone);

	TEST(sizeOfTaskData == taskData->Length());

	// Now check the information return from the server pertaining to a specific task...

	{

	TTaskInfo taskFromServer;

	HBufC* taskDataFromServer					= HBufC::NewLC(sizeOfTaskData);

	TPtr pTaskDataFromServer					= taskDataFromServer->Des();

	TTime nextDueTimeFromServer					= Time::NullTTime();

	TSchedulerItemRef schedulerRefFromServer;

	TEST2(TheScheduler.GetTaskInfoL(taskInfo.iTaskId, taskFromServer, pTaskDataFromServer, schedulerRefFromServer, nextDueTimeFromServer), KErrNone);

	TEST(SchSvrHelpers::IsTimeTheSame(nextTaskDueTime, TTime(KTimeToStartTask)) == (TInt) ETrue);

	TEST(SchSvrHelpers::IsTaskInfoTheSame(taskFromServer, taskInfo) == (TInt) ETrue);

	TEST(SchSvrHelpers::IsItemRefTheSame(schedulerRefFromServer, schedulerItemReference) == (TInt) ETrue);

	CleanupStack::PopAndDestroy(); // taskDataFromServer

	}

	// Disable the schedule and check when it is next schedule to run

	TEST2(TheScheduler.DisableSchedule(schedulerItemReference.iHandle), KErrNone);

	// Get the new schedule info - check that the nextDueTime is still reported even

	// though the schedule has been disabled

	nextTaskDueTime = Time::NullTTime();

	TEST2(TheScheduler.GetScheduleL(schedulerItemReference.iHandle, scheduleState, *entryArray, *taskInfoArray, nextTaskDueTime), KErrNone);

	TEST(SchSvrHelpers::IsTimeTheSame(nextTaskDueTime, TTime(KTimeToStartTask)) == (TInt) ETrue);

	TEST(SchSvrHelpers::IsTaskInfoTheSame(taskInfoArray->At(0), taskInfo) == (TInt) ETrue);

	// Re-enable the schedule

	TEST2(TheScheduler.EnableSchedule(schedulerItemReference.iHandle), KErrNone);

	// Delete the only task (relating to this test) from the server

	TEST2(TheScheduler.DeleteTask(taskInfo.iTaskId), KErrNone);

	ret = TheScheduler.GetScheduleL(schedulerItemReference.iHandle, scheduleState, *entryArray, *taskInfoArray, nextTaskDueTime);

	TEST2(ret, KErrNotFound); // there is no longer any tasks associated with this schedule

	CleanupStack::PopAndDestroy(3); // taskInfoArray, entryArray, taskData

	}

/**

@SYMTestCaseID          SYSLIB-SCHSVR-CT-1036

@SYMTestCaseDesc	    Tests for defect EDNAALR-4JKEFC

@SYMTestPriority 	    High

@SYMTestActions  	    Create the schedule for the task,re-register the client with the server.

                        check for the information that the scheduler knows about.

@SYMTestExpectedResults Test must not fail

@SYMREQ                 REQ0000

*/		

static void Test4L()

	{

	// Test title

	TheTest.Next(_L(" @SYMTestCaseID:SYSLIB-SCHSVR-CT-1036 \nTest for defect EDNAALR-4JKEFC "));

	TheTest.Next(_L("Connect to Scheduler"));

	TInt res = TheScheduler.Connect();

	TEST2(res, KErrNone);

	TheTest.Next(_L("Registering Client"));

	TEST2(SchSvrHelpers::RegisterClientL(TheScheduler), KErrNone);

	// Constants / vars used in this function

	TSchedulerItemRef itemRef;

	// Create some scheduling entries

	CArrayFixFlat<TScheduleEntryInfo>* entries = new(ELeave) CArrayFixFlat<TScheduleEntryInfo>(10);

	CleanupStack::PushL(entries);

	TScheduleEntryInfo entry1;

	entry1.iIntervalType	= EHourly;

	entry1.iStartTime		= SchSvrHelpers::TimeBasedOnOffset(1, 1); // 1m:01s from "now"

	entry1.iInterval		= 1;

	entry1.iValidityPeriod	= 20;

	entries->AppendL(entry1);

	TScheduleEntryInfo entry2;

	entry2.iIntervalType	= EHourly;

	entry2.iStartTime		= SchSvrHelpers::TimeBasedOnOffset(5, 5); // 5m:05s from "now"

	entry2.iInterval		= 1;

	entry2.iValidityPeriod	= 20;

	entries->AppendL(entry2);