/*

* Copyright (c) 2005 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:  S60 Audio Stream Source implementation

*

*/

#include "S60AudioClientStreamSource.h"

#include "S60SourceEventDispatcher.h"

#include "WriteRequest.h"

// CONSTANTS

const TInt KMinBufferSize = 5120;

_LIT8(KAMRMimetype,"audio/amr");

_LIT8(KAMRWBMimetype,"audio/amr-wb");

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

// CS60AudioStreamSource::~CS60AudioStreamSource

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

//

CS60AudioStreamSource::~CS60AudioStreamSource()

	{

#ifdef _DEBUG

    RDebug::Print(_L("CS60AudioStreamSource::~CS60AudioStreamSource [%x]"),iDispatcher);

#endif

	delete iDispatcher;

	iDispatcher = NULL;

	delete iMimeType;

	iMimeType = NULL;

	iControllers.Close();

	iWriteRequests.ResetAndDestroy();

	}

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

// CS60AudioStreamSource::CS60AudioStreamSource

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

//

CS60AudioStreamSource::CS60AudioStreamSource()

	{

#ifdef _DEBUG

    RDebug::Print(_L("CS60AudioStreamSource::CS60AudioStreamSource"));

#endif

	}

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

// CS60AudioStreamSource::NewL

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

//

EXPORT_C CS60AudioStreamSource* CS60AudioStreamSource::NewL(

	MS60AudioStreamSourceObserver& aObserver,

	const TDesC8& aMimeType )

	{

#ifdef _DEBUG

    RDebug::Print(_L("CS60AudioStreamSource::NewL"));

#endif

	CS60AudioStreamSource* self = new(ELeave) CS60AudioStreamSource();

	CleanupStack::PushL(self);

	self->ConstructL(aObserver, aMimeType);

	CleanupStack::Pop(self);

	return self;

	}

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

// CS60AudioStreamSource::ConstructL

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

//

void CS60AudioStreamSource::ConstructL(

	MS60AudioStreamSourceObserver& aObserver,

	const TDesC8& aMimeType )

	{

#ifdef _DEBUG

    RDebug::Print(_L("CS60AudioStreamSource::ConstructL "));

#endif

	TInt err = KErrNone;

	iDispatcher = CS60SourceEventDispatcher::NewL(aObserver);

	if(!aMimeType.Compare(KAMRMimetype) || !aMimeType.Compare(KAMRWBMimetype))

		iMimeType = aMimeType.Alloc();

	else

		User::Leave(KErrNotSupported);

	//TRAP(err, FindControllersL());

	User::LeaveIfError(err);

	}

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

// CS60AudioStreamSource::FindControllersL

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

//

void CS60AudioStreamSource::FindControllersL()

	{

#if _DEBUG

  RDebug::Print(_L("CS60AudioStreamSource::FindControllersL"));

#endif

	// Retrieve a list of possible controllers from ECOM

	// If we don't have a match, leave with unsupported

	iControllers.ResetAndDestroy();

	CMMFControllerPluginSelectionParameters* cSelect = CMMFControllerPluginSelectionParameters::NewLC();

	CMMFFormatSelectionParameters* fSelect = CMMFFormatSelectionParameters::NewLC();

	RArray<TUid> mediaIds;

	CleanupClosePushL(mediaIds);

	User::LeaveIfError(mediaIds.Append(KUidMediaTypeAudio));

	cSelect->SetMediaIdsL(mediaIds, CMMFPluginSelectionParameters::EAllowOnlySuppliedMediaIds);

 	if (*iMimeType != KNullDesC8)

		{

		fSelect->SetMatchToMimeTypeL(*iMimeType);//We match to mime type

		}

	else

		{

		User::Leave(KErrNotSupported);

		}

	cSelect->SetRequiredPlayFormatSupportL(*fSelect);

	__UHEAP_MARK;

	RMMFControllerImplInfoArray siControllers;

	CleanupClosePushL(siControllers);

	cSelect->ListImplementationsL(siControllers);

	if ( siControllers.Count() == 0 )

		{

		User::Leave(KErrNotSupported);

		}

	siControllers.ResetAndDestroy();

	CleanupStack::PopAndDestroy();

	__UHEAP_MARKEND;

	CleanupStack::PopAndDestroy();

	CleanupStack::PopAndDestroy(fSelect);

	CleanupStack::PopAndDestroy(cSelect);

	}

EXPORT_C TInt CS60AudioStreamSource::WriteAudioData(

	CClientAudioBuffer& aBuffer )

	{

#ifdef _DEBUG

    RDebug::Print(_L("CS60AudioStreamSource::WriteAudioData"));

#endif

	TInt index;

	 if ( GetFreeRequestSlot(index) )

		{

		iWriteRequests[index]->WriteAudioData(aBuffer);

		}

	else

		{

			CWriteRequest* request = CWriteRequest::NewL(iSourceHandle, iController, *iDispatcher);

			iWriteRequests.Append(request);

			request->WriteAudioData(aBuffer);

		}

		return KErrNone;

	}

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

// CS60AudioStreamSource::NextAudioBuffer

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

//

TBool CS60AudioStreamSource::GetFreeRequestSlot(TInt& index)

	{

#ifdef _DEBUG

    RDebug::Print(_L("CS60AudioStreamSource::NextAudioBuffer"));

#endif

	for ( TInt i=0; i < iWriteRequests.Count(); i++)

		{

		if ( iWriteRequests[i]->IsFree() )

			{

			index = i;

			return ETrue;

			}

		}

	return EFalse;

	}

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

// CS60AudioStreamSource::SetSize

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

//

EXPORT_C TInt CS60AudioStreamSource::SetSize(

	TUint aSize)

	{

#ifdef _DEBUG

    RDebug::Print(_L("CS60AudioStreamSource::SetSize"));

#endif

	iSize = aSize;

	return KErrNone;

	}

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

// CS60AudioStreamSource::MinimumBufferSize

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

//

EXPORT_C TInt CS60AudioStreamSource::GetMinimumBufferSize()

	{

#ifdef _DEBUG

    RDebug::Print(_L("CS60AudioStreamSource::MinimumBufferSize"));

#endif

	return KMinBufferSize;

	}

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

// CS60AudioStreamSource::GetMimeTypeL

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

//

EXPORT_C void CS60AudioStreamSource::GetMimeType(TDes8& aMimeType)

	{

#ifdef _DEBUG

    RDebug::Print(_L("CS60AudioStreamSource::GetMimeType"));

#endif

	aMimeType.Copy(*iMimeType);

	}

EXPORT_C TUint CS60AudioStreamSource::GetSize()

	{

#ifdef _DEBUG

    RDebug::Print(_L("CS60AudioStreamSource::GetSize"));

#endif

	return iSize;

	}

EXPORT_C TInt64 CS60AudioStreamSource::GetPosition()

	{

#ifdef _DEBUG

    RDebug::Print(_L("CS60AudioStreamSource::GetPosition"));

#endif

	return iPosition;

	}

EXPORT_C TInt CS60AudioStreamSource::SetPosition(

	TInt64 aPosition)

	{

#ifdef _DEBUG

    RDebug::Print(_L("CS60AudioStreamSource::SetPosition"));

#endif

	iPosition = aPosition;

	return KErrNone;

	}

TBool CS60AudioStreamSource::IsSeekingSupported()

{

#ifdef _DEBUG

    RDebug::Print(_L("CS60AudioStreamSource::IsSeekingSupported"));

#endif

	return EFalse;

}

TBool CS60AudioStreamSource::IsRandomSeekingSupported()

{

#ifdef _DEBUG

    RDebug::Print(_L("CS60AudioStreamSource::IsRandomSeekingSupported"));

#endif

	return EFalse;

}