// Copyright (c) 2003-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 __CSOCKETWRITER_H__

#define __CSOCKETWRITER_H__

#include <e32base.h>

#include <http/framework/logging.h>

#include "moutputstream.h"

#include "mhttptimerobserver.h"

#include "chttptimer.h"

class CSocket;

class MOutputSocketObserver;

class MSocketController;

class CSocketWriter : public CActive,

					  public MOutputStream,

					  public MHttpTimerObserver

/**	

	The CSocketWriter class encapsulates the writing functionality and behaviour

	for a connected socket. It implements the MOutputStream API.

	@see		MOutputStream

	@internalComponent

*/

	{

public:	// methods

	static CSocketWriter* NewL(CSocket& aSocket, MSocketController& aController, TBool aPriority);

	virtual ~CSocketWriter();

	void SocketClosed(TInt aError);

	virtual void SecureClientReq(const TDesC8& aHostName);

private:	// methods from MOutputStream

	virtual void Bind(MOutputStreamObserver& aObserver);

	virtual void SendDataReqL(const TDesC8& aBuffer);

	virtual void ShutdownReq();

	virtual void Close();

	virtual const CX509Certificate* ServerCert();

	virtual TInt CipherSuite(TDes8& aCipherSuite);

	virtual void MOutputStream_Reserved();

	virtual void Reset();

	virtual void SetTCPCorking(TBool aValue);

	void CompleteSelf();

private:	// methods from CActive

	virtual void RunL();

	virtual void DoCancel();

	virtual TInt RunError(TInt aError);

private:	// methods from MHttpTimerObserver

	virtual void TimeOut();

private:	// methods

	CSocketWriter(CSocket& aSocket, MSocketController& aController, TBool aPriority);

private:	// enums

/**	

	The state machine for the output stream.

	@internalComponent		

*/

	enum TOutputState

		{

		/** The output stream is waiting for an observer to bind itself to it.

		*/

		EIdle			= 0,

		/** The output stream is ready to send data to the socket. It is waiting

			for the observer to request a data send.

		*/

		EPendingSend,

		/** Data has been sent to the socket. The output stream is waiting for 

			the socket to notify it that the write was successful.

		*/

		ESentData,

		/**	The observer has requested that the connection be upgraded to secure.

			Need to start the secure handshake.

		*/

		EStartSecureHandshake,

		/** The secure handshake has completed successfully. Inform the observer

			that the connection is now secure.

		*/

		ESecureHandshakeComplete,

		/**	The observer has asked the output stream to close the socket.

		*/

		EClosing,

		/**	The socket has been closed - data can no longer be sent to it.

		*/

		EClosed

		};

private:	// attributes

/** The connected socket.

*/

	CSocket&					iSocket;

/** The socket controller that owns the socket.

*/

	MSocketController&			iController;

/**	The state of the output stream.

*/

	TOutputState				iState;

/**	The observer for the output stream.

*/

	MOutputStreamObserver*		iObserver;

//CHttpTimer Object

	CHttpTimer*					iSendTimer;

	TPtrC8						iHostName;

public:	// attributes

/** Logger handle

*/

	__FLOG_DECLARATION_MEMBER2

	};

#endif	// __CSOCKETWRITER_H__