// shutapp.cpp
// 
// Copyright (c) 2007 - 2010 Accenture. All rights reserved.
// This component and the accompanying materials are made available
// under the terms of the "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:
// Accenture - Initial contribution
//

#include <w32std.h>
#include <apgtask.h>
#include <apgwgnam.h>
#include "shutapp.h"


CCommandBase* CCmdShutApp::NewLC()
	{
	CCmdShutApp* self = new(ELeave) CCmdShutApp();
	CleanupStack::PushL(self);
	self->BaseConstructL();
	return self;
	}

CCmdShutApp::~CCmdShutApp()
	{
	iWgIds.Close();
	iWgNames.ResetAndDestroy();
	}

CCmdShutApp::CCmdShutApp()
	: iTimeout(5)
	{
	}

const TDesC& CCmdShutApp::Name() const
	{
	_LIT(KName, "shutapp");
	return KName;
	}

void CCmdShutApp::DoRunL()
	{
	RWsSession wsSession;
	User::LeaveIfError(wsSession.Connect());
	CleanupClosePushL(wsSession);

	const TInt numIds = iWgIds.Count();
	for (TInt i = 0; i < numIds; ++i)
		{
		ShutL(wsSession, iWgIds[i]);
		}

	const TInt numNames = iWgNames.Count();
	for (TInt i = 0; i < numNames; ++i)
		{
		const TDesC& name = *(iWgNames[i]);
		TInt id = 0;
		while ((id = wsSession.FindWindowGroupIdentifier(id, name)) != KErrNotFound)
			{
			ShutL(wsSession, id);
			}
		}

	if (iAll)
		{
		TInt numWgs = wsSession.NumWindowGroups(0);
		if (numWgs > 0)
			{
			CArrayFixFlat<TInt>* wgIds = new(ELeave) CArrayFixFlat<TInt>(numWgs);
			CleanupStack::PushL(wgIds);
			User::LeaveIfError(wsSession.WindowGroupList(0, wgIds));
			numWgs = wgIds->Count();
			for (TInt i = 0; i < numWgs; ++i)
				{
				ShutL(wsSession, (*wgIds)[i]);
				}
			CleanupStack::PopAndDestroy(wgIds);
			}
		}
	CleanupStack::PopAndDestroy(&wsSession);
	}
	
void CCmdShutApp::ShutL(RWsSession& aWsSession, TInt aWindowGroupId)
	{
	CApaWindowGroupName* wgn = CApaWindowGroupName::NewLC(aWsSession, aWindowGroupId);
	if (iVerbose)
		{
		_LIT(KUnknown, "not named");
		TPtrC caption(wgn->Caption());
		if (caption.Length() == 0)
			{
			caption.Set(KUnknown);
			}
		Printf(_L("Shutting down %d (%S)\r\n"), aWindowGroupId, &caption);
		}

	TThreadId threadId;
	User::LeaveIfError(aWsSession.GetWindowGroupClientThreadId(aWindowGroupId, threadId));

	RThread thread;
	User::LeaveIfError(thread.Open(threadId));
	CleanupClosePushL(thread);

	TRequestStatus threadStatus;
	thread.Logon(threadStatus);
	if (threadStatus != KRequestPending)
		{
		User::WaitForRequest(threadStatus);
		User::Leave(KErrGeneral);
		}

	RTimer timer;
	User::LeaveIfError(timer.CreateLocal());
	CleanupClosePushL(timer);
	TRequestStatus timeoutStatus;
	timer.After(timeoutStatus, iTimeout * 1000000);

	TApaTask task(aWsSession);
	task.SetWgId(aWindowGroupId);
#ifdef EKA2
	if (iForce)
		{
		task.SendSystemEvent(EApaSystemEventSecureShutdown);
		}
	else
		{
		task.SendSystemEvent(EApaSystemEventShutdown);
		}
#else
	task.SendSystemEvent(EApaSystemEventShutdown);
#endif

	User::WaitForRequest(threadStatus, timeoutStatus);

	if (timeoutStatus != KRequestPending)
		{
		// Timeout occurred.
		thread.LogonCancel(threadStatus);
		User::WaitForRequest(threadStatus);
		User::Leave(KErrTimedOut);
		}
	else
		{
		timer.Cancel();
		User::WaitForRequest(timeoutStatus);
		}

	CleanupStack::PopAndDestroy(3, wgn);
	}

void CCmdShutApp::OptionsL(RCommandOptionList& aOptions)
	{
	_LIT(KOptWgId, "id");
	aOptions.AppendUintL(iWgIds, KOptWgId);

	_LIT(KOptWgPattern, "match");
	aOptions.AppendStringL(iWgNames, KOptWgPattern);

	_LIT(KOptTimeout, "timeout");
	aOptions.AppendIntL(iTimeout, KOptTimeout);

	_LIT(KOptVerbose, "verbose");
	aOptions.AppendBoolL(iVerbose, KOptVerbose);

	_LIT(KOptAll, "all");
	aOptions.AppendBoolL(iAll, KOptAll);

#ifdef EKA2
	_LIT(KOptForce, "force");
	aOptions.AppendBoolL(iForce, KOptForce);
#endif
	}

void CCmdShutApp::ArgumentsL(RCommandArgumentList&)
	{
	}


#ifdef EXE_BUILD
EXE_BOILER_PLATE(CCmdShutApp)
#endif