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