/*

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

//  EXTERNAL INCLUDES

#include <digia/eunit/eunitmacros.h>

//  INTERNAL INCLUDES

#include "rtpmanager.h"

const TUint KIap1 = 0;

const TUint KIAPID = 6;

const TUint KIap2 = 1;

const TInt KLength = 20;

_LIT8(KHello, "hello...testing");

#define RTP_EUNIT_ASSERT_SPECIFIC_LEAVE( func, leaveCode ) \

TRAPD( leaveErr, func );\

if ( leaveErr == KErrNoMemory )\

    {\

    User::Leave( KErrNoMemory );\

    }\

else\

    {\

    EUNIT_ASSERT_EQUALS( leaveErr, leaveCode );\

    }

#define RTP_EUNIT_ASSERT_EQUALS( func, val2 ) \

{TInt val1 = func;\

if ( val2 != KErrNoMemory && val1 == KErrNoMemory ){\

	User::Leave( KErrNoMemory );\

	}\

else{\

	EUNIT_ASSERT_EQUALS( val1, val2 );\

	}}

// CONSTRUCTION

UT_CRtpManager* UT_CRtpManager::NewL()

    {

    UT_CRtpManager* self = UT_CRtpManager::NewLC();

    CleanupStack::Pop();

    return self;

    }

UT_CRtpManager* UT_CRtpManager::NewLC()

    {

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

    CleanupStack::PushL( self );

    self->ConstructL();

    return self;

    }

// Destructor (virtual by CBase)

UT_CRtpManager::~UT_CRtpManager()

    {

    }

// Default constructor

UT_CRtpManager::UT_CRtpManager()

    {

    }

// Second phase construct

void UT_CRtpManager::ConstructL()

    {

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

    // It generates the test case table.

    CEUnitTestSuiteClass::ConstructL();

    }

//  METHODS

void UT_CRtpManager::ErrorNotify( TInt /*aErrCode*/ ) 

	{

	}

void UT_CRtpManager::SetupL(  )

    {

	TCommDbConnPref prefs;

    prefs.SetDialogPreference( ECommDbDialogPrefDoNotPrompt );	

	prefs.SetDirection( ECommDbConnectionDirectionOutgoing );

    prefs.SetIapId( KIAPID );//6

    TInt err( KErrCouldNotConnect );

    // Opens a session to the socket server

    // i.e. creates an IPC communication channel to the socket server

    if ( ( err = iSocketServ.Connect() ) != KErrNone )

    	{

    	EUNIT_ASSERT( err==KErrNone );

    	}

    // Opens a new RConnection instance

    else if (( err = iConnection.Open( iSocketServ )) != KErrNone )

       	{

		iConnection.Close(); 

		EUNIT_ASSERT( err==KErrNone );

        }

    else if (( err = iConnection.Start( prefs )) != KErrNone )

        {	

        iConnection.Close();

        EUNIT_ASSERT( err==KErrNone );

        }

 	err = iSocket.Open( iSocketServ, 

                                  KAfInet,

                                  KSockDatagram, 

                                  KProtocolInetUdp, 

                                  iConnection 

                                );   

	iRtpManager = CRtpManager::NewL( *this );

    }

void UT_CRtpManager::Teardown(  )

    {

	delete iRtpManager; iRtpManager=NULL;

	iSocket.Close(); 

	iConnection.Stop();

    iConnection.Close(); 

    iSocketServ.Close(); 

    }

void UT_CRtpManager::UT_CRtpManager_NewLL(  )

    {

    EUNIT_ASSERT( ETrue );

    }

void UT_CRtpManager::UT_CRtpManager_OpenLL(  )

    {

    TInt result(KErrNone);

    TRtpSdesParams params;

    TPtrC16 fileName( _L16( "rtppacket.dll" ) );

    const TDesC16* temp= &fileName;

    RTP_EUNIT_ASSERT_SPECIFIC_LEAVE(iRtpManager->

    		OpenL( params, temp, &iSocketServ, &iConnection ), KErrNotFound);

    }

void UT_CRtpManager::UT_CRtpManager_StartConnectionL(  )

    {

    TInt result(KErrNone);

    TRtpSdesParams params;

    iRtpManager->OpenL( params, NULL, &iSocketServ, &iConnection );

    RTP_EUNIT_ASSERT_EQUALS(iRtpManager->StartConnection(KIAPID), KErrNone);

    iRtpManager->Close();

    }

    {

    TInt result(KErrNone);

    TRtpSdesParams params;

    iRtpManager->OpenL( params, NULL, &iSocketServ, &iConnection );

    iSocketServ.iNextError = KErrNotReady;

    RTP_EUNIT_ASSERT_EQUALS(iRtpManager->StartConnection(KIAPID), KErrNotReady);

    iSocketServ.iNextError = KErrNone;

    iRtpManager->Close();

    }

    {

    TInt result(KErrNone);

    TRtpSdesParams params;

    iRtpManager->OpenL( params, NULL, &iSocketServ, &iConnection );

    iConnection.iNextError = KErrNotReady;

    RTP_EUNIT_ASSERT_EQUALS(iRtpManager->StartConnection(KIAPID), KErrNotReady);

    iConnection.iNextError = KErrNone;

    iRtpManager->Close();

    }

void UT_CRtpManager::UT_CRtpManager_CancelStartL(  )

    {

    EUNIT_ASSERT( ETrue );

    }

void UT_CRtpManager::UT_CRtpManager_CloseL(  )

    {

    EUNIT_ASSERT( ETrue );

    }

void UT_CRtpManager::UT_CRtpManager_SetLocalSdesL(  )

    {

    EUNIT_ASSERT( ETrue );

    }

void UT_CRtpManager::UT_CRtpManager_GetLocalIPAddressL1L(  )

    {

    TInt result(KErrNone);

    TRtpSdesParams params;

    iRtpManager->OpenL( params, NULL, &iSocketServ, &iConnection );

    RTP_EUNIT_ASSERT_EQUALS(iRtpManager->StartConnection(0), KErrNone);

    iRtpManager->iIapId = 0;

    EUNIT_ASSERT_SPECIFIC_LEAVE( iRtpManager->GetLocalIPAddressL(), 

    				KErrNotSupported);

    iRtpManager->iIapId=KIAPID;				

    iRtpManager->Close();				

    }

 void UT_CRtpManager::UT_CRtpManager_GetLocalIPAddressL2L(  )

    {

    TInt result(KErrNone);

    TRtpSdesParams params;

    iRtpManager->OpenL( params, NULL, &iSocketServ, &iConnection );

    RTP_EUNIT_ASSERT_EQUALS(iRtpManager->StartConnection(KIAPID), KErrNone);

    iRtpManager->iConnPtr=NULL;	

    iRtpManager->GetLocalIPAddressL();			

    iRtpManager->Close();

    }   

void UT_CRtpManager::UT_CRtpManager_GetIAPIdL(  )

    {

    TInt result(KErrNone);

    TRtpSdesParams params;

    iRtpManager->OpenL( params, NULL, &iSocketServ, &iConnection );

    RTP_EUNIT_ASSERT_EQUALS(iRtpManager->StartConnection(KIAPID), KErrNone);

    iRtpManager->iConnPtr=NULL;	

    TUint32 iapId;

    EUNIT_ASSERT(iRtpManager->GetIapId(iapId)== KErrNotReady);			

    iRtpManager->Close();

    }   

void UT_CRtpManager::UT_CRtpManager_RemoveRtpObjectLL(  )

	{

TInt result(KErrNone);

    TRtpSdesParams params;

    iRtpManager->OpenL( params, NULL, &iSocketServ, &iConnection );

    RTP_EUNIT_ASSERT_EQUALS(iRtpManager->StartConnection(KIAPID), KErrNone);

     TCreateSessionParams sessionParams;

    sessionParams.iPriority = TCreateSessionParams::EPriorityStandard;

    sessionParams.iSocketBufSize = KSocketBufSize;

    TUint port( 5000 );

    TBool enableRtcp( EFalse );

    TRtcpParams rtcpParams;

    rtcpParams.iRtcpFraction = 0.10;

    rtcpParams.iRtcpTimeOut = 0;

    rtcpParams.iSessionBWidth = 32000;

    TRtpId sessionId( KNullId );

    sessionId = iRtpManager->CreateSessionL( sessionParams,

                                    port,

                                    enableRtcp,

                                    &rtcpParams );

    EUNIT_ASSERT( sessionId != KNullId );

	iRtpManager->RemoveRtpObject(sessionId, ESession);

	iRtpManager->CloseSession(sessionId);

    iRtpManager->Close();

	}

void UT_CRtpManager::UT_CRtpManager_CreateSessionLL(  )

    {

    EUNIT_ASSERT( ETrue );

    }

void UT_CRtpManager::UT_CRtpManager_StartSessionL(  )

    {

    EUNIT_ASSERT( ETrue );

    }

void UT_CRtpManager::UT_CRtpManager_CloseSessionL(  )

    {

    TInt result(KErrNone);

    TRtpSdesParams params;

    iRtpManager->OpenL( params, NULL, &iSocketServ, &iConnection );

    RTP_EUNIT_ASSERT_EQUALS(iRtpManager->StartConnection(KIAPID), KErrNone);

     TCreateSessionParams sessionParams;

    sessionParams.iPriority = TCreateSessionParams::EPriorityStandard;

    sessionParams.iSocketBufSize = KSocketBufSize;

    TUint port( 5000 );

    TBool enableRtcp( EFalse );

    TRtcpParams rtcpParams;

    rtcpParams.iRtcpFraction = 0.10;

    rtcpParams.iRtcpTimeOut = 0;

    rtcpParams.iSessionBWidth = 32000;

    TRtpId sessionId( KNullId );

    sessionId = iRtpManager->CreateSessionL( sessionParams,

                                    port,

                                    enableRtcp,

                                    &rtcpParams );

    EUNIT_ASSERT( sessionId != KNullId );

    //close

    iRtpManager->CloseSession(sessionId);

    iRtpManager->Close();

    }

void UT_CRtpManager::UT_CRtpManager_SetRemoteAddressL(  )

    {

    EUNIT_ASSERT( ETrue );

    }

void UT_CRtpManager::UT_CRtpManager_SetRemoteRtcpAddressL(  )

    {

    EUNIT_ASSERT( ETrue );

    }

void UT_CRtpManager::UT_CRtpManager_CreateStreamLL(  )

    {

    EUNIT_ASSERT( ETrue );

    }

void UT_CRtpManager::UT_CRtpManager_CreateReceiveStreamLL(  )

    {

    EUNIT_ASSERT( ETrue );

    }

void UT_CRtpManager::UT_CRtpManager_CreateTransmitStreamLL(  )

    {

    EUNIT_ASSERT( ETrue );

    }

void UT_CRtpManager::UT_CRtpManager_CreateTransmitStreamExtLL(  )

    {

    EUNIT_ASSERT( ETrue );

    }

void UT_CRtpManager::UT_CRtpManager_CloseStreamL(  )

    {

    EUNIT_ASSERT( ETrue );

    }

void UT_CRtpManager::UT_CRtpManager_RegisterRtpObserverL(  )

    {

    EUNIT_ASSERT( ETrue );

    }

void UT_CRtpManager::UT_CRtpManager_UnregisterRtpObserverL(  )

    {

    EUNIT_ASSERT( ETrue );

    }

void UT_CRtpManager::UT_CRtpManager_SetNonRTPDataObserverL(  )

    {

    EUNIT_ASSERT( ETrue );

    }

void UT_CRtpManager::UT_CRtpManager_SendRtpPacketL(  )

    {

    EUNIT_ASSERT( ETrue );

    }

void UT_CRtpManager::UT_CRtpManager_SendRtpPacket_1L(  )

    {

    EUNIT_ASSERT( ETrue );

    }

void UT_CRtpManager::UT_CRtpManager_SendRtpPacket_2L(  )

    {

    EUNIT_ASSERT( ETrue );

    }

void UT_CRtpManager::UT_CRtpManager_SendDataLL(  )

    {

     TInt result(KErrNone);

    TRtpSdesParams params;

    iRtpManager->OpenL( params, NULL, &iSocketServ, &iConnection );

    RTP_EUNIT_ASSERT_EQUALS(iRtpManager->StartConnection(KIAPID), KErrNone);

     TCreateSessionParams sessionParams;

    sessionParams.iPriority = TCreateSessionParams::EPriorityStandard;

    sessionParams.iSocketBufSize = KSocketBufSize;

    TUint port( 5000 );

    TBool enableRtcp( EFalse );

    TRtcpParams rtcpParams;

    rtcpParams.iRtcpFraction = 0.10;

    rtcpParams.iRtcpTimeOut = 0;

    rtcpParams.iSessionBWidth = 32000;

    TRtpId sessionId( KNullId );

    sessionId = iRtpManager->CreateSessionL( sessionParams,

                                    port,

                                    enableRtcp,

                                    &rtcpParams );

    EUNIT_ASSERT( sessionId != KNullId );

    iRtpManager->iStandardRtp=EFalse;

    HBufC8* data = HBufC8::NewLC(KLength);

	data->Des().Copy(KHello);

	CleanupStack::Pop(data);

	TRequestStatus status(KErrNone);

    EUNIT_ASSERT_SPECIFIC_LEAVE(iRtpManager->SendDataL(sessionId,

                       ETrue,

                       *data,

                       status), KErrNotSupported);

    //close

    delete data;

    iRtpManager->CloseSession(sessionId);

    iRtpManager->Close();

    }

void UT_CRtpManager::UT_CRtpManager_CancelSendL(  )

    {

    TInt result(KErrNone);

    TRtpSdesParams params;

    iRtpManager->OpenL( params, NULL, &iSocketServ, &iConnection );

    RTP_EUNIT_ASSERT_EQUALS(iRtpManager->StartConnection(KIAPID), KErrNone);

    TCreateSessionParams sessionParams;

    sessionParams.iPriority = TCreateSessionParams::EPriorityStandard;

    sessionParams.iSocketBufSize = KSocketBufSize;

    TUint port( 5000 );

    TBool enableRtcp( EFalse );

    TRtcpParams rtcpParams;

    rtcpParams.iRtcpFraction = 0.10;

    rtcpParams.iRtcpTimeOut = 0;

    rtcpParams.iSessionBWidth = 32000;

    TRtpId sessionId( KNullId );

    sessionId = iRtpManager->CreateSessionL( sessionParams,

                                    port,

                                    enableRtcp,

                                    &rtcpParams );

    EUNIT_ASSERT( sessionId != KNullId );

    iRtpManager->iStandardRtp=ETrue;

    iRtpManager->CancelSend( sessionId );                   

    //close

    iRtpManager->CloseSession( sessionId );

    iRtpManager->Close();

    }

void UT_CRtpManager::UT_CRtpManager_RegisterRtcpObserverL(  )

    {

    TInt result(KErrNone);

    TRtpSdesParams params;

    iRtpManager->OpenL( params, NULL, &iSocketServ, &iConnection );

    RTP_EUNIT_ASSERT_EQUALS(iRtpManager->StartConnection(KIAPID), KErrNone);

    TCreateSessionParams sessionParams;

    sessionParams.iPriority = TCreateSessionParams::EPriorityStandard;

    sessionParams.iSocketBufSize = KSocketBufSize;

    TUint port( 5000 );

    TBool enableRtcp( EFalse );

    TRtcpParams rtcpParams;

    rtcpParams.iRtcpFraction = 0.10;

    rtcpParams.iRtcpTimeOut = 0;

    rtcpParams.iSessionBWidth = 32000;

    TRtpId sessionId( KNullId );

    sessionId = iRtpManager->CreateSessionL( sessionParams,

                                    port,

                                    enableRtcp,

                                    &rtcpParams );

    EUNIT_ASSERT( sessionId != KNullId );

    iRtpManager->iStandardRtp=ETrue;

    iRtpManager->RegisterRtcpObserver( sessionId, *this );

    iRtpManager->UnregisterRtcpObserver( sessionId );

    iRtpManager->CloseSession( sessionId );

    iRtpManager->Close();

    }

void UT_CRtpManager::UT_CRtpManager_UnregisterRtcpObserverL(  )

    {

    EUNIT_ASSERT( ETrue );

    }

void UT_CRtpManager::UT_CRtpManager_SendRtcpByePacketL(  )

    {

    TInt result(KErrNone);

    TRtpSdesParams params;

    iRtpManager->OpenL( params, NULL, &iSocketServ, &iConnection );

    RTP_EUNIT_ASSERT_EQUALS(iRtpManager->StartConnection(KIAPID), KErrNone);

    TCreateSessionParams sessionParams;

    sessionParams.iPriority = TCreateSessionParams::EPriorityStandard;

    sessionParams.iSocketBufSize = KSocketBufSize;

    TUint port( 5000 );

    TBool enableRtcp( EFalse );

    TRtcpParams rtcpParams;

    rtcpParams.iRtcpFraction = 0.10;

    rtcpParams.iRtcpTimeOut = 0;

    rtcpParams.iSessionBWidth = 32000;

    TRtpId sessionId( KNullId );

    sessionId = iRtpManager->CreateSessionL( sessionParams,

                                    port,

                                    enableRtcp,

                                    &rtcpParams );

    EUNIT_ASSERT( sessionId != KNullId );

    iRtpManager->iStandardRtp=ETrue;

    iRtpManager->RegisterRtcpObserver( sessionId, *this );

    iRtpManager->SendRtcpByePacketL( KIAPID, _L8( "ByePacket" )  );

    iRtpManager->UnregisterRtcpObserver( sessionId );

    iRtpManager->CloseSession( sessionId );

    iRtpManager->Close();

    }

void UT_CRtpManager::UT_CRtpManager_SendRtcpAppPacketL(  )

    {

    TInt result(KErrNone);

    TRtpSdesParams params;

    iRtpManager->OpenL( params, NULL, &iSocketServ, &iConnection );