/*

* Copyright (c) 2006 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_cmcesrvstream.h"

//  EXTERNAL INCLUDES

#include <digia/eunit/EUnitMacros.h>

#include <sdpcodecstringconstants.h>

#include "mcemediamanager.h"

#include "CMccController_stub.h"

#define RESET()\

    iMcc->Reset();\

    iServer->Reset()

#include "mcesrvstream.h"

#include "mcesrvsink.h"

#include "mcesrvsource.h"

//  INTERNAL INCLUDES

// CONSTRUCTION

UT_CMceSrvStream* UT_CMceSrvStream::NewL()

    {

    UT_CMceSrvStream* self = UT_CMceSrvStream::NewLC(); 

    CleanupStack::Pop();

    return self;

    }

UT_CMceSrvStream* UT_CMceSrvStream::NewLC()

    {

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

    CleanupStack::PushL( self );

	self->ConstructL(); 

    return self;

    }

// Destructor (virtual by CBase)

UT_CMceSrvStream::~UT_CMceSrvStream()

    {

    }

// Default constructor

UT_CMceSrvStream::UT_CMceSrvStream()

    {

    }

// Second phase construct

void UT_CMceSrvStream::ConstructL()

    {

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

    // It generates the test case table.

    CEUnitTestSuiteClass::ConstructL();

    }

//  METHODS

void UT_CMceSrvStream::SetupL()

    {

	CMccControllerStub::OpenL();

    iMcc = CMccControllerStub::Stub();

    iServer = new (ELeave) CMceServerStub();

    iManager = CMceMediaManager::NewL( *iServer );

    iSession = MceMediaManagerTestHelper::CreateMultimediaOutSessionL();

    iSession->SetObserver( *iServer );

    iSession->PrepareL( *iManager );

    iStream = new (ELeave) CMceSrvStream();

    delete iStream;

    iStream = NULL;

	iStream = iSession->MccStreams()[0];

    } 

void UT_CMceSrvStream::Setup2L()

    {

    CMccControllerStub::OpenL();

    iMcc = CMccControllerStub::Stub();

    iServer = new (ELeave) CMceServerStub();

    iManager = CMceMediaManager::NewL( *iServer );

    iSession = MceMediaManagerTestHelper::CreateMultimediaBundledOutSessionL();

    iSession->SetObserver( *iServer );

    iSession->PrepareL( *iManager );

    iStream = new (ELeave) CMceSrvStream();

    delete iStream;

    iStream = NULL;

	iStream = iSession->MccStreams()[0];

    }

void UT_CMceSrvStream::Teardown()

    {

	CMceComSession::Delete( iSession, *iManager );

	delete iManager;

	iManager = NULL;

	delete iServer;

	iServer = NULL;

	CMccControllerStub::Close();

	iMcc = NULL;

    iStream = NULL;

    }

void UT_CMceSrvStream::UT_CMceSrvStream_SessionIdL()

    {

    EUNIT_ASSERT( iStream->SessionId() == KMceNotAssigned );

    }

void UT_CMceSrvStream::UT_CMceSrvStream_LinkIdL()

    {

    EUNIT_ASSERT( iStream->LinkId() == KMceNotAssigned );

    }

void UT_CMceSrvStream::UT_CMceSrvStream_SetLinkIdL()

    {

    EUNIT_ASSERT( iStream->LinkId() == KMceNotAssigned );

    iStream->SetLinkId( 200 );

    EUNIT_ASSERT( iStream->LinkId() == 200 );

    }

void UT_CMceSrvStream::UT_CMceSrvStream_IapIdL()

    {

    EUNIT_ASSERT( iStream->IapId() == 0 );

    }

void UT_CMceSrvStream::UT_CMceSrvStream_LocalMediaPortL()

    {

    EUNIT_ASSERT( iStream->LocalMediaPort() != 0 );

    }

void UT_CMceSrvStream::UT_CMceSrvStream_IsEqualL()

    {

    CMceSrvStream* stream = NULL;

    EUNIT_ASSERT( !iStream->IsEqual( *stream ) );

    stream = iSession->MccStreams()[1];

    stream->Codec().iID = 100;

    stream->Source().Data().iID = 100;

    stream->Sink().Data().iID = 100;

    EUNIT_ASSERT( !iStream->IsEqual( *stream ) );

    stream->Codec().iID = iStream->Codec().iID;

    EUNIT_ASSERT( !iStream->IsEqual( *stream ) );

    stream->Source().Data().iID = iStream->Source().Data().iID;

    EUNIT_ASSERT( !iStream->IsEqual( *stream ) );

    stream->Sink().Data().iID = iStream->Sink().Data().iID;

    EUNIT_ASSERT( iStream->IsEqual( *stream ) );

    }

void UT_CMceSrvStream::UT_CMceSrvStream_IsMccPreparedL()

    {

    EUNIT_ASSERT( !iStream->IsMccPrepared() );

    iStream->Id() = 200;

    EUNIT_ASSERT( iStream->IsMccPrepared() );

    }

void UT_CMceSrvStream::UT_CMceSrvStream_IsAdoptedL()

    {

    EUNIT_ASSERT( !iStream->IsAdopted() );

    }

void UT_CMceSrvStream::UT_CMceSrvStream_StateL()

    {

    EUNIT_ASSERT( iStream->State() == CMceSrvStream::ECreated );

    iStream->Data().Enable( EFalse, EFalse );

    EUNIT_ASSERT( iStream->State() == CMceSrvStream::EInactive );

    iStream->Source().SetState( CMceSrvStream::EStopped );

    EUNIT_ASSERT( iStream->State() == CMceSrvStream::EInactive );

    iStream->Sink().SetState( CMceSrvStream::EStopped );

    EUNIT_ASSERT( iStream->State() == CMceSrvStream::EStopped );

    iStream->Source().SetState( CMceSrvStream::EPending );

    EUNIT_ASSERT( iStream->State() == CMceSrvStream::EInactive );

    iStream->Sink().SetState( CMceSrvStream::EPending );

    EUNIT_ASSERT( iStream->State() == CMceSrvStream::EPending );

    iStream->Sink().SetState( CMceSrvStream::EPreparing );

    EUNIT_ASSERT( iStream->State() == CMceSrvStream::EPreparing );

    iStream->Source().SetState( CMceSrvStream::EPreparing );

    EUNIT_ASSERT( iStream->State() == CMceSrvStream::EPreparing );

    iStream->Source().SetState( CMceSrvStream::ECreated );

    iStream->Sink().SetState( CMceSrvStream::EStarting );

    EUNIT_ASSERT( iStream->State() == CMceSrvStream::EStarting );

    iStream->Source().SetState( CMceSrvStream::EStarting );

    EUNIT_ASSERT( iStream->State() == CMceSrvStream::EStarting );

    iStream->Source().SetState( CMceSrvStream::ECreated );

    iStream->Sink().SetState( CMceSrvStream::EPrepared );

    EUNIT_ASSERT( iStream->State() == CMceSrvStream::EPrepared );

    iStream->Source().SetState( CMceSrvStream::EPrepared );

    EUNIT_ASSERT( iStream->State() == CMceSrvStream::EPrepared );

    iStream->Source().SetState( CMceSrvStream::ECreated );

    iStream->Sink().SetState( CMceSrvStream::EStarted );

    EUNIT_ASSERT( iStream->State() == CMceSrvStream::EStarted );

    iStream->Source().SetState( CMceSrvStream::EStarted );

    EUNIT_ASSERT( iStream->State() == CMceSrvStream::EStarted );

    iStream->Source().SetState( CMceSrvStream::ECreated );

    iStream->Sink().SetState( CMceSrvStream::EPaused );

    EUNIT_ASSERT( iStream->State() == CMceSrvStream::EStarted );

    iStream->Source().SetState( CMceSrvStream::EPaused );

    EUNIT_ASSERT( iStream->State() == CMceSrvStream::EStarted );

    }

void UT_CMceSrvStream::UT_CMceSrvStream_SetLocalMediaPortL()

    {

    iStream->SetLocalMediaPort( 100 );

    EUNIT_ASSERT( iStream->LocalMediaPort() == 100 );

    }

void UT_CMceSrvStream::UT_CMceSrvStream_IdL()

    {

    EUNIT_ASSERT( iStream->Id() == KMceNotAssigned );

    }

void UT_CMceSrvStream::UT_CMceSrvStream_StreamTypeL()

    {

    EUNIT_ASSERT( iStream->StreamType() == CMceComMediaStream::EReceiveStream );

    }

void UT_CMceSrvStream::UT_CMceSrvStream_DirectionL()

    {

    EUNIT_ASSERT( iStream->Direction() == CMceComMediaStream::EReceiveStream );

    iStream->Data().Enable( EFalse, EFalse );

    EUNIT_ASSERT( iStream->Direction() == CMceComMediaStream::EReceiveStream );

    iStream->Data().Enable( ETrue, EFalse );

    iStream->Data().iLinkedStream->Enable( EFalse, EFalse );

    EUNIT_ASSERT( iStream->Direction() == CMceComMediaStream::EReceiveOnlyStream );

    iStream->Data().iLinkedStream->Enable( ETrue, EFalse );

    CMceSrvStream* stream = iSession->MccStreams()[1];

    EUNIT_ASSERT( stream->Direction() == CMceComMediaStream::ESendStream );

    stream->Data().Enable( EFalse, EFalse );

    EUNIT_ASSERT( stream->Direction() == CMceComMediaStream::ESendStream );

    stream->Data().Enable( ETrue, EFalse );

    stream->Data().iLinkedStream->Enable( EFalse, EFalse );

    EUNIT_ASSERT( stream->Direction() == CMceComMediaStream::ESendOnlyStream );

    }

void UT_CMceSrvStream::UT_CMceSrvStream_IsMergedL()

    {

    EUNIT_ASSERT( !iStream->IsMerged() );

    }

void UT_CMceSrvStream::UT_CMceSrvStream_DataL()

    {

    EUNIT_ASSERT( &iStream->Data() != NULL );

    }

void UT_CMceSrvStream::UT_CMceSrvStream_CodecL()

    {

    EUNIT_ASSERT( &iStream->Codec() != NULL );

    }

void UT_CMceSrvStream::UT_CMceSrvStream_SourceL()

    {

    EUNIT_ASSERT( &iStream->Source() != NULL );

    }

void UT_CMceSrvStream::UT_CMceSrvStream_SinkL()

    {

    EUNIT_ASSERT( &iStream->Sink() != NULL );

    }

void UT_CMceSrvStream::UT_CMceSrvStream_RemoteIpAddressL()

    {

    EUNIT_ASSERT( iStream->RemoteIpAddress().Length() > 0 );

    }

void UT_CMceSrvStream::UT_CMceSrvStream_MccStreamTypeL()

    {

    EUNIT_ASSERT( iStream->MccStreamType() == KMccAudioDownlinkStream );

    }

void UT_CMceSrvStream::UT_CMceSrvStream_LinkTypeL()

    {

    EUNIT_ASSERT( iStream->LinkType() == KMccLinkGeneral );

    }

void UT_CMceSrvStream::UT_CMceSrvStream_ConsumesL()

    {

    TMceMccComEvent event( KMccStreamStarted );

    event.iStreamId = 10;

    event.iEndpointId = 10;

    event.iLinkId = 10;

    EUNIT_ASSERT( !iStream->Consumes( event ) );

    iStream->Id() = event.iStreamId;

    EUNIT_ASSERT( iStream->Consumes( event ) );

    event.iStreamId = 0;

    EUNIT_ASSERT( !iStream->Consumes( event ) );

    iStream->SetLinkId( event.iLinkId );

    EUNIT_ASSERT( !iStream->Consumes( event ) );

    iStream->Source().Id() = event.iEndpointId;

    EUNIT_ASSERT( iStream->Consumes( event ) );

    iStream->Sink().Id() = event.iEndpointId;

    EUNIT_ASSERT( iStream->Consumes( event ) );

    event.iEndpointId = 0;

    EUNIT_ASSERT( iStream->Consumes( event ) );

    iStream->SetLinkId( 500 );

    EUNIT_ASSERT( !iStream->Consumes( event ) );

    }

void UT_CMceSrvStream::UT_CMceSrvStream_MccPrepareCalledLL()

    {

    //null test

    iStream->MccPrepareCalledL();

    }

void UT_CMceSrvStream::UT_CMceSrvStream_DecodeLL()

    {

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

	for ( TInt i = 0; i < iSession->Streams().Count(); i++)

		{

		CMceSrvStream::DecodeL( iSession->MccStreams(), *iSession->Streams()[i], *iManager );

		}

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

    iSession->Streams()[0]->BindL( NULL );

    CMceSrvStream::DecodeL( iSession->MccStreams(), *iSession->Streams()[0], *iManager );

    iSession->Streams()[0]->iType = KMceNotAssigned;

	EUNIT_ASSERT_LEAVE( 

	    CMceSrvStream::DecodeL( iSession->MccStreams(), *iSession->Streams()[0], *iManager ) );

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

    }

void UT_CMceSrvStream::UT_CMceSrvStream_EventReceived_Static_L()

    {

    TMceMccComEvent event( KMccStreamStarted );

    event.iStreamId = 10;

    event.iEndpointId = 10;

    event.iLinkId = 10;

	EUNIT_ASSERT( CMceSrvStream::EventReceived( iSession->MccStreams(), event ) == NULL );

    iStream->Id() = event.iStreamId;

	EUNIT_ASSERT( CMceSrvStream::EventReceived( iSession->MccStreams(), event ) != NULL );

    }

void UT_CMceSrvStream::UT_CMceSrvStream_EventReceivedL()

    {

    TMceMccComEvent event( KMccStreamStarted );

    event.iStreamId = 10;

    event.iEndpointId = 0;

    event.iLinkId = 10;

    EUNIT_ASSERT( iStream->EventReceived( event, ETrue ) == KMceEventConsumed );

    iStream->Id() = event.iStreamId;

    EUNIT_ASSERT( iStream->EventReceived( event, ETrue ) == KMceEventConsumed );

    iStream->SetLinkId( event.iLinkId );

    EUNIT_ASSERT( iStream->EventReceived( event, ETrue ) == KMceEventConsumed );

    EUNIT_ASSERT( iStream->EventReceived( event, EFalse ) == KMceEventConsumed );

    iStream->Sink().Id() = 100;

    iStream->Source().Id() = 200;

    event.iEndpointId = 10;

    EUNIT_ASSERT( iStream->EventReceived( event, ETrue ) == KMceEventConsumed );

    event.iEndpointId = 100;

    EUNIT_ASSERT( iStream->EventReceived( event, ETrue ) == KMceEventConsumed );

    event.iEndpointId = 200;

    EUNIT_ASSERT( iStream->EventReceived( event, ETrue ) == KMceEventConsumed );

    // Test that media error (ICMP) is ignored if stream is already disabled.

    event.iEvent = KMccStreamError;

    event.iError = KErrHostUnreach;

    iStream->Data().iState = CMceMediaStream::EStreaming;

    iServer->iItcData = CMceMediaStream::EStreaming;

    EUNIT_ASSERT( iStream->EventReceived( event, ETrue ) == KMceEventConsumed );

    EUNIT_ASSERT( iStream->Data().iState == CMceMediaStream::EDisabled );

    EUNIT_ASSERT( iServer->iItcData >> 8 == CMceMediaStream::EDisabled || 

                  iServer->iItcData == CMceMediaStream::EDisabled );

    iServer->iItcData = CMceMediaStream::EStreaming;

    EUNIT_ASSERT( iStream->EventReceived( event, ETrue ) == KMceEventConsumed );

    EUNIT_ASSERT( iServer->iItcData == CMceMediaStream::EStreaming );

    }

void UT_CMceSrvStream::UT_CMceSrvStream_CleanupL()

    {

    //Null testing

    iStream->Cleanup();

    iMcc->iRefCount = 0;

    iStream->Cleanup();

    }

void UT_CMceSrvStream::UT_CMceSrvStream_MergeL()

    {

    CMceSrvStream* stream = iSession->MccStreams()[1];

    EUNIT_ASSERT( !stream->IsMerged() );

    EUNIT_ASSERT( !iStream->IsMerged() );

    iStream->Merge( *stream );

    EUNIT_ASSERT( stream->IsMerged() );

    EUNIT_ASSERT( iStream->IsMerged() );

    }

void UT_CMceSrvStream::UT_CMceSrvStream_InvalidateL()

    {

    iStream->Invalidate();

    EUNIT_ASSERT( iStream->State() == CMceSrvStream::EStopped );

    }

void UT_CMceSrvStream::UT_CMceSrvStream_PrepareLL()

    {

    EUNIT_ASSERT_LEAVE( iStream->PrepareL() );