/*

* 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:    Part of TestConsole application.

**              Methods for the class CTestAppConsole

**

*/

#include <e32std.h>

#include <e32base.h>

#include "TestConsole.h"

#include "mccsymsubthreadclient.h"

#include "mcculdlclient.h"

#include "mccdefs.h"

#include "mccinternalcodecs.h"

#include "mcculdlclient.h"

#include <mmf/server/mmfaudioinput.h>

#include "mccrtpdatasource.h"

#include "mccrtpdatasink.h"

const TUint32 KUplinkStreamId = 1;

const TUint32 KDownlinkStreamId = 2;

// Main Instruction Text

_LIT(KTxtMainInstructions, "Please select one option:\n"

 L"1. Test basic controls in UL/DL 1\n"

 L"3. Test UL Basic controls\n"

 L"4. Test DL Basic controls\n"

 L"5. Test memory management\n"

 L"9. Quit\n");

//*******************************************************************************

// Method      : CTestAppConsole::NewL()

// Purpose     : 

// Parameters  : 

// Return Value: 

//*******************************************************************************

CTestAppConsole* CTestAppConsole::NewL( )

    {

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

    CleanupStack::PushL(self);

    self->ConstructL();

    CleanupStack::Pop();

    return self;

    }

//*******************************************************************************

// Method      : CTestAppConsole::CTestAppConsole()

// Purpose     : Constructor

// Parameters  : 

// Return Value: 

//*******************************************************************************

CTestAppConsole::CTestAppConsole( ) : CActive(EPriorityStandard)

    {

	CActiveScheduler::Add(this);

    }

//*******************************************************************************

// Method      : CTestAppConsole::ConstructL()

// Purpose     : 

// Parameters  : 

// Return Value: 

//*******************************************************************************

void CTestAppConsole::ConstructL()

    {

    _LIT(KTxtTitle, " RTP Test ");

	iConsole = Console::NewL(KTxtTitle, TSize(KConsFullScreen, KConsFullScreen));

	DisplayConsoleMenu(KTxtMainInstructions);

	// Create Log files

    /*

	TFileUtil::InitLogFile(KLogFileTest);	// test events

	TFileUtil::InitLogFile(KLogFileRtp);	// Rtp packets

	TFileUtil::InitLogFile(KLogFileRtcp);	// Rtcp packets

	TFileUtil::InitLogFile(KLogFileStat);	// Statistic

    */

    ConstructDlSinkSource();

    ConstructUlSinkSource();

    }

//*******************************************************************************

// Method      : CTestAppConsole::~CTestAppConsole()

// Purpose     : Destructor

// Parameters  : 

// Return Value: 

//*******************************************************************************

CTestAppConsole::~CTestAppConsole()

    {

    Cancel(); // any outstanding request

	if (iConsole)

	    {

		delete iConsole;

		}

	delete iInstruct;

    if(iDlsource)

        delete iDlsource;

    if(iUlsink)

        delete iUlsink;

    if(iDlsink)   

        delete iDlsink;

    if(iUlsource)

        delete iUlsource;

    }

//*******************************************************************************

// Method      : CRtpAppConsole::StartTesting()

// Purpose     : start this AO 

// Parameters  : 

// Return Value: 

//*******************************************************************************

void CTestAppConsole::StartTesting()

    {

	DoRead();

    }

//*******************************************************************************

// Method      : CRtpAppConsole::DoRead()

// Purpose     : get the user's option and send request to scheduler

// Parameters  : 

// Return Value: 

//*******************************************************************************

void CTestAppConsole::DoRead()

    {

	iConsole->Read(iStatus);

	SetActive();

    }

//*******************************************************************************

// Method      : CRtpAppConsole::RunL()

// Purpose     : 

// Parameters  : 

// Return Value: 

//*******************************************************************************

void CTestAppConsole::RunL()

    {	

	// According to current test case and direct the user's command

	// to proper command handler.

    ProcessMainInput();

    }

//*******************************************************************************

// Method      : CRtpAppConsole::DoCancel()

// Purpose     : 

// Parameters  : 

// Return Value: 

//*******************************************************************************

void CTestAppConsole::DoCancel()

    {

	iConsole->ReadCancel();

    }

//*******************************************************************************

// Method      : CRtpAppConsole::DisplayConsoleMenu()

// Purpose     : Display main or sub console menus for different test cases

// Parameters  : TDesc &aInstructions

// Return Value: void

//*******************************************************************************

void CTestAppConsole::DisplayConsoleMenu(const TDesC &aInstructions)

	{

	if (iInstruct)

	    {

	    delete iInstruct;

	    iInstruct = NULL;

	    }

	iInstruct = aInstructions.AllocL();

	iConsole->ClearScreen();

	iConsole->Write(*iInstruct);

	}

//*******************************************************************************

// Method      : CTestAppConsole::ProcessMainInput()

// Purpose     : Obtain user's option and decide which test case to run next.

// Parameters  : 

// Return Value: 

//*******************************************************************************

void CTestAppConsole::ProcessMainInput()

	{

	TChar inputChar = iConsole->KeyCode();

	switch(inputChar)

        {

        case '1':

            __UHEAP_MARK;

            RunTest1();

            __UHEAP_MARKEND;

            break;

        case '3':

            __UHEAP_MARK;

            RunTest3();

            __UHEAP_MARKEND;

            break;

        case '4':

            __UHEAP_MARK;

            RunTest4();

            __UHEAP_MARKEND;

            break;

        case '5':

            __UHEAP_MARK;

            RunTest5();

            __UHEAP_MARKEND;

            break;

        case '6':

            RunTest6();

            break;

        case '9':

            CActiveScheduler::Stop();

            break;

        default:

			_LIT(KTxtWrongOption, "Wrong Option! Try Again.");

            DisplayMsg(KTxtWrongOption);

            break;		

        }

	// Ready to get next input option.

   	DoRead();

	}

//*******************************************************************************

// Method      : CRtpAppConsole::DisplayMsg()

// Purpose     : Display testing message on screen

// Parameters  : TDesC &

// Return Value: 

//*******************************************************************************

void CTestAppConsole::DisplayMsg(const TDesC &aMsg)

	{

	iConsole->ClearScreen();

	iConsole->Write(*iInstruct);

	iConsole->Printf(KTxtLineBreak);

	iConsole->Printf(aMsg);

	iConsole->Printf(KTxtLineBreak);

	}

//*******************************************************************************

// Method      : CTestAppConsole::GetAddrFromConsole()

// Purpose     : 

// Parameters  : 

// Return Value: 

//*******************************************************************************

TKeyCode CTestAppConsole::GetStringFromConsole(TDes &aAddr)

    {

	// Get a line from console

    TKeyCode input = EKeyNull;

    const TInt start_pos = iConsole->WhereX();

    aAddr.Zero();

    // loop until descriptor full or EKeyEnter or EKeyEscape entered

    do {

        // get one character

        input = iConsole->Getch();

        // process it

        if(input == EKeyBackspace  ||  input == EKeyDelete)

            {

            // backspace or delete

            if(iConsole->WhereX() > start_pos)

                {

				iConsole->SetPos(iConsole->WhereX() - 1);

				iConsole->ClearToEndOfLine();

				if(aAddr.Length() > 0) 

                    {

					aAddr.SetLength(aAddr.Length() - 1);

                    }

                }

            }

        else

            {

            // other than backspace or delete

            TChar ch(input);

            if(ch.IsPrint())

                {

                aAddr.Append(ch);

                iConsole->Printf(_L("%c"), input);

                }

            }   

        } 

    while(aAddr.Length() < aAddr.MaxLength()  &&  input != EKeyEnter  &&  input != EKeyEscape);

    DisplayMsg(KTxtLineBreak);

    return input;

    }

//*******************************************************************************

// Method      : CTestAppConsole::RunTest1()

// Purpose     : 

// Parameters  : 

// Return Value: 

//*******************************************************************************

void CTestAppConsole::RunTest1()

    {

    SetUpRtpStack();

    TInt cells = User::CountAllocCells();

    iConsole->Printf( _L("Allocated cells: %d\n"), cells);

    iKeepgoingUL = ETrue;

    CMccSymSubthreadClient* ul_client = CMccSymSubthreadClient::NewL(this);

    iKeepgoingDL = ETrue;

    CMccSymSubthreadClient* dl_client = CMccSymSubthreadClient::NewL(this);

    if(!ul_client)

        {

        iKeepgoingUL = EFalse;

        }

    if(!dl_client)

        {

        iKeepgoingDL = EFalse;

        }

    iUlError = KErrNone;

    iDlError = KErrNone;

    if(iKeepgoingUL && iKeepgoingDL)

        {

        iConsole->Printf( _L("Allocations OK for UL & DL, going on...\n") );

        }

    else

        {

        if(!iKeepgoingDL)

            {

            iConsole->Printf( _L("DL Allocations failed...\n") );

            }

        else if(!iKeepgoingDL)

            {

            iConsole->Printf( _L("UL Allocations failed...\n") );

            }

        else

            {

            iConsole->Printf( _L("DL & UL Allocations failed!!!\n") );

            }

        }

    for(TInt k = 0; k < 1; k++)

        {

        TestOpen( ul_client, dl_client );

        TestParameters( ul_client, dl_client );

        TestPrepare( ul_client, dl_client );

        TestControls( ul_client, dl_client );

        }

    if(iKeepgoingDL && iKeepgoingDL)

        {

        iConsole->Printf( _L("All tests ran OK\n") );

        }

    else

        {

        iConsole->Printf( _L("Not all tests done\n") );

        }

    delete ul_client;

    delete dl_client;

    cells = User::CountAllocCells();

    iConsole->Printf( _L("Allocated cells: %d\n"), cells);

    iConsole->Getch();

   };

void CTestAppConsole::ErrorNotify(TInt aError)

    {

    iConsole->Printf( _L("Error notify: %d"), aError );

    };

void CTestAppConsole::RunTest3()

    {

    SetUpRtpStack();

    TInt cells = User::CountAllocCells();

    iConsole->Printf( _L("Allocated cells: %d\n"), cells);

    CMccSymSubthreadClient* ul_client = CMccSymSubthreadClient::NewL(this);

    TFourCC fourAMR(KMccFourCCIdAMRNB);

    TRtpId ulsession = KNullId;

    TRtpId ulstream = KNullId;

    ul_client->CreateSessionL(iPort, iIapid, EFalse, 0);

    iConsole->Printf( _L("UL Session created\n") );

    iConsole->Getch();

    TMMFPrioritySettings prior;

    prior.iPriority = EMdaPriorityNormal;

    prior.iPref = EMdaPriorityPreferenceQuality;

    ul_client->OpenL(EMccAudioUplinkStream, fourAMR, iUlsource, iUlsink, KUplinkStreamId, prior );

    iConsole->Printf( _L("UL stream created\n") );

    iConsole->Getch();

    ul_client->SetRemoteAddressL(iRemoteAddr);

    iConsole->Printf( _L("Setted remote address\n") );

    iConsole->Getch();

    ul_client->SetPrioritySettingsL( KUplinkStreamId, prior );

    iConsole->Printf( _L("Setted priority settings\n") );

    iConsole->Getch();

    ul_client->PrepareL( KUplinkStreamId, 0 );

    iConsole->Printf( _L("Stream prepared\n") );

    iConsole->Getch();

    ul_client->PlayL( KUplinkStreamId, 0, EFalse, ETrue );

    iConsole->Printf( _L("Stream recording\n") );

    iConsole->Getch();

    ul_client->PauseL( KUplinkStreamId, 0, ETrue );

    iConsole->Printf( _L("Stream paused\n") );

    iConsole->Getch();

    ul_client->ResumeL( KUplinkStreamId, 0, ETrue );

    iConsole->Printf( _L("Stream resumed\n") );

    iConsole->Getch();

    ul_client->StopL( KUplinkStreamId, 0 );

    iConsole->Printf( _L("Stream stopped\n") );

    iConsole->Getch();

    ul_client->CloseL( KUplinkStreamId );

    iConsole->Printf( _L("Stream closed\n") );

    delete ul_client;

    cells = User::CountAllocCells();

    iConsole->Printf( _L("Allocated cells: %d\n"), cells);

    iConsole->Getch();   

    };

void CTestAppConsole::RunTest4()

    {

    SetUpRtpStack();

    TInt cells = User::CountAllocCells();

    iConsole->Printf( _L("Allocated cells: %d\n"), cells);

    CMccSymSubthreadClient* dl_client = CMccSymSubthreadClient::NewL(this);

    TFourCC fourAMR(KMccFourCCIdAMRNB);

    TRtpId dlsession = KNullId;

    TRtpId dlstream = KNullId;

    dl_client->CreateSessionL(iPort, iIapid, EFalse, 0);

    iConsole->Printf( _L("DL Session created\n") );

    iConsole->Getch();

    TMMFPrioritySettings prior;

    prior.iPriority = EMdaPriorityNormal;

    prior.iPref = EMdaPriorityPreferenceQuality;

    dl_client->OpenL( EMccAudioDownlinkStream, fourAMR, iDlsource, iDlsink, KDownlinkStreamId, prior );

    iConsole->Printf( _L("DL stream created\n") );

    iConsole->Getch();

    dl_client->SetPrioritySettingsL( KDownlinkStreamId, prior );

    iConsole->Printf( _L("Setted priority settings\n") );

    iConsole->Getch();

    dl_client->PrepareL( KDownlinkStreamId, 0 );

    iConsole->Printf( _L("Stream prepared\n") );

    iConsole->Getch();

    dl_client->PlayL( KDownlinkStreamId, 0, EFalse, ETrue );

    iConsole->Printf( _L("Stream playing\n") );

    iConsole->Getch();

    dl_client->PauseL( KDownlinkStreamId, 0, ETrue );

    iConsole->Printf( _L("Stream paused\n") );

    iConsole->Getch();

    dl_client->ResumeL( KDownlinkStreamId, 0, ETrue );

    iConsole->Printf( _L("Stream resumed\n") );

    iConsole->Getch();

    dl_client->StopL( KDownlinkStreamId, 0 );

    iConsole->Printf( _L("Stream stopped\n") );

    iConsole->Getch();

    dl_client->CloseL( KDownlinkStreamId );

    iConsole->Printf( _L("Stream closed\n") );

    delete dl_client;

    cells = User::CountAllocCells();

    iConsole->Printf( _L("Allocated cells: %d\n"), cells);

    iConsole->Getch();

    };

void CTestAppConsole::RunTest5()

    {

    TFourCC fourAMR(KMccFourCCIdAMRNB);

    TInt bitrate = 12200;

    iConsole->Printf( _L("Memory allocate/deallocate tests\n") );

    iConsole->Getch();

    __UHEAP_MARK;

    TInt cells = User::CountAllocCells();

    iConsole->Printf( _L("Allocated cells: %d\n"), cells);

    CMccSymSubthreadClient* dl_client = CMccSymSubthreadClient::NewL(this);

    delete dl_client;