// 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:
// Declares CWapSmsProtocolFamily, CWapSmsProtocol,
// CWapSmsProviderWrite and CWapSmsProvider
// 
//

/**
 @file
 @internalAll
*/

#ifndef WS_MAIN_H__
#define WS_MAIN_H__

#include <f32file.h>
#include "es_wsms.h"
#include <es_sock.h>
#include <es_prot.h>
#include <es_mbufif.h>
#include "smsstacklog.h"
#include <e32cmn.h>

#include "nbbackuprestoreint.h"

/**
 *  @internalComponent
 */
const TUint KWapSmsMajorVersionNumber=7;
const TUint KWapSmsMinorVersionNumber=0;
const TUint KWapSmsBuildVersionNumber=0;


class CWapSapMessageSender;
class CWapProtocolObserver;
class CSmsProtocol;
class CSmsMessage;
class CWapSmsProviderWrite;
class CBackupAndRestore;


/**
 *  @internalComponent
 */
class CWapSmsProtocolFamily : public CProtocolFamilyBase
	{
private:
	CWapSmsProtocolFamily();
public:
	static CWapSmsProtocolFamily * NewL();
	TInt Install();
	TInt Remove();
	CProtocolBase * NewProtocolL(TUint aSockType,TUint aProtocol);
	TUint ProtocolList(TServerProtocolDesc *& aProtocolList);
	};

/**
 *  @internalComponent
 */
extern "C"
	{
	IMPORT_C CProtocolFamilyBase* InstallWapSms();	// Force export
	}

class CWapSmsProvider;
class CWapDatagram;
class CWapReassemblyStore;


/**
 *  @internalComponent
 */
class CWapSmsProtocol : public CProtocolBase,
public MNBBackupAndRestoreObserver
	{
public:
	virtual ~CWapSmsProtocol();
	static CWapSmsProtocol *NewL();

// Calls from the socket server which we implement
	CServProviderBase *NewSAPL(TUint aSocketType);
	void InitL(TDesC& aTag);
	void StartL(void);
	void Identify(TServerProtocolDesc *)const;

	virtual CHostResolvProvdBase *NewHostResolverL();
	virtual CServiceResolvProvdBase *NewServiceResolverL();
	virtual CNetDBProvdBase* NewNetDatabaseL();

	void BindL(CProtocolBase *aProtocol, TUint aId);
	virtual void BindToL(CProtocolBase *protocol);
	TInt Send(TDes8 &, TSockAddr *to,TSockAddr *from,CProtocolBase* aSourceProtocol);
	TInt GetOption(TUint aLevel,TUint aName,TDes8 &aOption,CProtocolBase* aSourceProtocol);
	TInt SetOption(TUint aLevel,TUint aName,const TDesC8 &aOption,CProtocolBase* aSourceProtocol);
	void Error(TInt aError,CProtocolBase* aSourceProtocol);
public:
	void ProcessSmsL(const CSmsMessage& aSmsMessage);
	CSmsProtocol* SmsProtocol();
	TInt AddrAlreadyUsedByWAP(const TWapAddr& aAddr, const CWapSmsProvider* aSap);
	TBool AllocateLocalAddress(TWapAddr& aAddr);
	TBool FindAndDeleteMsg(CWapDatagram& aDatagram);
	TInt CheckSarL(const TWapAddr& aAddr,CWapSmsProvider* aSap);
private:
	CWapSmsProtocol();
	void BindObserversToSmsL();
	void RemoveObserversFromSmsProtocol();
	void AddSAP(CWapSmsProvider* aSAP, TUint aSockType);
	CWapSmsProvider* LookupSAP(CWapDatagram* aMsg);

	virtual void HandleBackupOrRestoreStartingL();
	virtual void HandleBackupOrRestoreCompleteL();

private:

	RFs iFs;
	CWapReassemblyStore* iWapStore;
	TDblQue<CWapSmsProvider> iSAPList;
	CSmsProtocol* iSmsProtocol;
	CWapProtocolObserver* iObserver[3];
	TInt iNextSapPort;

	CBackupAndRestore* iBackupRestoreSession;
	};


/**
 *  @internalComponent
 */
class CWapSmsProviderWrite : public CActive
	{
public:

    static CWapSmsProviderWrite* NewL(CWapSmsProvider& aWapSmsProvider);
    ~CWapSmsProviderWrite();
    void Start(RMBufChain& aBufChain, TSockAddr& aAddr);

private:
    CWapSmsProviderWrite(CWapSmsProvider& aWapSmsProvider);
    void RunL();
    void DoCancel();
    TInt RunError(TInt aError);
private:

    CWapSmsProvider& iWapSmsProvider;
    TWapAddr iWapAddr;

    HBufC8* iDes;
    CWapSapMessageSender* iMsgSender;
	};


/**
 *  @internalComponent
 */
class CWapSmsProvider : public CServProviderBase
	{

	friend class CWapSmsProviderWrite;

public:

	enum TWapSmsMessageType
		{
		ESmartMessage,
		EWapDatagram
		};

public:
	static CWapSmsProvider* NewL(CWapSmsProtocol* aProtocol);
	virtual ~CWapSmsProvider();

public:
	void Start();
public: // Not Implemented
	void RemName(TSockAddr& /*aAddr*/)const{BULLSEYE_OFF BULLSEYE_RESTORE}
	TInt SetRemName(TSockAddr& /*aAddr*/){BULLSEYE_OFF return KErrNotSupported; BULLSEYE_RESTORE}
	void ActiveOpen() {BULLSEYE_OFF BULLSEYE_RESTORE}
	void ActiveOpen(const TDesC8& /*aConnectionData*/){BULLSEYE_OFF BULLSEYE_RESTORE}
	TInt PassiveOpen(TUint /*aQueSize*/){BULLSEYE_OFF return KErrNotSupported; BULLSEYE_RESTORE}
	TInt PassiveOpen(TUint /*aQueSize*/,const TDesC8& /*aConnectionData*/){BULLSEYE_OFF return KErrNotSupported; BULLSEYE_RESTORE}
	void Shutdown(TCloseType /*option*/,const TDesC8& /*aDisconnectionData*/){BULLSEYE_OFF BULLSEYE_RESTORE}
	void AutoBind(){}
public:
	void LocalName(TSockAddr& aAddr) const;
	TInt SetLocalName(TSockAddr& aAddr);
	TInt GetOption(TUint level,TUint name,TDes8& aOption)const;
	void Ioctl(TUint level,TUint name,TDes8* aOption);
	void CancelIoctl(TUint aLevel,TUint aName);
	TInt SetOption(TUint level,TUint name,const TDesC8 &aOption);
 	TInt Write(RMBufChain& aBufChain,TUint options, TSockAddr* aAddr=NULL);
 	TInt GetData(RMBufChain& aBufChain, TUint aLength, TUint options,TSockAddr* aAddr=NULL);
	void Shutdown(TCloseType option);
	TBool IsNewStyleClient() {return iIsNewStyleClient;}
public:
	void Error(TInt aError, TUint aOperationMask);
	void AddToQueue(CWapDatagram* aMsg);
	void NewData(CWapDatagram* aMsg);
	void Deliver(TDes& aDesc);
	TBool MatchesLocalAddress(const TWapAddr& aAddr);
	TWapSmsStatusReportScheme GetStatusReportScheme();
	TWapSmsDataCodingScheme GetDataCodingScheme();

public:
	TWapSmsMessageType MessageType() { return iMessageType; }
	static TInt LinkOffset();

protected:
	CWapSmsProvider(CWapSmsProtocol* aProtocol);
	virtual TInt SecurityCheck(MProvdSecurityChecker* aSecurityChecker);
private:

	TSglQue<CWapDatagram> iRecvdMsgQueue;
	TWapSmsDataCodingScheme iDataCodingScheme;
	TWapSmsMessageType iMessageType;
	TDblQueLink iSAPLink;
	TWapAddr iLocalAddress;
	CWapSmsProtocol* iProtocol;
	TUint iName;							// The integer "name" of the current ioctl request
	TBool iSendPending;
	TBool iIoctlOutstanding;				// Bool value to indicate the outstanding ioctl
	TBool iIsNewStyleClient;						// Indicate if it is new client (BC)
	CWapSmsProviderWrite* iWapSmsProviderWrite;
	MProvdSecurityChecker* iSecurityChecker; 	//< ESOCK security checker object
	TWapSmsStatusReportScheme iStatusReportScheme;
	};


#endif // WS_MAIN_H__