// 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:

//

#ifndef __CUPNPRESPONSEPARSER_H_

#define __CUPNPRESPONSEPARSER_H_

// System includes

#include <e32base.h>

#include <http/mhttpdatasupplier.h>

#include <http/framework/cheadercodec.h>

#include <comms-infras/commsdebugutility.h>

#include <http/thttptable.h>

#include <rmemchunk.h>

// User includes

#include "mhttpmessageparserobserver.h"

#include "CResponse.h"

#include "rhttpmessageparser.h"

#include "mparserobserver.h"

class CUpnpResponseParser: public CBase,

							public MHttpMessageParserObserver,

							public MHTTPDataSupplier

	{

public:

	IMPORT_C static CUpnpResponseParser* NewL(MParserObserver& aObserver);

	IMPORT_C virtual ~CUpnpResponseParser();

	IMPORT_C void ParseResponse(RMemChunk& aMessage, CResponse* aResponse);

	IMPORT_C void ResetParser();

	inline CResponse& Response();

private: 

	// methods from MHTTPDataSupplier

	TBool GetNextDataPart(TPtrC8& aDataPart);

	void ReleaseData();

	TInt OverallDataSize();

	TInt Reset();

	// methods from MHttpMessageParserObserver

	void GetDataPacket(TPtrC8& aData);

	void ReleaseDataPacket();

	void StartLineL(const TDesC8& aStartLine);

	void HeaderL(const TDesC8& aFieldName, TDesC8& aFieldValue);

	TInt BodySizeL();

	void BodyChunkL(const TDesC8& aData);

	void BodyCompleteL();

	void MessageCompleteL(const TPtrC8& aExcessData);

	TInt HandleParserError(TInt aError);

private:

	CUpnpResponseParser(MParserObserver& aObserver);

	void ConstructL();

	void ResetData();

	inline TBool ConsumingResponse();

	inline TBool BodyComplete();

	inline TBool MessageComplete();

	inline TBool GotTrailers();

	inline TBool NotifyReleaseData();

	inline TBool IsExcessData();

private:

	enum THttpResponseFlags

		{

		EConsumingResponse		= 0x01,

		EBodyComplete			= 0x02,

		EMessageComplete		= 0x04,

	    ENotifyReleaseData		= 0x10,

		EBodyPresent			= 0x20,

		EExcessData				= 0x40		

		};

private:

	CResponse* 				iResponse;

	RHttpMessageParser		iMessageParser;

	TInt					iFlags;

	TInt					iOverallDataSize;

	MParserObserver& 		iObserver;

	RArray<TPtrC8>			iBodyParts;	

	RMemChunk				iMsgBuf;

	RArray<TPtrC8>			iRawDataArray;

	__FLOG_DECLARATION_MEMBER;

	};

inline TBool CUpnpResponseParser::ConsumingResponse()

	{

	return iFlags & EConsumingResponse;

	}

inline TBool CUpnpResponseParser::BodyComplete()

	{

	return iFlags & EBodyComplete;

	}

inline TBool CUpnpResponseParser::MessageComplete()

	{

	return iFlags & EMessageComplete;

	}

inline TBool CUpnpResponseParser::NotifyReleaseData()

	{

	return iFlags & ENotifyReleaseData;

	}

inline CResponse& CUpnpResponseParser::Response()

	{

	return (*iResponse);

	}

inline TBool CUpnpResponseParser::IsExcessData()

	{

	return iFlags & EExcessData;	

	}

#endif /*CUPNPRESPONSEPARSER_H_*/