// 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) != 1)

        {

          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;

		}

	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();

	}

// 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)

            return KErrNotFound;

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

        {

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

        return KErrNotFound;

        }

    //optional

    GetStringFromConfig(iSection,KTe_ConnectionStatus,subConnStatus);

    GetStringFromConfig(iSection,KTe_IncomingConnTimerSet,timerSet);

	return KErrNone;

    }

TVerdict CWaitForIncomingConnectionStep::doSingleTestStep()

	{

    /*

    These scenarios are tested here

    1.Timer expires since there is no incoming connection.

    2.Cancel the waitforincoming connection.

    */

    const int timerVal = 3000;

    TInt error;

    TInt errCancel;

    TRequestStatus reqStat;

    //Set the timer if subConnStatus is TimerOn

    if (timerSet.Compare(KTe_IncomingConnTimerStatus) == 0)

        {

        iTimer.CreateLocal();

        iTimer.After(reqStat,timerVal);

	    }

    TRequestStatus reqStat1;

    TInt error1 = iEsockTest->WaitforIncomingConnection(iParams,reqStat1);

    if (error1!=KErrNone)

        {

        INFO_PRINTF2(_L("Error in wait for incoming connection: %d."),error1);

        return EFail;

        }

	//check whether the cancel status is set or not.

	if ((subConnStatus.Compare(KTe_ConnCancelStatus)==0) && (reqStat1 != KErrNone))

    	{

        errCancel = iEsockTest->CancelIncomingConnection(iParams);

        if (errCancel != KErrNone)

            {

        	INFO_PRINTF2(_L("Error in cancelling the incoming connection: %d."),errCancel);

            }

    	}

	User::WaitForRequest(reqStat,reqStat1);

	error  = reqStat.Int();

	error1 = reqStat1.Int();

	//check whether the timer is expired.

   	if ((timerSet.Compare(KTe_IncomingConnTimerStatus)==0) && (error == KErrNone))

    	{

    	INFO_PRINTF1(_L("Timer was called since there was no incoming connection"));

    	iTimer.Close();

    	return EPass;

   		}

   	//check whether the KErrArgument is returned since the RSubConnection is already opened.

   	else if ((subConnStatus.Compare(KTe_ConnOpenStatus)==0) && (error1 == KErrArgument))

    	{

    	INFO_PRINTF1(_L("Returned KErrArgument since RsubCon was opened prior to Waitforincoming connection "));

    	return EPass;

   		}

   	//check whether KErrCancel is returned for cancelling incoming connection.

   	else if ((subConnStatus.Compare(KTe_ConnCancelStatus)==0) && (error1 == KErrCancel))

    	{

    	INFO_PRINTF1(_L("Successfully cancelled the incoming connection"));

    	return EPass;

   		}

	if (error1!=KErrNone)

		{

		INFO_PRINTF2(_L("Error in wait for incoming connection: %d."),error1);

    	return EFail;

		}

    return EPass;

	}

// Reject Incoming Connection

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

CRejectIncomingConnectionStep::CRejectIncomingConnectionStep(CCEsockTestBase*& aEsockTest)

:   CTe_EsockStepBase(aEsockTest)

	{

	SetTestStepName(KRejectIncomingConnectionStep);

	}

TInt CRejectIncomingConnectionStep::ConfigureFromIni()

    {

	//clean parameters from previous runs

	iParams.Reset();

    //try reading from ini file

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

        {

        return KErrNotFound;

        }

	return KErrNone;

    }

TVerdict CRejectIncomingConnectionStep::doSingleTestStep()

	{

    TInt error = iEsockTest->RejectIncomingConnection(iParams);

   	if (error!=KErrNone)

	    {

		INFO_PRINTF2(_L("Error in rejecting the  incoming connection: %d."),error);

	    return EFail;

		}

	return EPass;

	}

// Accept Incoming Connection

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

CAcceptIncomingConnectionStep::CAcceptIncomingConnectionStep(CCEsockTestBase*& aEsockTest)

:   CTe_EsockStepBase(aEsockTest)

	{

	SetTestStepName(KAcceptIncomingConnectionStep);

	}

TInt CAcceptIncomingConnectionStep::ConfigureFromIni()

	{

	iParams.Reset();

	// Read in appropriate fields

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

		|| (iParams.iSubConnectionName.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 CAcceptIncomingConnectionStep::doSingleTestStep()

	{

    TInt error = iEsockTest->AcceptIncomingConnection(iParams);

   	if (error!=KErrNone)

		{

		INFO_PRINTF2(_L("Error in accepting the  incoming connection: %d."),error);

	    return EFail;

		}

	return EPass;

	}

// Async Incoming Connection

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

CAsyncAcceptIncomingConnectionStep::CAsyncAcceptIncomingConnectionStep(CCEsockTestBase*& aEsockTest)

:   CTe_EsockStepBase(aEsockTest)