/*

* Copyright (c) 2006 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 MCCFILESINK_H

#define MCCFILESINK_H

//  INCLUDES

#include <e32base.h>

#include <f32file.h>

#include <e32std.h>

#include <3gplibrary/mp4lib.h>

#include <CamC3GPDataSink.h>

#include <CCMRMediaSink.h>

#include "mccdatasink.h"

#include "mmccevents.h"

#include "mccinternalcodecs.h"

/**

* Class to contain filesink user information.

*/   

 class TMccFileSinkUser

    {

    public:

        TMccFileSinkUser( MAsyncEventHandler* aEventHandler ) : 

            iEventHandler( aEventHandler ),

            iCodecInfo()

            {

            }

    public:

        MAsyncEventHandler* iEventHandler;

        TMccCodecInfo iCodecInfo;

    };

/**

* Class to handle file writing.

*/

class CMccFileSink: public CMccDataSink, public M3GPDataSinkObserver

    {

    public:

	    enum TFileSinkState 

	        {

	        EConstructed = 0,

	        EReady,           

	        EPaused,  

	        EStopped, 

	        ERecording 

	        };  

        /**

        * Two-phased constructor.

        */

        static MDataSink* NewSinkL( TUid aImplementationUid, 

                                        const TDesC8& aInitData );

		void ConstructSinkL ( const TDesC8& aInitData );

		CMccFileSink();

		virtual ~CMccFileSink();

    public: // New

        virtual void SetCurrentUser( MAsyncEventHandler* aEventHandler );

		virtual void SetFileNameL( const TFileName aFileName );

		virtual void RecordTimeAvailableL( TTimeIntervalMicroSeconds& aTime );

    public: // From MDataSource

        TFourCC SinkDataTypeCode( TMediaId /*aMediaId*/ );

        TInt SetSinkDataTypeCode( TFourCC aCodec, 

                                    TMediaId aMedia );

        void BufferEmptiedL( CMMFBuffer* aBuffer );

        TBool CanCreateSinkBuffer();

        CMMFBuffer* CreateSinkBufferL( TMediaId, 

                                         TBool& aReference );

        TInt SinkThreadLogon( MAsyncEventHandler& aEventHandler );

        void SinkThreadLogoff();

        void SinkPrimeL();

        void SinkPlayL();

        void SinkPauseL();

        void SinkStopL();

        void EmptyBufferL( CMMFBuffer* aBuffer,

                          MDataSource* aProvider,

                          TMediaId aMediaId );

        void BufferFilledL( CMMFBuffer* aBuffer );

	public:	// from M3GPDataSinkObserver

		void MfcoDiskFullL();

		void MfcoSizeLimitReachedL();

    public: // New methods

        virtual void SetVideoCodecL( const TMccCodecInfo& aVideoCodec );

        virtual void SetAudioCodecL( const TMccCodecInfo& aAudioCodec );

    private:

		void SendStreamEventToClient( TMccEventType aEventType, 

		                              TInt aError = KErrNone,

		                              TBool aToAllClients = EFalse );

		TTimeIntervalMicroSeconds TimeToPlayL( 

		    TTimeIntervalMicroSeconds aCurrentTimestamp );

		void CalculateAverageTimestampDifferenceL( 

		    const TTimeIntervalMicroSeconds& aCurrentTimestamp );

        void ResetTimers();

        void SetPausedDuration( TTime aT1, TTime aT2 );

        void AutomaticPauseL();

        TInt FinalizeSendEvent( MAsyncEventHandler* aEventHandler, TMccEvent& aEvent );

        HBufC8* GetCodecTypeStringLC( const TMccCodecInfo& aCodecInfo );

        /**

        * Resolve buffer type of passed buffer based on datatype value and

        * contents of data in some cases.

        * @param aBuffer

        * @param aDataType

        * @return buffer type

        */

        CCMRMediaBuffer::TBufferType ResolveBufferType( CMMFDataBuffer& aBuffer,

                                                        TFourCC aDataType );

        /**

        * Checks whether buffer should be written to file.

        * @param aBuffer

        * @param aBufferType

        * @return ETrue if writing to file is allowed 

        */

        TBool CheckWritingPermission( CMMFDataBuffer& aBuffer, 

                                      const CCMRMediaBuffer::TBufferType& aBufferType );

        TBool SetStateL( TFileSinkState aState );

        void DoSinkPrimeL( TBool aSendEvent = ETrue );

        void DoSinkPlayL( TBool aSendEvent = ETrue );

        void DoSinkPauseL( TBool aSendEvent = ETrue );

        void DoSinkStopL( TBool aSendEvent = ETrue );

        void DoCodecChangeL();

        void AddUserL( MAsyncEventHandler* aEventHandler );

        TMccFileSinkUser& ActiveUserL();

        TBool IsActiveUser( MAsyncEventHandler* aUser );

        /**

        * Check if active user has changed and update sink accordingly.

        * @param aMediaId

        * @param aDataProvider

        * @return data type of current data provider

        */

        TFourCC UpdateActiveUserL( TMediaId aMediaId, MDataSource& aDataProvider );

        void SetActiveUserIndex( TInt aIndex );

    private:   

	    TFileSinkState iCurrentState;

		CCamC3GPDataSink* iFileComposer;

    	TInt iMaxFileSize;

		TFileName iFileName; 

		TFourCC iAudioFourCC;

	    MAsyncEventHandler* iAsyncEventHandler;

	private:

	   	TTime iT1;

	   	TTime iT2;

	   	TTimeIntervalMicroSeconds iPausedDuration;

	   	RArray<TInt64> iTimestamps;

	   	TTimeIntervalMicroSeconds iPreviousTimestamp;

	   	TInt64 iAddToTimestamp;

	   	TBool iSizeLimitReached;

	   	TBool iNotifySizeLimitReached;

	   	TMccCodecInfo iVideoCodec;

	   	RPointerArray<TMccFileSinkUser> iUsers;

	   	TInt iActiveUserIndex;

	   	TBool iDecSpecInfoProvided;

	   	TBool iKeyFrameProvided;

	#ifdef EUNIT_TEST

        friend class UT_CMccFileSink;

    #endif	

        };

#endif 

// End of file