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

*/

#include <commsdattypesv1_1.h>

#include "TE_smsprtbase.h"

#include "smsulog.h"

#include "logcheck.h"

#include "TE_smsprt.h"

#include <sacls.h>

#include <exterror.h>

#include <emsformatie.h>

#include <logwraplimits.h>

#include <smspver.h>

using namespace CommsDat;

#if defined (__WINS__)

#define PDD_NAME _L("ECDRV")

#define LDD_NAME _L("ECOMM")

#else

#define PDD_NAME _L("EUART1")

#define LDD_NAME _L("ECOMM")

#endif

TVerdict CTestSimpleTxAndRx::doTestStepL()

/**

 *  Test a simple Transmit and Receive of a TPDU

 */

	{

	INFO_PRINTF1(_L("Test Simple Tx and Rx SMS"));

	RSocketServ socketServer;

	PrepareRegTestLC(socketServer, 0);

	RSocket socket;

	iSmsStackTestUtils->OpenSmsSocketL(socketServer,socket,ESmsAddrRecvAny);

	CleanupClosePushL(socket);

    // Create comms database object

#ifdef SYMBIAN_NON_SEAMLESS_NETWORK_BEARER_MOBILITY

	CMDBSession* db = CMDBSession::NewL(KCDVersion1_2);

#else

	CMDBSession* db = CMDBSession::NewL(KCDVersion1_1);

#endif

	CleanupStack::PushL(db);

	INFO_PRINTF1(_L("Testing recvMode change to EReceiveUnstoredClientAck"));

    // EReceiveUnstoredClientAck

	CMDBField<TUint32>* smsReceiveModeField = new(ELeave) CMDBField<TUint32>(KCDTIdSMSReceiveMode);

	CleanupStack::PushL(smsReceiveModeField);

	smsReceiveModeField->SetRecordId(1); //it's GlobalSettingsRecord

	*smsReceiveModeField = RMobileSmsMessaging::EReceiveUnstoredClientAck;

	smsReceiveModeField->ModifyL(*db);

	CleanupStack::PopAndDestroy(smsReceiveModeField);

	CleanupStack::PopAndDestroy(db);

	_LIT(KTestMsg1,"test message, 8bits, length 30");

	//Set destination and SC numbers

	iTelephoneNumber=KPekka;

	iServiceCenterNumber=KRadiolinjaSC;

	TSmsDataCodingScheme::TSmsAlphabet alphabet=TSmsDataCodingScheme::ESmsAlphabet8Bit;

	CSmsMessage* smsMessage=CreateSmsMessageL(KTestMsg1,alphabet);

	CleanupStack::PushL(smsMessage);

	INFO_PRINTF2(_L("Destination number:..... %S"),&iTelephoneNumber);

	INFO_PRINTF2(_L("ServiceCenter number:... %S"),&iServiceCenterNumber);

	//Send SMS

	SendSmsL(smsMessage,socket);

	CleanupStack::PopAndDestroy(smsMessage);

	//Receive SMS

	INFO_PRINTF1(_L("waiting for incoming SMS...") );

	WaitForRecvL(socket);

	smsMessage = RecvSmsL(socket);

	INFO_PRINTF1(_L("incoming SMS") );

	CleanupStack::PushL(smsMessage);

	TestSmsContentsL(smsMessage,KTestMsg1);

	//Save the received message to the SMS storage

	smsMessage->SetStorage(CSmsMessage::ESmsSIMStorage);

	WriteSmsToSimL(*smsMessage, socket);

	CleanupStack::PopAndDestroy(smsMessage);

	// Enumerate messages from Store

	RPointerArray<CSmsMessage> messages;

	ReadSmsStoreL(socket, messages);

	messages.ResetAndDestroy();

	CleanupStack::PopAndDestroy(&socket);

	CleanupStack::PopAndDestroy(&socketServer);

	return TestStepResult() ;

	}

TVerdict CTestBinaryTxAndRx::doTestStepL()

/**

 *  Test a binary Transmit and Receive of a TPDU

 */

	{

	INFO_PRINTF1(_L("Test Binary Tx and Rx SMS"));

	RSocketServ socketServer;

	PrepareRegTestLC(socketServer, 142);

	RSocket socket;

	iSmsStackTestUtils->OpenSmsSocketL(socketServer,socket,ESmsAddrRecvAny);

	CleanupClosePushL(socket);

    // Create comms database object

#ifdef SYMBIAN_NON_SEAMLESS_NETWORK_BEARER_MOBILITY

	CMDBSession* db = CMDBSession::NewL(KCDVersion1_2);

#else

	CMDBSession* db = CMDBSession::NewL(KCDVersion1_1);

#endif

	CleanupStack::PushL(db);

	INFO_PRINTF1(_L("Testing recvMode change to EReceiveUnstoredClientAck"));

    // EReceiveUnstoredClientAck

	CMDBField<TUint32>* smsReceiveModeField = new(ELeave) CMDBField<TUint32>(KCDTIdSMSReceiveMode);

	CleanupStack::PushL(smsReceiveModeField);

	smsReceiveModeField->SetRecordId(1); //it's GlobalSettingsRecord

	*smsReceiveModeField = RMobileSmsMessaging::EReceiveUnstoredClientAck;

	smsReceiveModeField->ModifyL(*db);

	CleanupStack::PopAndDestroy(smsReceiveModeField);

	CleanupStack::PopAndDestroy(db);

	//Set destination and SC numbers

	iTelephoneNumber=KPekka;

	iServiceCenterNumber=KRadiolinjaSC;

	const TInt KTestPDUSize = 128;

	TBuf<KTestPDUSize> arrBuf;

	arrBuf.SetLength(KTestPDUSize);

	for(TInt i = 0; i < KTestPDUSize; ++i)

		{			

		arrBuf[i] = i;

		}

	TSmsDataCodingScheme::TSmsAlphabet alphabet=TSmsDataCodingScheme::ESmsAlphabet8Bit;

	CSmsMessage* smsMessage=CreateSmsMessageL(arrBuf, alphabet);

	CleanupStack::PushL(smsMessage);

	INFO_PRINTF2(_L("Destination number:..... %S"),&iTelephoneNumber);

	INFO_PRINTF2(_L("ServiceCenter number:... %S"),&iServiceCenterNumber);

	//Send first SMS

	SendSmsL(smsMessage,socket);

	CleanupStack::PopAndDestroy(smsMessage);

	TBuf<KTestPDUSize> arrBuf2;

	arrBuf2.SetLength(KTestPDUSize);

	for(TInt i = 0; i < KTestPDUSize; ++i)

		{		

		arrBuf2[i] = 128 + i;

		}

	smsMessage=CreateSmsMessageL(arrBuf2, alphabet);

	CleanupStack::PushL(smsMessage);

	//Send second SMS

	SendSmsL(smsMessage,socket);

	CleanupStack::PopAndDestroy(smsMessage);		

	//Receive first SMS

	INFO_PRINTF1(_L("waiting for incoming first SMS...") );

	WaitForRecvL(socket);

	smsMessage = RecvSmsL(socket);

	INFO_PRINTF1(_L("incoming first SMS") );

	CleanupStack::PushL(smsMessage);

	TestSmsContentsL(smsMessage, arrBuf, ETrue);	

	//Save the received message to the SMS storage

	smsMessage->SetStorage(CSmsMessage::ESmsSIMStorage);

	WriteSmsToSimL(*smsMessage, socket);

	CleanupStack::PopAndDestroy(smsMessage);

	//Receive second SMS

	INFO_PRINTF1(_L("waiting for incoming second SMS...") );

	WaitForRecvL(socket);

	smsMessage = RecvSmsL(socket);

	INFO_PRINTF1(_L("incoming second SMS") );

	CleanupStack::PushL(smsMessage);

	TestSmsContentsL(smsMessage, arrBuf2, ETrue);	

	//Save the received message to the SMS storage

	smsMessage->SetStorage(CSmsMessage::ESmsSIMStorage);

	WriteSmsToSimL(*smsMessage, socket);

	CleanupStack::PopAndDestroy(smsMessage);				

	// Enumerate messages from Store

	RPointerArray<CSmsMessage> messages;

	ReadSmsStoreL(socket, messages);

	messages.ResetAndDestroy();

	CleanupStack::PopAndDestroy(&socket);

	CleanupStack::PopAndDestroy(&socketServer);	 

	return TestStepResult() ;	 	

	}	

TVerdict CTestStatusReport::doTestStepL()

/**

 *  Test a simple Transmit and Receive with status reporting

 */

	{

	INFO_PRINTF1(_L("Test Tx an SMS and then receive a status report"));

	RSocketServ socketServer;

	PrepareRegTestLC(socketServer, 1);

	RSocket socket;

	iSmsStackTestUtils->OpenSmsSocketLC(socketServer,socket,ESmsAddrRecvAny);

	_LIT(KTestMsg1,"test message, 8bits, length 30");

	//Set destination and SC numbers

	iTelephoneNumber=KPekka;

	iServiceCenterNumber=KRadiolinjaSC;

	TSmsDataCodingScheme::TSmsAlphabet alphabet=TSmsDataCodingScheme::ESmsAlphabet8Bit;

	CSmsMessage* smsMessage=CreateSmsWithStatusReportReqL(KTestMsg1,alphabet);

	CleanupStack::PushL(smsMessage);

	INFO_PRINTF2(_L("Destination number:..... %S"),&iTelephoneNumber);

	INFO_PRINTF2(_L("ServiceCenter number:... %S"),&iServiceCenterNumber);

	//Send SMS

	SendSmsL(smsMessage,socket);

	CleanupStack::PopAndDestroy(smsMessage);

	//Create and send the second SMS

	_LIT(KTest7bitMsg,"test message, length 23"); //7 bits test message, length 23 characters

	//Set destination number

	iTelephoneNumber=KOther;

	alphabet=TSmsDataCodingScheme::ESmsAlphabet7Bit;

	smsMessage=CreateSmsWithStatusReportReqL(KTest7bitMsg, alphabet);

	CleanupStack::PushL(smsMessage);

	INFO_PRINTF2(_L("Destination number:..... %S"),&iTelephoneNumber);

	INFO_PRINTF2(_L("ServiceCenter number:... %S"),&iServiceCenterNumber);

	//Send SMS

	SendSmsL(smsMessage,socket);

	CleanupStack::PopAndDestroy(smsMessage);

	//Create and send the third SMS

	//Set destination number

	iTelephoneNumber=KOther;

	alphabet=TSmsDataCodingScheme::ESmsAlphabet8Bit;

	smsMessage=CreateSmsWithStatusReportReqL(KTestMsg1,alphabet);

	CleanupStack::PushL(smsMessage);

	INFO_PRINTF2(_L("Destination number:..... %S"),&iTelephoneNumber);

	INFO_PRINTF2(_L("ServiceCenter number:... %S"),&iServiceCenterNumber);

	//Send SMS

	SendSmsL(smsMessage,socket);

	CleanupStack::PopAndDestroy(smsMessage);

	//Create and send the fourth SMS

	//Set destination and SC numbers

	iTelephoneNumber=KLocalNumber;

	iServiceCenterNumber=KRadiolinjaSC;

	alphabet=TSmsDataCodingScheme::ESmsAlphabet8Bit;

	smsMessage=CreateSmsWithStatusReportReqL(KTestMsg1,alphabet);

	CleanupStack::PushL(smsMessage);

	INFO_PRINTF2(_L("Destination number:..... %S"),&iTelephoneNumber);

	INFO_PRINTF2(_L("ServiceCenter number:... %S"),&iServiceCenterNumber);

	//Send SMS

	SendSmsL(smsMessage,socket);

	CleanupStack::PopAndDestroy(smsMessage);

	// Create and send the 5th SMS. Here the submit PDU contains an international number

	// and the Status Report that will be received contains the local version of that number

	_LIT(KTestInternationalSMSWithLocalSRMsg, "Test international number");

	//Set destination and SC numbers

	iTelephoneNumber = KInternationalTestNumber;

	alphabet = TSmsDataCodingScheme::ESmsAlphabet7Bit;

	smsMessage = CreateSmsWithStatusReportReqL(KTestInternationalSMSWithLocalSRMsg, alphabet);

	CleanupStack::PushL(smsMessage);

	INFO_PRINTF2(_L("Destination number:..... %S"), &iTelephoneNumber);

	INFO_PRINTF2(_L("ServiceCenter number:... %S"), &iServiceCenterNumber);

	//Send SMS

	SendSmsL(smsMessage, socket);

	CleanupStack::PopAndDestroy(smsMessage);

	//

	// PDEF137451

	//Create and send the sixth SMS

	//

	//Set destination and SC numbers

	iTelephoneNumber=KPekka;

	iServiceCenterNumber=KRadiolinjaSC;

	alphabet=TSmsDataCodingScheme::ESmsAlphabet8Bit;

	smsMessage=CreateSmsWithStatusReportReqL(KTestMsg1,alphabet);

	CleanupStack::PushL(smsMessage);

	INFO_PRINTF2(_L("Destination number:..... %S"),&iTelephoneNumber);

	INFO_PRINTF2(_L("ServiceCenter number:... %S"),&iServiceCenterNumber);

	//Send SMS

	SendSmsL(smsMessage,socket);

	CleanupStack::PopAndDestroy(smsMessage);

	//

	//Create and send the seventh SMS (7-bit)

	//

	//Set destination number

	iTelephoneNumber=KOther;

	alphabet=TSmsDataCodingScheme::ESmsAlphabet7Bit;

	smsMessage=CreateSmsWithStatusReportReqL(KTest7bitMsg, alphabet);

	CleanupStack::PushL(smsMessage);

	INFO_PRINTF2(_L("Destination number:..... %S"),&iTelephoneNumber);

	INFO_PRINTF2(_L("ServiceCenter number:... %S"),&iServiceCenterNumber);

	//Send SMS

	SendSmsL(smsMessage,socket);

	CleanupStack::PopAndDestroy(smsMessage);

	//

	//Receive status report

	TSmsServiceCenterAddress telephoneNumber;

	telephoneNumber.Copy( KOther );

	RecvStatusReportL(telephoneNumber, socket);

	telephoneNumber = KLocalNumber;

	RecvStatusReportL(telephoneNumber, socket);

	telephoneNumber = KOther;

	RecvStatusReportL(telephoneNumber, socket);

	telephoneNumber.Copy( KPekka );

	RecvStatusReportL(telephoneNumber, socket);

	// CSmsPDUProcessor::DecodeAndProcessPDUL sets the address of the SR

	// to the same as that of the original submit. So we expect the

	// received SR to have an international number, despite the SR PDU

	// having a local number.

	telephoneNumber.Copy(KInternationalTestNumber);

	RecvStatusReportL(telephoneNumber, socket);

	// truncated user data, 8-bit:

	telephoneNumber.Copy( KPekka );

	RecvStatusReportL(telephoneNumber, socket);

	// truncated user data, 7-bit:

	telephoneNumber.Copy( KOther );			

	RecvStatusReportL(telephoneNumber, socket);

	CleanupStack::PopAndDestroy(&socket);

	CleanupStack::PopAndDestroy(&socketServer);

	return TestStepResult() ;

	}

TVerdict CTestTxWithError::doTestStepL()

/**

 *  Test a simple Transmit and Receive. This test case tests different errors from TSY.

 */

	{

	INFO_PRINTF1(_L("Test Tx an SMS, completed with error"));

	RSocketServ socketServer;

	PrepareRegTestLC(socketServer, 2);

	RSocket socket;

	iSmsStackTestUtils->OpenSmsSocketLC(socketServer,socket,ESmsAddrRecvAny);

	RSocket socket2;

	iSmsStackTestUtils->OpenSmsSocketLC(socketServer,socket2,ESmsAddrSendOnly);

	_LIT(KTestMsg1,"test message, 8bits, length 30");

	//Set destination and SC numbers

	iTelephoneNumber=KPekka;

	iServiceCenterNumber=KSoneraSC;

	TSmsDataCodingScheme::TSmsAlphabet alphabet=TSmsDataCodingScheme::ESmsAlphabet8Bit;

	CSmsMessage* smsMessage=CreateSmsMessageL(KTestMsg1,alphabet);

	CleanupStack::PushL(smsMessage);

	//Set Status report request

	CSmsSubmit& submitPdu=(CSmsSubmit&)smsMessage->SmsPDU();

	submitPdu.SetStatusReportRequest(ETrue);

	INFO_PRINTF2(_L("Destination number:..... %S"),&iTelephoneNumber);

	INFO_PRINTF2(_L("ServiceCenter number:... %S"),&iServiceCenterNumber);

	INFO_PRINTF1(_L("waiting 2 secs for smsprot to load"));

	User::After(2000000);

	//Try sending, Tsy returns error

	SendSmsCancelL(smsMessage,socket, socket2);

//	SendSmsErrorL(smsMessage,socket);

	INFO_PRINTF1(_L("Try again sending the SMS"));

	//Now sending succeeds KErrNone

	SendSmsL(smsMessage,socket);

	//set reject duplicates to false

	submitPdu.SetRejectDuplicates(EFalse);

	INFO_PRINTF1(_L("Try sending duplicate SMS when Reject Duplicate is False"));

	SendSmsL(smsMessage,socket);

	TEST(submitPdu.RejectDuplicates() == EFalse);

	//set reject duplicates to true

	submitPdu.SetRejectDuplicates(ETrue);

	INFO_PRINTF1(_L("Try sending duplicate SMS when Reject Duplicate is True"));

	SendSmsL(smsMessage,socket);

	TEST(submitPdu.RejectDuplicates());

	TEST(ETrue);

	// Set reply path to False

    submitPdu.SetReplyPath(EFalse);

	INFO_PRINTF1(_L("Try sending SMS when Reply Path is False"));    

	SendSmsL(smsMessage,socket);

	TEST(submitPdu.ReplyPath() == EFalse);

	// Set reply path to True

    submitPdu.SetReplyPath(ETrue);

	INFO_PRINTF1(_L("Try sending SMS when Reply Path is True"));    

	SendSmsL(smsMessage,socket);

	TEST(submitPdu.ReplyPath());

	TEST(ETrue);

	CleanupStack::PopAndDestroy(smsMessage);

	//Receive SMS

	INFO_PRINTF1(_L("waiting for incoming SMS..."));

	WaitForRecvL(socket);

	smsMessage = RecvSmsL(socket);

	INFO_PRINTF1(_L("incoming SMS") );

	CleanupStack::PushL(smsMessage);

	TestSmsContentsL(smsMessage,KTestMsg1);

	CleanupStack::PopAndDestroy(3); // socket, socket2, smsMessage

	CleanupStack::PopAndDestroy(&socketServer);

	return TestStepResult() ;

	}

TVerdict CTestTxFailed::doTestStepL()

/**

 *  Test sending an SMS, transmit will be failed with different error codes

 */

	{

	INFO_PRINTF1(_L("Test Tx an SMS, failed with different error codes"));

	RSocketServ socketServer;

	PrepareRegTestLC(socketServer, 3);

	RSocket socket;

	TInt ret;

	iSmsStackTestUtils->OpenSmsSocketLC(socketServer,socket,ESmsAddrRecvAny);

	_LIT(KTestMsg1,"test message, 8bits, length 30");

	//Set destination and SC numbers

	iTelephoneNumber=KPekka;