// Copyright (c) 2008-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:
//

/**
 @file
 @internalComponent
 @deprecated
*/

#ifndef SOCKETWRITER_H_
#define SOCKETWRITER_H_

#include <e32base.h>
#include <es_sock.h>
#include <in_sock.h>
#include <securesocket.h>
#include "lbstimer.h"
#include <lbs/lbshostsettings.h>
#include "observers.h"



// Forwards
class CSuplSocketRequestQueue;
class CSocketReader;
class CSecureSocketReader;
class CLbsCallbackTimer;

class CSocketWriterBase : public CActive, 
						  public MLbsCallbackTimerObserver
	{
public:
	~CSocketWriterBase();

	// Methods
	void Connect(const TSuplLocalSessionId sessionId);
	void Disconnect();
	void SendMessageL(CSuplMessageBase* aMessage, const TSuplLocalSessionId& aSessionId);
	TLbsHostSettingsId HostSettingsId();
	TInt CallbackId();	
	
	// CActive
	void RunL();
	void DoCancel();
	TInt RunError(TInt aError);
	
protected:
	// Constructors
	CSocketWriterBase(const TLbsHostSettingsId& aSlpId,
					  TInt iCallbackId,
		   	  		  MSuplSocketObserver& aSocketWriterObserver,
		   	  		  RSocketServ& aSocketServer,
		   	  		  const TLbsHostSettingsSupl& aHostSettings);
	void BaseConstructL();
	
	// Methods
	void ResolveHost();
	void ConnectConnection();
	void CheckQueue();
	void DoConnect();
	void SelfComplete();
	
	// Virtual Methods
	virtual void DoConnectSocket() = 0;
	virtual void DoDisconnect() = 0;
	virtual void DoStartReaderL() = 0;
	virtual void DoSendMessage(TDesC8& aMessage) = 0;

	// Timer
	void StartTimer();
	void StopTimer();
private:
	// MLbsCallbackTimerObserver
	virtual void OnTimerEventL(TInt aTimerId);
	virtual TInt OnTimerError(TInt aTimerId, TInt aError);
protected:
	enum TSuplSocketState
	{
		EIdleDisconnected = 0,
		EResolvingSlpAddress,
		EConnectingConnection,
		EConnectingSocket,
		ETlsHandshaking,
		EIdleConnected,
		ESendingMessage,
		EClosing,
		ENone
	};
	
	TSuplSocketState iState;
	
	// TCP Socket
	RSocket iSocket;
	
	// Information about the resolved address
	TNameEntry iNameEntry;
	
	// Actual internet address
	TInetAddr iAddr;
	
	// Socket server
	RSocketServ& iSocketServ;
	
	// Connection
	RConnection iConnection;
	
	// Observer
	MSuplSocketObserver& iObserver;
	
	// Session index in connection manager => Used for call backs
	TInt iCallbackId;
	
	// Count of number of current sessions
	TInt iSessionCount;
	
	// Session Id of active request
	TSuplLocalSessionId iLastSessionId;
	
	// The actual host settings
	const TLbsHostSettingsSupl iHostSettings;
private:
	// Index into the Host Settings DataBase where SLP info is stored
	TLbsHostSettingsId iSlpSettings;
	
	// Resolver to find out the SLP's IP address
	RHostResolver iResolver;
	
	// Queue of messages to send
	CArrayFixFlat<HBufC8*> iQueue;
	
	// Call back timer
	CLbsCallbackTimer* iTimeout;
	};


class CSocketWriter : public CSocketWriterBase
	{
public:
	// Constructors
	static CSocketWriter* NewL(const TLbsHostSettingsId& aSlpId,
							   TInt aCallbackIndex,
							   MSuplSocketObserver& aSocketWriterObserver,
							   RSocketServ& aSocketServer,
							   TLbsHostSettingsSupl& aHostSettings);
	~CSocketWriter();
protected:
	// Constructors
	CSocketWriter(const TLbsHostSettingsId& aSlpId,
			   	  TInt aCallbackIndex,
				  MSuplSocketObserver& aSocketWriterObserver,
			   	  RSocketServ& aSocketServer,
			   	  TLbsHostSettingsSupl& aHostSettings);

	// CSocketWriterBase
	void DoConnectSocket();
	void DoDisconnect();
	void DoSendMessage(TDesC8& aMessage);
	void DoStartReaderL();
private:
	CSocketReader* iSocketReader;
	};


class CSecureSocketWriter : public CSocketWriterBase
	{
public:
	// Constructors
	static CSecureSocketWriter* NewL(const TLbsHostSettingsId& aSlpId,
							   		 TInt aCallbackIndex,
							   		 MSuplSocketObserver& aSocketWriterObserver,
							   		 RSocketServ& aSocketServer,
							   		 TLbsHostSettingsSupl& aHostSettings,
					   	  		     const CSuplSessionRecord::TServiceType& aServiceType);
	~CSecureSocketWriter();
protected:
	// Constructors
	CSecureSocketWriter(const TLbsHostSettingsId& aSlpId,
			   	  		TInt aCallbackIndex,
			   	  		MSuplSocketObserver& aSocketWriterObserver,
			   	  		RSocketServ& aSocketServer,
			   	  		TLbsHostSettingsSupl& aHostSettings,
		   	  		    const CSuplSessionRecord::TServiceType& aServiceType);
	
	// CActive
	void RunL(); // Override of RunL to handle security handshaking
	void DoCancel();

	// CSocketWriterBase
	void DoConnectSocket();
	void DoDisconnect();
	void DoSendMessage(TDesC8& aMessage);
	void DoStartReaderL();
	
	// New functions
	void StartSecureSocketL();
	TBool CheckTlsSecureL();
private:
	CSecureSocketReader* iSocketReader;
	
	CSecureSocket* iSecureSocket;
	
  	CSuplSessionRecord::TServiceType iServiceType;
	
	};

#endif /*SOCKETWRITER_H_*/