/*

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

*

*/

#include "MCEConstants.h"

#include "TCmdAddSink.h"

#include "CTcMCEContext.h"

#include <MceMediaStream.h>

#include <MCEAudioStream.h>

#include <MceRtpSink.h>

#include <MCESpeakerSink.h>

#include <MCERtpSource.h>

void TCmdAddSink::ExecuteL()

	{	

	// ---------- Setup --------------------------------------------------------

	// Get stream

	CMceMediaStream* mediaStream = reinterpret_cast<CMceMediaStream*>

		(GetObjectForIdL(KStreamId, ETrue));		

	if ( mediaStream->Type() != KMceAudio )

		{

		User::Leave( KErrNotSupported );

		}

	CMceAudioStream* audioStream = static_cast<CMceAudioStream*>(mediaStream);

	// Get type

	TPtrC8 sink = ExtractTextL( KParamSink, ETrue );

	//get path for media file sink

	TPtrC8 mediaFileSink = ExtractTextL( KParamMediaFileSink, EFalse );

	// ---------- Execution ----------------------------------------------------

	if (sink == KValueSinkRTP )

		{

		//CMceRtpSink* rtpSink = CMceRtpSink::NewLC();

		CMceRtpSink* rtpSink = CMceRtpSink::NewL(EFalse);

		CleanupStack::PushL(rtpSink);

		audioStream->AddSinkL(rtpSink);

		CleanupStack::Pop(rtpSink);	

		AddIdResponseL( KSinkId, *rtpSink );		

		}

	else if (sink == KValueSinkSpeaker )

		{

		CMceSpeakerSink* speaker = CMceSpeakerSink::NewLC();

		audioStream->AddSinkL( speaker );	

		CleanupStack::Pop( speaker );

		AddIdResponseL( KSinkId, *speaker );

		}

	else if ( sink == KValueSinkFile )

		{

		CMceAudioStream* audioOutStreamFile = CMceAudioStream::NewL();

		CleanupStack::PushL( audioOutStreamFile );

		//use the same source which was used for outgoing audio stream	

		if( audioStream->Source()->Type() != KMceRTPSource )

			{

			audioOutStreamFile->SetSourceL( audioStream->Source() );

			}

		else

			{

			if(audioStream->BoundStream())

				if( audioStream->BoundStreamL().Source()->Type() != KMceRTPSource )

					audioOutStreamFile->SetSourceL(audioStream->BoundStreamL().Source());

			}

		if( mediaFileSink.Compare( KNullDesC8 ) != 0 )

			{

			iSessionHelper.SetMediaFileSinkL(*audioOutStreamFile, mediaFileSink);

			}

		else

			{

			iSessionHelper.SetMediaFileSinkL(*audioOutStreamFile, TPtrC8( KTestAudioFileName ));

			}

		//add the stream to the session

		audioStream->Session()->AddStreamL(audioOutStreamFile);

		CleanupStack::Pop( audioOutStreamFile );

		}

	else 

		{

		User::Leave( KErrNotSupported );

		}

	// ---------- Response creation --------------------------------------------

	AddIdResponseL( KStreamId, *audioStream ); 

	// Sink added to response during execution

	}

TBool TCmdAddSink::Match( const TTcIdentifier& aId )

	{

	return TTcMceCommandBase::Match( aId, _L8("AddSink") );

	}

TTcCommandBase* TCmdAddSink::CreateL( MTcTestContext& aContext )

	{

	return new( ELeave ) TCmdAddSink( aContext );

	}