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

#include <e32base.h>
#include <http/framework/crxdata.h>
#include <http/framework/logging.h>

#include "mhttpmessageparserobserver.h"
#include "rhttpmessageparser.h"
#include "mhttpresponse.h"
#include "timerlogger.h"

class MHttpResponseObserver;

class CHttpResponseParser : public CRxData,
							public MHttpResponse,
							public MHttpMessageParserObserver
	{
public:

	static CHttpResponseParser* NewL(CProtTransaction& aProtTrans, MRxDataObserver& aObserver, MHttpResponseObserver& aResponseObserver);
	virtual ~CHttpResponseParser();

	TInt CancelTransaction(TInt aError);
	void ConvertToNotifyOnDisconnectError ( TInt& aError );

public:	// methods from CRxData

	virtual void ResetRxData();
	
private:	// methods from MHTTPDataSupplier via CRxData

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

	virtual void ResponseDataReceived(const TDesC8& aData);
	virtual void CancelResponse();
	virtual void ConnectionError(TInt aError);	
	virtual TBool ResponseCompleted ();

	virtual TBool NeedCompletion ();	
	virtual TBool CompleteResponse ( const TDesC8& aData );
	virtual void FailTransactionL();
	virtual void OnResponseReceiveTimeOut ();
	virtual TInt ReceiveTimeOutValue ();
	TBool ResponseInformational ();
	virtual void FlushBodyDataIfNotRead();

private:	// methods from MHttpMessageParserObserver

	virtual void GetDataPacket(TPtrC8& aData);
	virtual void ReleaseDataPacket();

	virtual void StartLineL(const TDesC8& aStartLine);
	virtual void HeaderL(const TDesC8& aFieldName, TDesC8& aFieldValue);
	virtual TInt BodySizeL();
	virtual void BodyChunkL(const TDesC8& aData);
	virtual void BodyCompleteL();
	virtual void MessageCompleteL(const TPtrC8& aExcessData);

	virtual TInt HandleParserError(TInt aError);

	virtual void Reserved_MHttpMessageParserObserver();

private:

	CHttpResponseParser(CProtTransaction& aProtTrans, MRxDataObserver& aObserver, MHttpResponseObserver& aResponseObserver);
	void ConstructL();

	void NotifyObserverError(TInt aError);

	TBool CheckForNonPersistentConnection();

	inline TBool ConsumingResponse();
	inline TBool BodyComplete();
	inline TBool MessageComplete();
	inline TBool GotTrailers();
	inline TBool NotifyReleaseData();
    inline TBool BodyPresent();
    
private:

	enum THttpResponseFlags
		{
		EConsumingResponse		= 0x01,
		EBodyComplete			= 0x02,
		EMessageComplete		= 0x04,
		EGotTrailers			= 0x08,
	    ENotifyReleaseData		= 0x10,
		EBodyPresent			= 0x20

		};

private:
	TBool				iCancellingResponse;	
	TInt				iOverallDataSize;
	TInt				iFlags;
	const TStringTable&    iStringTable;
	MHttpResponseObserver&	iResponseObserver;
	RHttpMessageParser		iMessageParser;
	TPtrC8				iRawData;
	
	RArray<TPtrC8>		iBodyParts;

	
	__DECLARE_PERFORMANCE_LOG
public:

	__FLOG_DECLARATION_MEMBER2

	};

inline TBool CHttpResponseParser::ConsumingResponse()
	{
	return iFlags & EConsumingResponse;
	}

inline TBool CHttpResponseParser::BodyComplete()
	{
	return iFlags & EBodyComplete;
	}

inline TBool CHttpResponseParser::MessageComplete()
	{
	return iFlags & EMessageComplete;
	}

inline TBool CHttpResponseParser::GotTrailers()
	{
	return iFlags & EGotTrailers;
	}

inline TBool CHttpResponseParser::NotifyReleaseData()
	{
	return iFlags & ENotifyReleaseData;
	}
	
	inline TBool CHttpResponseParser::BodyPresent()
	{
	return iFlags & EBodyPresent;
	}


#endif	// __CHTTPRESPONSEPARSER_H__