/*

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

#include "CTcMCEContext.h"

#include <MCESession.h>

#include <MceMediaStream.h>

#include <MceMediaSource.h>

#include <MceRtpSource.h>

#include <MceAudioStream.h>

#include <MCEAudioCodec.h>

#include <MceDtmfCodec.h>

const TUint KDtmfAudioPriority					= 45;

const TUint KDtmfAudioPref						= 0x00150001;

_LIT( KTestSequence, "0123456789abcd*#");

void TCmdSendStreamDtmf::ExecuteL()

	{	

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

// DTMF out-of-band means DTMF tones are sent as the numerical value in a packet

// (RTP type telephone-event, refer RFC2833).

	const TInt KDefaultDuration = 0;

		// Get session

	CMceSession* session = 

		reinterpret_cast<CMceSession*>(GetObjectForIdL(KSessionId, ETrue));

	TPtrC8 dtmfTones = ExtractTextL( KParamDtmfTones, EFalse );

	TInt dtmfDuration = ExtractIntegerL( KParamDtmfDuration, KDefaultDuration, EFalse );

	TBool isSingleTone = ExtractBooleanL( KParamDtmfIsSingleTone, EFalse );

	const RPointerArray<CMceMediaStream>& streams = session->Streams();	

	for ( TInt i = 0; i < streams.Count(); ++i )

        {                

        CMceMediaStream* mediaStream;

        mediaStream = streams[i];

        if ( mediaStream->Type() == KMceAudio && mediaStream->Source()->Type() == KMceRTPSource )

        	{

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

            const RPointerArray<CMceAudioCodec>& codecsMain =  audioStream->Codecs();

            TBool dtmfFound = EFalse;

            for (TInt i = codecsMain.Count()-1; dtmfFound == EFalse && i >= 0;  i --)

				{

				if ( codecsMain[i]->SdpName().Compare(KValueCodecDtmf()))

					{

					//TODO modify dtmf codec 

					codecsMain[i]->SetMMFPriorityL( KDtmfAudioPriority );

	   			 	codecsMain[i]->SetMMFPriorityPreferenceL( KDtmfAudioPref );	

		   			codecsMain[i]->SetPreferenceL(0);

	   			 	dtmfFound = ETrue;

					}

				}

            //getting the media source pointer from the audio stream;

            CMceMediaSource* dtmfSource = audioStream->Source();

			//checking if dtmf is available

			if(dtmfSource->DtmfAvailable() && (!dtmfSource->DtmfActive()) )

				{

				//sending dtmf tones

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

					{

					HBufC* buf = HBufC::NewLC(dtmfTones.Length());

                    buf->Des().Copy(dtmfTones);

					if( isSingleTone && dtmfDuration > 0)

						{

						TLex lexer( *buf );

						TChar tone = lexer.Get();

						//starts sending the tone

						dtmfSource->StartDtmfToneL( tone );

						iDtmfTimer = NULL;

						//create instance of timer to stop sending the tone after given duration

						iDtmfTimer = CDelayedProcess::NewL(dtmfSource);

						if(iDtmfTimer)

							{

							TTimeIntervalMicroSeconds32 delay = dtmfDuration * 1000;

							iDtmfTimer->StartProcess(delay);

							}

						}					

					else if( !isSingleTone )

						{

						iDtmfTimer = NULL;

						dtmfSource->SendDtmfToneSequenceL(*buf);	

						}

					iaudioStream = audioStream;

					CleanupStack::PopAndDestroy(buf);

					buf = NULL;					

					}

				else

					{

					//send default sequence if not present in the params

					dtmfSource->SendDtmfToneSequenceL(KTestSequence);

					iaudioStream = audioStream;

					}

				}

        	//stop sending dtmf        	

        	if( dtmfSource->DtmfActive() && ( !isSingleTone ) )

	        	{

	        	dtmfSource->CancelDtmfToneSequenceL();

	        	}

        	}

        }

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

    if(iaudioStream)

	    {

	    AddIdResponseL( KStreamId, *iaudioStream );

		AddTextResponseL( KParamDtmfTones, dtmfTones );

		AddIntegerResponseL( KResponseLocalMediaPort, 

						 iaudioStream->LocalMediaPort() );		

	    }

    else

	    {

	    AddIntegerResponseL(KResponseActionReturnCode, KErrArgument);

	    }

	}

TBool TCmdSendStreamDtmf::Match( const TTcIdentifier& aId )

	{

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

	}

TTcCommandBase* TCmdSendStreamDtmf::CreateL( MTcTestContext& aContext )

	{

	return new( ELeave ) TCmdSendStreamDtmf( aContext );

	}