// 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 BearerMobility.TestSteps.cpp

*/

#include "Connections.TestSteps.h"

#include "BearerMobility.TestSteps.h"

using namespace ESock;

// Accept

//-------

Cacceptcarrierrcommsmobilityapiext::Cacceptcarrierrcommsmobilityapiext(CCEsockTestBase*& aEsockTest)

:   CTe_EsockStepBase(aEsockTest)

	{

	SetTestStepName(Kacceptcarrierrcommsmobilityapiext);

	}

TInt Cacceptcarrierrcommsmobilityapiext::ConfigureFromIni()

    {

	//clean parameters from previous runs

	iMobilityExtName.Set(KNullDesC);

	iConnectionName.Set(KNullDesC);

    //try reading the name of the subconnection bundle

    if (GetStringFromConfig(iSection,KTe_MobilityAPIName,iMobilityExtName)!=1

        || iMobilityExtName.Length()==0)

            return KErrNotFound;

    return KErrNone;

    }

TVerdict Cacceptcarrierrcommsmobilityapiext::doSingleTestStep()

	{

	RCommsMobilityApiExt* mob = iEsockTest->FindMobilityExtension(iMobilityExtName);

    if (mob==NULL)

        {

        INFO_PRINTF1(_L("Could not find mobility extension."));

        return EFail;

        }

    mob->NewCarrierAccepted();

	return EPass;

	}

// Reject

//-------

Crejectcarrierrcommsmobilityapiext::Crejectcarrierrcommsmobilityapiext(CCEsockTestBase*& aEsockTest)

:   CTe_EsockStepBase(aEsockTest)

	{

	SetTestStepName(Krejectcarrierrcommsmobilityapiext);

	}

TInt Crejectcarrierrcommsmobilityapiext::ConfigureFromIni()

    {

	//clean parameters from previous runs

	iMobilityExtName.Set(KNullDesC);

	iConnectionName.Set(KNullDesC);

    //try reading the name of the subconnection bundle

    if (GetStringFromConfig(iSection,KTe_MobilityAPIName,iMobilityExtName)!=1

        || iMobilityExtName.Length()==0)

            return KErrNotFound;

    return KErrNone;

    }

TVerdict Crejectcarrierrcommsmobilityapiext::doSingleTestStep()

	{

    RCommsMobilityApiExt* mob = iEsockTest->FindMobilityExtension(iMobilityExtName);

    if (mob==NULL)

        {

        INFO_PRINTF1(_L("Could not find mobility extension."));

        return EFail;

        }   

   	mob->NewCarrierRejected();

	return EPass;

	}

// Cancel notification

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

CCancelMobilityNotificationStep::CCancelMobilityNotificationStep(CCEsockTestBase*& aEsockTest)

:   CTe_EsockStepBase(aEsockTest)

	{

	SetTestStepName(KCancelMobilityNotificationStep);

	}

TInt CCancelMobilityNotificationStep::ConfigureFromIni()

    {

	//clean parameters from previous runs

	iMobilityExtName.Set(KNullDesC);

    //try reading the name of the subconnection bundle

    if (GetStringFromConfig(iSection,KTe_MobilityAPIName,iMobilityExtName)!=1

        || iMobilityExtName.Length()==0)

            return KErrNotFound;

    return KErrNone;

    }

TVerdict CCancelMobilityNotificationStep::doSingleTestStep()

	{

	SetTestStepResult(EFail);

	RCommsMobilityApiExt* mob = iEsockTest->FindMobilityExtension(iMobilityExtName);

	if (mob==NULL)

		{

		INFO_PRINTF1(_L("Could not find mobility extension."));

		}

	else

		{

		mob->CancelMobilityNotification();

		SetTestStepResult(EPass);

		}

	return TestStepResult();

	}

// Migrate

//--------

Cmigratercommsmobilityapiext::Cmigratercommsmobilityapiext(CCEsockTestBase*& aEsockTest)

:   CTe_EsockStepBase(aEsockTest)

	{

	SetTestStepName(Kmigratercommsmobilityapiext);

	}

TInt Cmigratercommsmobilityapiext::ConfigureFromIni()

    {

	//clean parameters from previous runs

	iMobilityExtName.Set(KNullDesC);

	iConnectionName.Set(KNullDesC);

    //try reading the name of the subconnection bundle

    if (GetStringFromConfig(iSection,KTe_MobilityAPIName,iMobilityExtName)!=1

        || iMobilityExtName.Length()==0)

            return KErrNotFound;

    return KErrNone;

    }

TVerdict Cmigratercommsmobilityapiext::doSingleTestStep()

	{

    RCommsMobilityApiExt* mob = iEsockTest->FindMobilityExtension(iMobilityExtName);

    if (mob==NULL)

        {

        INFO_PRINTF1(_L("Could not find mobility extension."));

        return EFail;

        }

 	mob->MigrateToPreferredCarrier();

	return EPass;

	}

// Ignore

//-------

Cignorercommsmobilityapiext::Cignorercommsmobilityapiext(CCEsockTestBase*& aEsockTest)

:   CTe_EsockStepBase(aEsockTest)

	{

	SetTestStepName(Kignorercommsmobilityapiext);

	}

TInt Cignorercommsmobilityapiext::ConfigureFromIni()

    {

	//clean parameters from previous runs

	iMobilityExtName.Set(KNullDesC);

    //try reading the name of the subconnection bundle

    if (GetStringFromConfig(iSection,KTe_MobilityAPIName,iMobilityExtName)!=1

        || iMobilityExtName.Length()==0)

            return KErrNotFound;

    return KErrNone;

    }

TVerdict Cignorercommsmobilityapiext::doSingleTestStep()

	{

    RCommsMobilityApiExt* mob = iEsockTest->FindMobilityExtension(iMobilityExtName);

    if (mob==NULL)

        {

        INFO_PRINTF1(_L("Could not find mobility extension."));

        return EFail;

        }

	mob->IgnorePreferredCarrier();

	return EPass;

	}

// Check

//------

CCheckMobilityNotificationStep::CCheckMobilityNotificationStep(CCEsockTestBase*& aEsockTest)

:   CTe_EsockStepBase(aEsockTest)

    {

	SetTestStepName(KCheckMobilityNotificationStep);

	}

TInt CCheckMobilityNotificationStep::ConfigureFromIni()

	{

	iParams.Reset();

	iOldAP = 0;

	iNewAP = 0;

	iExpectedError = KExpectedErrorNotUsed;

	iExpectedError2 = KExpectedErrorNotUsed;

	// Read in appropriate fields

	if((GetStringFromConfig(iSection, KTe_MobilityAPIName, iParams.iMobilityExtName) != 1)

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

		{

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

		return KErrNotFound;

		}

	//calculate name for the event container (it is not settable from the ini)

	iEventName = iParams.iMobilityExtName;

	iEventName.Append(_L("_EvContainer"));

	iParams.iEventName.Set(iEventName);

	// Get any timeout value and if we have one then we are not expecting any notification

	if(!GetIntFromConfig(iSection, KTimeoutInMilliSeconds, iParams.iTimeoutMiliSecs))

		{

		// Default to 5 second timeout

		iParams.iTimeoutMiliSecs = 7000; //Seven for luck :)) and really to be shorter than the idle timer (10)

		}

	//there may be more than one expected event kind, register all of them

	TBool descriptionComplete = EFalse;

	for (TInt idx = 0; !descriptionComplete; idx++)

		{

		TBuf<KMaxTestExecuteNameLength> fieldName(KTe_Expected);

		fieldName.AppendNum(idx);

		TPtrC eventName;

		if (GetStringFromConfig(iSection,fieldName,eventName)==1)

			{

			TBuf<KMaxTestExecuteNameLength> fieldNameAp(fieldName);

			fieldNameAp.Append(KTe_MobilityNotificationPreferredCarrierAvailable_NewAP);

			if (eventName.Compare(KTe_MobilityNotificationPreferredCarrierAvailable)==0)

				{

				iParams.iEventMask |= ESock::EPreferredCarrierAvailable;

				GetIntFromConfig(iSection,fieldNameAp,iNewAP);

				fieldNameAp.Copy(fieldName);

				fieldNameAp.Append(KTe_MobilityNotificationPreferredCarrierAvailable_OldAP);

				GetIntFromConfig(iSection,fieldNameAp,iOldAP);

				}

			else if (eventName.Compare(KTe_MobilityNotificationNewCarrierActive)==0)

				{

				iParams.iEventMask |= ESock::ENewCarrierActive;

				GetIntFromConfig(iSection,fieldNameAp,iNewAP);

				}

			else

			   {

			   INFO_PRINTF3(_L("%S: Event type (%S) not recognised."),&iParams.iMobilityExtName,&eventName);

			   return KErrNotFound;

			   }

			}

		else

			{

			descriptionComplete = ETrue;

			}

		}

	// Log what events we are expecting if any

	if(iParams.iEventMask)

		{

		INFO_PRINTF3(_L("%S: Events to be expected: 0x%x"),&iParams.iMobilityExtName,iParams.iEventMask);

		}

	else

		{

		INFO_PRINTF2(_L("%S: No events specified so expecting no notifications and to timeout instead."), &iParams.iMobilityExtName);

		}

	// What error are we expecting?

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

		{

		iExpectedError = KExpectedErrorNotUsed;

		}

	else 

		{

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

		}

	// What error are we expecting?

	if (!GetIntFromConfig(iSection, KExpectedError2,iExpectedError2))

		{

		iExpectedError2 = KExpectedErrorNotUsed;

		}

    // All ok if we got this far

    return KErrNone;

	}

TVerdict CCheckMobilityNotificationStep::doSingleTestStep()

	{

    SetTestStepResult(EFail);

    TDesC8* buffer = NULL;

	// Wait for the outstanding mobility notifications

    TInt error = iEsockTest->ReceiveMobilityNotification(buffer, iParams);

	if ((iExpectedError != KExpectedErrorNotUsed && error == iExpectedError)

		|| (iExpectedError2 != KExpectedErrorNotUsed && error == iExpectedError2))

		{

		INFO_PRINTF2(_L("Error (%d) received as expected"),error);

		SetTestStepResult(EPass);

		return TestStepResult();

		}

	// If we weren't expecting any mobility events and timed out waiting then we passed

	// But if we weren't expecting any and received one then we failed

    if (error == KErrCancel)

    	{

		if(iParams.iEventMask == 0)

			{

			INFO_PRINTF1(_L("Timed out waiting for notifications when expecting to do so."));

			SetTestStepResult(EPass);

			}

		else

			{

			INFO_PRINTF1(_L("Timed out when expecting an event."));

			}

		return TestStepResult();

		}

	if((error == KErrNone) && (buffer != NULL))

		{

		if(iParams.iEventMask != 0)

			{

			CCommsApiExtRespMsg * msg = NULL;

			TRAP(error, msg = CCommsApiExtRespMsg::NewL(*buffer));

			if(error != KErrNone || msg == NULL)

				{

				INFO_PRINTF2(_L("Could not demarshall incoming notification. error:%d."), error);

				}

			else

				{

				//check types

				STypeId preferredCarrierAvailableTID = STypeId::CreateSTypeId(ESock::KMobilityMessagesImplementationUid, ESock::EPreferredCarrierAvailable);

				STypeId newCarrierActiveTID = STypeId::CreateSTypeId(ESock::KMobilityMessagesImplementationUid, ESock::ENewCarrierActive);

				if (msg->IsTypeOf(preferredCarrierAvailableTID))

					{

					CPreferredCarrierAvailable* pca = static_cast<CPreferredCarrierAvailable*>(msg);

					if ((iParams.iEventMask & ESock::EPreferredCarrierAvailable)

						&& (iNewAP==0 || iNewAP==pca->NewAPInfo().AccessPoint())

						&& (iOldAP==0 || iOldAP==pca->OldAPInfo().AccessPoint()))

						{

						INFO_PRINTF4(_L("%S: Received PreferredCarrierAvailable notification from AP%d to AP%d as expected."),&iParams.iMobilityExtName, pca->OldAPInfo().AccessPoint(), pca->NewAPInfo().AccessPoint());

						SetTestStepResult(EPass);

						}

					else

						{

						INFO_PRINTF4(_L("%S: Received PreferredCarrierAvailable notification from AP%d to AP%d which was unexpected."),&iParams.iMobilityExtName, pca->OldAPInfo().AccessPoint(), pca->NewAPInfo().AccessPoint());

						}

					}

				else if (msg->IsTypeOf(newCarrierActiveTID))

					{

					CNewCarrierActive* nca = static_cast<CNewCarrierActive*>(msg);

					if ((iParams.iEventMask & ESock::ENewCarrierActive)

						&& (iNewAP==0 || iNewAP==nca->NewAPInfo().AccessPoint()))

						{

						INFO_PRINTF3(_L("%S: Received NewCarrierActive notification for AP%d as expected."),&iParams.iMobilityExtName, nca->NewAPInfo().AccessPoint());

						SetTestStepResult(EPass);

						}

					else

						{

						INFO_PRINTF3(_L("%S: Received NewCarrierActive notification for AP%d which was unexpected."),&iParams.iMobilityExtName, nca->NewAPInfo().AccessPoint());

						}

					}

				}

			delete msg;

			REComSession::FinalClose(); //Different thread to the main one, need to be closed here as well

			}

		else

			{

			// We were expecting a timeout and instead received a notification so we have failed

			INFO_PRINTF1(_L("We were not expecting a notification expecting to timeout."));

			}

		}

    else if (error != KErrNone)

        {

        INFO_PRINTF3(_L("%S: The error code returned was %d."), &iParams.iMobilityExtName, error);

        SetTestStepError(error);

        }

    else if (buffer == NULL)

        {

        INFO_PRINTF2(_L("%S: Did not receive any notification"),&iParams.iMobilityExtName);

        }

	return TestStepResult();

	}

// Close 

//------

CCloseRCommsMobilityAPIExtStep::CCloseRCommsMobilityAPIExtStep(CCEsockTestBase*& aEsockTest)

:   CTe_EsockStepBase(aEsockTest)

	{

	SetTestStepName(KCloseRCommsMobilityAPIExtStep);

	}

TInt CCloseRCommsMobilityAPIExtStep::ConfigureFromIni()

	{

	iMobilityExtName.Set(KNullDesC);

	// Read in appropriate fields

	if((GetStringFromConfig(iSection, KTe_MobilityAPIName, iMobilityExtName) != 1)

		|| (iMobilityExtName.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 CCloseRCommsMobilityAPIExtStep::doSingleTestStep()

	{

    RCommsMobilityApiExt* mob = iEsockTest->FindMobilityExtension(iMobilityExtName);

    if (mob==NULL)

        {

        INFO_PRINTF1(_L("Could not find mobility extension."));

        return EFail;

        }

    mob->Close();

	return EPass;

	}

// Open

//-----

COpenRCommsMobilityAPIExtStep::COpenRCommsMobilityAPIExtStep(CCEsockTestBase*& aEsockTest)

:   CTe_EsockStepBase(aEsockTest)

	{

	SetTestStepName(KOpenRCommsMobilityAPIExtStep);

	}

TInt COpenRCommsMobilityAPIExtStep::ConfigureFromIni()

    {

	//clean parameters from previous runs

	iMobilityExtName.Set(KNullDesC);

	iConnectionName.Set(KNullDesC);

    //try reading the name of the subconnection bundle

    if (GetStringFromConfig(iSection, KTe_MobilityAPIName, iMobilityExtName)!=1

        || iMobilityExtName.Length()==0)

            return KErrNotFound;

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

        {

        INFO_PRINTF1(_L("Connection name missing."));

        return KErrNotFound;

        }

    return KErrNone;

    }

TVerdict COpenRCommsMobilityAPIExtStep::doSingleTestStep()

	{

	SetTestStepResult(EFail);

	RConnection* c = iEsockTest->FindConnection(iConnectionName);

	if (c==NULL)

		{

		INFO_PRINTF2(_L("Could not find RConnection (%S)."),&iConnectionName);

		return EFail;

		}

	TInt error = iEsockTest->CreateMobilityExtension(iMobilityExtName);

	if (error!=KErrNone)

		{

		INFO_PRINTF2(_L("Could not create mobility extension (%d)."),error);

		return EFail;

		}

	RCommsMobilityApiExt* mob = iEsockTest->FindMobilityExtension(iMobilityExtName);

	if (mob==NULL)

		{

		INFO_PRINTF1(_L("Could not find mobility extension."));

		return EFail;

		}

	error = mob->Open(*c);

	if (error!=KErrNone)

		{

		INFO_PRINTF3(_L("Could not apply %S to %S."),&iMobilityExtName,&iConnectionName);

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

		SetTestStepError(error);

		return EFail;

		}

	return EPass;

	}