/*

* Copyright (c) 2004 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:  

*

*/

//  CLASS HEADER

#include "UT_CMccInterface.h"

//  EXTERNAL INCLUDES

#include <digia/eunit/EUnitMacros.h>

#include <digia/eunit/CEunitAllocTestCaseDecorator.h>

#include "mccunittestmacros.h"

// CONSTANTS

const TUid KImplementMccController  = { KImplUidMccController };

#ifndef __WINSCW__

const TInt KTestIapId = 1;

#else

const TInt KTestIapId = 6;

#endif

//  INTERNAL INCLUDES

// CONSTRUCTION

UT_CMccInterface* UT_CMccInterface::NewL()

    {

    UT_CMccInterface* self = UT_CMccInterface::NewLC(); 

    CleanupStack::Pop();

    return self;

    }

UT_CMccInterface* UT_CMccInterface::NewLC()

    {

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

    CleanupStack::PushL( self );

    self->ConstructL(); 

    return self;

    }

// Destructor (virtual by CBase)

UT_CMccInterface::~UT_CMccInterface()

    {

    }

// Default constructor

UT_CMccInterface::UT_CMccInterface()

    {

    iNetsettings.iRemoteAddress = KInetAddrLoop;

    iNetsettings.iLocalRtcpPort = 5000;

    iNetsettings.iRemoteRtcpPort = 5001;

    iNetsettings.iIapId = KTestIapId;

    }

// Second phase construct

void UT_CMccInterface::ConstructL()

    {

    // The ConstructL from the base class CEUnitTestSuiteClass must be called.

    // It generates the test case table.

    CEUnitTestSuiteClass::ConstructL();

    }

//  INHERITED FUNCTIONS

/**

* Callback function to receive media signalling

* @param aSignal Received media signal

* @return void

*/

void UT_CMccInterface::MccEventReceived( const TMccEvent& /*aEvent*/ )

    {

    }

/**

* Callback function to receive stream started event.

* @param aSessionId Session ID

* @param aLinkId Link ID

* @param aStreamId Stream ID

*/

void UT_CMccInterface::MccMediaStarted( TUint32 aSessionId,

                            TUint32 aLinkId,     

                            TUint32 aStreamId,

                            TUint32 /*aSinkSourceId*/ )

    {

    RDebug::Print( _L("\n/********************* CALLBACK FUNCTION UT_CMccInterface *****************************/") );

    RDebug::Print( _L("UT_CMccInterface::StreamStarted -- Stream Started SessionId = %d"), aSessionId );

    RDebug::Print( _L("UT_CMccInterface::StreamStarted -- Stream Started LinkId    = %d"), aLinkId );

    RDebug::Print( _L("UT_CMccInterface::StreamStarted -- Stream Started StreamId  = %d\n"), aStreamId );

 //   CActiveScheduler::Stop();

    }

/**

* Callback function to receive stream stopped event.

* @param aSessionId Session ID

* @param aLinkId Link ID

* @param aStreamId Stream ID

*/

void UT_CMccInterface::MccMediaStopped( TUint32 aSessionId,

                            TUint32 aLinkId,

                            TUint32 aStreamId,

                            TUint32 /*aSinkSourceId*/ )

    {

    RDebug::Print( _L("\n/********************* CALLBACK FUNCTION UT_CMccInterface *****************************/") );

    RDebug::Print( _L("UT_CMccInterface::StreamStopped -- Stream Stopped SessionId = %d"), aSessionId );

    RDebug::Print( _L("UT_CMccInterface::StreamStopped -- Stream Stopped LinkId    = %d"), aLinkId );

    RDebug::Print( _L("UT_CMccInterface::StreamStopped -- Stream Stopped StreamId  = %d\n"), aStreamId );

 //   CActiveScheduler::Stop();

    }

/**

* Callback function to receive stream paused event.

* @param aSessionId Session ID

* @param aLinkId Link ID

* @param aStreamId Stream ID

*/

void UT_CMccInterface::MccMediaPaused( TUint32 aSessionId,

                           TUint32 aLinkId,

                            TUint32 aStreamId,

                            TUint32 /*aSinkSourceId*/ )

    {

    RDebug::Print( _L("\n/********************* CALLBACK FUNCTION UT_CMccInterface *****************************/") );

    RDebug::Print( _L("UT_CMccInterface::StreamPaused -- Stream Paused SessionId = %d"), aSessionId );

    RDebug::Print( _L("UT_CMccInterface::StreamPaused -- Stream Paused LinkId    = %d"), aLinkId );

    RDebug::Print( _L("UT_CMccInterface::StreamPaused -- Stream Paused StreamId  = %d\n"), aStreamId );

 //   CActiveScheduler::Stop();

    }

/**

* Callback function to receive stream resumed event.

* @param aSessionId Session ID

* @param aLinkId Link ID

* @param aStreamId Stream ID

*/

void UT_CMccInterface::MccMediaResumed( TUint32 aSessionId,

                            TUint32 aLinkId,

                            TUint32 aStreamId,

                            TUint32 /*aSinkSourceId*/ )

    {

    RDebug::Print( _L("\n/********************* CALLBACK FUNCTION UT_CMccInterface *****************************/") );

    RDebug::Print( _L("UT_CMccInterface::StreamResumed -- Stream Resumed SessionId = %d"), aSessionId );

    RDebug::Print( _L("UT_CMccInterface::StreamResumed -- Stream Resumed LinkId    = %d"), aLinkId );

    RDebug::Print( _L("UT_CMccInterface::StreamResumed -- Stream Resumed StreamId  = %d\n"), aStreamId );

 //   CActiveScheduler::Stop();

    }

/**

* Callback function to receive stream prepared event.

* @param aSessionId Session ID

* @param aLinkId Link ID

* @param aStreamId Stream ID

*/

void UT_CMccInterface::MccMediaPrepared( TUint32 aSessionId,

                             TUint32 aLinkId,

                            TUint32 aStreamId,

                            TUint32 /*aSinkSourceId*/ )

    {

    RDebug::Print( _L("\n/********************* CALLBACK FUNCTION UT_CMccInterface *****************************/") );

    RDebug::Print( _L("UT_CMccInterface::StreamPrepared -- Stream Prepared SessionId = %d"), aSessionId );

    RDebug::Print( _L("UT_CMccInterface::StreamPrepared -- Stream Prepared LinkId    = %d"), aLinkId );

    RDebug::Print( _L("UT_CMccInterface::StreamPrepared -- Stream Prepated StreamId  = %d\n"), aStreamId );

  //  CActiveScheduler::Stop();

    }

/**

* Callback function to receive stream inactivity event.

* @param aSessionId Session ID

* @param aLinkId Link ID

* @param aStreamId Stream ID

*/

void UT_CMccInterface::MccMediaInactive( TUint32 aSessionId,

                             TUint32 aLinkId,

                            TUint32 aStreamId,

                            TUint32 /*aSinkSourceId*/ )

    {

    RDebug::Print( _L("\n/********************* CALLBACK FUNCTION UT_CMccInterface *****************************/") );

    RDebug::Print( _L("UT_CMccInterface::StreamInactive -- Stream Prepared SessionId = %d"), aSessionId );

    RDebug::Print( _L("UT_CMccInterface::StreamInactive -- Stream Prepared LinkId    = %d"), aLinkId );

    RDebug::Print( _L("UT_CMccInterface::StreamInactive -- Stream Prepated StreamId  = %d\n"), aStreamId );

//    CActiveScheduler::Stop();

    }

/**

* Callback function to receive stream activity event.

* @param aSessionId Session ID

* @param aLinkId Link ID

* @param aStreamId Stream ID

*/

void UT_CMccInterface::MccMediaActive( TUint32 aSessionId,

                             TUint32 aLinkId,

                            TUint32 aStreamId,

                            TUint32 /*aSinkSourceId*/ )

    {

    RDebug::Print( _L("\n/********************* CALLBACK FUNCTION UT_CMccInterface *****************************/") );

    RDebug::Print( _L("UT_CMccInterface::StreamActive -- Stream Prepared SessionId = %d"), aSessionId );

    RDebug::Print( _L("UT_CMccInterface::StreamActive -- Stream Prepared LinkId    = %d"), aLinkId );

    RDebug::Print( _L("UT_CMccInterface::StreamActive -- Stream Prepated StreamId  = %d\n"), aStreamId ); 

 //   CActiveScheduler::Stop();

    }

/**

* Callback function to receive error event.

* @param aError Error code

* @return None

*/

void UT_CMccInterface::MccCtrlError( TInt /*aError*/ )

    {

    }

/**

* Callback function to receive error event.

* @param aError Error code

* @param aSessionId Session ID

* @param aLinkId Link ID

*/

void UT_CMccInterface::MccCtrlError( TInt /*aError*/,

                           TUint32 /*aSessionId*/,

                           TUint32 /*aLinkId*/,

                            TUint32 /*aStreamId*/,

                            TUint32 /*aSinkSourceId*/ )

    {

    }

// SETUP / TEARDOWN

void UT_CMccInterface::SetupL()

    {

    iInterface = CMccInterface::NewL( *this );

    } 

void UT_CMccInterface::Teardown()

    {

    delete iInterface;

    iInterface = NULL;

    }

// Create interface, session

void UT_CMccInterface::Setup2L(  )

    {

    iInterface = CMccInterface::NewL( *this );

    // Create session

    TInt error = iInterface->CreateSession( iSessionId );

    if ( ( error != KErrNone ) )

        {

        User::Leave( error );

        }

    } 

void UT_CMccInterface::Teardown2(  )

    {

    if( iInterface )

        {

        // Close session

        iInterface->CloseSession( iSessionId );

        delete iInterface;

        iInterface = NULL;

        }

    }

// TEST FUNCTIONS

//Create and close session

void UT_CMccInterface::UT_CMccInterface_CreateSessionL()

    {

    TInt error = iInterface->CreateSession( iSessionId );

    EUNIT_ASSERT_EQUALS( error, KErrNone );

    EUNIT_ASSERT( iSessionId >= 0 );

    TUint32 sessionId = 0;

    error = iInterface->CreateSession( sessionId );

    EUNIT_ASSERT_EQUALS( error, KErrNone );

    EUNIT_ASSERT( sessionId >= 0 );

    iInterface->CloseSession( iSessionId );

    iInterface->CloseSession( sessionId );

    }

void UT_CMccInterface::UT_CMccInterface_CreateLinkL(  )

    {

    TInt linkType = KMccLinkGeneral;

    //Wrong session number

    TInt error = iInterface->CreateLink( (iSessionId + 1),

                                         linkType,

                                         iUpLinkId,

                                         iNetsettings );

    EUNIT_ASSERT_EQUALS( error, KErrNotFound );                                        

    //Correct

    error = iInterface->CreateLink( iSessionId,

                                    linkType,

                                    iUpLinkId,

                                    iNetsettings );

    EUNIT_ASSERT_EQUALS( error, KErrNone );

    EUNIT_ASSERT( iUpLinkId >= 0 );

    if( error == KErrNone )

        {

        iInterface->CloseLink( iSessionId, iUpLinkId );    

        }

    }

void UT_CMccInterface::UT_CMccInterface_CreateStreamL(  )

    {

    //Create Uplink and start the stream

    TInt linkType = KMccLinkGeneral;

    TInt streamType = KMccAudioUplinkStream;

    TInt error = iInterface->CreateLink( iSessionId,

                                         linkType,

                                         iUpLinkId,

                                         iNetsettings );

    EUNIT_ASSERT_EQUALS( error, KErrNone );

    TUint32 streamId = 0;

    TUint32 endpointId = 0;

    RPointerArray<CMccCodecInformation> codecArray;

    CleanupResetAndDestroy< RPointerArray<CMccCodecInformation> >::PushL( codecArray );

    User::LeaveIfError( iInterface->GetCapabilities( codecArray ) );

    if( !codecArray.Count() )

        {

        User::Leave( KErrNotFound );

        }

    //Missing sink

	iInterface->AddDataSource( KUidMmfAudioInput, KNullDesC8, endpointId );

    error = iInterface->CreateStream( iSessionId, iUpLinkId, streamId, streamType, *codecArray[0] );

    EUNIT_ASSERT_EQUALS( error, KErrNotReady );

    //Create stream with wrong session id

	iInterface->AddDataSink( KUidMccRtpSink, KNullDesC8, endpointId );

    error = iInterface->CreateStream( ( iSessionId + 1 ), iUpLinkId, streamId, streamType, *codecArray[0] );

    EUNIT_ASSERT_EQUALS( error, KErrNotFound );

    //Correct

    error = iInterface->CreateStream( iSessionId, iUpLinkId, streamId, streamType, *codecArray[0] );

    EUNIT_ASSERT_EQUALS( error, KErrNone );

    if ( error == KErrNone )

        {

        iInterface->DeleteStream( iSessionId, iUpLinkId, streamId );

        }

    CleanupStack::Pop(); // codecarray

    codecArray.ResetAndDestroy();

    codecArray.Close();

    iInterface->CloseLink( iSessionId, iUpLinkId );

    }

void UT_CMccInterface::UT_CMccInterface_PrepareStreamL(  )

    {

    //Create Uplink, start and prepare the stream

    TInt linkType = KMccLinkGeneral;

    TInt streamType = KMccAudioUplinkStream;

    User::LeaveIfError( iInterface->CreateLink( iSessionId,

                                         linkType,

                                         iUpLinkId,

                                         iNetsettings ) );

    //EUNIT_ASSERT_EQUALS( error, KErrNone )

    TUint32 streamId = 0;

    TUint32 endpointId = 0;

    RPointerArray<CMccCodecInformation> codecArray;

    CleanupResetAndDestroy< RPointerArray<CMccCodecInformation> >::PushL( codecArray );

    User::LeaveIfError( iInterface->GetCapabilities( codecArray ) );

    if( !codecArray.Count() )

        {

        User::Leave( KErrNotFound );

        }

    //Add fmtp string to the codec

    _LIT8( KTxtFmtp, "a=fmtp:mode=30" );

    codecArray[0]->SetFmtpAttrL( KTxtFmtp );

    //Correct

	User::LeaveIfError( iInterface->AddDataSink( KUidMccRtpSink, KNullDesC8, endpointId ) );

	User::LeaveIfError( iInterface->AddDataSource( KUidMmfAudioInput, KNullDesC8, endpointId ) );        

    User::LeaveIfError( iInterface->CreateStream( iSessionId, iUpLinkId, streamId, streamType, *codecArray[0] ) );

    //EUNIT_ASSERT_EQUALS( error, KErrNone )

    //Prepare the stream

    //Correct

    User::LeaveIfError( iInterface->PrepareStream( iSessionId, iUpLinkId, streamId ) );

    //EUNIT_ASSERT_EQUALS( error, KErrNone )

    iInterface->DeleteStream( iSessionId, iUpLinkId, streamId );

    CleanupStack::Pop(); // codecarray

    codecArray.ResetAndDestroy();

    codecArray.Close();

    }

void UT_CMccInterface::UT_CMccInterface_StartStreamL(  )

    {

    //Create Uplink, Start, Pause, Resume and Stop the stream

    TInt linkType = KMccLinkGeneral;

    TInt streamType = KMccAudioUplinkStream;

    TInt error = iInterface->CreateLink( iSessionId,

                                         linkType,

                                         iUpLinkId,

                                         iNetsettings );

    EUNIT_ASSERT_EQUALS( error, KErrNone )

    TUint32 streamId = 0;

    TUint32 endpointId = 0;

    RPointerArray<CMccCodecInformation> codecArray;

    CleanupResetAndDestroy< RPointerArray<CMccCodecInformation> >::PushL( codecArray );

    User::LeaveIfError( iInterface->GetCapabilities( codecArray ) );

    if( !codecArray.Count() )

        {

        User::Leave( KErrNotFound );

        }

    /*

    If the active object has an observer interface, then the correct 

    completion and its status can be verified using a technique that 

    involves calling CActiveScheduler::Start() just after the 

    active object activation, and then CActiveScheduler::Stop() in 

    the observing method.

    The scheduler start call will cause a new event loop to be started, 

    so that the current event loop is halted. In other words, execution 

    in the test case method is halted at the scheduler start call. 

    When the asynchronous request is completed, the observer method will 

    be called in the newer scheduler loop. When CActiveScheduler::Stop() 

    is called in the observing method, the newest loop is terminated, 

    and execution continues in the test case method.

    */

	iInterface->AddDataSink( KUidMccRtpSink, KNullDesC8, endpointId );

	iInterface->AddDataSource( KUidMmfAudioInput, KNullDesC8, endpointId );        

    error = iInterface->CreateStream( iSessionId, iUpLinkId, streamId, streamType, *codecArray[0] );

    EUNIT_ASSERT_EQUALS( error, KErrNone )

    //Prepare the stream

    //Correct

    error = iInterface->PrepareStream( iSessionId, iUpLinkId, streamId );

//	CActiveScheduler::Start();

    EUNIT_ASSERT_EQUALS( error, KErrNone )

    //Start the stream

    error = iInterface->StartStream( iSessionId, iUpLinkId, streamId );

//    CActiveScheduler::Start();

    EUNIT_ASSERT_EQUALS( error, KErrNone )

    //Pause the stream

    error = iInterface->PauseStream( iSessionId, iUpLinkId, streamId );

//    CActiveScheduler::Start();

    EUNIT_ASSERT_EQUALS( error, KErrNone );

    //Resume the stream

    error = iInterface->ResumeStream( iSessionId, iUpLinkId, streamId );

//    CActiveScheduler::Start();

    EUNIT_ASSERT_EQUALS( error, KErrNone );

    //Stop the stream

    error = iInterface->StopStream( iSessionId, iUpLinkId, streamId );

//    CActiveScheduler::Start();

    EUNIT_ASSERT_EQUALS( error, KErrNone );

    iInterface->DeleteStream( iSessionId, iUpLinkId, streamId );

    CleanupStack::Pop(); // codecarray

    codecArray.ResetAndDestroy();

    codecArray.Close();

    iInterface->CloseLink( iSessionId, iUpLinkId );

    }

void UT_CMccInterface::UT_CMccInterface_StartStream2L(  )

    {

    //Create Downlink, Start, Pause, Resume and Stop the stream

    TInt linkType = KMccLinkGeneral;    

    TInt streamType = KMccAudioDownlinkStream;

    TInt error = iInterface->CreateLink( iSessionId,

                                     linkType,

                                     iDownLinkId,