// Copyright (c) 2002-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:

// This file contains an example Test step implementation 

// This demonstrates the various functions provided

// by the CTestStep base class which are available within

// a test step 

// 

//

// EPOC includes

#include <e32base.h>

#include <e32test.h>

#include <e32keys.h>

#include <c32comm.h>

#include <f32file.h>

#include <etel.h>

#include <etelmm.h>

// Test system includes

#include <testframework.h>

// Specific includes for this test suite

#include "TestStepUnitMMFAudClient.h"

#include "TestSuiteUnitMMFAudClient.h"

// Specific includes for these test steps

#include "TestStepAudInStream.h"

#include "mmfclientaudioinputstream.h"

#include <mda/common/audio.h>

//

// --------------------------------------------

//

// base class for some audio Input stream tests

//_LIT(KStreamRawFile,"c:\\mm\\mmf\\testfiles\\aclnt\\test.raw");	// EABI warning removal

//_LIT(KStreamIMADFile,"c:\\mm\\mmf\\testfiles\\aclnt\\test.raw");	// EABI warning removal

_LIT(KRecordStreamRawFile,"c:\\mm\\mmf\\testfiles\\aclnt\\streamrecorded.raw");

const TInt KMicroSecsInOneSec = 1000000;

//const TInt KBitsPerSample = 16;	// EABI warning removal

const TInt KBytesPerSample = 2;

const TInt KSampleRate = 8000;

// constant table of parameters for tests

const TStreamInConvParameters KTestParameters[] =

{	

	// straight encode test

	{ _S("MM-MMF-ACLNT-U-0740-CP"), KMMFFourCCCodePCMU8},

	{ _S("MM-MMF-ACLNT-U-0741-CP"), KMMFFourCCCodePCM16},

	{ _S("MM-MMF-ACLNT-U-0742-CP"), KMMFFourCCCodeALAW},

	{ _S("MM-MMF-ACLNT-U-0743-CP"), KMMFFourCCCodeMuLAW},

	{ _S("MM-MMF-ACLNT-U-0744-CP"), KMMFFourCCCodeIMAD},

	{ _S("MM-MMF-ACLNT-U-0745-CP"), KMMFFourCCCodePCM16B},

	{ _S("MM-MMF-ACLNT-U-0746-CP"), KMMFFourCCCodeGSM610}

};

CTestStepAudInStream* CTestStepAudInStream::NewL()

	{

	CTestStepAudInStream* s = new(ELeave) CTestStepAudInStream();

	CleanupStack::PushL(s);

	s->ConstructL();

	CleanupStack::Pop();

	return s;

	}

CTestStepAudInStream::CTestStepAudInStream() : iError(KErrNone)

	{

	iTestStepName = _L("MM-MMF-ACLNT-U-0999-CP");

	}

void CTestStepAudInStream::ConstructL()

	{

	// reset the buffer

	for(TInt i=0; i<KRecNumBuffer; i++)

		{

		iBufferList[i] = KNullDesC8;

		}

	iStartBuf=iEndBuf=0;

	}

CTestStepAudInStream::~CTestStepAudInStream()

	{

	}

void CTestStepAudInStream::MaiscOpenComplete(TInt aError)

	{

	iError = aError;

	CActiveScheduler::Stop();

	}

void CTestStepAudInStream::MaiscRecordComplete(TInt aError)

	{

	iError = aError;

	iWriteBufferActive->Cancel();

	TInt filePosition=0;

	iFile.Seek(ESeekStart, filePosition);

	iFile.Close();

	CActiveScheduler::Stop();

	}

void CTestStepAudInStream::MaiscBufferCopied(TInt aError, const TDesC8& /*aBuffer*/)

	{

	iError = aError;

	if(aError != KErrNone)

		{

		return;   

		}

	// Assume aBuffer == iBufferList[iEndBuf]

	// Increment iEndBuf

	if(iEndBuf==KRecNumBuffer-1)

		iEndBuf = 0;

	else

		iEndBuf++;

	// Starting writing out the buffers if we're not already

	if(!iWriteBufferActive->IsActive())

		iWriteBufferActive->Write(iBufferList[iStartBuf]);

	}

void CTestStepAudInStream::StartReadL()

	{

	// Issue reads on all available buffers

	for (TInt ii=0; ii<KRecNumBuffer; ii++)

	    {

		iAudInStream->ReadL(iBufferList[ii]);

	    }

	}

CTestStepAudInStream::CWriteBufferActive::CWriteBufferActive() : CActive(0)

	{

	CActiveScheduler::Add(this);

	}

CTestStepAudInStream::CWriteBufferActive::~CWriteBufferActive()

	{

	Cancel();

	}

void CTestStepAudInStream::CWriteBufferActive::RunL()

	{

	//ASSERT it wrote OK

	iParent->ProcessDataL();

	}

void CTestStepAudInStream::CWriteBufferActive::DoCancel()

	{

	// do nothing

	}

void CTestStepAudInStream::CWriteBufferActive::Write(const TDesC8& aBuffer)

	{

	iParent->iFile.Write(aBuffer, iStatus);      // read the 1st data trunk

	SetActive();		

	}

void CTestStepAudInStream::ProcessDataL()

	{

	// Set the next buffer to handle

	iBufferList[iStartBuf] = KNullDesC8; // done with that one

	// Issue another read to input stream

	iAudInStream->ReadL(iBufferList[iStartBuf]);

	// Increment iStartBuf

	if(iStartBuf==KRecNumBuffer-1)

		iStartBuf=0;

	else

		iStartBuf++;

	if (iBufferList[iStartBuf] != KNullDesC8)

		{

		// Still more to write

		iWriteBufferActive->Write(iBufferList[iStartBuf]);

		}

	// else just wait for more recorded data to come through

	}

/**

 *

 * Test step Preamble.

 *

 * @xxxx

 * 

 */

 enum TVerdict CTestStepAudInStream::DoTestStepPreambleL(void)

	{

	 enum TVerdict verdict;

	 // this installs the scheduler

	 verdict = CTestStepUnitMMFAudClient::DoTestStepPreambleL();

	// create the active object

	iWriteBufferActive = new(ELeave) CWriteBufferActive();

	iWriteBufferActive->iParent = this;

	iFs.Connect();

	TRAPD(err, iAudInStream = CMMFMdaAudioInputStream::NewL(*this) );

	if (err != KErrNone ||

		iAudInStream == NULL )

		return EInconclusive;

	 return verdict;

	}

/**

 *

 * Test step Postamble.

 *

 * @xxxx

 * 

 */

enum TVerdict CTestStepAudInStream::DoTestStepPostambleL(void)

	{

	iFs.Close();

	delete iAudInStream;

	iAudInStream = NULL;

	delete iWriteBufferActive;

	//[ Destroy the scheduler ]

	return CTestStepUnitMMFAudClient::DoTestStepPostambleL();

	}

/**

 *

 * Do the test step.

 * Each test step must supply an implementation for DoTestStepL.

 *

 * @return	"TVerdict"

 *			The result of the test step

 *

 * @xxxx

 * 

 */

TVerdict CTestStepAudInStream::DoTestStepL()

	{

	iTestStepResult = EPass;

	TInt err = KErrNone;

	if (iError != KErrNone )

		 return EFail;

	err = iFile.Replace( iFs, KRecordStreamRawFile, EFileWrite ) ;

	if (err != KErrNone)

		return EFail;

	StartReadL();

	CActiveScheduler::Start();

	iFile.Close();

	INFO_PRINTF1(_L("finished with this test step"));

	// test steps return a result

	return iTestStepResult;

	}

// --------------------------------------------

/**

 *

 * Static constructor for CTestStepAudInStreamNew.

 *

 *

 * @return	"CTestStepAudInStreamNew*"

 *			The constructed CTestStepAudInStreamNew

 *

 * @xxxx

 * 

 */

CTestStepAudInStreamNew* CTestStepAudInStreamNew::NewL()

	{

	CTestStepAudInStreamNew* self = new(ELeave) CTestStepAudInStreamNew;

	return self;

	}

/**

 *

 * Test step constructor.

 * Each test step initialises its own name.

 *

 * @xxxx

 * 

 */

CTestStepAudInStreamNew::CTestStepAudInStreamNew()

	{

	iTestStepResult = EPass;

	// store the name of this test case

	// this is the name that is used by the script file

	iTestStepName = _L("MM-MMF-ACLNT-U-0700-CP");

	}

/**

 *

 * Test step destructor.

 *

 * @xxxx

 * 

 */

CTestStepAudInStreamNew::~CTestStepAudInStreamNew()

	{

	}

/**

 * Implementation of the MMdaAudioOuputStreamCallback interface functions

 **/

void CTestStepAudInStreamNew::MaiscOpenComplete(TInt /*aError*/)

	{

	}

void CTestStepAudInStreamNew::MaiscBufferCopied(TInt /*aError*/, const TDesC8& /*aBuffer*/)

	{

	}

void CTestStepAudInStreamNew::MaiscRecordComplete(TInt /*aError*/)

	{

	}

/**

 *

 * Test step Preamble.

 *

 * @xxxx

 * 

 */

 enum TVerdict CTestStepAudInStreamNew::DoTestStepPreambleL(void)

	{

	 enum TVerdict verdict;

	 // this installs the scheduler

	 verdict = CTestStepUnitMMFAudClient::DoTestStepPreambleL();

	 return verdict;

	}

/**

 *

 * Test step Postamble.

 *

 * @xxxx

 * 

 */

enum TVerdict CTestStepAudInStreamNew::DoTestStepPostambleL(void)

	{

	//[ Destroy the scheduler ]

	return CTestStepUnitMMFAudClient::DoTestStepPostambleL();

	}

/**

 *

 * Do the test step.

 * Each test step must supply an implementation for DoTestStepL.

 *

 * @return	"TVerdict"

 *			The result of the test step

 *

 * @xxxx

 * 

 */

TVerdict CTestStepAudInStreamNew::DoTestStepL()

	{

	__MM_HEAP_MARK;

	// Printing to the console and log file

	INFO_PRINTF1(_L("MM-MMF-ACLNT-U-0700-CP"));

	INFO_PRINTF1(_L("this test is initialising an Audio Input Stream Utility Class"));

	iAudInStream = CMMFMdaAudioInputStream::NewL(*this);

	if ( iAudInStream == NULL )

		 iTestStepResult = EFail;

	else 

		 iTestStepResult = EPass;

	delete iAudInStream;

	iAudInStream = NULL;

	__MM_HEAP_MARKEND;

	INFO_PRINTF1(_L("finished with this test step"));

	// test steps return a result

	return iTestStepResult;

	}

//

// --------------------------------------------

//

/**

 *

 * Static constructor for CTestStepAudInStreamSetProp.

 *

 *

 * @return	"CTestStepAudInStreamSetProp*"

 *			The constructed CTestStepAudInStreamSetProp

 *

 * @xxxx

 * 

 */

CTestStepAudInStreamSetProp* CTestStepAudInStreamSetProp::NewL()

	{

	CTestStepAudInStreamSetProp* self = new(ELeave) CTestStepAudInStreamSetProp;

	return self;

	}

/**

 *

 * Test step constructor.

 * Each test step initialises its own name.

 *

 * @xxxx

 * 

 */

CTestStepAudInStreamSetProp::CTestStepAudInStreamSetProp()

	{

	iTestStepResult = EPass;

	// store the name of this test case

	// this is the name that is used by the script file

	iTestStepName = _L("MM-MMF-ACLNT-U-0701-CP");

	}

/**

 *

 * Test step destructor.

 *

 * @xxxx

 * 

 */

CTestStepAudInStreamSetProp::~CTestStepAudInStreamSetProp()

	{

	}

/**

 * Implementation of the MMdaAudioOuputStreamCallback interface functions

 **/

void CTestStepAudInStreamSetProp::MaiscOpenComplete(TInt aError)

	{

	iError = aError;

	CActiveScheduler::Stop();

	}

void CTestStepAudInStreamSetProp::MaiscBufferCopied(TInt aError, const TDesC8& /*aBuffer*/)

	{

	iError = aError;

	}

void CTestStepAudInStreamSetProp::MaiscRecordComplete(TInt aError)

	{

	iError = aError;

	}

/**

 *

 * Test step Preamble.

 *

 * @xxxx

 * 

 */

 enum TVerdict CTestStepAudInStreamSetProp::DoTestStepPreambleL(void)

	{

	 enum TVerdict verdict;

	 // this installs the scheduler

	 verdict = CTestStepUnitMMFAudClient::DoTestStepPreambleL();

	 // Printing to the console and log file

	INFO_PRINTF1(_L("MM-MMF-ACLNT-U-0701-CP"));

	INFO_PRINTF1(_L("this test is setting the audio properties of an Audio Input Stream Utility Class"));

	iAudInStream = CMMFMdaAudioInputStream::NewL(*this);

	if (iAudInStream == NULL)

		return EInconclusive;

	iAudInStream->Open(NULL);

		CActiveScheduler::Start();

	 return verdict;

	}

/**

 *

 * Test step Postamble.

 *

 * @xxxx

 * 

 */

enum TVerdict CTestStepAudInStreamSetProp::DoTestStepPostambleL(void)

	{

	delete iAudInStream;

	iAudInStream = NULL;

	//CActiveScheduler::Stop();

	//[ Destroy the scheduler ]

	return CTestStepUnitMMFAudClient::DoTestStepPostambleL();

	}

/**

 *

 * Do the test step.

 * Each test step must supply an implementation for DoTestStepL.

 *

 * @return	"TVerdict"

 *			The result of the test step

 *

 * @xxxx

 * 

 */

TVerdict CTestStepAudInStreamSetProp::DoTestStepL()

	{

	//TMdaAudioDataSettings settings;

		//	settings.Query();

		//	settings.iSampleRate = TMdaAudioDataSettings::ESampleRate8000Hz; // ESampleRateAnyInRange

		//	settings.iChannels = TMdaAudioDataSettings::EChannelsMono;

		//	settings.iFlags = TMdaAudioDataSettings::ENoNetworkRouting;

		//	settings.iVolume = 0;

	iTestStepResult = EPass;

	TInt err = KErrNone;

	// test 1

	TRAP(err, iAudInStream->SetAudioPropertiesL(TMdaAudioDataSettings::ESampleRate8000Hz,TMdaAudioDataSettings::EChannelsMono) );

	if (!(err == KErrNone || 

		  err == KErrNotSupported) )