// 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 __CHTTPREQUESTCOMPOSER_H__
#define __CHTTPREQUESTCOMPOSER_H__

#include <e32base.h>
#include <http/thttphdrfielditer.h>
#include <http/framework/ctxdata.h>
#include <http/framework/logging.h>

#include "mhttpmessagecomposerobserver.h"
#include "rhttpmessagecomposer.h"
#include "mhttprequest.h"

class MHttpRequestObserver;

class CHttpRequestComposer : public CTxData,
							 public MHttpRequest,
							 public MHttpMessageComposerObserver
	{
public:
	
	static CHttpRequestComposer* NewL(CProtTransaction& aProtTrans, MHttpRequestObserver& aObserver);
	virtual ~CHttpRequestComposer();
	
	void NotifyMoreRequestBodyData();	
	TBool RequestSent () const;
	TBool IsSuspendedRequest() const;
	void ResumeSuspendedRequest();
	void CancelWaitFor100Continue();
	
private:	// methods from MHTTPDataSupplier, via CTxData

	virtual TBool GetNextDataPart(TPtrC8& aDataPart);
	virtual void ReleaseData();
	virtual TInt OverallDataSize();
	virtual TInt Reset();
	
private:	// methods from MHttpRequest

	virtual void StartRequest();
	virtual void CancelRequest();
	virtual void RequestDataSent();
	virtual TBool CheckRequestPendingComplete();
	virtual TBool NeedDisconnectNotification();
	virtual MHttpDataOptimiser* HttpDataOptimiser(TBool& aBatchingEnabled);
	virtual void OnRequestSendTimeOut();
	virtual TInt SendTimeOutValue();

private:	// methods from MHttpMessageComposerObserver

	virtual void StartLineL(TPtrC8& aMethod, TPtrC8& aRequestUri, TPtrC8& aVersion);
	virtual TInt NextHeaderL(TPtrC8& aHeaderName, TPtrC8& aHeaderValue);
	virtual MHTTPDataSupplier* HasBodyL();
	virtual TInt NextTrailerL(TPtrC8& aHeaderName, TPtrC8& aHeaderValue);
	virtual void MessageComplete();

	virtual void MessageDataReadyL();

	virtual TInt HandleComposeError(TInt aError);

	virtual void Reserved_MHttpMessageComposerObserver();
	
private:

	CHttpRequestComposer(CProtTransaction& aProtTrans, MHttpRequestObserver& aObserver);
	void ConstructL();

	void InitHeadersL();
	TBool IsTrailerHeader(RStringF aHeader);
	
private:
    TBool                   iRequestHeaderSent;
    TBool                   iCorkingEnabled;
    TBool					iRequestSent;
	TBool					iSuspendRequest;
	const TStringTable&     iStringTable;
	MHttpRequestObserver&	iObserver;
	RStringPool				iStringPool;
	RHTTPRequest			iRequest;	
	THTTPHdrFieldIter		iFields;
	TPtrC8					iData;
	RHttpMessageComposer	iMessageComposer;
	RHTTPTransactionPropertySet	iPropertySet;
	RArray<RStringF>		iTrailerHeaders;

public:

	__FLOG_DECLARATION_MEMBER2
	
	};


#endif	// __CHTTPREQUESTCOMPOSER_H__