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

// implementation of test steps

// 

//

/**

 @file

*/

#include "WapIoctlSteps.h"

#include "WapProtSuiteDefs.h"

#include <etel.h>

#include <es_wsms.h>

#include <simtsy.h>

#include <sacls.h>

#include <s32mem.h>

#include <smspver.h>

TVerdict CIoctlStep_1::doTestStepL()

/**

 *  Test step one:

 *  Sends/receives a 7Bit business card using IOCTL

 *  @return - TVerdict code

 *  

 */

	{

	INFO_PRINTF1(_L("IOCTL Test step 1: send/receive 7-Bit business card"));

	TPtrC TestData1;

	TPtrC16 TelNumber;

	TInt port=226;

	TInt testNumber=1;

	if(!GetStringFromConfig(ConfigSection(),KTestData1, TestData1) ||

	   !GetStringFromConfig(ConfigSection(),KSCNumber,TelNumber) ||

	   !GetIntFromConfig(ConfigSection(),KWapPort,port))

		{

		// Leave if there's any error.

		User::Leave(KErrNotFound);

		}

	User::LeaveIfError(RProperty::Set(KUidSystemCategory, KUidPhonePwr.iUid, ESAPhoneOn));

	User::LeaveIfError(RProperty::Set(KUidPSSimTsyCategory, KPSSimTsyTestNumber, testNumber));

	//

    //	Setting the port number and service center number of the wap address

	//	The service center number should be the same as the sim phone number used

	//  for test (not required for SIM tsy)

	//

	TWapAddr wapAddr;

	TWapAddr recvWapAddr;

	wapAddr.SetWapPort(TWapPortNumber(port));

	TBuf8<100> scNumber;

	scNumber.Copy(TelNumber);

	TPtrC8 scAddr(scNumber);

	wapAddr.SetWapAddress(scAddr);

	//

	//	Connect to socket server

	//

	RSocketServ socketServer;

    User::LeaveIfError(socketServer.Connect());

	CleanupClosePushL(socketServer);

	//

	//	Define and open the socket

	//

	RSocket sock;

    OpenSocketLC(socketServer, sock);

 	//

	//	Waiting for the phone to be initialised

	//

	WaitForInitializeL();

	TRequestStatus ioctlStatus;

	TRequestStatus recvStatus;

	TPckgBuf<TInt> length;

	//

	//	Indicating to the protocol that it's a new client

	//

	INFO_PRINTF1(_L("Socket set option for indicating new client"));

	User::LeaveIfError(sock.SetOpt(KWapSmsOptionNewStyleClient,KWapSmsOptionLevel, 0));

	//

	//	Bind

	//

	User::LeaveIfError(sock.Bind(wapAddr));

	//

	//	Send a business card

	//

	TRequestStatus  status;

	TBuf8<200> data;

	data.Copy(TestData1);

	sock.SendTo(data, wapAddr, 0, status);

	User::WaitForRequest(status);

	User::LeaveIfError(status.Int());

	INFO_PRINTF1(_L("Message sent..."));

	//

	//	Issue Ioctl for getting the length of the message

	//

	INFO_PRINTF1(_L("Issue of IOCTL for GetLength"));

	sock.Ioctl(KSOGetLength, ioctlStatus, &length, KSolWapProv);

	//

	//	Get the size of the first incomming message

	//

	User::WaitForRequest(ioctlStatus);

	User::LeaveIfError(ioctlStatus.Int());

	INFO_PRINTF1(_L("IOCTL completed"));

	//

	//	Check if reported length is correct

	//

	TBuf8<256> recvBuf(length);

	TEST(length()==data.Length());

	//

	//	Receiving a datagram

	//

	sock.RecvFrom(recvBuf,recvWapAddr,0,recvStatus);

	User::WaitForRequest(recvStatus);

	User::LeaveIfError(recvStatus.Int());

	INFO_PRINTF1(_L("Received the message..."));

	//

	//	Confirm the receipt of the message to the client

	//

	INFO_PRINTF1(_L("Socket set option for indicating receipt of message"));

	User::LeaveIfError(sock.SetOpt(KWapSmsOptionOKToDeleteMessage,KWapSmsOptionLevel, 0));

	TEST(recvBuf.Compare(data) == 0);

	//

	//	Closing the socket

	//

	CleanupStack::PopAndDestroy(&sock);

    CleanupStack::PopAndDestroy(&socketServer);

	return TestStepResult();

	}

TVerdict CIoctlStep_2::doTestStepL()

/** 

 *	Test step two: 

 *	Sends/receives a 7-Bit calendar entry and VCard using IOCTL(two segments each)

 *	@return - TVerdict code

 * 

 */

	{

	INFO_PRINTF1(_L("IOCTL Test step 2: send/receive a VCal and VCard"));

	TPtrC TestData1;

	TPtrC TestData2;

	TPtrC16 TelNumber;

	TInt port=226;

	TInt testNumber = 2;

	if(!GetStringFromConfig(ConfigSection(),KTestData1, TestData1) ||

	   !GetStringFromConfig(ConfigSection(),KTestData2, TestData2) ||

	   !GetStringFromConfig(ConfigSection(),KSCNumber,TelNumber) ||

	   !GetIntFromConfig(ConfigSection(),KWapPort,port)

		)

		{

		// Leave if there's any error.

		User::Leave(KErrNotFound);

		}

	User::LeaveIfError(RProperty::Set(KUidSystemCategory, KUidPhonePwr.iUid, ESAPhoneOn));

	User::LeaveIfError(RProperty::Set(KUidPSSimTsyCategory, KPSSimTsyTestNumber, testNumber));

	//

    //	Setting the port number and service center number of the wap address

	//	The service center number should be the same as the sim phone number used 

	//  for test (not required for SIM Tsy)

	//

	TWapAddr wapAddr;

	TWapAddr recvWapAddr;

	wapAddr.SetWapPort(TWapPortNumber(port));

	TBuf8<100> scNumber;

	scNumber.Copy(TelNumber);

	TPtrC8 scAddr(scNumber);

	wapAddr.SetWapAddress(scAddr);

	//

	//	Connect to socket server

	//

	RSocketServ socketServer;

    User::LeaveIfError(socketServer.Connect());

	CleanupClosePushL(socketServer);

	//

	//	Define and open the socket

	//

	RSocket sock;

    OpenSocketLC(socketServer, sock);

	//

	//	Waiting for the phone to be initialised

	//

	WaitForInitializeL();

	TRequestStatus ioctlStatus;

	TRequestStatus recvStatus;

	TPckgBuf<TInt> length;

	//

	//	Indicating to the protocol that it's a new client

	//

	INFO_PRINTF1(_L("Socket set option for indicating new client"));

	User::LeaveIfError(sock.SetOpt(KWapSmsOptionNewStyleClient,KWapSmsOptionLevel, 0));

	//

	//	Bind

	//

	User::LeaveIfError(sock.Bind(wapAddr));

	//

	//	Issue Ioctl for getting the length of the message

	//

	INFO_PRINTF1(_L("Issue of the IOCTL for GetLength for first VCal entry"));

	sock.Ioctl(KSOGetLength, ioctlStatus, &length, KSolWapProv);

	TBuf8<300> data;

	//

	//	Send a calendar entry  

	//	

	TRequestStatus  status;

	data.Copy(TestData1);

	sock.SendTo(data, wapAddr, 0, status);

	User::WaitForRequest(status);

	User::LeaveIfError(status.Int());

	INFO_PRINTF1(_L("First Message (VCal) sent..."));

	//	Send a VCard entry 	

	data.Copy(TestData2);

	sock.SendTo(data, wapAddr, 0, status);

	User::WaitForRequest(status);

	User::LeaveIfError(status.Int());

	INFO_PRINTF1(_L("Second message (VCard with extended GSM alphabets) sent..."));

	//

	//	Get the size of the first incomming message

	//

	User::WaitForRequest(ioctlStatus);

	User::LeaveIfError(ioctlStatus.Int());

	INFO_PRINTF1(_L("IOCTL completed"));

	//

	//	Check if reported length is correct

	//

	TBuf8<300> recvBuf;

	TEST(length()==TestData1.Length());

	//

	//	Receiving a datagram

	//

	sock.RecvFrom(recvBuf,recvWapAddr,0,recvStatus);

	User::WaitForRequest(recvStatus);

	User::LeaveIfError(recvStatus.Int());

	INFO_PRINTF1(_L("Received the first message (VCal)..."));

	//	Compare the received VCal message with the original one.

	//	They should be identical

	data.Copy(TestData1);	

	if (recvBuf.Compare(data) != 0)

		{

		ERR_PRINTF1(_L("VCal message received does not match with original message."));

		TEST(recvBuf.Compare(data) == 0);

		}		

	//

	//	Confirm the receipt of the message to the client

	//

	INFO_PRINTF1(_L("Socket set option for indicating receipt of first message (VCal)"));

	User::LeaveIfError(sock.SetOpt(KWapSmsOptionOKToDeleteMessage,KWapSmsOptionLevel, 0));

	//Issue Ioctl for getting the length of the second message	

	INFO_PRINTF1(_L("Issue of the IOCTL for GetLength for second VCard entry"));

	sock.Ioctl(KSOGetLength, ioctlStatus, &length, KSolWapProv);

	//Get the size of the second incomming message

	User::WaitForRequest(ioctlStatus);

	User::LeaveIfError(ioctlStatus.Int());

	INFO_PRINTF1(_L("IOCTL completed for second message (VCard)"));

	//Check if reported length is correct	

	TEST(length()==TestData2.Length());

	//Receiving a datagram (VCard)

	sock.RecvFrom(recvBuf,recvWapAddr,0,recvStatus);

	User::WaitForRequest(recvStatus);

	User::LeaveIfError(recvStatus.Int());

	INFO_PRINTF1(_L("Received the second message (VCard)..."));

	//	Compare the received VCard message with the original one

	//	They should be identical

	data.Copy(TestData2);	

	if (recvBuf.Compare(data) != 0)

		{

		ERR_PRINTF1(_L("VCard message received does not match with original message."));

		TEST(recvBuf.Compare(data) == 0);

		}

	//Confirm the receipt of the message to the client	

	INFO_PRINTF1(_L("Socket set option for indicating receipt of message"));

	User::LeaveIfError(sock.SetOpt(KWapSmsOptionOKToDeleteMessage,KWapSmsOptionLevel, 0));

	//

	//	Closing the socket

	//

	sock.Close();

	socketServer.Close();

    CleanupStack::PopAndDestroy(&sock);

	CleanupStack::Pop(&socketServer);

	return TestStepResult();

	}

TVerdict CIoctlStep_3::doTestStepL()

/**

 *  Test step 3:

 *  send/receive one 7-Bit two segments message and one 7-Bit one segment message

 *  @return - TVerdict code

 *  

 */

	{

	INFO_PRINTF1(_L("IOCTL Test step 3: send/receive two 7-Bit messages"));

	TPtrC TestData1;

	TPtrC TestData2;

	TPtrC16 TelNumber;

	TInt port=226;

	TInt testNumber = 3;

	if(!GetStringFromConfig(ConfigSection(),KTestData1, TestData1) ||

	   !GetStringFromConfig(ConfigSection(),KTestData2, TestData2) ||

	   !GetStringFromConfig(ConfigSection(),KSCNumber,TelNumber) ||

	   !GetIntFromConfig(ConfigSection(),KWapPort,port))

		{

		// Leave if there's any error.

		User::Leave(KErrNotFound);

		}

	User::LeaveIfError(RProperty::Set(KUidSystemCategory, KUidPhonePwr.iUid, ESAPhoneOn));

	User::LeaveIfError(RProperty::Set(KUidPSSimTsyCategory, KPSSimTsyTestNumber, testNumber));

	//

    //	Setting the port number and service center number of the wap address

	//	The service center number should be the same as the sim phone number used

	//  for test

	//

	TWapAddr wapAddr;

	TWapAddr recvWapAddr;

	wapAddr.SetWapPort(TWapPortNumber(port));

	TBuf8<100> scNumber;

	scNumber.Copy(TelNumber);

	TPtrC8 scAddr(scNumber);

	wapAddr.SetWapAddress(scAddr);

	//

	//	Connect to socket server

	//

	RSocketServ socketServer;

    User::LeaveIfError(socketServer.Connect());

	CleanupClosePushL(socketServer);

	//

	//	Define and open the socket

	//

	RSocket sock;

	OpenSocketLC(socketServer, sock);

	//

	//	Waiting for the phone to be initialised

	//

	WaitForInitializeL();

	TRequestStatus ioctlStatus;

	TRequestStatus recvStatus;

	TPckgBuf<TInt> length;

	//

	//	Indicating to the protocol that it's a new client

	//

	INFO_PRINTF1(_L("Socket set option for indicating new client"));

	User::LeaveIfError(sock.SetOpt(KWapSmsOptionNewStyleClient,KWapSmsOptionLevel, 0));

	//

	//	Bind

	//

	User::LeaveIfError(sock.Bind(wapAddr));

	//

	//	Issue Ioctl for getting the length of the message

	//

	INFO_PRINTF1(_L("Issue of first IOCTL for GetLength"));

	sock.Ioctl(KSOGetLength, ioctlStatus, &length, KSolWapProv);

	//

	//	Send a calendar entry

	//

	TRequestStatus  status;

	TBuf8<300> data2;

	data2.Copy(TestData2);

	sock.SendTo(data2, wapAddr, 0, status);

	User::WaitForRequest(status);

	User::LeaveIfError(status.Int());

	INFO_PRINTF1(_L("First message sent..."));

	//

	//	Send a business card

	//

	TBuf8<200> data1;

	data1.Copy(TestData1);

	sock.SendTo(data1, wapAddr, 0, status);

	User::WaitForRequest(status);

	User::LeaveIfError(status.Int());

	INFO_PRINTF1(_L("Second message sent..."));

	//

	//	Get the size of the first incomming message

	//

	User::WaitForRequest(ioctlStatus);

	User::LeaveIfError(ioctlStatus.Int());

	INFO_PRINTF1(_L("IOCTL completed..."));

	TBuf8<256> recvBuf2(length);

	//

	//	Receiving a datagram

	//

	sock.RecvFrom(recvBuf2,recvWapAddr,0,recvStatus);

	User::WaitForRequest(recvStatus);

	User::LeaveIfError(recvStatus.Int());

	INFO_PRINTF1(_L("Received the first message..."));

	TEST(recvBuf2.Compare(data2) == 0);

	//

	//	Confirm the receipt of the message to the client

	//

	INFO_PRINTF1(_L("Socket set option for indicating receipt of message"));

	User::LeaveIfError(sock.SetOpt(KWapSmsOptionOKToDeleteMessage,KWapSmsOptionLevel, 0));

	//

	//	Issue Ioctl for getting the length of the second message

	//

	sock.Ioctl(KSOGetLength, ioctlStatus, &length, KSolWapProv);

	INFO_PRINTF1(_L("Issue of the 2nd IOCTL for GetLength"));

	//

	//	Get the size of the SECOND incomming message

	//

	User::WaitForRequest(ioctlStatus);

	User::LeaveIfError(ioctlStatus.Int());

	INFO_PRINTF1(_L("IOCTL completed"));

	//

	//	Check if reported length is correct

	//

	TBuf8<256> recvBuf1(length);

	TEST(length()==data1.Length());

	//

	//	Receiving the second message

	//

	sock.RecvFrom(recvBuf1,recvWapAddr,0,recvStatus);

	User::WaitForRequest(recvStatus);

	User::LeaveIfError(recvStatus.Int());

	INFO_PRINTF1(_L("Receievd the second datagram"));

	TEST(recvBuf1.Compare(data1) == 0);

	//

	//	Confirm the receipt of the second message to the client

	//

	INFO_PRINTF1(_L("Socket set option for indicating receipt of the second message"));

	User::LeaveIfError(sock.SetOpt(KWapSmsOptionOKToDeleteMessage,KWapSmsOptionLevel, 0));

	//

	//	Closing the socket

	//

	sock.Close();

	socketServer.Close();

	CleanupStack::PopAndDestroy(&sock);

    CleanupStack::Pop(&socketServer);

	return TestStepResult();

	}

TVerdict CIoctlStep_4::doTestStepL()

/**

 *  

 *  Test step 4:

 *  simulating client crash conditions with 7bit message

 *  @return - TVerdict code

 *  

 */

	{

	INFO_PRINTF1(_L("IOCTL Test step 4: client crash condition 7-Bit message "));

	TPtrC TestData;

	TPtrC16 TelNumber;

	TInt port=226;

	TInt testNumber =4;

	if(!GetStringFromConfig(ConfigSection(),KTestData1, TestData) ||

	   !GetStringFromConfig(ConfigSection(),KSCNumber,TelNumber) ||

	   !GetIntFromConfig(ConfigSection(),KWapPort,port))

		{