// 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 <s32mem.h>

#include "uloggersession.h"

#include "uloggershared.h"

#include "uloggerclient.h"

#include "uloggershared.h"

#include "uloggertools.h"

namespace Ulogger {

CULoggerSession* CULoggerSession::NewL(RThread& aClient, CULoggerServer& aServer)

	{

	CULoggerSession* self = CULoggerSession::NewLC(aClient, aServer);

	CleanupStack::Pop(); //self

	return self;

	}//</NewL>

CULoggerSession* CULoggerSession::NewLC(RThread& aClient, CULoggerServer& aServer)

	{

	CULoggerSession* self = new(ELeave) CULoggerSession( aClient, aServer );

	CleanupStack::PushL( self );

	self->ConstructL();

	return self;

	}//</NewLC>

void CULoggerSession::ConstructL()

	{

	iServer.IncrementSessions();

	}//</ConstructL>

CULoggerSession::CULoggerSession(RThread& aClient, CULoggerServer& aServer)

: CSession2(),

iServer( aServer ),

iClient( aClient )

	{

	}//</constructor>

CULoggerSession::~CULoggerSession()

{

	iServer.DecrementSessions();

}//</destructor>

/** Process message from 'client' (actually another instance of ourselves)

*/

void CULoggerSession::ServiceL(const RMessage2& aMessage)

	{

	TInt error = KErrNone;

	switch(aMessage.Function())

		{

		case ERunAsService:

			{

			iServer.RunAsService(ETrue);

			error = KErrNone;

			}

		break;

		case EDontRunAsService:

			{

			iServer.RunAsService(EFalse);

			error = KErrNone;

			}

		break;

		case EStart:

			{

			//Starts the BTrace

			//r= iServer.Start();

			if(!iServer.ServerState())

				error = iServer.RestartOutputting();

			else

				error = KErrInUse;

			}

		break;

		case EStop:

			{		

			//Stops the BTrace

			error = iServer.Stop();

			//iServer.UnconfigureCurrentChannel();

			}

		break;

		case ERestart:

			{

			error = iServer.RestartOutputting();

			}

		break;

		case ESetPrimaryFilter:

			{

			//Set filter 1

			RArray<TUint32> filterArray;

			TInt elementsCount = aMessage.Int1();

			if(elementsCount > 0)

				{

				TPtr8 readPtr(desData->Des());

				aMessage.ReadL(0, readPtr);

				CArrayFixFlat<TUint8> *array = new (ELeave) CArrayFixFlat<TUint8>(1);

				CleanupStack::PushL(array);

				InternalizeFromBufL(readPtr, *array, tmp);

					{

					}

				error = iServer.SetActiveFilterL(filterArray, EPrimaryFilter);

				}

			else

				error = KErrArgument;

			}

			break;

		case ERemovePrimaryFilter:

			{

			//remove primaryfilters

			TInt elementsCount = aMessage.Int1();

			if(elementsCount > 0)

				{

				RArray<TUint32> filterArray;

				TPtr8 readPtr(desData->Des());

				aMessage.ReadL(0, readPtr);

				CArrayFixFlat<TUint8> *array = new (ELeave) CArrayFixFlat<TUint8>(1);

				CleanupStack::PushL(array);

				InternalizeFromBufL(readPtr, *array, tmp);

					{

					}

				error = iServer.RemoveActiveFilter(filterArray,EPrimaryFilter);

				}

			else

				error = KErrArgument;

			}

			break;

		case EGetPrimaryFilters:

			{

			//Get primaryfilters

			RArray<TUint32> listBuffer;

			error = iServer.GetActiveFilters(listBuffer,EPrimaryFilter);

			CArrayFixFlat<TUint8> *fixArray = new (ELeave)CArrayFixFlat<TUint8>(1);

			CleanupStack::PushL(fixArray);

			for(TInt i=0; i<listBuffer.Count(); ++i)

				fixArray->AppendL((TUint8)listBuffer[i]);

			HBufC8* desData = ExternalizeToBufL((const CArrayFix<TUint8>&) *fixArray, sizeof(TUint8));

			CleanupStack::PopAndDestroy(); //fixArray

			aMessage.Write(0,*desData);

			delete desData;

			desData = NULL;

			listBuffer.Close();

			}

			break;

		case ESetSecondaryFilter:

			{

			//Set filter 2

			TInt elementsCount = aMessage.Int1();

			if(elementsCount > 0)

				{

				HBufC8* desData = HBufC8::NewLC(elementsCount*sizeof(TUint32));

				TPtr8 readPtr(desData->Des());

				aMessage.ReadL(0, readPtr);

				RArray<TUint32> filterArray;

				TUint32 tmp=1;

				InternalizeFromBufL(readPtr, filterArray, tmp);

				error = iServer.SetActiveFilterL(filterArray,ESecondaryFilter);

				CleanupStack::PopAndDestroy(); //desData

				filterArray.Close();

				}

			else

				error = KErrArgument;

			}

			break;

		case ERemoveSecondaryFilter:

			{

			//remove secondaryfilters

			TInt elementsCount = aMessage.Int1();

			if(elementsCount > 0)

				{

				HBufC8* desData = HBufC8::NewLC(elementsCount*sizeof(TUint32));

				TPtr8 readPtr(desData->Des());

				aMessage.ReadL(0, readPtr);

				RArray<TUint32> filterArray;

				TUint32 tmp=1;

				InternalizeFromBufL(readPtr, filterArray, tmp);

				error = iServer.RemoveActiveFilter(filterArray,ESecondaryFilter);

				CleanupStack::PopAndDestroy(); //desData

				filterArray.Close();

				}

			else

				error = KErrArgument;

			}

			break;

		case EGetSecondaryFilters:

			{		

			//Get secondary filters

			RArray<TUint32> listBuffer;

			error=iServer.GetActiveFilters(listBuffer,ESecondaryFilter);

			HBufC8* desData = ExternalizeToBufL(listBuffer, sizeof(TUint32));

			TPtr8 readPtr2(desData->Des());

			aMessage.Write(0,readPtr2);

			delete desData;

			desData = NULL;

			listBuffer.Close();

			}

		break;

		case EEnableSecondaryFiltering:

			{

			error = iServer.SetSecondaryFiltering(KEnable);

			}

			break;

		case EDisableSecondaryFiltering:

			{

			error = iServer.SetSecondaryFiltering(KDisable);

			}

			break;

		case EGetSecondaryFiltering:

			{

			TBool enabled = EFalse;

			iServer.GetSecondaryFiltering(enabled);

			SendIntegerL(aMessage, (TInt)enabled);

			}

			break;

		case ESetActivePlugin:

			{

			//Set the active plugin

			HBufC8* pluginName = NULL;

			TInt dataSize1 = aMessage.GetDesLength(0);

			if(dataSize1 > 0)

				{

				pluginName = HBufC8::NewLC( dataSize1 );

				TPtr8 namePtr(pluginName->Des());

				aMessage.ReadL(0,namePtr);

				error = iServer.SetActiveOutputPlugin(pluginName->Des());

				CleanupStack::PopAndDestroy(1);

				}

			else

				error = KErrArgument;

			}

			break;

		case ESetActiveInputPlugin:

			{

			//Set the active control plugin

			HBufC8* pluginName = NULL;

			TInt dataSize1 = aMessage.GetDesLength(0);

			if(dataSize1 > 0)

				{

				pluginName = HBufC8::NewLC( dataSize1 );

				TPtr8 namePtr(pluginName->Des());

				aMessage.ReadL(0,namePtr);

				error = iServer.SetActiveInputPlugin(pluginName->Des());

				CleanupStack::PopAndDestroy(1); //pluginName

				}

			else

				error = KErrArgument;

			}

		break;

		case ESetPluginSettings:

			{

			//Set the channel settings

			HBufC8* pluginName = NULL;

			HBufC8* setting = NULL;

			RArray<TPtrC8> value;

			TInt dataSize1 = aMessage.GetDesLength(0);

			TInt dataSize2 = aMessage.GetDesLength(1);

			CArrayPtrFlat<HBufC8> *ptrArray = new (ELeave) CArrayPtrFlat<HBufC8>(1);

			CleanupStack::PushL(ptrArray);

			if(dataSize1>0 && dataSize2>0)

				{

				pluginName = HBufC8::NewLC( dataSize1 );

				setting = HBufC8::NewLC( dataSize2 );

				TPtr8 data1Ptr(pluginName->Des());		

				TPtr8 data2Ptr(setting->Des());	

				aMessage.ReadL(0,data1Ptr);	

				aMessage.ReadL(1,data2Ptr);	

				_LIT8(KSeparator,";");

				TInt pos = KErrNone;

				while(pos != KErrNotFound)

					{

					pos = setting->Des().Find(KSeparator);

					if(pos > 0)	

						{

						TPtrC8 ptrVal(setting->Des().Left(pos));

						HBufC8 *bufDes = HBufC8::NewLC(ptrVal.Length()+8);

						bufDes->Des().Copy(ptrVal);

						CleanupStack::Pop(bufDes);

						ptrArray->AppendL(bufDes);

						setting->Des().Delete(0,pos+1);

						}

					}

				for(TInt i=0; i<ptrArray->Count(); ++i)

					value.AppendL(*(ptrArray->At(i)));

				error = iServer.SetPluginSettings(pluginName->Des(), value);

				CleanupStack::PopAndDestroy(2);

				}

			else

				error = KErrArgument;

			CleanupStack::PopAndDestroy(ptrArray);

			}

			break;

		case ERemovePluginSettings:

			{

			TInt dataSize = aMessage.GetDesLength(0);

			TBuf8<KMaxPluginName> pluginName;

			if (dataSize > 0)

				{

				aMessage.ReadL(0, pluginName);

				error = iServer.RemovePluginSettingsL(pluginName);

				}

			else

				error = KErrArgument;

			}

		break;

		case EGetPluginSettings:

			{

			TInt dataSize1 = aMessage.GetDesLength(0);

			TBuf8<128> mediaName;			

			if(dataSize1 > 0)

				{

				aMessage.ReadL(0, mediaName);

				RArray<TPtrC8> tmpArray;

				error = iServer.GetOptionsSettingsL(mediaName,tmpArray);

				//<rewrite array and add separator to each record>

				_LIT8(KFormatString,"%S;");//';' is a separator

				RArray<TPtrC8> tmpArray2;

				//count total_length + separators

				TInt length = 1;

				TInt i=0;

				for(i=0; i<tmpArray.Count(); ++i)

					length+=tmpArray[i].Length()+1;

				HBufC8* b = HBufC8::NewLC(length);

				for(i=0; i<tmpArray.Count(); ++i)

					b->Des().AppendFormat(KFormatString, &tmpArray[i]);

				//</rewrite array and add separator to each record>

				aMessage.Write(1,*b);

				CleanupStack::PopAndDestroy(); // b

				}

			else

				error = KErrArgument;

			}

			break;

		case EGetInstalledPlugins:

			{

			//Get the installed plugins	

				RArray<TPtrC8> tmpArray;

				iServer.GetInstalledOutputPlugins(tmpArray);	

				//<rewrite array and add separator to each record>

				_LIT8(KFormatString,"%S;");//';' is a separator

				RArray<TPtrC8> tmpArray2;

				//count total_length + separators

				TInt length = 1;

				TInt i=0;

				for(i=0; i<tmpArray.Count(); ++i)

					length+=tmpArray[i].Length()+1;

				HBufC8* b = HBufC8::NewLC(length);

				for(i=0; i<tmpArray.Count(); ++i)

					b->Des().AppendFormat(KFormatString, &tmpArray[i]);

				//</rewrite array and add separator to each record>

				aMessage.Write(0,*b);

				CleanupStack::PopAndDestroy(); // b	

			}

		break;

		case EGetInputPlugins:

			{

			//Get the installed plugins	

			RArray<TPtrC8> tmpArray;

			error = iServer.GetInstalledInputPluginsL(tmpArray);

			if(!error)

				{

			//<rewrite array and add separator to each record>

			_LIT8(KFormatString,"%S;");//';' is a separator

			//count total_length + separators

			TInt length = 1;

			TInt i=0;

			for(i=0; i<tmpArray.Count(); ++i)

				length+=tmpArray[i].Length()+1;

			HBufC8* b = HBufC8::NewLC(length);

			for(i=0; i<tmpArray.Count(); ++i)

				b->Des().AppendFormat(KFormatString, &tmpArray[i]);

			//</rewrite array and add separator to each record>

			aMessage.Write(0,*b);

			CleanupStack::PopAndDestroy(); // b	

				}

			}

			break;

		case EGetActivePlugin:

			{

			//Reads the active plugin

			RArray<TPtrC8> tmpArray;

			error = iServer.GetActiveOutputPlugin(tmpArray);

			if(!error)

				{

				//<rewrite array and add separator to each record>

				_LIT8(KFormatString,"%S;");//';' is a separator

				RArray<TPtrC8> tmpArray2;

				//count total_length + separators

				TInt length = 1;

				TInt i=0;

				for(i=0; i<tmpArray.Count(); ++i)

					length+=tmpArray[i].Length()+1;

				HBufC8* b = HBufC8::NewLC(length);

				for(i=0; i<tmpArray.Count(); ++i)

					b->Des().AppendFormat(KFormatString, &tmpArray[i]);

				//</rewrite array and add separator to each record>

				aMessage.Write(0,*b);

				CleanupStack::PopAndDestroy(); // b

				}

			}

			break;

		case EGetActiveInputPlugin:

			{

			RArray<TPtrC8> tmpArray;

			error = iServer.GetActiveInputPlugin(tmpArray);

			if(!error)

				{

				if(tmpArray.Count() == 0)

					error = KErrNotFound;

				//<rewrite array and add separator to each record>

				_LIT8(KFormatString,"%S;");//';' is a separator

				RArray<TPtrC8> tmpArray2;

				//count total_length + separators

				TInt length = 1;

				TInt i=0;

				for(i=0; i<tmpArray.Count(); ++i)

					length+=tmpArray[i].Length()+1;