--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/messagingfw/biomsgfw/BioWatchers/Inc/NBSSocketWatcher.h	Mon Jan 18 20:36:02 2010 +0200
@@ -0,0 +1,124 @@
+// 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:
+//
+
+#ifndef __NBSSOCKETWATCHER_H__
+#define __NBSSOCKETWATCHER_H__
+
+#include <s32mem.h>
+#include <e32base.h>
+#include <smsuaddr.h>
+#include <gsmumsg.h>
+#include <gsmubuf.h>
+#include <smsustrm.h>
+#include <smutset.h>
+#include "SmsSocketWatcher.h"
+#include "class0sms.h"
+
+class CSmsHeader;
+
+//UID for Class 0 SMS Implementation
+const TUid KUidClass0SmsHandler = {0x2000BDF1};
+
+#include "SmsSocketWatcher.h"
+
+class CNbsSmsSocketWatcher : public CBaseSmsActiveSocketWatcher
+	{
+public:
+	static CNbsSmsSocketWatcher* NewLC(TMsvId aBioServiceId, 
+									   TMsvId aSmsServiceId, 
+									   CBIODatabase& aBioDb, 
+									   CWatcherLog& aLog, 
+									   TInt aPriority, 
+									   TUid aBioID, 
+									   RFs& aFs, 
+									   const TDesC& 
+									   aNbsPattern, 
+									   TSmsAddrFamily aAddrFamily = ESmsAddrMatchText);
+	virtual ~CNbsSmsSocketWatcher();
+
+public:	// methods from CBaseSmsActiveSocketWatcher
+	virtual void DoSetupL();
+	virtual void WaitForMessageL();
+	virtual void ReceiveL();
+	virtual void DoComplete(TInt&);
+	virtual void DoRunL();
+
+public:	// methods from CActive
+	virtual void DoCancel();
+	void CheckForClass0SmsSupport();
+	void SupportForClass0SmsL();
+
+protected:
+	CNbsSmsSocketWatcher(CWatcherLog& aLog, TInt aPriority, TUid aBioID, RFs& aFs, const TDesC& aNbsPattern, TSmsAddrFamily aAddrFamily);
+	void ConstructL(TMsvId aBioServiceId, TMsvId aSmsServiceId, CBIODatabase& aBioDb);
+	void DoReceiveL();
+	void ExternalizeL(RBufWriteStream& aWriteStream, TInt aStartPos, TInt endPos, TBool aIsLastMessage, TPtr aData);
+		
+private:
+	TBool MessageHasPort(const CSmsMessage& aSmsMessage);
+	TBool IsJavaTextMessage(const CSmsMessage& aSmsMessage);
+	
+protected:
+	TSmsAddrFamily			iAddrFamily;
+	TBioMsgIdText			iNbsPattern;
+	TSmsAddr				iSmsAddr;
+	TPckgBuf<TUint>			iOctlRes;
+	RSocketServ				iSocketServer;
+	RSocket					iSocket;
+	TBool					iIoCtlActive;
+	
+	TUid					iDtor_ID_Key;
+	CSmsClass0Base* 		iSmsClass0;
+	TInt					iMsgRefNumber;
+	};
+
+/**
+Handles Status Reports and Special (Message Waiting) Messages
+
+@internalComponent
+@released
+*/
+class CSpecialNbsSmsSocketWatcher : public CNbsSmsSocketWatcher
+	{
+public:
+	static CSpecialNbsSmsSocketWatcher* NewL(TMsvId aBioServiceId, TMsvId aSmsServiceId, CBIODatabase& aBioDb, CWatcherLog& aLog, TInt aPriority, TUid aBioID, RFs& aFs, const TDesC& aNbsPattern, TSmsAddrFamily aAddrFamily);
+	static CSpecialNbsSmsSocketWatcher* NewLC(TMsvId aBioServiceId, TMsvId aSmsServiceId, CBIODatabase& aBioDb, CWatcherLog& aLog, TInt aPriority, TUid aBioID, RFs& aFs, const TDesC& aNbsPattern, TSmsAddrFamily aAddrFamily);
+	virtual ~CSpecialNbsSmsSocketWatcher();
+
+protected:
+	CSpecialNbsSmsSocketWatcher(CWatcherLog& aLog, TInt aPriority, TUid aBioID, RFs& aFs, const TBioMsgIdText& aNbsPattern, TSmsAddrFamily aAddrFamily);
+	
+protected:	// methods from CBaseSmsActiveSocketWatcher
+	virtual inline TBool CanStoreMessage() const;
+	virtual inline TBool Visible() const;
+	virtual void RestoreSettingsL(CMsvSession&);
+	virtual void RestoreSettingsL(TMsvId aBioServiceId, TMsvId aSmsServiceId);
+	virtual void SetBioMsgText(CBIODatabase& aBioDb);
+	virtual void PreStoreActionL(CMsvSession& aSession, CSmsMessage& aSmsMessage);
+
+protected:
+	void ConstructL(TMsvId aBioServiceId, TMsvId aSmsServiceId, CBIODatabase& aBioDb);
+	void MatchStatusReportL(CMsvSession& aSession, TLogId aLogId, TSmsStatus::TSmsStatusValue aDeliveryStatus);
+	TBool SearchForMessageL(CMsvEntry& aMsvEntry, CSmsHeader& aHeader, const CMsvEntrySelection& aSelection, TLogId aLogId, TMsvId& aMessageId);
+	void UpdateMessageEntryL(CMsvEntry& aMsvEntry, CSmsHeader& aHeader, TMsvId aMessageId, TLogId aLogId, TSmsStatus::TSmsStatusValue aDeliveryStatus);
+
+protected:
+	CSmsSettings::TSmsReportHandling iReportHandling;
+
+	};
+
+#include "NBSSocketWatcher.inl"
+
+#endif	// __NBSSOCKETWATCHER_H__