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

//

#ifndef MMFCLIENTAUDIOINPUTSTREAM_H

#define MMFCLIENTAUDIOINPUTSTREAM_H

#include <mmf/server/sounddevice.h>

#include <mmf/common/mmfstandardcustomcommands.h>

#include <mda/common/audio.h>

template<class T>

class CMMFFifo;

class CMMFBuffer;

class MMdaAudioInputStreamCallback;

class TMdaPackage;

class CMMFMdaAudioInputStream;

NONSHARABLE_CLASS( CMMFMdaAudioInputStream ): public CBase, 

											  public MDevSoundObserver

	{

	enum TIsOpenState

		{

		EIsNotOpen,

		EIsOpening,  // Open() called but not responded to

		EIsOpen,     // Open callback made and successfully opened

		};

public:

	static CMMFMdaAudioInputStream* NewL(MMdaAudioInputStreamCallback& aCallback);

	static CMMFMdaAudioInputStream* NewL(MMdaAudioInputStreamCallback& aCallback, TInt aPriority, TInt aPref);

	~CMMFMdaAudioInputStream();

	void SetAudioPropertiesL(TInt aSampleRate, TInt aChannels);

	void Open(TMdaPackage* aSettings);

	void SetGain(TInt aGain);

	TInt Gain() const;

	TInt MaxGain() const;

	void SetBalanceL(TInt aBalance = KMMFBalanceCenter);

	TInt GetBalanceL() const;

	void SetPriority(TInt aPriority, TInt aPref);

	void ReadL(TDes8& aData);

	void Stop();

	const TTimeIntervalMicroSeconds& Position();

	TInt GetBytes();

	void SetDataTypeL(TFourCC aAudioType);

	TFourCC DataType() const;

	void GetSupportedBitRatesL(RArray<TInt>& aSupportedBitRates);

	TInt BitRateL() const;

	void SetBitRateL(TInt aBitRate);

	TAny* CustomInterface(TUid aInterfaceId);

	void SetSingleBufferMode(TBool aSingleMode);

	void RequestStop();

	void ShutDown();

public:		

	// from MDevSoundObserver

	void InitializeComplete(TInt aError);

	void ToneFinished(TInt aError); 

	void BufferToBeFilled(CMMFBuffer* aBuffer);

	void PlayError(TInt aError); 

	void BufferToBeEmptied(CMMFBuffer* aBuffer); 

	void RecordError(TInt aError); 

	void ConvertError(TInt aError);

	void DeviceMessage(TUid aMessageType, const TDesC8& aMsg);

private:

	void RealSetAudioPropertiesL(TInt aSampleRate, TInt aChannels);

private:

	// class to allow asynchronous user callbacks

	class CActiveCallback : public CActive

		{

	public:

		CActiveCallback(MMdaAudioInputStreamCallback& aCallback);

		~CActiveCallback();

		void Signal(const TInt aReason);

	protected:

		void RunL();

		void DoCancel();

	private:

		MMdaAudioInputStreamCallback& iCallback;

		};

private:

	enum TState { EStopped, ERecording, EStopping };

private:

	CMMFMdaAudioInputStream(MMdaAudioInputStreamCallback& aCallback);

	void ConstructL(TInt aPriority, TInt aPref);

	TInt Read(TDes8& aData);

private:

	MMdaAudioInputStreamCallback&		iCallback;

	TTimeIntervalMicroSeconds			iPosition;

	CMMFDevSound*						iDevSound;

	CMMFFifo<TDes8>*					iFifo;

	TBool								iSingleBuffer;

	TPtr8								iStorageItem;

	TPtr8								iBufferPtr;

	TInt								iState;

	CActiveCallback*					iActiveCallback;

	TInt								iBytesRecorded;//tracks bytes supplied by devsound

	TFourCC								iDataTypeCode;

	TIsOpenState						iIsOpenState;

	TMdaAudioDataSettings				iSettings;

	TBool								iAudioDataStored;

	// only for testing

	friend class						CTestStepUnitMMFAudClient;

	TBool								iInitCallFrmSetDataType;//Flag to indicate that InitializeL is called from SetDataTypeL.

	TInt								iInitializeState;

	CActiveSchedulerWait*				iActiveSchedulerWait;

	}; 

#endif