// Copyright (c) 2007-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:
// The main SUPL SMS Trigger Plug-in class. It implements the ECOM interface, listens for the incoming messages,
// and notifies the SPM via the SUPL Push API.
// 
//

#ifndef __LBSSUPLWDPWATCHER_H__
#define __LBSSUPLWDPWATCHER_H__

/**
@file
@internalComponent
@prototype
*/


#include <e32base.h>
#include <lbs/lbssuplpush.h>
#include <wapmessage.h>
#include "lbstimer.h"

/** 
A watcher interface conformant class which has one NewL export called by 
the watcher framework to create the watcher. 
*/
NONSHARABLE_CLASS(CLbsSuplWdpWatcher) : public CActive, public MLbsSuplPushObserver, 
public MLbsCallbackTimerObserver
	{
public:
	/**The states of the class*/ 
	enum TState
		{
		EDisconnected = 1,
		EAwaitingDataSize = 2,
		EAwaitingData = 4
		};
		
public:

#ifdef TE_UNITTESTMODE_ON
	static CLbsSuplWdpWatcher* NewLC(CTe_WatcherLog* aWatcherLog);
	void CheckStateL(TInt aPossibleStates);
#endif //TE_UNITTESTMODE_ON

	static CLbsSuplWdpWatcher* NewL(TAny* aWatcherParams);
	~CLbsSuplWdpWatcher();
	
	virtual void OnSuplInitComplete(TLbsSuplPushChannel aChannel, TLbsSuplPushRequestId aReqId, 
			TInt aError, TInt aReserved);	
	virtual void OnTimerEventL(TInt aTimerId);
	virtual TInt OnTimerError(TInt aTimerId, TInt aError);

	
	
private:
#ifdef TE_UNITTESTMODE_ON
protected:	
#endif	
	CLbsSuplWdpWatcher(TInt aPriority, CWatcherLog& aLog);
	
private:	
	void ConstructL();
	
	virtual void Restart();

	void RunL();
	void DoCancel();
	TInt RunError(TInt aError);
	
	void ScheduleRestart(TInt aError);
	
private:
	/** The state of the object */
	TState iState;
	/** The WAP datagram conection*/
	CWapBoundDatagramService *iWdpConn;
	/** The size of the received data */
	TUint16 iDataSize;
	/** The packaging descriptor of the received data size*/
	TPckg<TUint16> iDataSizePckg;
	/** The remote host name */
	TBuf8<32> iRemoteHost;
	/** The local port */ 
	Wap::TPort iLocalPort;
	/** The remote port */
	Wap::TPort iRemotePort;
	/** The received data buffer */
	RBuf8	iData;
	/** The flag if the received data is truncated */
	TBool iTruncated;
	/** The watcher framework logger */
	CWatcherLog& iLog;
	/** The SUPL Push API */
	CLbsSuplPush* iSuplPush;
	/** The timer to generate the restart events */
	CLbsCallbackTimer* iTimer;
	/** Number of pending messages*/
	TUint iPendingMsg;
	
	}; 
	
#endif //__LBSSUPLWDPWATCHER_H__