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

 @internalTechnology

 @test

*/

#ifndef LBS_SUPLTEST_H

#define LBS_SUPLTEST_H

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

#include <e32base.h>

#include <lbs/lbsassistancedatasourcemodule.h>

#include <es_sock.h>

#include <in_sock.h>

#include <lbs/test/suplmessage.h>

#include <lbs/test/suplstart.h>

#include <lbs/test/suplpos.h>

#include <lbs/test/suplposinit.h>

#include <lbs/test/rrcassistancedatadelivery.h>

#include "lbssuplsocketlistener.h"

//#include <suplresponse.h>

#include <lbs/test/suplend.h>

/**

This class defines the LBS Assistance Data Source Module

plug-in interface. It is used by the LBS Network Simulator.

@see CAssistanceDataSourceModule

The class also implements the internal MProtocolMgrObserver interface

which is used to receive calls from within the protocol module.

@see MProtocolMgrObserver

*/

NONSHARABLE_CLASS(CSuplProtocolSession)

 : public CAssistanceDataSourceBase, public CActive

	{

public:

    static CSuplProtocolSession* NewL(MLbsAssistanceDataSourceObserver& aObserver,RSocketServ& aSocketServer, const TInt16& aSessionNumber);

	~CSuplProtocolSession();

	// Implementation of interface CAsssistanceDataSourceBase

	void GetAssistanceData(RLbsAssistanceDataBuilderSet& aSet, const TLbsAssistanceDataGroup& aAssistanceDataFilter, const TCoordinate& aPosition);

	void CancelGetAssistanceData();

	// Methods from CActive

	void RunL();

	void DoCancel();

    TInt RunError(TInt aError);

	// Call back for timeouts

	static TInt OnTimerEventL(TAny* aPtr);

private:

 	/** SUPL session states

	*/

	enum TSuplSessionState

		{

		/**  */

		EIdle,

		/**  */

		EConnectingToRemoteServer,

		/**  */

		EConnectedAwaitingRequest,

		/** */

		EAssistanceDataRequested,

		/**  */

		ESendingSuplStart,

		/** */

		EAwaitingSuplResponse,

		/** */

		ESuplResponseAvailable,

		/** */

		ESendingSuplPosInit,

		/**  */

		EAwaitingSuplPos,

		/** */

		ESuplPosAvailable,

		/**  */

		ERrcPayloadDecodeComplete,

		/**  */

		EDisconnectingFromServer,

		/**  */

		ENetworkTimeout,

		/** */

		EProtocolError,

		/** */

		EEndingSession,

		/** */

		ESuplEndSent,

		};

	CSuplProtocolSession(MLbsAssistanceDataSourceObserver& aObserver, const TInt16& aSessionNumber);

	void ConstructL(RSocketServ& aSocketServerSession);

	// Utility methods for creating messages for sending

	void CreateSuplStartMessageL();

	void CreatePosInitMessageL();

	void CreateSuplEndMessageL();

    void BuildCellInfoL(CSuplCellInfoContent* aContent, TCellInformationChoice aCellInfoChoice);

	void BuildSetCapabilitiesL(CSuplSetCapabilitiesContent* aContent);

	void BuildCommonPartL(CSuplMessageContent* aSuplMsgContent);

	void BuildPositionInfoL(CSuplPositionContent* posContent);

	// Utility methods for decoding received messages

	void DecodeSuplMessageL(TSuplMessageType aSuplMessageType);

	TSuplMessageType DoDecodeMessageL();

	void DecodeRRCPayloadL();

    void TransitionAccordingToRequestAvailability();

	// Asynchronous services requested by state machine

	void ConnectToRemoteServer();

	void ReadSuplMessage();

	void SendSuplMessageL(TSuplMessageType aSuplMessageType);

	void PrepareSelfTransition();

	// Process a timeout

	void DoProcessTimeoutL();

private:

	// From the Network Simulator

	MLbsAssistanceDataSourceObserver* iObserver; // For callbacks into the NetSim

	RLbsAssistanceDataBuilderSet* iBuilderSet; // Not owned, belongs to the NetSim

	TInt16 iSessionNumber;

 	// Passed in GetAssistanceData

    TLbsAsistanceDataGroup iAssistanceDataFilter;

    TCoordinate iPosition;

    // Used for sending/receiving messages

    //

	RBuf8 iTxBuf;

	RBuf8 iRxBuf;

	RSocket iSocket;

	TInetAddr iAddress; // Remote server IP address

	CSuplSocketListener* iSuplSocketListener;

	// Used by the state machine

	//

	TBool iAssistanceDataRequestPending;

	TSuplSessionState iSessionState;

	CPeriodic* iTimer; 

	// Obtained from SUPL RESPONSE message

	TBuf8<4> iSlpSessionId;

	// Obtained from SUP POS message

	TUint iRrcOffset; // offset to the RRC payload in an encoded SUPLPOS message	

	};

/**

This class implements the LBS Assistance Data Source Module

plug-in interface. It is used by the LBS Network Simulator.

@see CAssistanceDataSourceModule

@see 

*/

NONSHARABLE_CLASS(CSuplProtocolModule)

 : public CAssistanceDataSourceModuleBase

	{

public:

	static CSuplProtocolModule* NewL(TAny* aParams);

	~CSuplProtocolModule();

    CAssistanceDataSourceBase* NewDataSourceL();

private:

	CSuplProtocolModule(TAny*);

	CSuplProtocolModule();

	void ConstructL();

private:

	/** Reference to this module's observer.

	This is used to make callbacks into the Network Simulator.

	*/

	MLbsAssistanceDataSourceObserver& iObserver;

	/** Socket Server Session.

	This session with the Socket Server will be used

	by the SUPL sessions to obtain their TCP/IP sockets.

	*/

	RSocketServ iSocketServerSession;

	/* To be part of the session ID of the next SUPL

	session that is created*/

	TInt16 iNextSessionNumber;

	};

#endif //LBS_SUPLTEST_H