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

// PARAM_MESS_NAME_CStep.CPP

// 

//

//Test Step header

#include "PARAM_MESS_NAME_CStep.h"

//TO BE SAFE

IMPORT_C TInt StartDialogThread();

const TUint KMagicConfigDaemonTestLevel  = 777;

const TUint KMagicConfigDaemonTestOption = 778;

CPARAM_MESS_NAMEStep::CPARAM_MESS_NAMEStep(TBool aUpsAuthorisationGranted)

/** Each test step initialises it's own name

*/

	{

	// store the name of this test case

	// this is the name that is used by the script file

	//DEF iTestStepName = _L("CPARAM_MESS_NAMEStep");

	//The server name and IPC number is obtained and all messages are checked Sync

	SR_ServerName		= _L("PARAM_SVR_NAME");

	SR_MESSAGE_TYPE		=	2;

	SR_MESSAGE_ID		= PARAM_MESS_VALUE;

	SR_MESSAGE_MASK		= PARAM_MESS_CAPMASK;

	// ECNControl level and name.

	iControlLevel		= PARAM_MESS_OPTLEVEL;

	iControlOption		= PARAM_MESS_OPTNAME;

	if(PARAM_MESS_OPTLEVEL == KMagicConfigDaemonTestLevel && PARAM_MESS_OPTNAME == KMagicConfigDaemonTestOption)

		{

		// For this particular case, NetworkServices capability is not controlled by the UPS (it is enforced

		// by the DHCP server).

		aUpsAuthorisationGranted = EFalse;

		}

	//The iServer_Panic is a unique name from Server,but always truncated to KMaxExitCategoryName

	iServer_Panic		=	_L("PARAM_SVR_T16_PANIC");

	TCapability cap[] = {ECapabilityPARAM_MESS_NAMECAP, ECapability_Limit};

	TSecurityInfo info;

	info.Set(RProcess());

	TBool result = EFalse;

	for (TInt i = 0; cap[i] != ECapability_Limit; i++)

	{

		if ((!aUpsAuthorisationGranted || cap[i] != ECapabilityNetworkServices) &&

			!(info.iCaps.HasCapability(cap[i])))

		{

			result=ETrue;

		}

	}

	iExpect_Rejection = result;

	iStepCap			= (TUint32)PARAM_MESS_CAPMASK;

	//Get a unique thread name

	ChildThread_SR.Format(_L("ChildThread_%S_%d"),&SR_ServerName,SR_MESSAGE_ID);

	}

TInt CPARAM_MESS_NAMEStep::Exec_SendReceive()

	{

	_LIT(KEsockSessStartMutex,"KESSMTX"); //Keep the descriptor short

	RMutex mutex;

	TInt r;

	// Protect the openning of the session

	// with a mutex to stop thread collision

	FOREVER

		{

		r = mutex.CreateGlobal(KEsockSessStartMutex());

		if (r == KErrNone)

			break;

		if (r != KErrAlreadyExists)

			return r;

		r=mutex.OpenGlobal(KEsockSessStartMutex());

		if (r == KErrNone)

			break;

		if (r != KErrNotFound)

			return r;

		}

	mutex.Wait(); // the exclusion ensures the session is started atomically

	iResult_Server=CreateSession(SOCKET_SERVER_NAME,Version());

	// Because ESock is now loaded by the Comms Root Server which is generally started during

	// the boot this should commonly succeed; however for test code this is still a possibility

	// Hence here we try starting it; this is an atomic operation (and cheap if it's already started)

	if (iResult_Server==KErrNotFound)

		{

		r=StartC32();

		if (r==KErrNone || r==KErrAlreadyExists)

			{

			iResult_Server=CreateSession(SOCKET_SERVER_NAME,Version());

			}

		}

	mutex.Signal();

	mutex.Close();

	if (iResult_Server == KErrNone)

		{

		iSessionCreated = ETrue;

		const TInt test_id = dispatch_num<PARAM_MESS_VALUE>::result;

		iResult_SR = do_execute(Int2Type<test_id>());

		// This is essentially an RSocketServ, so must be closed

		Close();

		}

	else

		{

		iSessionCreated = EFalse;

		return 0;

		}

	return r;

	}

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

// testing

// RConnection::ESCPSStop

// Requires alive connection. Uses Ethernet one

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

TInt CPARAM_MESS_NAMEStep::do_execute(Int2Type<ESCPSStop>)

{

    TInt result;

    //-- 1. Create and start a connection.

    result = CreateStartDefaultConnection();

    if(result != KErrNone)

        return result;

    result =SendReceive(ESCPSStop,TIpcArgs(1, 0, 0, iSSRef));

    //-- stop and close connection

    StopCloseConnection();

    return result;

}

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

// testing

// RConnection::ESCPSProgressNotification and ESCPSCancelProgressNotification

// Requires alive connection. Uses Ethernet one

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

TInt CPARAM_MESS_NAMEStep::do_execute(Int2Type<ESCPSProgressNotification>)

{

    TInt result;

    //-- 1. Create and start a connection.

    result = CreateStartDefaultConnection();

    if(result != KErrNone)

        return result;

    TNifProgressBuf nifProgrBuf;

    TRequestStatus  rqStat;

    const TSubConnectionUniqueId subConnId = 1;

    //-- subscribe to the progress notification

    SendReceive(ESCPSProgressNotification,TIpcArgs(subConnId, &nifProgrBuf, KConnProgressDefault, iSSRef), rqStat);

    result = rqStat.Int();

    if((result != KErrNone) && (result != KRequestPending))

        {

		StopCloseConnection();

        return result;

	    }

    //-- now cancel the progress notification

    result = SendReceive(ESCPSCancelProgressNotification,TIpcArgs(subConnId, 0, 0, iSSRef));

    User::WaitForRequest(rqStat);

    //-- stop and close connection

    StopCloseConnection();

    return result;

}

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

// testing

// RConnection::ECNGetIntSetting

// Requires alive connection. Uses Ethernet one

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

TInt CPARAM_MESS_NAMEStep::do_execute(Int2Type<ECNGetIntSetting>)

{

    TInt result;

    //-- 1. Create and start a connection.

    result = CreateStartDefaultConnection();

    if(result != KErrNone)

        return result;

    // read an integer value from commdb (IAP\Id chosen)

	_LIT(KName, "IAP\\id");

	TBufC<7> name(KName);

	TUint32 intval= 0;

    TPckg<TUint32> intPckg(intval);

    result =SendReceive(ECNGetIntSetting,TIpcArgs(&name, &intPckg, 0, iSSRef));

    //-- stop and close connection

    StopCloseConnection();

    return result;

}

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

// testing

// RConnection::ECNGetBoolSetting

// Requires alive connection. Uses Ethernet one

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

TInt CPARAM_MESS_NAMEStep::do_execute(Int2Type<ECNGetBoolSetting>)

{

    TInt result;

    //-- 1. Create and start a connection.

    result = CreateStartDefaultConnection();

    if(result != KErrNone)

        return result;

	// read a bool value from commdb (DialOutISP\IfPromptForAuth chosen)

	_LIT(KName, "LANService\\IpAddrFromServer");

	TBufC<27> name(KName);

	TBool boolval=EFalse;

    TPckg<TBool> boolPckg(boolval);

    result =SendReceive(ECNGetBoolSetting,TIpcArgs(&name, &boolPckg, 0, iSSRef));

    //-- stop and close connection

    StopCloseConnection();

    return result;

}

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

// testing

// RConnection::ECNGetDes8Setting

// Requires alive connection. Uses Ethernet one

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

TInt CPARAM_MESS_NAMEStep::do_execute(Int2Type<ECNGetDes8Setting>)

{

    TInt result;

    //-- 1. Create and start a connection.

    result = CreateStartDefaultConnection();

    if(result != KErrNone)

        return result;

	_LIT(KName, "LANBearer\\Agent");

	TBufC<21> name(KName);

	TBuf8<128> desval8;

    result =SendReceive(ECNGetDes8Setting,TIpcArgs(&name, &desval8, 0, iSSRef));

    //-- stop and close connection

    StopCloseConnection();

    return result;

}

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

// testing

// RConnection::ECNGetDes16Setting

// Requires alive connection. Uses Ethernet one

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

TInt CPARAM_MESS_NAMEStep::do_execute(Int2Type<ECNGetDes16Setting>)

{

    TInt result;

    //-- 1. Create and start a connection.

    result = CreateStartDefaultConnection();

    if(result != KErrNone)

        return result;

	_LIT(KName, "LANBearer\\Agent");

	TBufC<21> name(KName);

	TBuf16<128> desval16;

    result =SendReceive(ECNGetDes16Setting,TIpcArgs(&name, &desval16, 0, iSSRef));

    //-- stop and close connection

    StopCloseConnection();

    return result;

}

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

// testing

// RConnection::ECNGetLongDesSetting

// Requires alive connection. Uses Ethernet one

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

TInt CPARAM_MESS_NAMEStep::do_execute(Int2Type<ECNGetLongDesSetting>)

{

    TInt result;

    //-- 1. Create and start a connection.

    result = CreateStartDefaultConnection();

    if(result != KErrNone)

        return result;

	_LIT(KName, "LANBearer\\Agent");

	TBufC<23> name(KName);

	TBuf<128> longdesval;

    result =SendReceive(ECNGetLongDesSetting,TIpcArgs(&name, &longdesval, 0, iSSRef));

    //-- stop and close connection

    StopCloseConnection();

    return result;

}

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

// testing

// RConnection::ECNStart

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

TInt CPARAM_MESS_NAMEStep::do_execute(Int2Type<ECNCreate>)

{

    TInt result;

    //-- 1. Create (Open) a connection

    const TUint KConnectionType = KAfInet;

    TPckgBuf<TInt> session(iSSRef);

    result = SendReceive(ECNCreate,TIpcArgs(KConnectionType, 0, 0, &session));

    iSSRef = session(); //-- this is the esock subsession handle

    //-- close connection

    CloseConnection();

    return result;

}

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

// testing

// RConnection::ECNCreate

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

TInt CPARAM_MESS_NAMEStep::do_execute(Int2Type<ECNCreateWithName>)

{

    TInt result;

    //-- 1. Create a connection.

    result = CreateConnection();

    if(result != KErrNone)

        return result;

    TName connName;

    result =SendReceive(ECNReference,TIpcArgs(&connName, 0, 0, iSSRef));

	if (result != KErrNone)

	    return result;

	result = SendReceive(ECNCreateWithName,TIpcArgs(&connName, 0, 0, iSSRef));

    //-- close connection

    CloseConnection();

	return result;

}

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

// testing

// RConnection::ECNStart

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

TInt CPARAM_MESS_NAMEStep::do_execute(Int2Type<ECNStart>)

{

    TInt result;

    //-- 1. Create a connection.

    result = CreateConnection();

    if(result != KErrNone)

        return result;

    //-- 2. start the connection

    result = SendReceive(ECNStart,TIpcArgs(0,0,0,iSSRef));

    //-- stop and close connection

    StopCloseConnection();

    return result;

}

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

// testing

// RConnection::ECNSetStartPrefs

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

TInt CPARAM_MESS_NAMEStep::do_execute(Int2Type<ECNSetStartPrefs>)

{

    TInt result;

    //-- 1. Create a connection.

    result = CreateConnection();

    if(result != KErrNone)

        return result;

    //-- 2. start connection with preferences

    TCommDbConnPref prefs;

    prefs.SetDialogPreference(ECommDbDialogPrefDoNotPrompt);

    result =SendReceive(ECNSetStartPrefs,TIpcArgs(&prefs, 0, 0, iSSRef));

	if (result == KErrNone)

		{

		// Continue starting connection so that session is not left in a half-started state

		// Note this may fail, but the test succeeds based on "result" since that is the IPC being tested

		TInt err = SendReceive(ECNStart,TIpcArgs(0,0,0,iSSRef));

		}

    //-- stop and close connection

    StopCloseConnection();

    return result;

}

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

// testing

// RConnection::ECNStop

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

TInt CPARAM_MESS_NAMEStep::do_execute(Int2Type<ECNStop>)

{

    TInt result;

    //-- 1. Create and start a connection.

    result = CreateStartDefaultConnection();

    if(result != KErrNone)

        return result;

    //-- 2. start the connection

    result = SendReceive(ECNStop,TIpcArgs(RConnection::EStopAuthoritative,0,0,iSSRef));

    //-- stop and close connection

    CloseConnection();

    return result;

}

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

// testing

// RConnection::ECNReference

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

TInt CPARAM_MESS_NAMEStep::do_execute(Int2Type<ECNCancelIoctl>)

{

    TInt result;

    //-- 1. Create a connection.

    result = CreateConnection();

    if(result != KErrNone)

        return result;

    result =SendReceive(ECNCancelIoctl,TIpcArgs(0, 0, 0, iSSRef));

    //-- close connection

    CloseConnection();

    return result;

}

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

// testing

// RConnection::ECNReference

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

TInt CPARAM_MESS_NAMEStep::do_execute(Int2Type<ECNReference>)

{

    TInt result;

    //-- 1. Create a connection.

    result = CreateConnection();

    if(result != KErrNone)

        return result;

    TName connName;

    result =SendReceive(ECNReference,TIpcArgs(&connName, 0, 0, iSSRef));

    //-- close connection

    CloseConnection();

    return result;

}

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

// testing

// RConnection::ECNProgress

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

TInt CPARAM_MESS_NAMEStep::do_execute(Int2Type<ECNProgress>)

{

    TInt result;

    //-- 1. Create a connection.

    result = CreateConnection();

    if(result != KErrNone)

        return result;

    TNifProgress progr;

    TPckg<TNifProgress> progrPckg(progr);

    result =SendReceive(ECNProgress,TIpcArgs(&progrPckg, 0, 0, iSSRef));

    //-- close connection

    CloseConnection();

    return result;

}