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

#define __SMSSOCKETWATCHER_H_

#include <e32base.h>

#include <msvstd.h>

#include <mtsr.h>

#include <msvapi.h>

#include <es_sock.h>

#include <bif.h>

#include <bsp.h>

#include <csmsgetdetdescinterface.h>

enum TBioWatcherPanic

	{

	EMainSchedulerError1 = 0,

	EMainSchedulerError2 = 1,

	ECreateTrapCleanup = 2,

	ESocketWatcherAlreadyActive = 3,

	EAllSocketWatchersComplete = 4,

	EHandleBifChangeError = 5,

	EReportHandlingInvalid = 6,

	EUnexpectedErrorCode = 7,

	EBufferNotNull = 8,

	EObjectNotConstructed = 9,

	EAddrFamilyNotSupported1 = 10,

	EAddrFamilyNotSupported2 = 11,

	EAddrFamilyNotSupported3 = 12

	};

#ifdef _BIOMSG_NO_LOGGING

#define BIOWATCHERLOG(a)

#else

#define BIOWATCHERLOG(a) a

#endif

_LIT(KSocketWatcherPanicString, "BioWatcher");

inline void PanicWatcher(TBioWatcherPanic aPanic)

	{

	User::Panic(KSocketWatcherPanicString, aPanic);

	}

class CSmsMessage;

class CBaseSmsActiveSocketWatcher;

class CWatcherLog;

class CBIODatabase;

class CSmsSettings;

class MBioWatcherObserver

	{

	public:

		virtual void HandleWatcherComplete(CBaseSmsActiveSocketWatcher& aWatcher, TInt aError) = 0;

	};

class CBaseSmsActiveSocketWatcher : public CActive, public MMsvSessionObserver

	{

public:

	IMPORT_C virtual ~CBaseSmsActiveSocketWatcher();

	// Setup gets called synchronously to set up sockets and

	// mail server before we get going asynchy

	IMPORT_C void SetupL();

	// over-ride setup code here

	virtual void DoSetupL() = 0;

	// StartL gets called to kick off the AO putting 

	IMPORT_C void StartL();

	// Sets up the Sockets to wait

	virtual void WaitForMessageL() = 0;

	// Receives the message from the Socket

	virtual void ReceiveL() = 0;

	// Store the message in the mail server

	IMPORT_C void StoreMsgL(CSmsMessage* aSmsMsg);

	IMPORT_C void StoreMsgL(CSmsMessage* aSmsMsg, TBool aCheckForSID);

	inline void SetObserver(MBioWatcherObserver* aObserver);

	inline TUid BioMsgUID() const;

	virtual void DoComplete(TInt&) = 0;

	virtual void DoRunL() = 0;

private:

	void ReplaceTypeMessageL(CMsvEntry&, CSmsMessage& aMessage, TBool& aRetainOriginalMessage);

	void DeleteReplaceTypeMessagesL(CMsvEntry& aEntry, TUint8 aPid, CSmsMessage& aMessage, TBool& aRetainOriginalMessage);

	void CreateMessageL(CMsvEntry& aEntry, CSmsMessage* aMessage, TBool aCheckForSecureId);

	void SetBioServiceId(CMsvSession& aSession);

	void SetBioServiceId(TMsvId aBioServiceId, TMsvId aSmsServiceId);

	TBool CheckMessageExistsL(CMsvSession& aSession, TMsvId aId) const;

	TBool CheckForSID(TPtr& aMessage, TSecureId& aSecureId);

private:	// methods from MMsvSessionObserver

	virtual void HandleSessionEventL(TMsvSessionEvent, TAny*, TAny*, TAny*) {};

private:	// methods from CActive

	IMPORT_C virtual void RunL();

	IMPORT_C virtual TInt RunError(TInt aError);

private:

#ifndef _BIOMSG_NO_LOGGING

	void LogMessageL(const CSmsMessage& aMessage); //will only leave with KErrNoMemory

	void LogEachLine(const TDesC& aInput);

	void Log(const TDesC& aInput);

	void Log(const TDesC8& aInput);

#endif

protected:

	// Constructor

	IMPORT_C CBaseSmsActiveSocketWatcher(CWatcherLog& iWatcherLog, TInt aPriority, TUid aBioID, RFs& aFs);

	IMPORT_C void Complete(TInt aStatus);

	inline void WatcherComplete(TInt aError);

	inline virtual TBool CanStoreMessage() const;

	inline virtual TBool Visible() const;

	IMPORT_C virtual void RestoreSettingsL(CMsvSession&);

	IMPORT_C virtual void RestoreSettingsL(TMsvId aBioServiceId, TMsvId aSmsServiceId);

	IMPORT_C virtual void ConstructL(CBIODatabase& aBioDb, TMsvId aBioServiceId, TMsvId aSmsServiceId);

	IMPORT_C virtual void SetBioMsgText(CBIODatabase& aBioDb);

	IMPORT_C virtual void PreStoreActionL(CMsvSession& aSession, CSmsMessage& aMessage);

public:

	enum TSmsWatcherState

		{

		ESmsWWaitForMsg,

		ESmsWReadMsg,

		ESmsWRetryError,

		ESmsIsClass0Msg,

		ESmsSupportClass0Msg

		} iState;

protected:

	TUid					iBioMsgUID;

	TMsvId					iBioServiceId;

	TMsvId					iSmsServiceId;

	TBioMsgIdText			iBioMsgText;

	CWatcherLog&			iWatcherLog;

	RTimer					iTimer;

	RFs&					iFs;

	CSmsSettings*			iSettings;

private:

	MBioWatcherObserver*	iObserver;

	CSmsGetDetDescInterface* iGetDetDesc;

	};

#include "SmsSocketWatcher.inl"

#endif