// 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:

//

#include "smstestbase.h"

#include <msvapi.h>

#include <smsuaddr.h>

_LIT(KSmsSendRecvTestName, "Send and Receive");

class CEntryObserver : public CBase, public MMsvEntryObserver

	{

public:

	void HandleEntryEventL(TMsvEntryEvent aEvent, TAny* aArg1, TAny* aArg2, TAny* aArg3);

	~CEntryObserver();

public:

	static CEntryObserver* NewL(CSmsTestUtils& aTestUtils, const TInt& aCurrentMessageNum);

	const CMsvEntrySelection& Received() const {return *iReceived;}

	TMsvId Received(TInt aItem) const {return iReceived->At(aItem);}

	TInt Count() const {return iReceived->Count();}

	TMsvId LastReceived() const {return Count() ? Received(Count() - 1) : KErrNotFound;}

	TMsvId ItemReceived(TInt aItem) const {return Count() ? Received(aItem) : KErrNotFound;}

private:

	void CheckReceivedMessageL(TMsvId aId);

	CEntryObserver(CSmsTestUtils& aTestUtils, const TInt& aCurrentMessageNum);

	CMsvEntrySelection* iReceived;			//< An array containing the received messages

	const TInt& iCurrentMessageNum;			//< Number of the current message

	CSmsTestUtils& iSmsTest;				//< Sms Test Util

	};

const TTimeIntervalMicroSeconds32 KWaitForReceiveIteration = 2000000;

const TTimeIntervalMicroSeconds32 KMaxWaitForMsg = 90000000;

const TTimeIntervalMicroSeconds32 KWaitForWatchersToStart = 20000000;

const TTimeIntervalMicroSeconds32 KWaitForWatchersToStartDisplayInterval = 5000000;

const TTimeIntervalMicroSeconds32 KWaitForWatchersToDie = 2000000;

//Command Line Switches

_LIT(KParseAfterReceive, "/p");

_LIT(KSaveAfterReceive, "/s");

_LIT(KWaitForever, "/w");

_LIT(KTestBifs, "/b");

_LIT(KRunEmsTests, "/e"); // if on, uses ems script instead

//Test Bifs

_LIT(KSendRecvScript, "sendrecv.script");

_LIT(KSendRecvEmsScript, "sendrecv_ems.script");

_LIT(KTestBif1, "Koala.rsc");

_LIT(KTestBif2, "Giraffe.rsc");

_LIT(KBifDir, "c:\\system\\bif\\"); 

const TTimeIntervalMicroSeconds32 KBifWait = 4000000;

class CSmsSendRecvTest : public CSmsTestBase

	{

public:

	static CSmsSendRecvTest* NewLC(CSmsTestUtils& aSmsTest, const TDesC& aScriptFile, TInt& aNextTest);

	~CSmsSendRecvTest();

private:

	CSmsSendRecvTest(CSmsTestUtils& aSmsTest, const TDesC& aScriptFile, TInt& aNextTest);

	TBool WatchersAlreadyRunningL();

	void TestSendingL();

	TBool SendNextMessageL();

	void StartWatcherL();

	void TestWaitForReceiveL();

	void TestParseL();

	void DoRunTestParseL();

	void TestBifsL();

	void TestAddBifL(const TDesC& aBifName);

	void TestRemoveBifL(const TDesC& aBifName);

	void ConstructL();

	void RunL();

	void DoCancel();

	TInt RunError(TInt aError);

	void RunComplete();

	void ShowMenuL();

	void RunAutoL();

	void DoRunSendingL();

	void DoRunWaitingToReceiveL();

	void DoWaitL();

	void WaitForExtraL();

	void DoRunWaitForExtraL();

	TInt CountRecipientsL(TMsvId aId);

	void StoreMessageL(TMsvId aId, const CSmsHeader& aHeader);

	void SendMessageIndicationL(TUint8 aMessageType = TSmsUtilities::EVoiceMessageWaiting, TUint8 aMessageCount=1);

	void SendReplaceTypeMessageL();

	TInt GetIndexOfSectionL(const TDesC& aSectionName);

	void TestReplyL();

 	void SetSmsSettingsL();

	CEntryObserver* iEntryObserver;			//< An Entry Observer

	TInt iSent;								//< Total number of messages sent

	TInt iTotal;							//< Total number of messages received

	TInt iCountWaits;						//< Count to wait 

	CTestUtilsWatcherStarter* iWatchers;	//< A Watcher

	CMsvEntry* iEntryForObserver;			//< A Msv Entry

	TInt iCurrentMessageNum;				//< The number of the current message

	TBool iParse;							//< A boolean

	TBool iSaveToFile;						//< A boolean

	TBool iWaitForever;						//< A boolean

	TInt iMsgVCalenderIndex;				//< store the index of vCalender received message

	enum TSmsSendTestState

	/**	@enum	TSmsSendTestState

	 *	Enum defining the states of this test harness

	 */

		{

		EStateWaiting,

		EStateSending,

		EStateWaitingToReceive,

		EStateParsing,

		EStateMessageReceived,

		EStateWaitingToReceiveAnyExtra

		} iState;

	RSocketServ iSocketServ;	//< A Socket Server

	RSocket iSocket;			//< A Socket

	TBool iTestBifs;			

	};