@file

    @test

#include <Gsmumsg.h>

#include <gsmubuf.h>

#include "smspver.h"

#include "WapProtSuiteDefs.h"

#include "wap_sock.h"

#include "smsstacktestconsts.h"

TVerdict CWapProtSuiteStepBase::doTestStepPreambleL()

 *  @return - TVerdict

 *  Implementation of CTestStep base class virtual

 *  Do all initialisation common to derived classes in here.

    //base class preamble - marks the heap

    CSmsBaseTestStep::doTestStepPreambleL();

	return TestStepResult();

	}

TVerdict CWapProtSuiteStepBase::doTestStepPostambleL()

	{

    //base class postamble - unmarks the heap

    CSmsBaseTestStep::doTestStepPostambleL();

	return TestStepResult();

	Set up and open socket

*/

void CWapProtSuiteStepBase::SetupWapSocketL()

	SetupWapSocketL(iSocket, iWapAddr, KWapPort);

void CWapProtSuiteStepBase::SetupWapSocketL(RSocket& aSocket, TWapAddr& aWapAddr, const TDesC& aPort, TBool aNewStyleClient)

    {

    OpenSocketL(iSocketServer, aSocket);

    //Read port and SC number from ini file

    ReadWapPortSettingsL(aWapAddr, aPort);

    if (aNewStyleClient)

        {

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

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

        TInt ret = aSocket.SetOpt(KWapSmsOptionNewStyleClient,KWapSmsOptionLevel, 0);

        TESTCHECKL(ret, KErrNone, "Indicating to the protocol that it's a new client")

        }

    //  Bind

    TInt ret = aSocket.Bind(aWapAddr);

    TESTCHECKL(ret, KErrNone, "Socket bind");

    TProtocolDesc desc;

    aSocket.Info(desc);

    INFO_PRINTF2(_L("Protocol name: %S"), &desc.iName);

    TTimeIntervalMicroSeconds32 InitPause=9000000;  //Required Pause to Allow SMSStack to Complete its Async Init

    User::After(InitPause);                         //call to the TSY and finish its StartUp.

    }

    //  Open the socket for receiving status reports

    OpenSocketL(iSocketServer, iStatusReportSocket, KSMSAddrFamily, KSMSDatagramProtocol);

    //Bind to the socket

    iSmsAddr.SetSmsAddrFamily(ESmsAddrStatusReport);

    TInt ret=iStatusReportSocket.Bind(iSmsAddr);

    TESTCHECKL(ret, KErrNone, "Status Report Socket bind");

    TProtocolDesc desc;

    iStatusReportSocket.Info(desc);

    INFO_PRINTF2(_L("Protocol name: %S"), &desc.iName);

    TTimeIntervalMicroSeconds32 InitPause=9000000;  //Required Pause to Allow SMSStack to Complete its Async Init

    User::After(InitPause);                         //call to the TSY and finish its StartUp.

}

void CWapProtSuiteStepBase::ReadWapPortSettingsL(TWapAddr& aWapAddr, const TDesC& aPort)

	User::LeaveIfError(GetStringFromConfig(ConfigSection(),KSCNumber,telNumber));

	User::LeaveIfError(GetIntFromConfig(ConfigSection(), aPort, port));

	aWapAddr.SetWapAddress(scAddr);	

/**

Get the coding of the message

*/

void CWapProtSuiteStepBase::SetCodingSchemeL()

    {

    TInt dataCoding;

    TInt err = KErrNone;

    //Get the port number from the ini file

    GetIntFromConfig(ConfigSection(),_L("dataCoding"), dataCoding);

    if(dataCoding==8)

        {

        err = iSocket.SetOpt(KWapSmsOptionNameDCS,KWapSmsOptionLevel,EWapSms8BitDCS);

        }

    else

        {

        err = iSocket.SetOpt(KWapSmsOptionNameDCS,KWapSmsOptionLevel,EWapSms7BitDCS);

        }

    TESTCHECKL(err, KErrNone, "Setting Data Coding Scheme");

    }

void CWapProtSuiteStepBase::SetMessageTypeL()

    {

    TInt err = KErrNone;

    TPtrC messageType;

    //Get the type of message

    GetStringFromConfig(ConfigSection(),_L("type"), messageType);

    //Set the message type to WapDatagram

    if(messageType.Compare(_L("Datagram")) == 0)

        {

        err = iSocket.SetOpt(KWapSmsOptionWapDatagram,KWapSmsOptionLevel);

        }

    //The creation of the message will set the type to SMART by default

    //  else

    //      User::LeaveIfError(iSocket.SetOpt(KWapSmsOptionSmartMessage,KWapSmsOptionLevel));   

    TESTCHECKL(err, KErrNone, "Setting Message Type");

    }

	INFO_PRINTF1(_L("Getting message parameter..."));

	TESTCHECK(getParamStatus.Int(), KErrNone, "Getting message parameter");

	CleanupStack::PushL(smsMessageBuf);

	CleanupStack::PopAndDestroy(3, &reader); // reader, rFs, smsMessageBuf

void CWapProtSuiteStepBase::ReceiveWapMessageFromSocket(TInt aLength, TPtrC& aData)

    {

    //  Receiving a message, length of which should be requested prior to calling

    // this method from the socket and supplied thought aLength parameter

    TRequestStatus  status;

    TWapAddr recvWapAddr;           

    HBufC8* recvBuf = HBufC8::NewLC(aLength);

    TPtr8 recvPtr = recvBuf->Des(); 

    INFO_PRINTF1(_L("Receiving a message from the socket..."));

    iSocket.RecvFrom(recvPtr, recvWapAddr, 0, status);

    User::WaitForRequest(status);

    TESTCHECKL(status.Int(), KErrNone, "Receiving a message");

    TBuf8<300> data;

    data.Copy(aData);

    TESTCHECK(recvPtr.Compare(data), 0, "Checking the received message matched expected");

    //  Confirm the receipt of the message to the client

    INFO_PRINTF1(_L("Setting Socket option for indicating receipt of the message..."));

    TInt ret = iSocket.SetOpt(KWapSmsOptionOKToDeleteMessage,KWapSmsOptionLevel, 0);

    TESTCHECKL(ret, KErrNone, "Setting Socket option for indicating receipt of the message");

    CleanupStack::PopAndDestroy(recvBuf);

    }

void CWapProtSuiteStepBase::ReceiveWapMessage(TPtrC& aData)

    {

    TRequestStatus ioctlStatus;

    TPckgBuf<TInt> length;

    INFO_PRINTF1(_L("Issuing IOCTL for getting the length of the message..."));

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

    User::WaitForRequest(ioctlStatus);

    TESTCHECKL(ioctlStatus.Int(), KErrNone, "Getting the length of the incoming message");

    //  Check if reported length is correct

    TESTCHECK(length(), aData.Length(), "Check if reported length is correct");

    ReceiveWapMessageFromSocket(length(), aData);

    }

void CWapProtSuiteStepBase::SendWapMessage(TPtrC& aData)

    {

    TRequestStatus status;

    TBuf8<300> data;

    data.Copy(aData);

    INFO_PRINTF1(_L("Sending a message..."));

    iSocket.SendTo(data, iWapAddr, 0, status);

    User::WaitForRequest(status);

    TESTCHECKL(status.Int(), KErrNone, "Sending a message");

    }