// pubsub.cpp

// 

// Copyright (c) 2008 - 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 <fshell/common.mmh>

#include <fshell/memoryaccesscmd.h>

#ifdef FSHELL_TRACE_SUPPORT

#include <fshell/extrabtrace.h>

#include <fshell/btrace_parser.h>

#endif

#include <fshell/ltkutils.h>

#include <fshell/qr3dll.h>

using namespace IoUtils;

#ifdef FSHELL_TRACE_SUPPORT

class CCmdPubsub : public CMemoryAccessCommandBase, public MBtracePubSubObserver

	{

private: // From MBtracePubSubObserver

	void HandlePropertyChangedL(const TBtraceTickCount& aTickCount, TUint aCategory, TUint aKey, TInt aNewValue);

	void HandlePropertyChangedL(const TBtraceTickCount& aTickCount, TUint aCategory, TUint aKey, const TDesC8& aNewValue);

#else

class CCmdPubsub : public CMemoryAccessCommandBase

	{

#endif

public:

	static CCommandBase* NewLC();

	~CCmdPubsub();

private:

	CCmdPubsub();

	void PrintKey(TUint aCategory, TUint aKey, TBool aFull=EFalse);

	template <class KEYTYPE>

	void SetKeyL(const KEYTYPE& aVal);

	static TInt PropertyChanged(TAny* aSelf);

	void GetAllL(TBool aNotify);

	TBool IsExcluded(TUint aCat, TUint aKey) const;

private: // From CCommandBase.

	virtual const TDesC& Name() const;

	virtual void DoRunL();

	virtual void ArgumentsL(RCommandArgumentList& aArguments);

	virtual void OptionsL(RCommandOptionList& aOptions);

	void DoCancel();

	void RunL();

private:

	// Arguments

	enum TCmd

		{

		EGet, ESet, EDefine, ENotify

		};

	TCmd iCommand;

	TUid iCategory;

	TUint iKey;

	// Options

	HBufC* iStringVal;

	TInt iIntVal;

	TBool iForce;

	TBool iNotify;

	TBool iDefine;

	// Other assorted stuff

#ifdef FSHELL_MEMORY_ACCESS_SUPPORT

	TPropNotifyResult iNotifyResult;

#endif

#ifdef FSHELL_TRACE_SUPPORT

	CBtraceReader* iReader;

	CBtracePubSub* iPubSub;

#endif

	TBool iUseBtrace;

	CPropertyManager* iPropertyManager;

	RBuf8 iValDescription;

	};

CCommandBase* CCmdPubsub::NewLC()

	{

	CCmdPubsub* self = new(ELeave) CCmdPubsub();

	CleanupStack::PushL(self);

	self->BaseConstructL();

	return self;

	}

CCmdPubsub::~CCmdPubsub()

	{

	Cancel();

	delete iStringVal;

#ifdef FSHELL_TRACE_SUPPORT

	delete iPubSub;

	delete iReader;

#endif

	delete iPropertyManager;

	iValDescription.Close();

	}

CCmdPubsub::CCmdPubsub()

	: CMemoryAccessCommandBase(EManualComplete)

	{

	}

const TDesC& CCmdPubsub::Name() const

	{

	_LIT(KName, "pubsub");	

	return KName;

	}

void CCmdPubsub::DoRunL()

	{

#if defined (FSHELL_MEMORY_ACCESS_SUPPORT)

	if (iForce || iUseBtrace)

		{

		// In order to implement the --force option, we talk to the memaccess device driver, which uses an RPropertyRef

		// that isn't subject to security checks

		LoadMemoryAccessL();

		}

#endif

	iValDescription.CreateL(RProperty::KMaxLargePropertySize);

	/*

	if (iDelete)

		{

		if (!iArgList->IsPresent(1))

			{

			// Delete all not supported for pubsub

			PrintError(KErrArgument, _L("You must specify a key for the delete option"));

			User::Leave(KErrArgument);

			}

		else

			{

#ifdef FSHELL_MEMORY_ACCESS_SUPPORT

			if (iForce)

				{

				err = iMemAccess.DeleteProperty(iCategory, iKey);

				}

			else

#endif

				{

				err = RProperty::Delete(iCategory, iKey);

				}

			}

		if (err == KErrPermissionDenied)

			{

			PrintError(err, _L("Delete failed, retry with --force"));

			}

		User::LeaveIfError(err);

		}

	*/

	if (iCommand == EDefine) iDefine = ETrue;

	if (iCommand == ENotify) iNotify = ETrue;

	if ((iCommand == ESet) || iDefine)

		{

		if (iOptions.IsPresent(&iIntVal))

			{

			// Set int

			SetKeyL(iIntVal);

			}

		else if (iOptions.IsPresent(&iStringVal))

			{

			// Set string

			TPtrC8 data((TUint8*)iStringVal->Ptr(), iStringVal->Size());

			SetKeyL(data);

			}

		else

			{

			LeaveIfErr(KErrArgument, _L("set/define command requires --int or --string arguments"));

			}

		}

	else if ((iCommand == EGet) || iNotify)

		{

		// Get

		if (!iArguments.IsPresent(1))

			LeaveIfErr(KErrArgument, _L("get command requires key and category"));

		PrintKey(iCategory.iUid, iKey, ETrue);

		if (iNotify)

			{

#if defined (FSHELL_MEMORY_ACCESS_SUPPORT)

			if (iForce || iUseBtrace)

				{

				//TPckgBuf<SKeyPair> key;

				//key().iCat = iCategory.iUid;

				//key().iKey = iKey;

				//LeaveIfErr(iMemAccess.SetupMassPropertyNotify(key), _L("Couldn't set up notification"));

				LeaveIfErr(iMemAccess.SubscribeToProperty(iCategory, iKey, iUseBtrace), _L("Couldn't subscribe to property"));

#ifdef FSHELL_TRACE_SUPPORT

				if (iUseBtrace)

					{

					const TInt KFlushInterval = 1000000; // 1s

					const TInt KBtraceBufferSize = 1 * 1024 * 1024;

					TRAPL(iReader = CBtraceReader::NewL(CBtraceReader::EFlushOnBtraceThreshold, KBtraceBufferSize, KBtraceBufferSize / 2), _L("Couldn't create btrace reader"));

					TRAPL(iPubSub = CBtracePubSub::NewL(*iReader), _L("Couldn't create CBtracePubSub"));

					TBtraceTickCount now;

					now.SetToNow();

					iReader->Start(now, KFlushInterval);

					iPubSub->NotifyPropertyChangedL(*this);

					return; // iPubSub will take it from here

					}

				else

#endif

					{

					iMemAccess.NotifyPropertyChange(iNotifyResult, iStatus);

					SetActive();

					}

				}

			else

#endif

				{

				iPropertyManager = CPropertyManager::NewL(TCallBack(&PropertyChanged, this));

				iPropertyManager->ChangeProperty(iCategory.iUid, iKey);

				}

			return; // Don't complete

			}

		}

	Complete();

	}

template <class KEYTYPE>

void CCmdPubsub::SetKeyL(const KEYTYPE& aVal)

	{

	if (!iArguments.IsPresent(1))

		{

		LeaveIfErr(KErrArgument, _L("You must specify a key to set"));

		}

	TInt err = KErrNone;

#if defined (FSHELL_MEMORY_ACCESS_SUPPORT)

	if (iForce)

		{

		err = iMemAccess.SetProperty(iCategory, iKey, aVal);

		}

	else

#endif

		{

		err = RProperty::Set(iCategory, iKey, aVal);

		if (err == KErrArgument)

			{

			LeaveIfErr(err, _L("Key does not appear to be of the right type"));

			}

		}

#if defined (FSHELL_MEMORY_ACCESS_SUPPORT)

	if (err == KErrNotFound && iDefine)

		{

		if (!iForce)

			{

			LeaveIfErr(err, _L("Key does not exist, cannot define it unless --force is also specified"));

			}

		err = iMemAccess.SetProperty(iCategory, iKey, aVal, ETrue);

		}

#endif

	if (err)

		{

		LeaveIfErr(err, _L("Error setting key"));

		}

	}

void CCmdPubsub::PrintKey(TUint aCategory, TUint aKey, TBool aFull)

	{

	TUid cat = { aCategory };

	TInt valInt;

	RBuf8& valDes = iValDescription;

	valDes.Zero();

	enum TType { EUnknown, EInt, EDes };

	TType type = EUnknown;

	TInt reallen = 0;

	TInt err = KErrNotFound;

#if defined (FSHELL_MEMORY_ACCESS_SUPPORT)

	if (iForce)

		{

		err = iMemAccess.GetProperty(cat, aKey, valInt);

		if (err == KErrNone)

			{

			type = EInt;

			}

		else

			{

			err = iMemAccess.GetProperty(cat, aKey, valDes, reallen);

			type = EDes;

			}

		}

	else

#endif

		{

		// Guess the value type

		// Int?

		if (type == EUnknown)

			{

			err = RProperty::Get(cat, aKey, valInt);

			if (err != KErrArgument)

				{

				type = EInt;

				}

			}

		if (type == EUnknown)

			{

			// Des?

			err = RProperty::Get(cat, aKey, valDes);

			if (err != KErrArgument)

				{

				type = EDes;

				}

			}

		}

	switch(err)

		{

		case KErrNotFound:

			PrintError(err, _L("Key 0x%x 0x%x not found"), aCategory, aKey);

			break;

		case KErrArgument:

			PrintError(err, _L("Unknown key type, not int, des8 or des16"));

			break;

		case KErrPermissionDenied:

			PrintError(err, _L("Permission denied on 0x%x 0x%x, retry with --force"), aCategory, aKey);

			break;

		case KErrNone:

			// do nothing

			break;

		default:

			PrintError(err, _L("Unrecognised error returned from RProperty"));

			break;

		}

	if (err == KErrNone)

		{

		switch (type)

			{

			case EInt:

				Printf(_L("0x%08x 0x%08x TInt: %d (0x%x)\r\n"), aCategory, aKey, valInt, valInt);

				break;

			case EDes:

				{

				TPtrC8 des(valDes);

				if (!aFull) des.Set(valDes.Left(32)); // Don't print the whole thing, only 2 lines max

				Printf(_L("0x%08x 0x%08x TDesC8 hex dump:\r\n"), aCategory, aKey);

				LtkUtils::HexDumpToOutput(des, Stdout());

				if (des.Length() < valDes.Length()) Write(_L("...\r\n"));

				break;

				}

			default:

				break;

			}

		}

	}

void CCmdPubsub::ArgumentsL(RCommandArgumentList& aArguments)

	{

	aArguments.AppendEnumL((TInt&)iCommand, _L("command"));

	aArguments.AppendUintL((TUint&)iCategory.iUid, _L("category"));

	aArguments.AppendUintL(iKey, _L("key"));

	}

void CCmdPubsub::OptionsL(RCommandOptionList& aOptions)

	{

	aOptions.AppendIntL(iIntVal, _L("int"));

	aOptions.AppendStringL(iStringVal, _L("string"));

#ifdef FSHELL_MEMORY_ACCESS_SUPPORT

	aOptions.AppendBoolL(iForce, _L("force"));

#endif

#ifdef FSHELL_TRACE_SUPPORT

	aOptions.AppendBoolL(iUseBtrace, _L("btrace"));

#endif

	//aOptions.AppendStringL(iStringVal, '8', _L("set-data"), _L("Sets the specified key to this 8-bit value"));

	//aOptions.AppendBoolL(iDelete, 'l', _L("delete"), _L("Deletes the specified property"));

	}

TInt CCmdPubsub::PropertyChanged(TAny* aSelf)

	{

	CCmdPubsub* self = static_cast<CCmdPubsub*>(aSelf);

	self->PrintKey(self->iCategory.iUid, self->iKey);

	return 0;

	}

EXE_BOILER_PLATE(CCmdPubsub)

void CCmdPubsub::DoCancel()

	{

#if defined (FSHELL_MEMORY_ACCESS_SUPPORT)

	iMemAccess.CancelPropertyChange();

#endif

	}

void CCmdPubsub::RunL()

	{

#if defined (FSHELL_MEMORY_ACCESS_SUPPORT)

	TPropNotifyResult notifyResult = iNotifyResult;

	// rerequest asap

	if (iStatus == KErrNone)

		{

		iMemAccess.NotifyPropertyChange(iNotifyResult, iStatus);

		SetActive();

		}

	if (notifyResult.iMissedChanges)

		{

		PrintWarning(_L("Missed %d publish and subscribe notifications"), notifyResult.iMissedChanges);

		}

	if (notifyResult.iError)

		{

		Printf(_L("NotifyChange for 0x%08x 0x%x completed with error %d\r\n"), notifyResult.iCategory, notifyResult.iKey, notifyResult.iError);

		}

	else

		{

		//Printf(_L("P&S Key changed:\r\n"));

		PrintKey(notifyResult.iCategory, notifyResult.iKey);

		}

#endif

	}

#ifdef FSHELL_TRACE_SUPPORT

void CCmdPubsub::HandlePropertyChangedL(const TBtraceTickCount&, TUint aCategory, TUint aKey, TInt /*aNewValue*/)

	{

	PrintKey(aCategory, aKey);

	}

void CCmdPubsub::HandlePropertyChangedL(const TBtraceTickCount&, TUint aCategory, TUint aKey, const TDesC8& /*aNewValue*/)

	{

	PrintKey(aCategory, aKey);

	}

#endif