// 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:
// BIO-message Socket Port Watcher
// 
//

#ifndef WAPSOCKETWATCHER_H__
#define WAPSOCKETWATCHER_H__

#include <smsuaddr.h>
#include <gsmumsg.h>
#include <gsmubuf.h>
#include <smsustrm.h>
#include <etelmm.h>


#include <e32base.h>
#include "SmsSocketWatcher.h"
#include <es_wsms.h>

#include <wapmessage.h>

const TInt KReceiveBufferSize = 256;
const TInt KWspReceiveHeaderSize = 64;


//**********************************
// CWapPortWatcher
//**********************************
//
// 
//
class CWapPortWatcher : public CBaseSmsActiveSocketWatcher
	{
	public:
		static CWapPortWatcher* NewL(TMsvId aBioServiceId, 
									 TMsvId aSmsServiceId, 
									 CBIODatabase& aBioDb, 
									 CWatcherLog& aWatcherLog,
									 TInt aPriority, 
									 TUid aBioID, 
									 RFs& aFs, 
									 const TBioMsgId& aBioMsg); 
		~CWapPortWatcher();
		
	protected:
		CWapPortWatcher(CWatcherLog& aWatcherLog, TInt aPriority, TUid aBioID, RFs& aFs, Wap::TPort aWapPort);
		void DoReceiveL(const TDesC8& aRecvFrom);

		void DoComplete(TInt&);
		virtual void CloseConn();
		void AppendToHBufC8L(HBufC8*& aBuf, const TDesC8& aAppend);

		void DoRunL();
		void CompleteSelf();
	protected:
		//The entire received message
		HBufC8* iRecvBuf;
		Wap::TPort iWapPort;
	};



//
// CWdpPortWatcher
//

class CWdpPortWatcher : public CWapPortWatcher
	{
	public:
		CWdpPortWatcher(CWatcherLog& aWatcherLog, TInt aPriority, TUid aBioID, RFs& aFs, TUint16 aWapPort);
		~CWdpPortWatcher();
		void DoCancel();
		void DoSetupL();

	private:
		void CloseConn();
		void WaitForMessageL();
		void ReceiveL();

	private:
		//Members required for receiving
		TBuf8<RMobilePhone::KMaxMobileTelNumberSize> iRemoteAddress;
		Wap::TPort iRemotePort;
		CWapBoundDatagramService* iWdpConn;
		TBool	iTruncated;

		TPtr8 iRecvPtr;
		TUint16 iDataSize;
		TPckg<TUint16> iDataSizePckg;

		enum TWdpRecvState
			{
			ERecvSize,
			ERecv
			} iRecvNext;
	};



//
// CWspPortWatcher
//

class CWspPortWatcher : public CWapPortWatcher
	{
	public:
		CWspPortWatcher(CWatcherLog& aWatcherLog, TInt aPriority, TUid aBioID, RFs& aFs, TUint16 aWapPort);
		~CWspPortWatcher();

		void DoCancel();
		void DoSetupL();

	private:
		void CloseConn();
		void WaitForMessageL();
		void ReceiveL();

	private:
		//Members required for receiving
		HBufC8* iRecvHeader;
		TPckgBuf <TUint8> iPushPckgId;
		CWapBoundCLPushService* iWspConn;

		//Used to receive parts of each message.
		TBuf8<KReceiveBufferSize> iTempRecvBuf;
		TBuf8<KWspReceiveHeaderSize> iTempRecvHeader;
	};

#endif //WAPSOCKETWATCHER_H__