/*

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

//  EXTERNAL INCLUDES

#include <digia/eunit/EUnitMacros.h>

#include <in_sock.h>

//  INTERNAL INCLUDES

#include <SdpCodecStringConstants.h>

#include <SdpCodecStringPool.h>

#include <sdpdocument.h>

#include <SdpOriginField.h>

#include <SdpConnectionField.h>

#include <SdpMediaField.h>

#include <SdpAttributeField.h>

#include <SdpFmtAttributeField.h>

#include <SdpRtpmapValue.h>

#include <sdpbandwidthfield.h>

#include "mcesdpsession.h"

#include "mcecomsession.h"

#include "mcecomaudiostream.h"

#include "mcecomvideostream.h"

#include "mcecomvideocodec.h"

#include "mcemediamanager.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 "mcecomamrcodec.h"

#include "mceaudiosdpcodec.h"

#include "mcevideosdpcodec.h"

#include "mcecomcamerasource.h"

#include "mcecomdisplaysink.h"

#include "mcecomh263codec.h"

#include "cleanupresetanddestroy.h"

#include "CMccController_stub.h"

#include "mcemedianegotiated.h"

#include "mcemediamanagertesthelper.h"

#include "mcemediadefs.h"

#include "mcenatpluginmanager.h"

#include "mmcccodecinformation.h"

_LIT8( KMceMMTestSdpMessage_AudioVideo_sendrecv_MT_NOK, "v=0\r\n\

o=mhandley 2890844526 2890842807 IN IP4 126.16.64.4\r\n\

s=SDP	Seminar\n\

i=A Seminar on the session description protocol\r\n\

u=http://www.cs.ucl.ac.uk/staff/M.Handley/sdp.03.ps\r\n\

e=mjh@isi.edu (Mark Handley)\r\n\

e=j.doe@example.com (Jane Doe)\r\n\

p=+44-171-380-7777\r\n\

p=+1 617 555 6011\r\n\

c=IN IP4 510.21.32.148\r\n\

b=X-YZ:128\r\n\

t=0 0\r\n\

r=604800 3600 0 90000\r\n\

t=2873397496 2873404696\r\n\

z=2882844526 -1h 2898848070 0\r\n\

k=uri:http://www.cs.ucl.ac.uk/staff/M.Handley/sdp.03.ps\r\n\

a=sendrecv\r\n\

a=orient:landscape\r\n\

m=application 32416/234 udp wb\r\n\

a=orient:portrait\r\n\

m=audio 49170 RTP/AVP 0 96\r\n\

c=IN IP4 224.2.17.88/127\r\n\

a=rtpmap:96 AMR/8000/1\r\n\

a=fmtp:96 mode-set=0,2; octet-align=0\r\n\

a=sendrecv\r\n\

i=A Seminar on the session description protocol\r\n\

b=X-YZ:128\r\n\

m=video 51372 RTP/AVP 106\r\n\

c=IN IP4 224.2.17.88/127\r\n\

a=rtpmap:106 H263-2000/90000\r\n\

a=fmtp:106 profile=0;level=10\r\n\

a=sendrecv\r\n");

_LIT8( KMceMMTestSdpMessage_MT_Confield_In_MediaLine, "v=0\r\n\

o=- 123 123 IN IP4 10.36.7.239\r\n\

s=-\r\n\

t=0 0\r\n\

m=audio 5000/1 RTP/AVP 96\r\n\

c=IN IP4 10.36.7.239\r\n\

a=rtpmap:96 AMR/8000\r\n");

_LIT8( KMceMMTestSdpMessage_MT_No_rtpmap, "v=0\r\n\

o=- 123 123 IN IP4 10.36.7.239\r\n\

s=-\r\n\

c=IN IP4 10.36.7.239\r\n\

t=0 0\r\n\

m=audio 5000/1 RTP/AVP 96\r\n\

");

_LIT8( KMceTestSdpAMR, "v=0\r\n\

o=userb 1234567890 1234567890 IN IP4 10.20.180.72\r\n\

s=-\r\n\

i=-\r\n\

c=IN IP4 10.20.180.72\r\n\

t=0 0\r\n\

a=ptime:20\r\n\

a=maxptime:400\r\n\

m=audio 5078 RTP/AVP 96\r\n\

a=sendrecv\r\n\

a=curr:qos local sendrecv\r\n\

a=curr:qos remote none\r\n\

a=des:qos mandatory local sendrecv\r\n\

a=des:qos none remote sendrecv\r\n\

a=rtpmap:96 AMR/8000\r\n\

a=ptime:20\r\n\

a=maxptime:400\r\n\

a=fmtp:96 octet-align=0; mode-set=0,1,2,3,4,5,6,7\r\n");

_LIT8( KMceTestSdpAMRWithb, "v=0\r\n\

o=userb 1234567890 1234567890 IN IP4 10.20.180.72\r\n\

s=-\r\n\

i=-\r\n\

c=IN IP4 10.20.180.72\r\n\

b=AS:80\r\n\

t=0 0\r\n\

a=ptime:20\r\n\

a=maxptime:400\r\n\

m=audio 5078 RTP/AVP 96\r\n\

a=sendrecv\r\n\

a=curr:qos local sendrecv\r\n\

a=curr:qos remote none\r\n\

a=des:qos mandatory local sendrecv\r\n\

a=des:qos none remote sendrecv\r\n\

a=rtpmap:96 AMR/8000\r\n\

a=ptime:20\r\n\

a=maxptime:400\r\n\

a=fmtp:96 octet-align=0; mode-set=0,1,2,3,4,5,6,7\r\n");

_LIT8( KOffer, "v=0\r\n\

o=- 123 123 IN IP4 10.36.7.239\r\n\

s=-\r\n\

t=0 0\r\n\

m=audio 5000/1 RTP/AVP 96\r\n\

c=IN IP4 10.36.7.239\r\n\

a=rtpmap:96 AMR/8000\r\n");

_LIT8( KOfferOldSchoolOrigin, "v=0\r\n\

o=- 123 123 IN IP4 0.0.0.0\r\n\

s=-\r\n\

t=0 0\r\n\

m=audio 5000/1 RTP/AVP 96\r\n\

c=IN IP4 10.36.7.239\r\n\

a=rtpmap:96 AMR/8000\r\n");

_LIT8( KMceSdpMediaFieldOld, "v=0\r\n\

o=- 123 123 IN IP4 0.0.0.0\r\n\

s=-\r\n\

t=0 0\r\n\

m=audio 5000/1 RTP/AVP 96\r\n\

c=IN IP4 10.36.7.239\r\n\

a=rtpmap:0 PCMU/8000\r\n");

_LIT8( KMceSdpMediaFieldNew, "v=0\r\n\

o=- 123 123 IN IP4 0.0.0.0\r\n\

s=-\r\n\

t=0 0\r\n\

m=audio 5000/1 RTP/AVP 96\r\n\

c=IN IP4 10.36.7.239\r\n\

a=rtpmap:0 AMR/8000\r\n");

_LIT8( KConnectionField1, "v=0\r\n\

o=- 123 123 IN IP4 0.0.0.0\r\n\

s=-\r\n\

t=0 0\r\n\

m=audio 5000/1 RTP/AVP 96\r\n\

c=IN IP4 10.36.7.239\r\n\

a=rtpmap:96 AMR/8000\r\n\

m=video 0 RTP/AVP 97\r\n\

c=IN IP4 193.65.182.50\r\n");

_LIT8( KConnectionField2, "v=0\r\n\

o=- 123 123 IN IP4 0.0.0.0\r\n\

s=-\r\n\

t=0 0\r\n\

m=audio 5000/1 RTP/AVP 96\r\n\

a=rtpmap:96 AMR/8000\r\n\

m=video 0 RTP/AVP 97\r\n\

c=IN IP4 193.65.182.50\r\n");

#define SDP_STRING_L( stringIndex )\

    SdpCodecStringPool::StringPoolL().StringF( stringIndex, SdpCodecStringPool::StringTableL() )

// CONSTRUCTION

UT_CMceSdpSession* UT_CMceSdpSession::NewL()

    {

    UT_CMceSdpSession* self = UT_CMceSdpSession::NewLC(); 

    CleanupStack::Pop();

    return self;

    }

UT_CMceSdpSession* UT_CMceSdpSession::NewLC()

    {

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

    CleanupStack::PushL( self );

	self->ConstructL(); 

    return self;

    }

// Destructor (virtual by CBase)

UT_CMceSdpSession::~UT_CMceSdpSession()

    {

    }

// Default constructor

UT_CMceSdpSession::UT_CMceSdpSession()

    {

    }

// Second phase construct

void UT_CMceSdpSession::ConstructL()

    {

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

    // It generates the test case table.

    CEUnitTestSuiteClass::ConstructL();

    }

//  METHODS

void UT_CMceSdpSession::SetupL(  )

    {

    SIPStrings::OpenL();

    iMcc = CMccControllerStub::Stub();

    iServer = new (ELeave) CMceServerStub();

    iManager = CMceMediaManager::NewL( *this );

    // Make a dummy call to NatEnabled() to cause plugin to be loaded.

    // When the actual test case function

    // (e.g. UT_CMceSdpSession_DecodeOfferLL_CreateAnswer_OK_1) uses the plugin,

    // it is already loaded. Because if the test function would load the plugin,

    // then EUnit reports a memory leak, since the plugin is unloaded in

    // Teardown().

    iManager->NatPluginManager().NatEnabledL();

    RPointerArray<CMceComAudioCodec> audioCapabilities;

    RPointerArray<CMceComVideoCodec> videoCapabilities;

    MceCleanupResetAndDestroyPushL( audioCapabilities );

    MceCleanupResetAndDestroyPushL( videoCapabilities );

    iManager->GetCapabilitiesL( audioCapabilities );

    iManager->GetCapabilitiesL( videoCapabilities );

    CleanupStack::PopAndDestroy( 2 );//capas

    __ASSERT_ALWAYS( iManager->iSdpCodecs.Count() >= 2, User::Leave( KErrNotFound ) );

    iAudioSdpCodec = static_cast<CMceMediaSdpCodec*>( iManager->iSdpCodecs[ 0 ] );

    iVideoSdpCodec = static_cast<CMceMediaSdpCodec*>( iManager->iSdpCodecs[ 1 ] );

    iAudio = SdpCodecStringPool::StringPoolL().StringF( 

    											SdpCodecStringConstants::EMediaAudio, 

												SdpCodecStringPool::StringTableL());

    iVideo = SdpCodecStringPool::StringPoolL().StringF( 

    											SdpCodecStringConstants::EMediaVideo, 

												SdpCodecStringPool::StringTableL());

	iProtocol = SdpCodecStringPool::StringPoolL().StringF( 

												SdpCodecStringConstants::EProtocolRtpAvp, 

												SdpCodecStringPool::StringTableL() );

	iAudioOutSession = CreateSessionWithDowlinkL();

	iVideoOutSession = CreateSessionWithVideoDowlinkL();

    iInSession = CMceComSession::NewL(CMceComSession::EInSession);

    iAudioOutSession->SetObserver( *iServer );

    iVideoOutSession->SetObserver( *iServer );

    iInSession->SetObserver( *iServer );

    iSdpSession = CMceSdpSession::NewL( *iAudioOutSession, *iManager ); 

    iAudioOutSession->AttachSDPSessionL( *iSdpSession );

    } 

void UT_CMceSdpSession::Teardown(  )

    {

    CMceComSession::Delete( iAudioOutSession, *iManager );

    CMceComSession::Delete( iVideoOutSession, *iManager );

    CMceComSession::Delete( iInSession, *iManager );

	delete iServer;

	iServer = NULL;

    delete iSdpSession;

    iSdpSession = NULL;

    delete iManager;

	iManager = NULL;

	CMccControllerStub::Close();

	iMcc = NULL;

    SIPStrings::Close();

    }

// ---------------------------------------------------------

// Test offers and answers containing audio

// ---------------------------------------------------------    

//

void UT_CMceSdpSession::UT_CMceSdpSession_MatchingStreamsToMLinesL()

    {

    RPointerArray<CMceComMediaStream>& streams = iAudioOutSession->Streams();

    CMceComAMRCodec *amr = CMceComAMRCodec::NewL(_L8("PCMU"));

	CleanupStack::PushL( amr );

	amr->iSamplingFreq = 6000;

	amr->iPayloadType = 99;

	CMceComAudioStream* audio = static_cast <CMceComAudioStream*> (streams[0]);

    audio->AddCodecL( static_cast <CMceComAudioCodec*> ( amr ));

    CleanupStack::Pop( amr );

    CSdpDocument* sdpDocument = CSdpDocument::NewLC();

    RPointerArray< CSdpMediaField >& mediaLines = sdpDocument->MediaFields();

    CSdpMediaField* mediaLine = iSdpSession->CreateMediaLineLC( *audio );

    mediaLines.AppendL( mediaLine );

    CleanupStack::Pop( mediaLine );

    iSdpSession->MatchingStreamsToMLinesL(*sdpDocument, *iAudioOutSession);

    CleanupStack::PopAndDestroy( sdpDocument );   

    sdpDocument = NULL;

    mediaLine = NULL;

    /////

    ///// one stream and two media line

    sdpDocument = CSdpDocument::NewLC();

    mediaLines = sdpDocument->MediaFields();

    RPointerArray<CMceComMediaStream>& videoStreams = iVideoOutSession->Streams();

    CMceComVideoStream* video = static_cast <CMceComVideoStream*> (videoStreams[0]);

    mediaLine = iSdpSession->CreateMediaLineLC( *video );

    mediaLines.AppendL( mediaLine );

    CleanupStack::Pop( mediaLine );

    mediaLine = NULL;

    mediaLine = iSdpSession->CreateMediaLineLC( *audio );

    mediaLines.AppendL( mediaLine );

    CleanupStack::Pop( mediaLine );

    mediaLine = NULL;

    iSdpSession->MatchingStreamsToMLinesL(*sdpDocument, *iAudioOutSession);

    CleanupStack::PopAndDestroy( sdpDocument );   

    sdpDocument = NULL;

    }

void UT_CMceSdpSession::UT_CMceSdpSession_DecodePullModeUpdateMediaLineL()

    {    

    RPointerArray<CMceComMediaStream>& streams = iAudioOutSession->Streams();

    CMceComAMRCodec *amr = CMceComAMRCodec::NewL(_L8("PCMU"));

	CleanupStack::PushL( amr );

	amr->iSamplingFreq = 6000;

	amr->iPayloadType = 99;

    CMceComAudioStream* audio = static_cast <CMceComAudioStream*> (streams[0]);

	audio->SdpIndex() = 1;

    audio->AddCodecL( static_cast <CMceComAudioCodec*> ( amr ));

    CleanupStack::Pop( amr );

    CSdpDocument* sdpDocument = CSdpDocument::NewLC();

    RPointerArray< CSdpMediaField >& mediaLines = sdpDocument->MediaFields();

    RPointerArray<CMceComMediaStream>& videoStreams = iVideoOutSession->Streams();

    CMceComVideoStream* video = static_cast <CMceComVideoStream*> (videoStreams[0]);

    CSdpMediaField* mediaLine1 = iSdpSession->CreateMediaLineLC( *video );

    mediaLines.InsertL( mediaLine1, 0 );

    CleanupStack::Pop( mediaLine1 );

    CSdpMediaField* mediaLine2 = iSdpSession->CreateMediaLineLC( *audio );

    mediaLines.AppendL( mediaLine2 );

    CleanupStack::Pop( mediaLine2 );

    CMceSdpCodec* sdpCodec1 = iSdpSession->Manager().SdpCodec( *mediaLine1 );

    CMceSdpCodec* sdpCodec2 = iSdpSession->Manager().SdpCodec( *mediaLine2 );

    EUNIT_ASSERT_SPECIFIC_LEAVE( iSdpSession->DecodePullModeUpdateMediaLineL( 

        *sdpDocument, *iAudioOutSession, *mediaLine1, 0, *sdpCodec1 ), KErrNotFound );

    mediaLine1->SetPortL(0);

    EUNIT_ASSERT_NO_LEAVE(iSdpSession->DecodePullModeUpdateMediaLineL( 

        *sdpDocument, *iAudioOutSession, *mediaLine1, 0, *sdpCodec1 ));

    mediaLine2->KeepFormatL(_L8("97"));

    EncodeDirectionAttrL( *mediaLine2, SdpCodecStringConstants::EAttributeSendonly );

    EUNIT_ASSERT_LEAVE(iSdpSession->DecodePullModeUpdateMediaLineL( 

        *sdpDocument, *iAudioOutSession, *mediaLine2, 1, *sdpCodec2 ) );

    CleanupStack::PopAndDestroy( sdpDocument );

    }

void UT_CMceSdpSession::UT_CMceSdpSession_CreateOfferLL_OK_1(  )

    { 

    CSdpDocument* sdp = iSdpSession->CreateOfferL( *iAudioOutSession );

    CleanupStack::PushL( sdp );

    CSdpOriginField* origin = sdp->OriginField();

    const TDesC8& username = origin->UserName();

    TInt64 sessionid = origin->SessionId(); 

    RStringF attr = origin->NetType();

    RStringF addr = origin->AddressType();

    EUNIT_ASSERT( attr == SdpCodecStringPool::StringPoolL().StringF( 

  									SdpCodecStringConstants::ENetType, 

         							SdpCodecStringPool::StringTableL() ));

	EUNIT_ASSERT( addr == SdpCodecStringPool::StringPoolL().StringF( 

  									SdpCodecStringConstants::EAddressTypeIP4, 

         							SdpCodecStringPool::StringTableL() ));

    const TDesC8& inet = origin->Address();

    const TDesC8& sessionname = sdp->SessionName();

    CSdpConnectionField* conn = sdp->ConnectionField();

    RStringF attr2 = conn->NetType();

    RStringF addr2 = conn->AddressType();

    EUNIT_ASSERT( attr2 == SdpCodecStringPool::StringPoolL().StringF( 

  									SdpCodecStringConstants::ENetType, 

         							SdpCodecStringPool::StringTableL() ));

	EUNIT_ASSERT( addr2 == SdpCodecStringPool::StringPoolL().StringF( 

  									SdpCodecStringConstants::EAddressTypeIP4, 

         							SdpCodecStringPool::StringTableL() ));

    const TDesC8& inet2 = conn->Address();

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

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

    CleanupStack::PopAndDestroy( sdp );

    }

void UT_CMceSdpSession::UT_CMceSdpSession_CreateOfferLL_REFRESH_OK_1(  )

	{

	// Create the SDP document with a different port 

	// than in the iAudioOutSession

	CSdpDocument* originalSdpDocument = 

	    CSdpDocument::DecodeLC( KMceTestSdpAMR );

	iSdpSession->iSdpDocument = originalSdpDocument;

	EUNIT_ASSERT( originalSdpDocument->MediaFields()[0]->IsValid() )

	originalSdpDocument->MediaFields()[0]->SetPortL( 

	    iAudioOutSession->Streams()[0]->LocalMediaPort() + 1 );

	iSdpSession->iOldLocalMediaPort = iAudioOutSession->Streams()[0]->LocalMediaPort();

	//assign the offer type to refresh, and get the new sdp

	CSdpDocument* offeredSdp = 

	    iSdpSession->CreateOfferL( *iAudioOutSession, CMceSdpSession::ERefresh );

	EUNIT_ASSERT( offeredSdp == originalSdpDocument )

	//test that whether the port is changed

	EUNIT_ASSERT( offeredSdp->MediaFields()[0]->IsValid());

	EUNIT_ASSERT_EQUALS( 

	    iAudioOutSession->Streams()[0]->LocalMediaPort(), 

	    offeredSdp->MediaFields()[0]->Port() )

	CleanupStack::PopAndDestroy( originalSdpDocument );

	}

void UT_CMceSdpSession::UT_CMceSdpSession_CreateOfferLL_NOK_1(  )

    {

	CMceComSession* session = CMceComSession::NewL(CMceComSession::EOutSession);

	CleanupStack::PushL( session );

	session->AddStreamL( NULL );

    iSdpSession->SetMediaSession( session );

    EUNIT_ASSERT_LEAVE( CSdpDocument* sdp = iSdpSession->CreateOfferL( *session ));

    delete iSdpSession->iSdpDocument;

    CleanupStack::Pop( session );

    CMceComSession::Delete( session, *iManager );

    }

void UT_CMceSdpSession::UT_CMceSdpSession_DecodeAnswerLL_OK_1(  )