/*

* Copyright (c) 2005-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:  

* Source file for the client api

*

*/

/**

 @file Client.cpp

*/

#include <testexecutepipslog.h>

const TInt KMaxFilename = 50;

// EKA1 requires DLL entry point

EXPORT_C TInt RTestExecutePIPSLogServ::Connect()

/**

 * @return int - Standard error codes

 * EKA2 all variants and EKA1 target.

 * Server is an exe

 */

	{

	TVersion version(KTestExecuteLoggerMajorVersion,KTestExecuteLoggerMinorVersion,KTestExecuteLoggerBuildVersion);

	// Assume the server is already running and attempt to create a session

	TInt err = CreateSession(KTestExecutePIPSLogServerName,version,8);

	if(err == KErrNotFound)

		{

		// Server not running

		// Construct the server binary name

		_LIT(KEmpty,"");

		// EKA2 is simple

		// No path required

		TBuf<32> serverFile;

		serverFile.Copy(KTestExecutePIPSLogServerName);

		_LIT(KExe,".exe");

		serverFile.Append(KExe);

		RProcess server;

		err = server.Create(serverFile,KEmpty);

		if(err != KErrNone)

			return err;

		// Synchronise with the server

		TRequestStatus reqStatus;

		server.Rendezvous(reqStatus);

		server.Resume();

		// Server will call the reciprocal static synchronise call

		User::WaitForRequest(reqStatus);

		server.Close();

		if(reqStatus.Int() != KErrNone)

			return reqStatus.Int();

		// Create the root server session

		err = CreateSession(KTestExecutePIPSLogServerName,version,8);

		}

#ifdef TEF_SHARE_AUTO

	// Makes the session shared among all threads in the process

  	if( err == KErrNone )

  		{

  		err = ShareAuto();

  		}

#endif

	return err;

	}

EXPORT_C TInt RTestExecutePIPSLogServ::CreateLog(const TDesC& aLogFilePath)

/**

 * @param aLogFilePath - Full path and filename of the log file

 * @param aMode - Overwrite or Append

 * Makes synchronous call to the log server to create a log session

 */

	{

	iLogFilename = aLogFilePath; 

	return KErrNone;

	}

EXPORT_C void RTestExecutePIPSLogServ::LogExtra(const TText8* aFile, TInt aLine, TInt aSeverity,TRefByValue<const TDesC> aFmt,...)

/**

 * @param aFile - Source file name

 * @param aLine - Source file line number

 * @param aSeverity - ERR, WARN, INFO

 * @param aFmt - UNICODE format string

 */

	{

	if (aSeverity>iLogLevel) 

		{

		return;

		}

	// Set up a Variable argument list and call private method

	VA_LIST aList;

	VA_START(aList, aFmt);

	LogExtra(aFile, aLine, aSeverity, aFmt, aList);

	VA_END(aList); 

	}

EXPORT_C void RTestExecutePIPSLogServ::WriteFormat(TRefByValue<const TDesC> aFmt,...)

/**

 * @param aFmt - UNICODE format string

 */

	{

	// Set up a Variable argument list and call private method

	VA_LIST aList;

	VA_START(aList, aFmt);

	WriteFormat(aFmt, aList);

	VA_END(aList); 

	}

EXPORT_C void RTestExecutePIPSLogServ::Write(const TDesC& aLogBuffer)

/**

 * @param aLogBuffer - Pre-formatted UNICODE buffer

 */

	{

	// Just call private method

	// Ignore errors. Could put in ASSERT

	TRAP_IGNORE(WriteL(aLogBuffer));

	}

EXPORT_C void RTestExecutePIPSLogServ::WriteFormat(TRefByValue<const TDesC8> aFmt,...)

/**

 * @param aFmt - Narrow format string

 */

	{

	// Set up a Variable argument list and call private method

	VA_LIST aList;

	VA_START(aList, aFmt);

	WriteFormat(aFmt, aList);

	VA_END(aList); 

	}

EXPORT_C void RTestExecutePIPSLogServ::Write(const TDesC8& aLogBuffer)

/**

 * @param aLogBuffer - Pre-formatted Narrow buffer

 */

	{

	// Create a larger buffer for adding terminators

	// Could do more formatting but just allow for CRLF plus time stamp for the time being

	HBufC8* buffer = HBufC8::New(aLogBuffer.Length()+20);

	if(buffer)

		{

		TPtr8 ptr(buffer->Des());

		AddTime(ptr);

		ptr.Append(aLogBuffer);

		// Ignore error for the time being. Could do an ASSERT

		TRAP_IGNORE(WriteL(ptr));

		delete buffer;

		}

	}

void RTestExecutePIPSLogServ::AddTime(TDes8& aLogBuffer)

/**

 * @param aLogBuffer - the line to be decorated

 * decorate the output with current time

 */

	{

	TTime now;

	now.UniversalTime();

	TDateTime dateTime = now.DateTime();

	_LIT8(KFormat,"%02d:%02d:%02d:%03d ");

	// add the current time 

	aLogBuffer.AppendFormat(KFormat,dateTime.Hour(),dateTime.Minute(),dateTime.Second(),(dateTime.MicroSecond()/1000)); 

	}

EXPORT_C void RTestExecutePIPSLogServ::LogExtra(const TText8* aFile, TInt aLine, TInt aSeverity,TRefByValue<const TDesC> aFmt, VA_LIST aList)

/**

 * @param aFile - Source file name

 * @param aLine - Source file line number

 * @param aSeverity - ERR, WARN, INFO

 * @param aFmt - UNICODE format string

 * @param aList - Variable argument list

 *

 * Format a log output line

 */

	{

	if (aSeverity>iLogLevel) 

		{

		return;

		}

	// Create a filename string

	TBuf16<KMaxFilename> fileName;

	GetCPPModuleName(fileName, aFile);

	// Create a buffer for formatting

	HBufC* buffer = HBufC::New(KMaxTestExecuteLogLineLength*2);

	if (buffer)

		{

		TPtr ptr(buffer->Des());

		_LIT(KErr,"ERROR - ");

		_LIT(KHigh,"HIGH - ");

		_LIT(KWarn,"WARN - ");

		_LIT(KMedium,"MEDIUM - ");

		_LIT(KInfo,"INFO - ");

		_LIT(KLow,"LOW - ");

		_LIT(KFormat," %d %S %d ");

		if(aSeverity == ESevrErr)

			ptr.Append(KErr);

		else if(aSeverity == ESevrHigh)

			ptr.Append(KHigh);

		else if(aSeverity == ESevrWarn)

			ptr.Append(KWarn);

		else if(aSeverity == ESevrMedium)

			ptr.Append(KMedium);

		else if (aSeverity == ESevrInfo)

			ptr.Append(KInfo);

		else if(aSeverity == ESevrLow)

			ptr.Append(KLow);

		else //if(aSeverity == ESevrAll)

			ptr.Append(KInfo);

		// Add the thread id

		ptr.AppendFormat(KFormat,(TInt)RThread().Id(),&fileName, aLine);

		TTEFDes16OverflowPIPS des16OverflowObject;

		ptr.AppendFormatList(aFmt, aList, &des16OverflowObject);

		TRAP_IGNORE(WriteL(ptr));

		delete buffer;

		}

	}

EXPORT_C void RTestExecutePIPSLogServ::WriteFormat(TRefByValue<const TDesC> aFmt, VA_LIST aList)

/**

 * @param aFmt - UNICODE format string

 * @param aList - Variable argument list

 */

	{

	HBufC* buffer = HBufC::New(KMaxTestExecuteLogLineLength*2);

	if (buffer)

		{

		TPtr ptr(buffer->Des());

		TTEFDes16OverflowPIPS des16OverflowObject;

		ptr.AppendFormatList(aFmt, aList, &des16OverflowObject);

		TRAP_IGNORE(WriteL(ptr));

		delete buffer;

		}

	}

EXPORT_C void RTestExecutePIPSLogServ::WriteFormat(TRefByValue<const TDesC8> aFmt, VA_LIST aList)

/**

 * @param aFmt - UNICODE format string

 * @param aList - Variable argument list

 */

	{

	HBufC8* buffer = HBufC8::New(KMaxTestExecuteLogLineLength*2);

	if (buffer)

		{

		TPtr8 ptr(buffer->Des());

		AddTime(ptr);

		TTEFDes8OverflowPIPS des8OverflowObject;

		ptr.AppendFormatList(aFmt, aList, &des8OverflowObject);

		TRAP_IGNORE(WriteL(ptr));

		delete buffer;

		}

	}

void RTestExecutePIPSLogServ::WriteL(const TDesC& aLogBuffer)

/**

 * @param aLogBuffer - UNICODE buffer

 */

	{

	HBufC8* buffer = HBufC8::NewLC(aLogBuffer.Length()+20);

	TPtr8 ptr(buffer->Des());

	AddTime(ptr);

	ptr.Append(aLogBuffer);

	WriteL(ptr);

	CleanupStack::PopAndDestroy(buffer);

	}

void RTestExecutePIPSLogServ::WriteL(TDes8& aLogBuffer)

/**

 * @param aLogBuffer - pre-formatted narrow buffer

 * 

 * Synchronous write to the server

 */

	{

	//try to make a buf out of pipeName...

	HBufC8* bufferFile = HBufC8::NewL(iLogFilename.Length());

	TPtr8 ptrFile(bufferFile->Des());

	ptrFile.Append(iLogFilename);

	_LIT8(KEnd,"\r\n");

	TInt retValue = 0 ; 

	// Check to see if there's room to add CRLF

	if(aLogBuffer.Length()+2 > aLogBuffer.MaxLength())

		{

		HBufC8* buffer = HBufC8::NewLC(aLogBuffer.Length()+2);

		TPtr8 ptr(buffer->Des());

		ptr.Copy(aLogBuffer);

		ptr.Append(KEnd);

		TIpcArgs args;

		args.Set(0,&ptr);

		args.Set(1,ptr.Length());

		args.Set(2,&ptrFile);

		args.Set(3,iLogFilename.Length());

		//User::LeaveIfError(SendReceive(EWriteLog,args));

		retValue = SendReceive(EWriteLog,args) ; 

		CleanupStack::PopAndDestroy(buffer);

		}

	else

		{

		aLogBuffer.Append(KEnd);

		TIpcArgs args;

		args.Set(0,&aLogBuffer);

		args.Set(1,aLogBuffer.Length());

		args.Set(2,&ptrFile);

		args.Set(3,iLogFilename.Length());

		//User::LeaveIfError(SendReceive(EWriteLog,args));

		retValue = SendReceive(EWriteLog,args) ; 

		}

	delete bufferFile;

	User::LeaveIfError(retValue) ; 

	}

void RTestExecutePIPSLogServ::GetCPPModuleName(TDes& aModuleName, const TText8* aCPPFileName)

/**

 * @return aModuleName - Filename in descriptor

 * @param aCppFileName - Filename

 * Borrowed from scheduletest

 */

	{

	TPtrC8 fileNamePtrC8(aCPPFileName);

	// We do our own filename munging here; TParse can't help us since that's

	// expressly for EPOC filepaths and here we've got whatever the build system is

	// At present Win32 and Unix directory delimiters are supported

	TInt lastDelimiter = Max(fileNamePtrC8.LocateReverse('\\'), fileNamePtrC8.LocateReverse('/'));

	if(lastDelimiter >= 0 && lastDelimiter < fileNamePtrC8.Length() - 1)

		{

		// Found a delimiter which isn't trailing; update the ptr to start at the next char

		TInt fileNameLen = Min(KMaxFilename, fileNamePtrC8.Length() - (lastDelimiter + 1));

		fileNamePtrC8.Set(aCPPFileName + lastDelimiter + 1, fileNameLen);

		}

	else

		{

		// Didn't find a delimiter; take as much of the right-end of the name as fits

		fileNamePtrC8.Set(aCPPFileName + Max(0, fileNamePtrC8.Length() - KMaxFilename), Min(fileNamePtrC8.Length(), KMaxFilename));

		}

	aModuleName.Copy(fileNamePtrC8);

	}

EXPORT_C void RTestExecutePIPSLogServ::SetLogLevel(TLogSeverity aSeverity)

/**

 * @return void

 * @param aSeverity - severity of the logs

 */

	{

	iLogLevel = aSeverity;

	}