// Copyright (c) 2000-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 <schinfo.h>
#include <schinfointernal.h>
#include <schtask.h>
#include <s32file.h>
#include <e32math.h>
#include <e32cons.h>

// Constants
_LIT(KMinimalTaskConsoleName, "MinimalTaskExecutor");

static void SignalTestExe()
	{
	_LIT(KSchSemaphoreName, "SCHMinimalTaskHandler");
	RSemaphore sem;
	TInt ret = sem.OpenGlobal(KSchSemaphoreName);
	if (ret == KErrNone)
		{
		sem.Signal();
		sem.Close();
		}
	}

//***********************************************************************************
LOCAL_D TInt GetRandomNumber(const TInt aLow, const TInt aHigh, TInt64& aSeed)
	{
	TReal initialRand = (Math::FRand(aSeed) * (aHigh - aLow));
	TInt32 rand;

	// Round to 0 decimal places, ie. the nearest whole numer
	Math::Round(initialRand, initialRand, 0);
	Math::Int(rand, initialRand);

	return (aLow + rand);
	}

//***********************************************************************************
LOCAL_D void ConstructConsoleL(RFile& aTaskFile)
	{
	CConsoleBase* console=Console::NewL(KMinimalTaskConsoleName, TSize(KConsFullScreen, KConsFullScreen));
	CleanupStack::PushL(console);
	console->Printf(_L(" contents of task file\n"));
	
	CFileStore* store;
	// Open the filestore
	store = CDirectFileStore::FromLC(aTaskFile);//pushes store
	RStoreReadStream instream;
	instream.OpenLC(*store,store->Root());//pushes instream

	// Get task count
	TInt count = instream.ReadInt32L();
	for (TInt i=0;i<count;i++)
		{
		CScheduledTask* task = CScheduledTask::NewLC(instream);
		
		TBuf<150> buf;
		buf.Format(_L("Running task \"%S\""), &task->Info().iName);
		User::LeaveIfError(User::InfoPrint(buf));
		
		console->Printf(task->Info().iName);
		console->Printf(_L("\n"));
		HBufC* data = const_cast<HBufC*>(&(task->Data()));
		console->Printf(*data);
		console->Printf(_L("\n"));
		console->Printf(_L("%d \n"),task->Info().iTaskId);
		TTsTime tstime = task->ValidUntil();
		const TTime time = tstime.GetLocalTime();
		TBuf<30> dateString;
		time.FormatL(dateString,(_L("%H%:1%T%*E%*D%X%*N%Y %1 %2 %3")));
		console->Printf(_L(":%S\n"), &dateString);
		CleanupStack::PopAndDestroy(task);
		}
	console->Printf(_L("Pausing for a one second..."));
	User::After(1000000);
	CleanupStack::PopAndDestroy(3); //console, store, instream
	}


//***********************************************************************************
LOCAL_D TInt Execute()
	{
	TInt err = KErrNoMemory;
	CTrapCleanup* cleanup=CTrapCleanup::New();	//can fail
	if (cleanup)
		{
		RFile file;
		
		// Adopt the task file from the Task Scheduler
		err = file.AdoptFromCreator(TScheduledTaskFile::FsHandleIndex(),
									TScheduledTaskFile::FileHandleIndex());
		if (err != KErrNone)
			return err;
		
		// The aParam is the name of a file where the relevant CTaskExCmdLine is
		// do the executing 
		TRAPD(err, ConstructConsoleL(file));
		if(err == KErrNone)
			{
			// Sometimes we want to return a bogus error value, 
			// sometimes we don't.
			TTime now;
			now.HomeTime();
			TInt64 seed = now.Int64();
			err = GetRandomNumber(-50, 200, seed); //20% chance of error being returned
			}
		
		file.Close();// Close the file		
		delete cleanup;
		}
	SignalTestExe();		
	return err;
	}


//***********************************************************************************
GLDEF_C TInt E32Main()
	{
	return Execute();
	}