/*
* 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:  
* System Includes
*
*/



#include <stdio.h>
#include <stdlib.h>
#include <windows.h>
#include <assert.h>


/**********************************************************************************************
 *
 * Local Includes
 *
 *********************************************************************************************/
#include "CApplicationControlNull.h"
#include "../Core/UCCS_ErrorCodes.h"


/**********************************************************************************************
 *
 * Defines
 *
 *********************************************************************************************/
#define MAXTOKENS 64


/**********************************************************************************************
 *
 * Constructor
 *
 *********************************************************************************************/
CApplicationControlNull::CApplicationControlNull( MUccsControl *aCallBackService, IOutput *aOutput )
{
	assert( aCallBackService != NULL );
	assert( aOutput != NULL );
	iOutput = aOutput;
	iCallBackService = aCallBackService;
}

/**********************************************************************************************
 *
 * Destructor
 *
 *********************************************************************************************/
CApplicationControlNull::~CApplicationControlNull()
{
}


/**********************************************************************************************
 *
 * Run() -- the main routine called to run the serial listener.
 *
 *********************************************************************************************/
TCommandControlError CApplicationControlNull::Start( TRemoteControlTransport aTransport, char* aPortname, int *aErrorCode, int *aScriptError )
{
	int err, i;
	static int execution_count = 0;

	// check params
	assert( aScriptError != NULL );
	*aScriptError = 0;

	// check the parameters are valid
	if( aPortname == NULL ) {
		return EAC_INVALIDPORT;
	}

	// only run once -- then exit
	if( execution_count > 0 ) {
		return EAC_QUIT;
	}
	execution_count++;

	// parse the params
	err = ParseArgumentString( aPortname );
	if( err == -1 ) {
		return EAC_INVALIDPORT;
	}

	// start the use-case
	err = iCallBackService->StartUsecase( iArgs.iUsecaseID );
	if( err != UCCS_OK ) {
		*aErrorCode = err;
		return EAC_STARTUSECASEFAILED;
	}

	// run rendezvous the set number of times - wait for user input before each one 
	// if the interactive flag is set. The last rendezvous is never interactive.
	for( i = 0; i < iArgs.iRendezvousCount; i++ ) {
		if( (iArgs.iInteractiveFlag != 0) && (i != (iArgs.iRendezvousCount-1)) ) {
			fprintf( stdout, "Press enter to rendezvous.\n" );
			getchar();
		}
		err = iCallBackService->Rendezvous( iArgs.iUsecaseID );
		if( err != UCCS_OK ) {
			*aErrorCode = err;
			return EAC_RENDEZVOUSFAILED;
		}
	}

	// put in a wait so that the other thread has time to finish up
	Sleep( 1000 );

	// end use-case 
	err = iCallBackService->EndUsecase( iArgs.iUsecaseID, 0, aScriptError );
	*aErrorCode = err; 
	if( ( err != UCCS_OK ) ){
		return EAC_ENDUSECASEFAILED;
	}

	// done
	return EAC_SUCCESS;
}


/**********************************************************************************************
 *
 * ParseArgumentString() - portname should be a string:
 * "<usecaseid>[:<rendezvous count>[:<interactive_flag>]]"
 *
 *********************************************************************************************/
int CApplicationControlNull::ParseArgumentString( char *str )
{
	char *ptr, *tokens[MAXTOKENS];
	int token_count = 0, i;

	// check params
	assert( str != NULL );

	// tokenise the string based on the ':' delimiter
	for( ptr = str, i = 0; i < MAXTOKENS; i++ ) {
		tokens[i] = ptr;
		ptr = strchr( ptr, ':' );
		if( ptr == NULL ) 
			break;
		*ptr = 0;
		ptr++;
	}
	token_count = i + 1;

	// check that at least one token was found
	if( token_count == 0 ) {
		return -1;
	}

	// initialise the optional args to their defaults
	iArgs.iRendezvousCount = 1;
	iArgs.iInteractiveFlag = 0;

	// now convert the tokens into meaningful things
	iArgs.iUsecaseID = atoi(tokens[0]);
	if( token_count > 1 ) {
		iArgs.iRendezvousCount = atoi(tokens[1]);
	}
	if( token_count > 2 ) {
		iArgs.iInteractiveFlag = atoi(tokens[2]);
	}

	// done - success
	return 0;
}