/*

* 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_cmcemediamanager.h"

#include "MCETestHelper.h"

//  EXTERNAL INCLUDES

#include <digia/eunit/EUnitMacros.h>

#include <digia/eunit/CEUnitAllocTestCaseDecorator.h>

//  INTERNAL INCLUDES

#include "mcemediamanager.h"

#include "mcesdpsession.h"

#include "mcecomsession.h"

#include "mcecomaudiostream.h"

#include "mcemediaobserver.h"

#include "mceamrcodec.h"

#include "mceg711codec.h"

#include "mcemediasdpcodec.h"

#include "mcecommicsource.h"

#include "mcecomspeakersink.h"

#include "mcecomrtpsource.h"

#include "mcertpsource.h"

#include "mcertpsink.h"

#include "mcecomrtpsink.h"

#include "mcemicsource.h"

#include "mcespeakersink.h"

#include "mceamrcodec.h"

#include "mceadoptedsrvstream.h"

#include "mcemediadefs.h"

#include "CMccController_stub.h"

#include "mcemediastate.h"

#include "cleanupresetanddestroy.h"

const TInt KVideo = 0;

const TInt KCamera = 1;

const TInt KRtpSource = 0;

const TInt KCameraSource = 0;

const TInt KRtpSink = 0;

const TInt KDisplaySink = 0;

const TInt KAudio = 0;

const TInt KSpeakerSink = 0;

#define SRVSTREAM( n ) iSession->MccStreams()[ n ]

#define SRVUPDATESTREAM( n ) iUpdate->MccStreams()[ n ]

#define PREPARESRVSTREAMS( n )\

    if ( n )\

        {\

        for( TInt i=0;i<n;i++)\

            {\

            iSession->MccStreams()[i]->Id() = i+10;\

            }\

        }

#define SETUP( CreateStreamL )\

    iSession = MceMediaManagerTestHelper::CreateStreamL();\

    iSession->SetObserver( *iServer )

#define FULL_SETUP( CreateStreamL )\

    if ( !iSession )\

        {\

        SETUP( CreateStreamL );\

        }\

    iManager->CreateSessionL( *iSession )

#define SETUP_AND_PREPARE( CreateStreamL )\

    SETUP( CreateStreamL );\

    iSession->PrepareL( *iManager )

#define FULL_SETUP_AND_PREPARE( CreateStreamL )\

    FULL_SETUP( CreateStreamL );\

    iSession->PrepareL( *iManager )

// CONSTRUCTION

UT_CMceMediaManager* UT_CMceMediaManager::NewL()

    {

    UT_CMceMediaManager* self = UT_CMceMediaManager::NewLC(); 

    CleanupStack::Pop( self );

    return self;

    }

UT_CMceMediaManager* UT_CMceMediaManager::NewLC()

    {

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

    CleanupStack::PushL( self );

	self->ConstructL(); 

    return self;

    }

// Destructor (virtual by CBase)

UT_CMceMediaManager::~UT_CMceMediaManager()

    {

    }

// Default constructor

UT_CMceMediaManager::UT_CMceMediaManager():

	iSession( NULL )

    {

    }

// Second phase construct

void UT_CMceMediaManager::ConstructL()

    {

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

    // It generates the test case table.

    CEUnitTestSuiteClass::ConstructL();

    }

//  METHODS

void UT_CMceMediaManager::SetupL()

    {

	CMccControllerStub::OpenL();

    iMcc = CMccControllerStub::Stub();

    iServer = new (ELeave) CMceServerStub();

    iManager = CMceMediaManager::NewL( *iServer );

    RPointerArray<CMceComAudioCodec> audioCapabilities;

    RPointerArray<CMceComVideoCodec> videoCapabilities;

    MceCleanupResetAndDestroyPushL( audioCapabilities );

    MceCleanupResetAndDestroyPushL( videoCapabilities );

    iManager->GetCapabilitiesL( audioCapabilities );

    iManager->GetCapabilitiesL( videoCapabilities );

    CleanupStack::PopAndDestroy( 2 );//capas

    Reset();

    } 

void UT_CMceMediaManager::Setup_BasicL()

    {

	CMccControllerStub::OpenL();

    iMcc = CMccControllerStub::Stub();

    iServer = new (ELeave) CMceServerStub();

    iMcc->Reset();

    } 

void UT_CMceMediaManager::Teardown()

    {

    Reset();

	delete iSdpDocument; // received from the session

    iSdpDocument = NULL;

	CMceComSession::Delete( iUpdate, *iManager );

	CMceComSession::Delete( iSession, *iManager );

	delete iManager;

    iManager = NULL;

	delete iServer;

    iServer = NULL;

	CMccControllerStub::Close();

	iMcc = NULL;

    }

void UT_CMceMediaManager::UT_CMceMediaManager_BasicLL()

    {

    delete iManager;

    iManager = NULL;

	CMceMediaManager* manager = NULL;

	manager = CMceMediaManager::NewL( *iServer );

    CleanupStack::PushL( manager );

    EUNIT_ASSERT( iMcc->iActions[ 0 ].iAction == CMccControllerStub::EMccGetSupportedCodecs );

    CleanupStack::PopAndDestroy( manager );

    }

void UT_CMceMediaManager::Reset()

    {

    if ( CMccControllerStub::Stub() )

    	{

    	iMcc->Reset();

    	}

    iServer->Reset();

    }

//

// Tests

//

// CSdpDocument* EncodeL( CMceComSession& aSession )

//

///

void UT_CMceMediaManager::UT_CMceMediaManager_EncodeLL()

    {

    SETUP( CreateAudioOutSessionL );

    iSession->iClientCryptoSuites.Append( EAES_CM_128_HMAC_SHA1_32 );

    Reset();

    EUNIT_ASSERT( iSession->Streams().Count() == 1 );

    EUNIT_ASSERT( iSession->MccStreams().Count() == 0 );

    EUNIT_ASSERT( &iSession->NegotiationState() == NULL );

    EUNIT_ASSERT( &iSession->SdpSession() == NULL );

    EUNIT_ASSERT( iSession->iMccID == KMceNotAssigned );

    EUNIT_ASSERT( iManager->iMceSdpSessions.Count() == 0 );

    EUNIT_ASSERT( iManager->iSdpCodecs.Count() == 2 );

    //encode leaves

    MCE_EUNIT_ASSERT_LEAVE( iManager->EncodeL( *iSession ) );

    //update

    TMceReturnStatus status = iManager->UpdateL( *iSession );

    iSession->Modifier( KMceSecPreconditions ) = KMcePreconditionsE2ESupported;

    EUNIT_ASSERT( status == KMceAsync );

    //session asserts

    EUNIT_ASSERT( iSession->MccStreams().Count() == 2 );

    EUNIT_ASSERT( iSession->NegotiationState().Id() == KMcePreparingOffererStreams );

    EUNIT_ASSERT( &iSession->SdpSession() != NULL );

    EUNIT_ASSERT( iSession->SdpSession().MediaSession() == iSession );

    EUNIT_ASSERT( iSession->SdpSession().Backup() == NULL );

    EUNIT_ASSERT( iSession->iMccID == 0 );

    //server asserts

    EUNIT_ASSERT( iServer->iEvent == KMMTestNoValue );

    EUNIT_ASSERT( iServer->iSession == NULL );

	MCE_CHECK_MEMORY_LEAVE( iManager->iMceSdpSessions.Count() != 1 )

    //manager asserts

    EUNIT_ASSERT( iManager->iMceSdpSessions.Count() == 1 );

    //actions asserts

    EUNIT_ASSERT( iMcc->iActions[ 0 ].iAction == CMccControllerStub::EMccCreateSession );

    EUNIT_ASSERT( iMcc->iActions[ 1 ].iAction == CMccControllerStub::EMccCreateLink );

    EUNIT_ASSERT( iMcc->iActions[ 2 ].iAction == CMccControllerStub::ENone );

    //srvstream  asserts

    EUNIT_ASSERT( SRVSTREAM(0)->StreamType() == CMceComMediaStream::EReceiveStream );

    EUNIT_ASSERT( SRVSTREAM(0)->State() == CMceSrvStream::ECreatingLink );

    EUNIT_ASSERT( SRVSTREAM(1)->StreamType() == CMceComMediaStream::ESendStream );

    EUNIT_ASSERT( SRVSTREAM(1)->State() == CMceSrvStream::ECreatingLink );

    //encode leaves

    EUNIT_ASSERT_LEAVE( iManager->EncodeL( *iSession ) );

    Reset();

    //1. link created

    MceMediaManagerTestHelper::LinkCreated( *iManager, SRVSTREAM(0)->LinkId() );

	MCE_CHECK_MEMORY_LEAVE( iMcc->iActions[ 0 ].iAction != CMccControllerStub::EMccGetSourceId )

	//actions asserts

    EUNIT_ASSERT( iMcc->iActions[ 0 ].iAction == CMccControllerStub::EMccGetSourceId );

    EUNIT_ASSERT( iMcc->iActions[ 1 ].iAction == CMccControllerStub::EMccGetSinkId );

    EUNIT_ASSERT( iMcc->iActions[ 2 ].iAction == CMccControllerStub::EMccCreateStream );

    EUNIT_ASSERT( iMcc->iActions[ 3 ].iAction == CMccControllerStub::EMccSetCodec );

    MCE_CHECK_MEMORY_LEAVE( iMcc->iActions[ 4 ].iAction != CMccControllerStub::EMccGetSourceId )

    EUNIT_ASSERT( iMcc->iActions[ 4 ].iAction == CMccControllerStub::EMccGetSourceId );

    EUNIT_ASSERT( iMcc->iActions[ 5 ].iAction == CMccControllerStub::EMccGetSinkId );

    EUNIT_ASSERT( iMcc->iActions[ 6 ].iAction == CMccControllerStub::EMccCreateStream );

    EUNIT_ASSERT( iMcc->iActions[ 7 ].iAction == CMccControllerStub::EMccSetCodec );

    EUNIT_ASSERT( iMcc->iActions[ 8 ].iAction == CMccControllerStub::EMccPrepareStream );

    EUNIT_ASSERT( iMcc->iActions[ 9 ].iAction == CMccControllerStub::EMccPrepareStream );

    EUNIT_ASSERT( iMcc->iActions[ 10 ].iAction == CMccControllerStub::EMccGetSSRC );

    EUNIT_ASSERT( iMcc->iActions[ 11 ].iAction == CMccControllerStub::ENone );

    //srvstream  asserts

    EUNIT_ASSERT( SRVSTREAM(0)->StreamType() == CMceComMediaStream::EReceiveStream );

    EUNIT_ASSERT( SRVSTREAM(0)->State() == CMceSrvStream::EPreparing );

    EUNIT_ASSERT( SRVSTREAM(1)->StreamType() == CMceComMediaStream::ESendStream );

    EUNIT_ASSERT( SRVSTREAM(1)->State() == CMceSrvStream::EPreparing );

    Reset();

    //1. prepared

    iManager->MccMediaPrepared( iSession->iMccID,

                                SRVSTREAM(0)->LinkId(),

                                SRVSTREAM(0)->Id(),

                                SRVSTREAM(0)->Sink().Id() );

    MCE_MCC_EVENT_POSTCONDITION_L 

    iManager->MccMediaPrepared( iSession->iMccID,

                                SRVSTREAM(0)->LinkId(),

                                SRVSTREAM(0)->Id(),

                                SRVSTREAM(0)->Source().Id() );

    MCE_MCC_EVENT_POSTCONDITION_L 

    //session asserts

    EUNIT_ASSERT( iSession->NegotiationState().Id() == KMcePreparingOffererStreams );

    //server asserts

    EUNIT_ASSERT( iServer->iEvent == KMMTestNoValue );

    EUNIT_ASSERT( iServer->iSession == NULL );

    //actions asserts

    EUNIT_ASSERT( iMcc->iActions[ 0 ].iAction == CMccControllerStub::ENone );

    //srvstream asserts

    EUNIT_ASSERT( SRVSTREAM(0)->State() == CMceSrvStream::EPrepared );

    EUNIT_ASSERT( SRVSTREAM(1)->State() == CMceSrvStream::EPreparing );

    Reset();

    //2. prepared

    iManager->MccMediaPrepared( iSession->iMccID,

                                SRVSTREAM(1)->LinkId(),

                                SRVSTREAM(1)->Id(),

                                SRVSTREAM(1)->Sink().Id() );

    MCE_MCC_EVENT_POSTCONDITION_L                            

    iManager->MccMediaPrepared( iSession->iMccID,

                                SRVSTREAM(1)->LinkId(),

                                SRVSTREAM(1)->Id(),

                                SRVSTREAM(1)->Source().Id() );

    MCE_MCC_EVENT_POSTCONDITION_L 

	MCE_CHECK_MEMORY_LEAVE( iSession->NegotiationState().Id() != KMceStartingOffererReceiveStreams )

    //session asserts

    EUNIT_ASSERT( iSession->NegotiationState().Id() == KMceStartingOffererReceiveStreams );

    //server asserts

    EUNIT_ASSERT( iServer->iEvent == KMMTestNoValue );

    EUNIT_ASSERT( iServer->iSession == NULL );

    //actions asserts

    EUNIT_ASSERT( iMcc->iActions[ 0 ].iAction == CMccControllerStub::EMccStartStream );

    //always synchronizing

    EUNIT_ASSERT( iMcc->iActions[ 1 ].iAction == CMccControllerStub::EMccGetCodec );

    EUNIT_ASSERT( iMcc->iActions[ 2 ].iAction == CMccControllerStub::EMccSetCodec );

    EUNIT_ASSERT( iMcc->iActions[ 3 ].iAction == CMccControllerStub::ENone );

    //srvstream asserts

    EUNIT_ASSERT( SRVSTREAM(0)->State() == CMceSrvStream::EStarting );

    EUNIT_ASSERT( SRVSTREAM(1)->State() == CMceSrvStream::EPrepared );

    Reset();

    //1. started

    iManager->MccMediaStarted( iSession->iMccID,

                                SRVSTREAM(0)->LinkId(),

                                SRVSTREAM(0)->Id(),

                                KNoEndpointId );

    MCE_MCC_EVENT_POSTCONDITION_L 

	MCE_CHECK_MEMORY_LEAVE( iSession->NegotiationState().Id() != KMceOfferingMedia )

    //session asserts

    EUNIT_ASSERT( iSession->NegotiationState().Id() == KMceOfferingMedia );

    //server asserts

    EUNIT_ASSERT( iServer->iEvent == EMceMediaUpdated );

    EUNIT_ASSERT( iServer->iSession == iSession );

    //actions asserts

    EUNIT_ASSERT( iMcc->iActions[ 0 ].iAction == CMccControllerStub::ENone );

    //srvstream asserts

    EUNIT_ASSERT( SRVSTREAM(0)->State() == CMceSrvStream::EStarted );

    EUNIT_ASSERT( SRVSTREAM(1)->State() == CMceSrvStream::EPrepared );

    Reset();

    //encode 

    iSdpDocument = iManager->EncodeL( *iSession );

    HBufC8* sdpDocument = MceMediaManagerTestHelper::ToTextLC( *iSdpDocument );

    EUNIT_ASSERT( sdpDocument->Find( _L8("m=audio 5006 RTP/SAVP 96\r\n") ) > 0 );

    EUNIT_ASSERT( sdpDocument->Find( _L8("a=sendrecv\r\n") ) > 0 );

    EUNIT_ASSERT( sdpDocument->Find( _L8("a=fmtp:96 mode-set=0,1,2,3,4,5,6,7\r\n") ) > 0 );

    EUNIT_ASSERT( sdpDocument->Find( _L8("a=ptime:60\r\n") ) > 0 );

    EUNIT_ASSERT( sdpDocument->Find( _L8("a=maxptime:120\r\n") ) > 0 );

    EUNIT_ASSERT( sdpDocument->Find( _L8("a=client:session attribute 1\r\n") ) > 0 );

    EUNIT_ASSERT( sdpDocument->Find( _L8("a=client:session attribute 2\r\n") ) > 0 );

    EUNIT_ASSERT( sdpDocument->Find( _L8("a=client:media attribute 1\r\n") ) > 0 );

    EUNIT_ASSERT( sdpDocument->Find( _L8("a=client:media attribute 2\r\n") ) > 0 )

    EUNIT_ASSERT( sdpDocument->Find( _L8("a=curr:sec") ) > 0 );

    EUNIT_ASSERT( sdpDocument->Find( _L8("a=des:sec optional") ) > 0 );

    EUNIT_ASSERT( sdpDocument->Find( _L8("a=crypto:") ) > 0 );

    CleanupStack::PopAndDestroy( sdpDocument );

    //session asserts

    EUNIT_ASSERT( iSession->NegotiationState().Id() == KMceOfferingMedia );

    //server asserts

    EUNIT_ASSERT( iServer->iEvent == KMMTestNoValue );

    EUNIT_ASSERT( iServer->iSession == NULL );

    //actions asserts

    EUNIT_ASSERT( iMcc->iActions[ 0 ].iAction == CMccControllerStub::ENone );

    //srvstream asserts

    EUNIT_ASSERT( SRVSTREAM(0)->State() == CMceSrvStream::EStarted );

    EUNIT_ASSERT( SRVSTREAM(1)->State() == CMceSrvStream::EPrepared );

    RPointerArray<CSdpMediaField>& mediafields = iSdpDocument->MediaFields();

    EUNIT_ASSERT( mediafields.Count() == 1 );

    }

//

// Tests

//

// TMceSipWarningCode DecodeL( CMceComSession& aSession,

//                             CSdpDocument& aSdpDocument )

//

///

void UT_CMceMediaManager::UT_CMceMediaManager_DecodeLL()

    {

//

//Decode answer

//

    SETUP( CreateAudioOutSessionL );

    Reset();

    //update

    TMceReturnStatus status = iManager->UpdateL( *iSession );

    EUNIT_ASSERT( status == KMceAsync );

//decode leaves

    MCE_EUNIT_ASSERT_LEAVE( iManager->DecodeL( *iSession, *iSdpDocument ) );

//1. link created

    MceMediaManagerTestHelper::LinkCreated( *iManager, SRVSTREAM(0)->LinkId() );

//1. prepared

    iManager->MccMediaPrepared( iSession->iMccID,

                                SRVSTREAM(0)->LinkId(),

                                SRVSTREAM(0)->Id(),

                                SRVSTREAM(0)->Sink().Id() );

    MCE_MCC_EVENT_POSTCONDITION_L 

    iManager->MccMediaPrepared( iSession->iMccID,

                                SRVSTREAM(0)->LinkId(),

                                SRVSTREAM(0)->Id(),

                                SRVSTREAM(0)->Source().Id() );

    MCE_MCC_EVENT_POSTCONDITION_L 

//2. prepared

    iManager->MccMediaPrepared( iSession->iMccID,

                                SRVSTREAM(1)->LinkId(),

                                SRVSTREAM(1)->Id(),

                                SRVSTREAM(1)->Sink().Id() );

    MCE_MCC_EVENT_POSTCONDITION_L 

    iManager->MccMediaPrepared( iSession->iMccID,

                                SRVSTREAM(1)->LinkId(),

                                SRVSTREAM(1)->Id(),

                                SRVSTREAM(1)->Source().Id() );

    MCE_MCC_EVENT_POSTCONDITION_L 

//1. started

    iManager->MccMediaStarted( iSession->iMccID,

                                SRVSTREAM(0)->LinkId(),

                                SRVSTREAM(0)->Id(),

                                SRVSTREAM(0)->Sink().Id() );

    MCE_MCC_EVENT_POSTCONDITION_L 

    iManager->MccMediaStarted( iSession->iMccID,

                                SRVSTREAM(0)->LinkId(),

                                SRVSTREAM(0)->Id(),

                                SRVSTREAM(0)->Source().Id() );

    MCE_MCC_EVENT_POSTCONDITION_L 

    Reset();

//encode 

    iSdpDocument = iManager->EncodeL( *iSession );

    //session asserts

    EUNIT_ASSERT( iSession->NegotiationState().Id() == KMceOfferingMedia );

    //server asserts

    EUNIT_ASSERT( iServer->iEvent == KMMTestNoValue );

    EUNIT_ASSERT( iServer->iSession == NULL );

    //actions asserts

    EUNIT_ASSERT( iMcc->iActions[ 0 ].iAction == CMccControllerStub::ENone );

    //srvstream asserts

    EUNIT_ASSERT( SRVSTREAM(0)->State() == CMceSrvStream::EStarted );

    EUNIT_ASSERT( SRVSTREAM(1)->State() == CMceSrvStream::EPrepared );

    RPointerArray<CSdpMediaField>& mediafields = iSdpDocument->MediaFields();

    EUNIT_ASSERT( mediafields.Count() == 1 );

    delete iSdpDocument;

    iSdpDocument = NULL;

    iSdpDocument = CSdpDocument::DecodeL( KMceMMTestSdpAnswerAudioIMS5PrecsSendrecv );

    Reset();

//decode answer

    iSession->AnswerType() = KMceNegotiationAnswerTypeFinal;

    TMceSipWarningCode decodeStatus = iManager->DecodeL( *iSession, *iSdpDocument );

    EUNIT_ASSERT( decodeStatus == KErrNone );

    //session asserts

    EUNIT_ASSERT( iSession->NegotiationState().Id() == KMceOfferingMedia );

    //server asserts

    EUNIT_ASSERT( iServer->iEvent == KMMTestNoValue );

    EUNIT_ASSERT( iServer->iSession == NULL );

    //actions asserts

    EUNIT_ASSERT( iMcc->iActions[ 0 ].iAction == CMccControllerStub::ENone );

    //srvstream asserts

    EUNIT_ASSERT( SRVSTREAM(0)->State() == CMceSrvStream::EStarted );

    EUNIT_ASSERT( SRVSTREAM(1)->State() == CMceSrvStream::EPrepared );

    CMceComSession::Delete( iSession, *iManager );

    Reset();

//

//Decode offer

//