/*

* Copyright (c) 2006-2008 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:    Defines source for multiplexer, where Media Wrapper is mounted to

*

*/

#ifndef C_CNCMMEDIASOURCE_H

#define C_CNCMMEDIASOURCE_H

#include <e32base.h> 

#include "natfwmediawrapperobserver.h"

#include "natfwconnectivityapidefs.h"

#include "mncmsenderobserver.h"

class MNcmSourceObserver;

class MNcmMediaSourceObserver;

class MNATFWMediaWrapper;

class RSocketServ;

class TInetAddr;

/**

 *  Defines source for multiplexer, where Media Wrapper is mounted to

 *

 *  @lib connectionmux.lib

 *  @since S60 v3.2

 */

NONSHARABLE_CLASS( CNcmMediaSource ) : public CBase, 

    public MNATFWMediaWrapperObserver, public MNcmSenderObserver

    {

public:

    /**

     * Two-phased constructor

     *

     * @param   aMediaObserver      Media source observer

     * @param   aMediaWrapper       Media wrapper

     * @param   aSocketServ         Socket server

     * @param   aLocalAddr          Local address

     */

    static CNcmMediaSource* NewL(

        MNcmMediaSourceObserver& aMediaObserver,

        MNATFWMediaWrapper& aMediaWrapper,

        const RSocketServ& aSocketServ,

        const TInetAddr& aLocalAddr );

    /**

     * Two-phased constructor

     *

     * @param   aMediaObserver      Media source observer

     * @param   aMediaWrapper       Media wrapper

     * @param   aSocketServ         Socket server

     * @param   aLocalAddr          Local address

     */

    static CNcmMediaSource* NewLC(

        MNcmMediaSourceObserver& aMediaObserver,

        MNATFWMediaWrapper& aMediaWrapper,

        const RSocketServ& aSocketServ,

        const TInetAddr& aLocalAddr );

    /**

     * Destructor

     */

    virtual ~CNcmMediaSource();

    /**

     * Registers message observer. Enables media sending to media socket wrapper

     *

     * @since   S60 v3.2

     * @param   aMessageObserver    The message observer        

     */    

    void RegisterMessageObserver( MNcmSourceObserver& aMessageObserver );

    /**

     * Unregisters message observer. Disables media sending to media socket wrapper

     *

     * @since   S60 v3.2

     * @param   aMessageObserver        The message observer

     */    

    void UnregisterMessageObserver(

        const MNcmSourceObserver& aMessageObserver );

    /**

     * Enables/disables media receiving from mux to wrapper.

     *

     * @since   S60 v3.2

     * @param   aState        The receiving state

     */ 

    void SetReceivingState( TNATFWStreamingState aState );

    /**

     *

     * @since   S60 v3.2

     * @param   aMessage        Message is a reference to message which

     *                          is copied by caller

     */

    void PutMessageL( const TDesC8& aMessage );

// from base class MNATFWMediaWrapperObserver

    /**

     * Indicates how sending to user succeed

     *

     * @since   S60 v3.2

     * @param   aError system-wide error code

     */

    void SendingCompleted( TInt aError );

    /**

     * From MNATFWMediaWrapperObserver.

     *

     * Called after data were sent to wrapper. 

     *

     * @since   S60 v3.2

     * @param   aStreamId           An ID for stream the data

     *                              was received from

     * @param   aStreamPortion      Stream portion which were sent by client

     * @return  system-wide error code

     */

    TInt ReceivedFrom( TUint aStreamId, TDes8& aStreamPortion );

    /**

     * From MNATFWMediaWrapperObserver.

     *

     * Called by socket media wrapper object when local port is allready in use.

     * Get new free port.

     *

     * @since   S60 v3.2

     * @param   aPort       New free port

     */ 

    void GetNewFreePort( TUint& aPort );

// from base class MNcmSenderObserver

    /**

     * From MNcmSenderObserver.

     *

     * Called when sending the message is succesfully completed.

     *

     * @since   S60 v3.2

     * @return  void

     */ 

    void MessageSent();

    /**

     * From MNcmSenderObserver.

     *

     * Called when sending the message is failed.

     *

     * @since   S60 v3.2

     * @param   aError      A reason for the failure.

     * @return  void

     */

    void MessageSentFailure( TInt aError );

private:

    CNcmMediaSource(

        MNcmMediaSourceObserver& aMediaObserver,

        MNATFWMediaWrapper& aMediaWrapper );

    void ConstructL( const RSocketServ& aSocketServ,

                     const TInetAddr& aLocalAddr );    

private: // data

    /**

     * Observer for this source.

     * Not own.

     */

    MNcmSourceObserver* iMessageObserver;

    /**

     * Observer for this media source

     */  

    MNcmMediaSourceObserver& iMediaObserver;

    /**

     * Media wrapper associated with this source

     */

    MNATFWMediaWrapper& iMediaWrapper;  

    /**

     * Receiving status

     */

    TNATFWStreamingState iReceivingState;

    /**

     * Indicates that the first media packet is sent to the remote end

     */

    TBool iFirstMediaPacketIsSent;   

    };

#endif // C_CNCMMEDIASOURCE_H