// Copyright (c) 2010 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:

// Contains the implementation of all the commands, which is used by the script file.

//

/**

 @file te_tundrivertestwrapper.h

 @internalTechnology

 */

#include "te_tundrivertestwrapper.h"

#include <e32base.h>

#include <utf.h>

#include <in_sock.h>

#include <es_sock.h>

#include <metadatabase.h> 

#include <commsdattypesv1_1.h> 

#include <commsdat.h>

#include <commsdattypesv1_1_partner.h>

#include <commsdattypeinfov1_1_internal.h>

#include <commdb.h>

#include <commdbconnpref.h>

//Virtual Interface 

// Commands

_LIT(KRConnTest1_1,         "RConnTest1_1");

_LIT(KRConnTest1_2,         "RConnTest1_2");

_LIT(KRConnTest1_3,         "RConnTest1_3");

_LIT(KRConnTest1_4,         "RConnTest1_4");

_LIT(KRConnTest1_5,         "RConnTest1_5");

_LIT(KRConnTest1_6,         "RConnTest1_6");

_LIT(KRConnTest1_7,         "RConnTest1_7");

_LIT(KRConnTest1_8,         "RConnTest1_8");

_LIT(KRConnTest1_9,         "RConnTest1_9");

_LIT(KRConnTest1_10,        "RConnTest1_10");

_LIT(KRConnTest1_11,        "RConnTest1_11");

_LIT(KRConnTest1_12,        "RConnTest1_12");

_LIT(KRConnTest1_13,        "RConnTest1_13");

_LIT(KRConnTest1_14,        "RConnTest1_14");

_LIT(KRConnTest1_15,        "RConnTest1_15");

_LIT(KRConnTest1_16,        "RConnTest1_16");

_LIT(KRConnTest1_17,        "RConnTest1_17");

_LIT(KRConnTest1_18,        "RConnTest1_18");

_LIT(KRConnTest1_19,        "RConnTest1_19");

_LIT(KRConnTest1_20,        "RConnTest1_20");

_LIT(KRConnTest1_21,        "RConnTest1_21");

_LIT(KRConnTest1_22,        "RConnTest1_22");

_LIT(KRConnTest1_23,        "RConnTest1_23");

_LIT(KRConnTest1_24,        "RConnTest1_24");

_LIT(KRConnTest1_25,        "RConnTest1_25");

_LIT(KRConnTest1_26,        "RConnTest1_26");

_LIT(KRConnTest1_27,        "RConnTest1_27");

_LIT(KRConnTest1_28,        "RConnTest1_28");

_LIT(KRConnTest1_29,        "RConnTest1_29");

_LIT(KRConnTest1_30,        "RConnTest1_30");

_LIT(KRConnTest1_31,        "RConnTest1_31");

_LIT(KRConnTest1_32,        "RConnTest1_32");

_LIT(KRConnTest1_33,        "RConnTest1_33");

// Config file

_LIT(KNameDefault, 	    	"default");

_LIT(KIpAddr,               "IpAddr");

_LIT(KGatewayAddr,          "GatewayAddr");

_LIT(KDestAddr, 		    "DestAddr");

_LIT(KLocalAddr,            "LocalAddr");

_LIT(KLocalPort,            "LocalPort");

_LIT(KDestPort,             "DestPort");

_LIT(KTcpDestPort,          "TcpDestPort");

_LIT(KRealDestAddr,         "RealDestAddr");

_LIT(KRealDestPort,         "RealDestPort");

//Test code

_LIT(KCommand, 			    "aCommand = %S");

_LIT(KSection, 			    "aSection = %S");

//Test code error

_LIT(KInetInputFail,         "TInetAddr Input failed with error: %d");

#define TUNDRIVER_IAP   14

#define REAL_IAP    9

#define LOCAL_PORT 7777

// public

//LOCAL_D CConsoleBase* console; 

/**

Constructor.

@internalTechnology

 */

CTunDriverTestWrapper::CTunDriverTestWrapper()

    {

    }

/**

Destructor.

@internalTechnology

 */

CTunDriverTestWrapper::~CTunDriverTestWrapper()

    {

    }

/**

Function to instantiate TestWrapper.

@return Returns constructed TestWrapper instance pointer

@internalTechnology

 */

CTunDriverTestWrapper* CTunDriverTestWrapper::NewL()

    {

    CTunDriverTestWrapper*	ret = new (ELeave) CTunDriverTestWrapper();

    CleanupStack::PushL(ret);

    ret->ConstructL();

    CleanupStack::Pop(ret);

    return ret;	

    }

/**

Second level constructor, constructs TestWrapper instance.

@internalTechnology

 */

void CTunDriverTestWrapper::ConstructL()

    {

    iInitNumOfInterfaces    = 0;

    iCurNumOfInterfaces     = 0;

    iDestPort               = 0;

    }

/**

Function to map the input command to respective function.

@return - True Upon successfull command to Function name mapping otherwise False

@param aCommand Function name has to be called

@param aSection INI file paramenter section name

@param aAsyncErrorIndex Error index

@see Refer the script file COMMAND section.

@internalTechnology

 */

TBool CTunDriverTestWrapper::DoCommandL(const TTEFFunction& aCommand, const TTEFSectionName& aSection, const TInt /*aAsyncErrorIndex*/)

    {

    TBool ret = ETrue;

    // Print out the parameters for debugging

    INFO_PRINTF2( KCommand, &aCommand );

    INFO_PRINTF2( KSection, &aSection );

    //INFO_PRINTF2( KAsyncErrorIndex, aAsyncErrorIndex );

    //RConnection Testcases

    if(KRConnTest1_1() == aCommand)

        {

        DoRConnTest1_1();

        }

    else if(KRConnTest1_2() == aCommand)

        {

        DoRConnTest1_2();

        }

    else if(KRConnTest1_3() == aCommand)

        {

        DoRConnTest1_3(aSection);

        }

    else if(KRConnTest1_4() == aCommand)

        {

        DoRConnTest1_4(aSection);

        }

    else if(KRConnTest1_5() == aCommand)

        {

        DoRConnTest1_5(aSection);

        }

    else if(KRConnTest1_6() == aCommand)

        {

        DoRConnTest1_6(aSection);

        }

    else if(KRConnTest1_7() == aCommand)

        {

        DoRConnTest1_7(aSection);

        }

    else if(KRConnTest1_8() == aCommand)

        {

        DoRConnTest1_8(aSection);

        }

    else if(KRConnTest1_9() == aCommand)

        {

        DoRConnTest1_9(aSection);

        }

    else if(KRConnTest1_10() == aCommand)

        {

        DoRConnTest1_10(aSection);

        }

    else if(KRConnTest1_11() == aCommand)

        {

        DoRConnTest1_11();

        }

    else if(KRConnTest1_12() == aCommand)

        {

        DoRConnTest1_12();

        }

    else if(KRConnTest1_13() == aCommand)

        {

        DoRConnTest1_13(aSection);

        }

    else if(KRConnTest1_14() == aCommand)

        {

        DoRConnTest1_14(aSection);

        }

    else if(KRConnTest1_15() == aCommand)

        {

        DoRConnTest1_15();

        }

    else if(KRConnTest1_16() == aCommand)

        {

        DoRConnTest1_16(aSection);

        }

    else if(KRConnTest1_17() == aCommand)

        {

        DoRConnTest1_17(aSection);

        }

    else if(KRConnTest1_18() == aCommand)

        {

        }

    else if(KRConnTest1_19() == aCommand)

        {

        }

    else if(KRConnTest1_20() == aCommand)

        {

        DoRConnTest1_20();

        }

    else if(KRConnTest1_21() == aCommand)

        {

        DoRConnTest1_21();

        }

    else if(KRConnTest1_22() == aCommand)

        {

        DoRConnTest1_22();

        }

    else if(KRConnTest1_23() == aCommand)

        {

        DoRConnTest1_23();

        }

    else if(KRConnTest1_24() == aCommand)

        {

        DoRConnTest1_24();

        }

    else if(KRConnTest1_25() == aCommand)

        {

        DoRConnTest1_25();

        }

    else if(KRConnTest1_26() == aCommand)

        {

        DoRConnTest1_26();

        }

    else if(KRConnTest1_27() == aCommand)

        {

        DoRConnTest1_27();

        }

    else if(KRConnTest1_28() == aCommand)

        {

        DoRConnTest1_28();

        }

    else if(KRConnTest1_29() == aCommand)

        {

        DoRConnTest1_29();

        }

    else if(KRConnTest1_30() == aCommand)

        {

        DoRConnTest1_30();

        }

	else if(KRConnTest1_31() == aCommand)

        {

        DoRConnTest1_31();

        }

	else if(KRConnTest1_32() == aCommand)

        {

        DoRConnTest1_32();

        }

    else if(KRConnTest1_33() == aCommand)

        {

        DoRConnTest1_33();

        }	

    else

        {

        ret = EFalse;

        User::LeaveIfError(KErrNone); // just to suppress LeaveScan warning

        }

    return ret;

    }

/**

Function to open Virtual Socket.

@internalTechnology

 */

TBool CTunDriverTestWrapper::FindInterface(TPckgBuf<TSoInet6InterfaceInfo> &info)

    {

    TBool success = FALSE;

    if((iStatus = iSocketServ.Connect()) == KErrNone )

        INFO_PRINTF1(_L("Socket Server Opened.\n"));

    else

        {

        ERR_PRINTF2(_L("Error Opening Socket Server: %d"), iStatus.Int());

        SetError(iStatus.Int());

        return success;

        }

    if((iStatus = iConnection1.Open(iSocketServ)) == KErrNone )

        INFO_PRINTF1(_L("Connection1 opened. \n"));

    else

        {

        ERR_PRINTF2(_L("Error Opening Connection1: %d"), iStatus.Int());

        SetError(iStatus.Int());

        return success;

        }

    iCommDbPref.SetIapId(TUNDRIVER_IAP);             // Virtual Interface

    iCommDbPref.SetBearerSet(KCommDbBearerVirtual);

    iCommDbPref.SetDialogPreference(ECommDbDialogPrefDoNotPrompt);

    iConnection1.Start(iCommDbPref, iStatus);

    //open socket on interface. 

    if((iStatus = iSocket1.Open(iSocketServ, KAfInet, KSockDatagram, KProtocolInetUdp, iConnection1)) == KErrNone )

        INFO_PRINTF1(_L("Socket Opened!\n "));

    User::LeaveIfError( iSocket1.SetOpt( KSoInetEnumInterfaces, KSolInetIfCtrl ) );

    TProtocolDesc in;

    User::LeaveIfError( iSocket1.Info( in ) );

    TInt res = iSocket1.GetOpt( KSoInetNextInterface, KSolInetIfCtrl, info );

    if (res != KErrNone)

        {

        User::Leave( res );

        }

    TPckgBuf<TSoInet6InterfaceInfo> next;

    while (res == KErrNone)

        {

        res = iSocket1.GetOpt( KSoInetNextInterface, KSolInetIfCtrl, next );

        if (res == KErrNone)

            info = next;

        //Compare the string with interface name

        if (info().iName.Mid(1,4).Compare(_L("TunDriver")))

            //if (info().iName == KIfName)

            {

            success = TRUE;

            break;

            }

        else

            {

            continue;

            }

        }

    return success;

    }

TInt CTunDriverTestWrapper::StartD3PApp()

    {

    TInt err(0);

    if ((err = p.Create(KDummy3rdPartyApp,KArg)) == KErrNone)

        {

        p.Resume();

        }

    else

        {

        ERR_PRINTF2(_L("Error Opening Dummy3rdPartyApp: %d"), iVTunError);

        SetError(err);

        return(err);        

        }

    //Wait for Dummy3rdPartyApp to be up and running!

    User::After(10000000);   //10 Sec

    return(err);

    }

void CTunDriverTestWrapper::StopD3PApp()

    {

    p.Kill(NULL);   //Kill Dummy3rdPartyApp.       

    }

//Gurpreet: RConnection Testcases

void CTunDriverTestWrapper::DoRConnTest1_1()

    {

    INFO_PRINTF1(_L("********************************************"));

    INFO_PRINTF1(_L("           Test: DoRConnTest1_1             "));

    INFO_PRINTF1(_L("********************************************"));

    if((iStatus = iSocketServ.Connect()) == KErrNone )

        INFO_PRINTF1(_L("Socket Server Opened.\n"));

    else

        {

        ERR_PRINTF2(_L("Error Opening Socket Server: %d"), iStatus.Int());

        SetError(iStatus.Int());

        return;

        }

    if((iStatus = iConnection.Open(iSocketServ /*, KAfInet*/)) == KErrNone )

        INFO_PRINTF1(_L("Connection opened. \n"));

    else

        {

        ERR_PRINTF2(_L("Error Opening Connection: %d"), iStatus.Int());

        SetError(iStatus.Int());

        return;

        }

    iCommDbPref.SetIapId(TUNDRIVER_IAP);             // Virtual Interface

    iCommDbPref.SetBearerSet(KCommDbBearerVirtual);

    iCommDbPref.SetDialogPreference(ECommDbDialogPrefDoNotPrompt);

    iVTunError = iConnection.Start(iCommDbPref);

    //User::WaitForRequest(iStatus);

    INFO_PRINTF2(_L("Starting Connection %d.\n"), iVTunError);

    if(iVTunError!= KErrNone)

        {

        SetError(iVTunError);

        }

    iConnection.Close();

    iSocketServ.Close();    

    }

void CTunDriverTestWrapper::DoRConnTest1_2()

    {

    INFO_PRINTF1(_L("********************************************"));

    INFO_PRINTF1(_L("           Test: DoRConnTest1_2             "));

    INFO_PRINTF1(_L("********************************************"));

    if((iStatus = iSocketServ.Connect()) == KErrNone )

        INFO_PRINTF1(_L("Socket Server Opened.\n"));

    else

        {

        ERR_PRINTF2(_L("Error Opening Socket Server: %d"), iStatus.Int());

        SetError(iStatus.Int());

        return;

        }

    if((iStatus = iConnection.Open(iSocketServ /*, KAfInet*/)) == KErrNone )

        INFO_PRINTF1(_L("Connection opened. \n"));

    else

        {

        ERR_PRINTF2(_L("Error Opening Connection: %d"), iStatus.Int());

        SetError(iStatus.Int());

        return;

        }

    iCommDbPref.SetIapId(TUNDRIVER_IAP);             // Virtual Interface

    iCommDbPref.SetBearerSet(KCommDbBearerVirtual);

    iCommDbPref.SetDialogPreference(ECommDbDialogPrefDoNotPrompt);

    iConnection.Start(iCommDbPref, iStatus);

    User::WaitForRequest(iStatus);

    INFO_PRINTF2(_L("Starting Connection %d.\n"), iStatus.Int());

    iConnection.Close();

    iSocketServ.Close();    

    }

void CTunDriverTestWrapper::DoRConnTest1_3(const TDesC& aSection)

    {

    INFO_PRINTF1(_L("*********************************************"));

    INFO_PRINTF1(_L("           Test: DoRConnTest1_3             "));

    INFO_PRINTF1(_L("********************************************"));

    //start the dummy3rdpartyapp

    if ((iVTunError = StartD3PApp()) != KErrNone)

        {

        return;

        }

    if((iStatus = iSocketServ.Connect()) == KErrNone )

        INFO_PRINTF1(_L("Socket Server Opened.\n"));

    else

        {

        ERR_PRINTF2(_L("Error Opening Socket Server: %d"), iStatus.Int());

        SetError(iStatus.Int());

        StopD3PApp();

        return;

        }

    if((iStatus = iConnection.Open(iSocketServ)) == KErrNone )

        INFO_PRINTF1(_L("Connection opened. \n"));

    else

        {

        ERR_PRINTF2(_L("Error Opening Connection: %d"), iStatus.Int());

        SetError(iStatus.Int());

        StopD3PApp();

        return;

        }

    iCommDbPref.SetIapId(TUNDRIVER_IAP);             // Virtual Interface

    iCommDbPref.SetBearerSet(KCommDbBearerVirtual);

    iCommDbPref.SetDialogPreference(ECommDbDialogPrefDoNotPrompt);

    iConnection.Start(iCommDbPref, iStatus);

		User::WaitForRequest(iStatus);

		if (iStatus.Int() != KErrNone)

			{

			ERR_PRINTF2(_L("Error starting connection: %d"), iStatus.Int());	

			SetError(iStatus.Int());

			StopD3PApp();

			return;

			}

	INFO_PRINTF1(_L("Connection started!\n "));