// Copyright (c) 1997-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 "Starter.h"
#include "AppStarter.h"
#include "ThreadWatch.h"
#include <e32property.h>
#include "MsvTestUtils.h"
#include <Start.rsg>
#include "Start.hrh"

typedef TInt (*ShellEntryPoint)(TAny *);
#if defined(__WINS__)
LOCAL_D const TUint KHeapSize=0x10000;
LOCAL_D const TUint KMaxHeapSize=0x400000;
#endif


_LIT(KStubRunResourceFileName, "Z:\\SYSTEM\\PROGRAMS\\Start.RSC");
_LIT(KGlobalSemaphore, "SPLASH");
_LIT(KStartChunkName,"Start");

const TInt KRetryTime = 100000;

/**
@internalComponent
*/
TBool definedPhonePwrValue = EFalse;


/**
* Contructor
*/
CStarter::CStarter() :	CActive(EPriorityStandard), iNrSemaphore(0)
	{}

/**
* Destructor.
*/
CStarter::~CStarter()
	{
	if (iQueHeader)
		{
		while (!(iQueHeader->IsEmpty()))
			{
			CThreadWatcher* threadWatcher = iQueHeader->First();
			iQueHeader->Remove(*threadWatcher);
			delete threadWatcher;
			}
		delete iQueHeader;
		}

	iLsSess.Close();
#if defined (__WINS__)
	iAppUiSession.Close();
#endif
	delete iStartupList;
	delete iExtrasList;
	delete iSplashExe;
	iCmdLineArgs.Close();
	iResourceFile.Close();
	iFsSession.Close();
	}

/**
* Creates an instance of a CStarter object.
* @return			a pointer to this object
*/
CStarter* CStarter::NewL()
	{
	CStarter* self = new (ELeave) CStarter;
	CleanupStack::PushL(self);
	self->ConstructL();
	CleanupStack::Pop();
	return self;
	}

/**
* Handles the actual initialization of this object.
*/
void CStarter::ConstructL()
	{
	// Connect to the File Server
	while (iFsSession.Connect() != KErrNone)
		{
		User::After(KRetryTime);
		}

	//Connected to File Server
	iResourceFile.OpenL(iFsSession, KStubRunResourceFileName);

	// read the first one
    HBufC8* res = iResourceFile.AllocReadLC(R_APP_START_PARAMS);
    TResourceReader theReader;
    theReader.SetBuffer(res);
	//Main configuration resource read

	// get data from it
	iSplashExe = theReader.ReadHBufCL();

	TUint32 applicationsListId = theReader.ReadInt32();
	TUint32 exeListId = theReader.ReadInt32();

	// free up memory
	CleanupStack::PopAndDestroy();	// res

	// prepare the data for the active object
	iStartupList = iResourceFile.AllocReadL(applicationsListId);
    iStartupListReader.SetBuffer(iStartupList);
	iStartupCount = iStartupListReader.ReadUint16();	//The size of the resource array

	iExtrasList= iResourceFile.AllocReadL(exeListId);
    iExtrasListReader.SetBuffer(iExtrasList);
	iExtrasCount = iExtrasListReader.ReadUint16();	//The size of the resource array

	iQueHeader = new (ELeave) TSglQue<CThreadWatcher>(_FOFF(CThreadWatcher,iLink));

	// Tell system agent the phone is on.
	// This is only appropriate for 2-box solutions, and is needed for SMS sending and receiving.
	// Also, at some point, this should probably be moved to a separate component that startup launches.
	TInt testState;
	if(KErrNone != RProperty::Get(KUidSystemCategory, KMsvTestUidPhonePwrValue, testState))
		{
		User::LeaveIfError(RProperty::Define(KUidSystemCategory, KMsvTestUidPhonePwrValue, RProperty::EInt));
		definedPhonePwrValue = ETrue;
		}
	User::LeaveIfError(RProperty::Set(KUidSystemCategory, KMsvTestUidPhonePwrValue, EMsvTestPhoneOn));

	if(definedPhonePwrValue)
		{
		User::LeaveIfError(RProperty::Delete(KUidSystemCategory, KMsvTestUidPhonePwrValue));
		}

	RChunk chunk;
	TUint8 finish=0;
	if(	chunk.CreateGlobal(KStartChunkName,1,1)== KErrNone)
		{
		if(	chunk.OpenGlobal(KStartChunkName,EFalse)== KErrNone)
			{
			TUint8* base=chunk.Base();
			*base=finish;
			chunk.Close();
			}
		}
	}

/**
* Actually launch the splash screen exe
*/
void CStarter::StartSplashScreenL()
	{
	if (iSplashExe == NULL || iSplashExe->Length() == 0)
		{
		return;
		}

	// launch the splash screen
	TPtrC splashCmd;
	splashCmd.Set(*iSplashExe);

#if defined(__WINS__)
	TParse fileName;
	User::LeaveIfError(fileName.Set(_L(".DLL"),&splashCmd,NULL));
	User::LeaveIfError(iLib.Load(fileName.FullName()));
	ShellEntryPoint libFunc=(ShellEntryPoint)iLib.Lookup(1);
	if (!libFunc)
		{
		User::Leave(KErrGeneral);
		}
	TBuf<256> name;
	TInt num=0;
	TInt ret=KErrNone;
	do
		{
		name.Format(TRefByValue<const TDesC>(_L("Splash%d")),num++);
		ret=iSplash.Create(name,libFunc,KDefaultStackSize,&splashCmd,&iLib,NULL,/*NULL,*/KHeapSize,KMaxHeapSize,EOwnerProcess);
		} while(ret==KErrAlreadyExists);
	User::LeaveIfError(ret);
#else
	TFindFile findShell(iFsSession);
	User::LeaveIfError(findShell.FindByDir(splashCmd,_L("\\System\\Programs\\.EXE")));
	//User::LeaveIfError(iSplash.Create(findShell.File(),splashCmd));
	TInt err1 = 0;
	TRAPD(err,(err1 = iSplash.Create(findShell.File(),splashCmd)));	//Change back to commented out line when E32 bug is fixed ###
	if (err!=KErrNone && err1 != KErrNone)
		{
		iSplash.SetHandle(KNullHandle);
		User::Leave(err);
		}
#endif
	iSplash.Resume();

	}

/**
* Method to be called to procced the startup
*/
void CStarter::Start()
	{
	iStage = ESplashScreen;
	RequestNotify();
	}

/**
* Start then connect the Eikon server
*/
void CStarter::Connect()
	{
	// Connect to the AppUi session, effective starting it.
	while(iAppUiSession.Connect() != KErrNone)
		{
		User::After(KRetryTime);
		}

	// Connect to the AppLsServer
	while(iLsSess.Connect() != KErrNone)
		{
		User::After(KRetryTime);
		}

	TInt count=0;
	while(iLsSess.GetAllApps() != KErrNone) //collect data
		{
		}
  	while(iLsSess.AppCount(count) != KErrNone) //collect data
		{
		}
	RequestNotify();
	}

/**
* Proceed the next application to be launched
*/
void CStarter::LaunchNextStartupAppL()
	{
	TUint32 applicationUid = iStartupListReader.ReadUint32();
	TFullName exeFilePath = iStartupListReader.ReadTPtrC();
	TFullName dllFilePath = iStartupListReader.ReadTPtrC();
	iCmdLineArgs.Append( iStartupListReader.ReadTPtrC());
	TDesC *commandLineArgs = &iCmdLineArgs[ iCmdLineArgs.Count()-1];

	TUint32 stackSize = iStartupListReader.ReadUint32();
	stackSize = stackSize ? stackSize : KDefaultStackSize;
	TUint32 minHeapSize = iStartupListReader.ReadUint32();
	minHeapSize = minHeapSize ? minHeapSize : KMinHeapSize;
	TUint32 maxHeapSize = iStartupListReader.ReadUint32();

	TBool monitored = (TUint16)iStartupListReader.ReadUint16();
	TBool semaphore = (TUint16)iStartupListReader.ReadUint16();
	TBool viewless = (TUint16)iStartupListReader.ReadUint16();
	TInt bootType  = (TUint16)iStartupListReader.ReadUint16();
			
	if(semaphore)
		{
		iNrSemaphore++; //increase with one.
		iWaiting++;
		}

	iStartupCount--; // next app
	CAppStarter::NewLD(bootType, applicationUid, exeFilePath, dllFilePath, commandLineArgs,
						stackSize, minHeapSize, maxHeapSize, monitored, viewless,
						semaphore, iQueHeader, iLsSess, this);
	}

/**
* Proceed the next extra app to be launched
*/
void CStarter::LaunchNextExtrasL()
	{
	TUint32 applicationUid = iExtrasListReader.ReadUint32();
	TFullName exeFilePath = iExtrasListReader.ReadTPtrC();
	TFullName dllFilePath = iExtrasListReader.ReadTPtrC();
	iCmdLineArgs.Append( iExtrasListReader.ReadTPtrC());
	TDesC *commandLineArgs = &iCmdLineArgs[ iCmdLineArgs.Count()-1];

	TUint32 stackSize = iExtrasListReader.ReadUint32();
	stackSize = stackSize ? stackSize : KDefaultStackSize;
	TUint32 minHeapSize = iExtrasListReader.ReadUint32();
	minHeapSize = minHeapSize ? minHeapSize : KMinHeapSize;
	TUint32 maxHeapSize = iExtrasListReader.ReadUint32();
	
	TBool monitored = (TUint16)iExtrasListReader.ReadUint16();
	TBool viewless = (TUint16)iExtrasListReader.ReadUint16();
	TInt bootType  = (TUint16)iExtrasListReader.ReadUint16();

	iExtrasCount--; // next app
	CAppStarter::NewLD(bootType, applicationUid, exeFilePath, dllFilePath, commandLineArgs,
						stackSize, minHeapSize, maxHeapSize, monitored, viewless,
						EFalse, iQueHeader, iLsSess, this);
	}

void CStarter::RestartMonitoredThreadL(TInt appType, TThreadId& aThreadId, TDesC& aExeFileName, TUint32 aAppUid, TBool aViewless)
  	{
  	if(appType == EExecutableType) 
  		{
  		User::LeaveIfError(iLsSess.StartDocument(aExeFileName, TUid::Uid(0), aThreadId));
  		} 
  	else if(aViewless)
  		{
  		TApaAppInfo info;
  		User::LeaveIfError(iLsSess.GetAppInfo(info,TUid::Uid(aAppUid)));
  		CApaCommandLine* cmdLine=CApaCommandLine::NewLC();	
  		cmdLine->SetLibraryNameL(info.iFullName);
  		cmdLine->SetCommandL(EApaCommandRunWithoutViews);
  		User::LeaveIfError(iLsSess.StartApp(*cmdLine, aThreadId));
  		CleanupStack::PopAndDestroy();	// cmdLine
		}
  	else
  		{
  		TApaAppInfo info;
  		User::LeaveIfError(iLsSess.GetAppInfo(info,TUid::Uid(aAppUid)));
  		TFileName fName;
  		if (info.iUid!=KNullUid)
  			{
  			User::LeaveIfError(iLsSess.StartDocument(fName, TUid::Uid(aAppUid), aThreadId));
  			}
  		}
   	}

/**
* Method called when the requested step have been procced
*/
void CStarter::RunL()
	{
	switch (iStage)
		{
		case ESplashScreen:
			{
			iStage =  EStarting;
			// don't care about the error - for now
			TRAPD(err, StartSplashScreenL());
			iSplashStarted = (err == KErrNone);
			RequestNotify();		
			}
			break;
		case EStarting:
			iStage = EConnected;
			Connect();
			break;
		case EConnected:
			{
			iStage = EStart;
			iSema.CreateGlobal(KGlobalSemaphore, EOwnerProcess); //For Shell
			RequestNotify();
			}
			break;
		case EStart:
			{
			iStage = EStart;
			if (iStartupCount)
				{
				LaunchNextStartupAppL();
				RequestNotify();
				}
			break;
		case EWait:
 			iStage = EStartExtras;
			if(iSema.OpenGlobal(KGlobalSemaphore, EOwnerProcess) == KErrNone)
				{
				while(iNrSemaphore > 0) //Defined in the resourcefile for apps that has to be started before the splash screen is removed
					{
					iSema.Wait();
					iNrSemaphore--;
					}
				iSema.Close();
				}

			if(iSplashStarted)
				{
				//use chunk to tell splash screen to stop by setting to 1
				RChunk chunk;
				TUint8 finish=1;
				if(	chunk.OpenGlobal(KStartChunkName,EFalse)== KErrNone)
					{
					TUint8* base=chunk.Base();
					*base=finish;
					chunk.Close();
					}
				}

			RequestNotify();
			}
			break;
		case EStartExtras:
			if(iExtrasCount)
				{
				LaunchNextExtrasL();
				RequestNotify();
				}
			break;
		default: 
			iStage = ESplashScreen;
			break;
		}
	}

TInt CStarter::RunError(TInt /*aError*/)
	{
	return KErrNone;
	}

void CStarter::Done(TBool aSuccess)
	{
	if(aSuccess)
		{
		iWaiting--;
		}
	else
		{
		iWaiting--;
		iNrSemaphore--;
		}
	if(iWaiting <= 0)
		{
		iStage = EWait;
		RequestNotify();
		}
	}
/**
* Cancel the execution
*/
void CStarter::DoCancel()
	{
	TRequestStatus* status = &iStatus;
	User::RequestComplete(status, KErrCancel);
	}

void CStarter::RequestNotify()
	{
	TRequestStatus* status = &iStatus;
	User::RequestComplete(status, KErrNone);
	SetActive();
	}