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

//

/**

 @file Connections.TestSteps.cpp

*/

#include "SubConnections.TestSteps.h"

#include "Connections.TestSteps.h"

#include "SocketServer.TestSteps.h"

#include "Sockets.TestSteps.h"

#include <cdbcols.h>

#include <commsdattypeinfov1_1.h>

#include <comms-infras/es_commsdataobject.h>

#include <comms-infras/connectionqueryset.h>

#ifdef _DEBUG

// Panic category for "absolutely impossible!" vanilla ASSERT()-type panics from this module

// (if it could happen through user error then you should give it an explicit, documented, category + code)

_LIT(KSpecAssert_ESockTestCnctnsT, "ESockTestCnctnsT");

#endif

// Create Connection

//------------------

CCreateRConnectionStep::CCreateRConnectionStep(CCEsockTestBase*& aEsockTest)

:   CTe_EsockStepBase(aEsockTest)

	{

	SetTestStepName(KCreateRConnectionStep);

	}

TVerdict CCreateRConnectionStep::doTestStepPreambleL()

	{

	SetTestStepResult(EFail);

	if (iEsockTest==NULL)

	    iEsockTest = new (ELeave) CCEsockTestBase;

	SetTestStepResult(EPass);

	return TestStepResult();

	}

TInt CCreateRConnectionStep::ConfigureFromIni()

	{

	iParams.Reset();

	// Read in appropriate fields

	if((GetStringFromConfig(iSection, KTe_ConnectionName, iParams.iConnectionName) != 1)

		|| (iParams.iConnectionName.Length() == 0))

		{

		INFO_PRINTF1(_L("Couldn't find appropriate field in config file"));

		return KErrNotFound;

		}

    // All ok if we got this far

    return KErrNone;

	}

TVerdict CCreateRConnectionStep::doSingleTestStep()

	{

    TInt error = iEsockTest->CreateConnection(iParams.iConnectionName);

    if (error!=KErrNone)

        {

        INFO_PRINTF2(_L("Could not create connection (%S)."),&iParams.iConnectionName);

        INFO_PRINTF2(_L("Error: %d."),error);

		SetTestStepResult(EFail);

        }

	return TestStepResult();

	}

// Open Connection

//----------------

COpenRConnectionStep::COpenRConnectionStep(CCEsockTestBase*& aEsockTest)

:   CTe_EsockStepBase(aEsockTest)

	{

	SetTestStepName(KOpenRConnectionStep);

	}

TInt COpenRConnectionStep::ConfigureFromIni()

	{

	iParams.Reset();

	// Read in appropriate fields

	if((GetStringFromConfig(iSection, KTe_ConnectionName, iParams.iConnectionName) != 1)

		|| (iParams.iConnectionName.Length() == 0))

		{

		INFO_PRINTF1(_L("Couldn't find appropriate field in config file"));

		return KErrNotFound;

		}

    if (GetStringFromConfig(iSection, KTe_SocketServName, iParams.iSockServName) != 1)

        {

        INFO_PRINTF2(_L("%S: Socket server name missing."), &iParams.iConnectionName);

        return EFalse;

        }

    // Optional

    // Reads the protocol family to use

    if (!GetIntFromConfig(iSection, KTe_ConnectionType, iParams.iConnectionType))

        {

        iParams.iConnectionType = -1;

        }

    // All ok if we got this far

    return KErrNone;

	}

TVerdict COpenRConnectionStep::doSingleTestStep()

	{

    TInt error = iEsockTest->OpenConnection(iParams);

    if (error!=KErrNone)

        {

        INFO_PRINTF2(_L("Could not open connection (%S)."),&iParams.iConnectionName);

        INFO_PRINTF2(_L("Error: %d."),error);

        return EFail;

        }

	return EPass;

	}

// Start Connection

//-----------------

CStartRConnectionStep::CStartRConnectionStep(CCEsockTestBase*& aEsockTest)

:   CTe_EsockStepBase(aEsockTest)

	{

	SetTestStepName(KStartRConnectionStep);

	}

TInt CStartRConnectionStep::ConfigureFromIni()

	{

	iParams.Reset();

	TPtrC temp;

	// Read in appropriate fields

	if((GetStringFromConfig(iSection, KTe_ConnectionName, iParams.iConnectionName) != 1)

		|| (iParams.iConnectionName.Length() == 0))

		{

		INFO_PRINTF1(_L("Couldn't find appropriate field in config file"));

		return KErrNotFound;

		}

    GetStringFromConfig(iSection, KTe_SocketServName, iParams.iSockServName);

    // Optional

    // Reads the protocol family to use

    if (!GetIntFromConfig(iSection, KTe_ConnectionType, iParams.iConnectionType))

        {

          iParams.iConnectionType = -1;

        }

	TPtrC16 bearerSet;

	TBool bearerPresent = ((GetStringFromConfig(iSection,KTe_BearerName,bearerSet)==1)

		&& (bearerSet.Length()>0));

	TBool IAPpresent = (GetIntFromConfig(iSection,KTe_IAPIndexName,iParams.iIAP)==1);

	TBool SNAPpresent = (GetIntFromConfig(iSection,KTe_SNAPIndexName,iParams.iSNAP)==1);

	TBool ConnPrefPresent = (GetIntFromConfig(iSection,KTe_ConnPrefListIndexName,iParams.iSNAP)==1);

	TBool DummyPresent = (GetIntFromConfig(iSection,KTe_DummyPrefIndexName,iParams.iDummy)==1);

	TBool AsynchPresent = (GetStringFromConfig(iSection,KTe_AsynchIndexName,temp)==1);

	iParams.iStartWithOldPreferences = IAPpresent;

	iParams.iStartWithSnapPreferences = SNAPpresent;

	iParams.iStartWithConPrefList = ConnPrefPresent;

	iParams.iStartWithDummy = DummyPresent;

	iParams.iAsynch = AsynchPresent;

	GetBoolFromConfig(iSection, KTe_AutoStartPrefName, iParams.iStartAuto);

	if (iParams.iStartWithOldPreferences && iParams.iStartWithSnapPreferences)

		{

		INFO_PRINTF2(_L("Connection preferences for (%S) have both snap and IAP."),&iParams.iConnectionName);

		return KErrNotFound;

		}

	//with preferences?

	if (iParams.iStartWithOldPreferences)

		{

		if(!bearerPresent)

			{

			iParams.iBearer = KCommDbBearerUnknown;

			}

		else

			{

			if (bearerSet.Compare(KTe_CommDbBearerCSD)==0)

				{ iParams.iBearer = KCommDbBearerCSD; }

			else if (bearerSet.Compare(KTe_CommDbBearerWcdma)==0)

				{ iParams.iBearer = KCommDbBearerWcdma; }

			else if (bearerSet.Compare(KTe_CommDbBearerLAN)==0)

				{ iParams.iBearer = KCommDbBearerLAN; }

			else

				{

				INFO_PRINTF3(_L("%S: Bearer type (%S) not recognised."),&iParams.iConnectionName,&bearerSet);

				return KErrNotFound;

				}

			}

		}

	// What error are we expecting?

	if (!GetIntFromConfig(iSection, KExpectedError,iExpectedError))

		{

		iExpectedError = KExpectedErrorNotUsed;

		}

	else

		{

		INFO_PRINTF2(_L("Error to be expected: %d"),iExpectedError);

		}

    // All ok if we got this far

    return KErrNone;

	}

TVerdict CStartRConnectionStep::doSingleTestStep()

	{

	// Default to failing

	SetTestStepResult(EFail);

	TInt ret = iEsockTest->StartConnection(iParams);

	// Log any error found

	if(iExpectedError == KExpectedErrorNotUsed)

		{

		SetTestStepError(ret);

		if(ret == KErrNone)

			{

			SetTestStepResult(EPass);

			}

		else

			{

			INFO_PRINTF2(_L("Could not start connection (%S)."), &iParams.iConnectionName);

			INFO_PRINTF2(_L("Error: %d"), ret);

			}

		}

	else

		{

		// We are expecting a special kind of error

		INFO_PRINTF3(_L("Expected error used. expected:%d, observed:%d"), iExpectedError, ret);

		SetTestStepResult((ret == iExpectedError) ? EPass : EFail);

		SetTestStepError((ret == iExpectedError) ? KErrNone : ret);

		}

	return TestStepResult();

	}

// CStartStopCrazyLoopRConnectionStep

//-----------------

CStartStopCrazyLoopRConnectionStep::CStartStopCrazyLoopRConnectionStep(CCEsockTestBase*& aEsockTest)

:   CStartRConnectionStep(aEsockTest)

    {

    SetTestStepName(KStartStopCrazyLoopRConnectionStep);

    }

TInt CStartStopCrazyLoopRConnectionStep::CalibrateStart()

    {

    TTime timeBegin;

    TTime timeEnd;

    TRequestStatus* pConnectionStartStatus = iEsockTest->iRequestStatuses.Find(iParams.iConnectionName);

    if (pConnectionStartStatus == NULL)

        {

        return KErrCorrupt;

        }

    timeBegin.HomeTime();

    TInt error = iEsockTest->StartConnection(iParams);

    if (error != KErrNone)

        {

        return error;

        }

    User::WaitForRequest(*pConnectionStartStatus);

    if (pConnectionStartStatus->Int() != KErrNone)

        {

        return pConnectionStartStatus->Int();

        }    

    timeEnd.HomeTime();

    iEsockTest->StopConnection(iParams);

    return timeEnd.MicroSecondsFrom(timeBegin).Int64();

    }

TVerdict CStartStopCrazyLoopRConnectionStep::doSingleTestStep()

    {

    // Default to failing

    SetTestStepResult(EFail);

    iParams.iAsynch = ETrue; //force async.

    if (error!=KErrNone)

        {

        INFO_PRINTF2(_L("Creating RTimer object failed with %d"), error);

        return TestStepResult();

        }

        {

        INFO_PRINTF1(_L("Heap allocation for TRequestStatus failed"));

        return TestStepResult();

        }

    if (error!=KErrNone)

        {

        INFO_PRINTF2(_L("Failed "), error);

        return TestStepResult();

        }

    INFO_PRINTF1(_L("Calibrating timer by running full start"));

    //Well, we're running the full start twice as the first run is likely to take more than the representative time.

    TInt timerIncrement = Min<TInt>(CalibrateStart(), CalibrateStart());

    if (timerIncrement < 0)

        {

        INFO_PRINTF2(_L("Full start failed, unable to calibrate, test failed with %d"), timerIncrement);

        return TestStepResult();

        }

    TInt timerVal = 1;

        {

        INFO_PRINTF2(_L("[Loop %d], Starting a new loop=============================="), i);

        if (iEsockTest->OpenConnection(iParams) != KErrNone)

            {

            INFO_PRINTF1(_L("Can't reopen connection, most likely you didn't supply the session name"));

            return TestStepResult();

            }

        timerVal += timerIncrement;

        }

    SetTestStepResult(EPass);

    return TestStepResult();

    }

// Stop Connection

//----------------

CStopRConnectionStep::CStopRConnectionStep(CCEsockTestBase*& aEsockTest)

:   CTe_EsockStepBase(aEsockTest)

	{

	SetTestStepName(KStopRConnectionStep);

	}

TInt CStopRConnectionStep::ConfigureFromIni()

	{

	iParams.Reset();

	// Read in appropriate fields

	if((GetStringFromConfig(iSection, KTe_ConnectionName, iParams.iConnectionName) != 1)

		|| (iParams.iConnectionName.Length() == 0))

		{

		INFO_PRINTF1(_L("Couldn't find appropriate field in config file"));

		return KErrNotFound;

		}

    TPtrC shutdownType;

    if (GetStringFromConfig(iSection,KTe_ConnectionStopTypeName,shutdownType)!=1)

        {

        INFO_PRINTF2(_L("%S: Stop type missing."),&iParams.iConnectionName);

        return KErrNotFound;

        }

    if (shutdownType.Compare(KTe_ConnStopNormal)==0)

	    { iParams.iConnStopType = RConnection::EStopNormal; }

    else if (shutdownType.Compare(KTe_ConnStopAuthoritative)==0)

	    { iParams.iConnStopType = RConnection::EStopAuthoritative; }

    else

        {

        INFO_PRINTF3(_L("%S: Stop type (%S) not recognised."),&iParams.iConnectionName,&shutdownType);

        return KErrNotFound;

        }

    // All ok if we got this far

    return KErrNone;

	}

TVerdict CStopRConnectionStep::doSingleTestStep()

	{

        TInt error = iEsockTest->StopConnection(iParams);

        if (error!=KErrNone)

            {

            INFO_PRINTF2(_L("Could not stop connection (%S)."),&iParams.iConnectionName);

            INFO_PRINTF2(_L("Error: %d."),error);

            return EFail;

            }

	return EPass;

	}

// Close Connection

//-----------------

CCloseRConnectionStep::CCloseRConnectionStep(CCEsockTestBase*& aEsockTest)

:   CTe_EsockStepBase(aEsockTest)

	{

	SetTestStepName(KCloseRConnectionStep);

	}

TInt CCloseRConnectionStep::ConfigureFromIni()

	{

	if((GetStringFromConfig(iSection, KTe_ConnectionName, iParams.iConnectionName) != 1)

		|| (iParams.iConnectionName.Length() == 0))

		{

		INFO_PRINTF1(_L("Couldn't find appropriate field in config file"));

		return KErrNotFound;

		}

    // All ok if we got this far

    return KErrNone;

	}

TVerdict CCloseRConnectionStep::doSingleTestStep()

	{

    TInt error = iEsockTest->CloseConnection(iParams.iConnectionName);

    if (error!=KErrNone)

        {

        INFO_PRINTF2(_L("Could not close connection (%S)."),&iParams.iConnectionName);

        INFO_PRINTF2(_L("Error: %d."),error);

		return EFail;

		}

	return EPass;

	}

// Wait for Incoming Connection

//-----------------------------

CWaitForIncomingConnectionStep::CWaitForIncomingConnectionStep(CCEsockTestBase*& aEsockTest)

:   CTe_EsockStepBase(aEsockTest)

	{

	SetTestStepName(KWaitForIncomingConnectionStep);

	}

TInt CWaitForIncomingConnectionStep::ConfigureFromIni()

    {

	//clean parameters from previous runs

	iParams.Reset();

    //try reading the next socket's name

    if (GetStringFromConfig(iSection,KTe_SubConnectionName,iParams.iSubConnectionName)!=1

        || iParams.iSubConnectionName.Length()==0)