// 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>

#include <testframework.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 "TestStepAudOutStream.h"

#include "mmfclientaudiooutputstream.h"

#include <mda/common/audio.h>

#include "mmfclientaudiostreamutils.h"

//

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

//

// base class for some audio Ouput stream tests

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

//_LIT(KStreamWavFile,"c:\\16bitmPcm.wav");

const TInt KMicroSecsInOneSec = 1000000;

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

const TInt KBytesPerSample = 2;

const TInt KSampleRate = 8000;

const TInt KToneFrequency = 2000;

const TInt KOneSecond = 1000000;

const TInt KNumofThreads = 2;

const TInt KWaitReadTime = 500000;

// constant table of parameters for tests

const TConvParameters KTestParameters[] =

{	

	// straight encode test

	{ _S("MM-MMF-ACLNT-U-0631-CP"), KMMFFourCCCodePCM16,   TMdaAudioDataSettings::ESampleRate8000Hz,	TMdaAudioDataSettings::EChannelsMono, 	_S("PCMExp500hzMono8Khz.wav"),		KErrNone },

	{ _S("MM-MMF-ACLNT-U-0632-CP"), KMMFFourCCCodePCM16,   TMdaAudioDataSettings::ESampleRate8000Hz,	TMdaAudioDataSettings::EChannelsStereo, _S("PCMExp500hzStereo8Khz.wav"),	KErrNone },

	{ _S("MM-MMF-ACLNT-U-0633-CP"), KMMFFourCCCodePCM16,   TMdaAudioDataSettings::ESampleRate8000Hz,	TMdaAudioDataSettings::EChannelsMono, 	_S("PCMExp500hzMono8Khz.wav"),		KErrNone },

	{ _S("MM-MMF-ACLNT-U-0634-CP"), KMMFFourCCCodePCM16,   TMdaAudioDataSettings::ESampleRate8000Hz,	TMdaAudioDataSettings::EChannelsStereo, _S("PCMExp500hzStereo8Khz.wav"),	KErrNone },

	{ _S("MM-MMF-ACLNT-U-0635-CP"), KMMFFourCCCodePCM16,   TMdaAudioDataSettings::ESampleRate8000Hz,	TMdaAudioDataSettings::EChannelsMono, 	_S("PCMExp500hzMono8Khz.wav"),		KErrNone },

	{ _S("MM-MMF-ACLNT-U-0636-CP"), KMMFFourCCCodePCM16,   TMdaAudioDataSettings::ESampleRate8000Hz,	TMdaAudioDataSettings::EChannelsStereo, _S("PCMExp500hzStereo8Khz.wav"),	KErrNone },

	{ _S("MM-MMF-ACLNT-U-0637-CP"), KMMFFourCCCodePCM16,   TMdaAudioDataSettings::ESampleRate8000Hz,	TMdaAudioDataSettings::EChannelsMono, 	_S("PCMExp500hzMono8Khz.wav"),		KErrNone },

	{ _S("MM-MMF-ACLNT-U-0638-CP"), KMMFFourCCCodePCM16,   TMdaAudioDataSettings::ESampleRate8000Hz,	TMdaAudioDataSettings::EChannelsStereo, _S("PCMExp500hzStereo8Khz.wav"),	KErrNone },

	{ _S("MM-MMF-ACLNT-U-0639-CP"), KMMFFourCCCodePCM16,   TMdaAudioDataSettings::ESampleRate8000Hz,	TMdaAudioDataSettings::EChannelsMono, 	_S("PCMExp500hzMono8Khz.wav"),		KErrNone },

	{ _S("MM-MMF-ACLNT-U-0640-CP"), KMMFFourCCCodePCM16,   TMdaAudioDataSettings::ESampleRate8000Hz,	TMdaAudioDataSettings::EChannelsMono, 	_S("PCMExp500hzMono8Khz.wav"),		KErrNone },

	{ _S("MM-MMF-ACLNT-U-0641-CP"), KMMFFourCCCodePCM16,   TMdaAudioDataSettings::ESampleRate8000Hz,	TMdaAudioDataSettings::EChannelsStereo, _S("PCMExp500hzStereo8Khz.wav"),	KErrNone },

	{ _S("MM-MMF-ACLNT-U-0858-CP"), KMMFFourCCCodePCM16,   TMdaAudioDataSettings::ESampleRate8000Hz,	TMdaAudioDataSettings::EChannelsMono, 	_S("PCMExp500hzMono8Khz.wav"),		KErrNone },

	{ _S("MM-MMF-ACLNT-U-0859-CP"), KMMFFourCCCodePCM16,   TMdaAudioDataSettings::ESampleRate8000Hz,	TMdaAudioDataSettings::EChannelsStereo, _S("PCMExp500hzStereo8Khz.wav"),	KErrNone }

};

CTestStepAudOutStream* CTestStepAudOutStream::NewL()

	{

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

	CleanupStack::PushL(s);

	s->ConstructL();

	CleanupStack::Pop();

	return s;

	}

CTestStepAudOutStream::CTestStepAudOutStream() : iError(KErrNone)

	{

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

	iIsAllDataRead = EFalse;

	iIsAllDataWritten = EFalse;

	}

void CTestStepAudOutStream::ConstructL()

	{

	// reset the buffer

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

		{

		iBufferList[i] = KNullDesC8;

		}

	iStartBuf=iEndBuf=0;

	}

CTestStepAudOutStream::~CTestStepAudOutStream()

	{

	}

/*

TInt CTestStepAudOutputStream::HandleKeyEvent(TKeyCode aKeystroke)

	{

	TInt retval = KErrNotSupported;

	TInt key = aKeystroke;

	switch (key)

		{

	case 'o':

		if (!iStream)

			retval = KErrNotReady;

		else

			TRAP(retval, iAudOutStream->Open(NULL));

		break;

	case 'w':

		if (!iStream)

			retval = KErrNotReady;

		else

			{

			TInt err = iFile.Open(iFs, KStreamRawFile, EFileRead);

			iReadBufferActive.Read();

			retval = KErrNone;

			}

		break;

	case 's':

		if (!iAudOutStream)

			retval = KErrNotReady;

		else

			{

			iAudOutStream->Stop();

			retval = KErrNone;

			}

		break;

	case 'q': 

	case 'Q':

		iParent.TestComplete();

		retval = KErrNone;

		break;

	default:

		break;

		}

	return retval;

	}

void CTestStepAudOutputStream::StartL()

	{

	}

const TDesC& CTestStepAudOutputStream::Instructions()

	{

	return KTxtClientAudioOutputStreamInstructions;

	}

*/

void CTestStepAudOutStream::MaoscOpenComplete(TInt aError)

	{

	iError = aError;

	CActiveScheduler::Stop();

	}

void CTestStepAudOutStream::MaoscPlayComplete(TInt aError)

	{

	if (iIsAllDataWritten && (aError == KErrNone || aError == KErrUnderflow))

		iError = KErrNone;

	else

		iError = aError;

	iReadBufferActive->Cancel();

	TInt filePosition=0;

	iFile.Seek(ESeekStart, filePosition);

	iFile.Close();

	CActiveScheduler::Stop();

	}

void CTestStepAudOutStream::MaoscBufferCopied(TInt aError, const TDesC8& /*aBuffer*/)

	{

	iError = aError;

	if(aError)

		{

			//need add for deal with exception

			return;   

		}

	// adjust the buffer

	iBufferList[iStartBuf] = KNullDesC8;

	if(iStartBuf==KNumBuffer-1)

		iStartBuf = 0;

	else

		iStartBuf++;

	if (iIsAllDataRead && iStartBuf == iEndBuf)

		{

		iIsAllDataWritten = ETrue;

		}

	else if(!iReadBufferActive->IsActive())

		iReadBufferActive->Read();

	}

CTestStepAudOutStream::CReadBufferActive::CReadBufferActive() : CActive(0)

	{

	CActiveScheduler::Add(this);

	}

CTestStepAudOutStream::CReadBufferActive::~CReadBufferActive()

	{

	Cancel();

	}

void CTestStepAudOutStream::CReadBufferActive::RunL()

	{

	iParent->ProcessDataL(iBuffer);

	}

void CTestStepAudOutStream::CReadBufferActive::DoCancel()

	{

	// do nothing

	}

void CTestStepAudOutStream::CReadBufferActive::Read()

	{

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

	SetActive();		

	}

void CTestStepAudOutStream::CReadBufferActive::Read(TInt aPos)

	{

	iParent->iFile.Read(aPos, iBuffer, iStatus);      // read the 1st data trunk

	SetActive();		

	}

void CTestStepAudOutStream::ProcessDataL(TBuf8<KBufferSize>& aData)

	{

	if(aData.Length())

		{

		if(iBufferList[iEndBuf]==KNullDesC8)

			{

			iBufferList[iEndBuf] = aData;

			iAudOutStream->WriteL(iBufferList[iEndBuf]);

			// adjust the buffer

			if(iEndBuf==KNumBuffer-1)

				iEndBuf=0;

			else

				iEndBuf++;

			}

		if(iBufferList[iEndBuf]==KNullDesC8)

			{

			iReadBufferActive->Read();

			}

		// else all our buffers are full

		}

	else

		iIsAllDataRead = ETrue;

	}

/**

 *

 * Test step Preamble.

 *

 * @xxxx

 * 

 */

 enum TVerdict CTestStepAudOutStream::DoTestStepPreambleL(void)

	{

	 enum TVerdict verdict;

	 // this installs the scheduler

	 verdict = CTestStepUnitMMFAudClient::DoTestStepPreambleL();

	// create the active object

	iReadBufferActive = new(ELeave) CReadBufferActive();

	iReadBufferActive->iParent = this;

	iFs.Connect();

	TRAPD(err, iAudOutStream = CMMFMdaAudioOutputStream::NewL(*this) );

	if (err != KErrNone ||

		iAudOutStream == NULL )

		return EInconclusive;

	 return verdict;

	}

/**

 *

 * Test step Postamble.

 *

 * @xxxx

 * 

 */

enum TVerdict CTestStepAudOutStream::DoTestStepPostambleL(void)

	{

	iFs.Close();

	delete iAudOutStream;

	iAudOutStream = NULL;

	delete iReadBufferActive;

	//[ 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 CTestStepAudOutStream::DoTestStepL()

	{

	iTestStepResult = EPass;

	//TInt err = KErrNone;

	iAudOutStream->Open(NULL);

	CActiveScheduler::Start();

	iAudOutStream->SetVolume(iAudOutStream->MaxVolume()>>1); // half volume

	if (iError != KErrNone )

		 return EFail;

	TInt err = KErrNone;

	err = iFile.Open(iFs, KStreamRawFile, EFileRead);

	if (err != KErrNone)

		return EFail;

	iReadBufferActive->Read();

	CActiveScheduler::Start();

	// wait sometime to finish and then close the file

	User::After(1200000);

	iFile.Close();

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

	// test steps return a result

	return iTestStepResult;

	}

//

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

//

/**

 *

 * Static constructor for CTestStepAudOutStreamNew.

 *

 *

 * @return	"CTestStepAudOutStreamNew*"

 *			The constructed CTestStepAudOutStreamNew

 *

 * @xxxx

 * 

 */

CTestStepAudOutStreamNew* CTestStepAudOutStreamNew::NewL()

	{

	CTestStepAudOutStreamNew* self = new(ELeave) CTestStepAudOutStreamNew;

	return self;

	}

/**

 *

 * Test step constructor.

 * Each test step initialises its own name.

 *

 * @xxxx

 * 

 */

CTestStepAudOutStreamNew::CTestStepAudOutStreamNew()

	{

	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-0600-CP");

	}

/**

 *

 * Test step destructor.

 *

 * @xxxx

 * 

 */

CTestStepAudOutStreamNew::~CTestStepAudOutStreamNew()

	{

	}

/**

 * Implementation of the MMdaAudioOuputStreamCallback interface functions

 **/

void CTestStepAudOutStreamNew::MaoscOpenComplete(TInt /*aError*/)

	{

	}

void CTestStepAudOutStreamNew::MaoscBufferCopied(TInt /*aError*/, const TDesC8& /*aBuffer*/)

	{

	}

void CTestStepAudOutStreamNew::MaoscPlayComplete(TInt /*aError*/)

	{

	}

/**

 *

 * Test step Preamble.

 *

 * @xxxx

 * 

 */

 enum TVerdict CTestStepAudOutStreamNew::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-0600-CP"));

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

	return verdict;

	}

/**

 *

 * Test step Postamble.

 *

 * @xxxx

 * 

 */

enum TVerdict CTestStepAudOutStreamNew::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 CTestStepAudOutStreamNew::DoTestStepL()

	{

	__MM_HEAP_MARK;

	iAudOutStream = CMMFMdaAudioOutputStream::NewL(*this);

	if ( iAudOutStream == NULL )

		 iTestStepResult = EFail;

	else 

		 iTestStepResult = EPass;

	delete iAudOutStream;

	iAudOutStream = NULL;

	__MM_HEAP_MARKEND;

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

	// test steps return a result

	return iTestStepResult;

	}

//

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

//

/**

 *

 * Static constructor for CTestStepAudOutStreamSetProp.

 *

 *

 * @return	"CTestStepAudOutStreamSetProp*"

 *			The constructed CTestStepAudOutStreamSetProp

 *

 * @xxxx

 * 

 */

CTestStepAudOutStreamSetProp* CTestStepAudOutStreamSetProp::NewL()

	{

	CTestStepAudOutStreamSetProp* self = new(ELeave) CTestStepAudOutStreamSetProp;

	return self;

	}

/**

 *

 * Test step constructor.

 * Each test step initialises its own name.

 *

 * @xxxx

 * 

 */

CTestStepAudOutStreamSetProp::CTestStepAudOutStreamSetProp()

	{

	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-0601-CP");

	}

/**

 *

 * Test step destructor.

 *

 * @xxxx

 * 

 */

CTestStepAudOutStreamSetProp::~CTestStepAudOutStreamSetProp()

	{

	}

/**

 *

 * Test step Preamble.

 *

 * @xxxx