/*

* 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:  

* Implementation of the RTestServ and RTestSession API's

*

*/

/**

 @file TestClient.cpp

*/

#include <testexecuteclient.h>

#include <testexecutestepbase.h>

TVersion RTestServ::Version() const

	{

	return(TVersion(KTestExecuteMajorVersionNumber,KTestExecuteMinorVersionNumber,KTestExecuteBuildVersionNumber));

	}

EXPORT_C TInt RTestServ::Connect(const TDesC& aServerName, TBool aDebugMode)

/**

 * @param aServerName - Human readable name of the test server

 * @param aDebugMode - Set to true for just in time debugging

 * @return int - Standard error codes

 * Secure version of the API call. Expects the server binary to be

 * ServerXXX.exe

 */

	{

	if(aServerName.Length() > iServerName.MaxLength())

		return KErrTooBig;

	iServerName = aServerName;

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

	// 4 message slots

	TInt err = CreateSession(aServerName,Version(),-1);

	if(err == KErrNotFound || err == KErrServerTerminated)

		{

		// Server not running

		// Construct the server binary name

		TBuf<KMaxTestExecuteNameLength> serverFile;

		RProcess server;

		_LIT(KEmpty,"");

		_LIT(KExe,".exe");

		serverFile.Copy(aServerName);

		serverFile.Append(KExe);

		err = server.Create(serverFile,KEmpty);

		if(err != KErrNone)

			return err;

		// Synchronise with the server

		TRequestStatus reqStatus;

		server.Rendezvous(reqStatus);

		// Set just in time debugging for the process

		if(aDebugMode)

			server.SetJustInTime(ETrue);

		else

			server.SetJustInTime(EFalse);

		// Start the test harness

		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(aServerName,Version(),-1);

		}

	return err;

	}

EXPORT_C const TDesC& RTestServ::ServerName() const

/**

 * @return - The human readable server name

 */

	{

	return iServerName;

	}

///////

EXPORT_C TInt RTestSession::Open(RTestServ& aServ, const TDesC& aStepName, TBool aSharedData)

/**

 * @param aServ - Reference to the root server session

 * @param aStepName - Reference to the name of the test step owned by the server

 * @return Standard error codes

 * Secure and Non-secure variants

 * Synchronously open a server test step session

 */

	{

	if(aStepName.Length() > KMaxTestStepNameLength)

		return KErrTooBig;

	TIpcArgs args;

	args.Set(0,&aStepName);

	args.Set(1,aSharedData);

	return CreateSubSession(aServ,EOpenTestStep,args);

	}

EXPORT_C TInt RTestSession::Open(RTestServ& aServ, TBool aSharedData)

/**

 * @param aServ - Reference to the root server session

 * @param aStepName - Reference to the name of the test step owned by the server

 * @return Standard error codes

 * Secure and Non-secure variants

 * Synchronously open a server test step session

 */

	{

	TIpcArgs args;

	args.Set(1,aSharedData);

	return CreateSubSession(aServ,EOpenTestBlock,args);

	}

EXPORT_C void RTestSession::RunTestStep(const TDesC& aCommandString, TDes& aPanicString, TRequestStatus& aStatus)

/**

 *

 * @param aCommandString - The arguments to the RUN_TEST_STEP command

 * @return aPanicString  - If the test step panics, this member is set up with the panic string

 * @param aStatus - For completion to the caller

 * Secure and Non-secure variants

 * Send the RUN_TEST_STEP arguments to the test server

 */

	{

	if(aCommandString.Length() > KMaxTestExecuteCommandLength)

		{

		TRequestStatus* status = &aStatus;

		User::RequestComplete(status,KErrTooBig);

		}

	TIpcArgs args;

	args.Set(0,&aCommandString);

	args.Set(1,&aPanicString);

	SendReceive(ERunTestStep,args,aStatus);

	}

EXPORT_C void RTestSession::RunTestBlock(const TDesC& aCommandString, TDes& aPanicString, TDes8& aBlockArray, TRequestStatus& aStatus)

/**

 *

 * @param aCommandString - The arguments to the test block command

 * @return aPanicString  - If the test step panics, this member is set up with the panic string

 * @param aStatus - For completion to the caller

 * Secure and Non-secure variants

 * Send the RUN_TEST_STEP arguments to the test server

 */

	{

	if(aCommandString.Length() > KMaxTestExecuteCommandLength)

		{

		TRequestStatus* status = &aStatus;

		User::RequestComplete(status,KErrTooBig);

		}

	TIpcArgs args;

	args.Set(0,&aCommandString);

	args.Set(1,&aPanicString);

	args.Set(2,&aBlockArray);

	SendReceive(ERunTestBlock,args,aStatus);

	}

EXPORT_C TInt RTestSession::AbortTestStep()

/**

 *

 * @return - Standard Epoc error codes 

 * Secure and Non-secure variants

 * Synchronous abort of the the test step

 */

	{

	return SendReceive(EAbortTestStep);

	}

EXPORT_C void RTestSession::Close()

	{

	CloseSubSession(ECloseTestStep);

	}