// 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 __CUPNPREQUESTPARSER_H_
#define __CUPNPREQUESTPARSER_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>
#include <rmemcell.h>

// User includes
#include "mhttpmessageparserobserver.h"
#include "CRequest.h"
#include "rhttpmessageparser.h"
#include "mparserobserver.h"


class CUpnpRequestParser: public CBase,
							public MHttpMessageParserObserver,
							public MHTTPDataSupplier
	{
public:
	IMPORT_C static CUpnpRequestParser* NewL(MParserObserver& aObserver);
	IMPORT_C virtual ~CUpnpRequestParser();
	IMPORT_C void ParseRequest(RMemChunk& aMessage, CRequest* aRequest);
	IMPORT_C void ResetParser();
	inline void DataFailed ();
	
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:
	CUpnpRequestParser(MParserObserver& aObserver);
	void ConstructL();
	
	inline TBool BodyComplete();
	inline TBool MessageComplete();
	inline TBool NotifyReleaseData();
    inline TBool IsExcessData();

private:

	enum THttpResponseFlags
		{
		EBodyComplete			= 0x02,
	    ENotifyReleaseData		= 0x10,
		EBodyPresent			= 0x20,
		EExcessData				= 0x40,
		};

private:
	CRequest* 				iRequest;
	RHttpMessageParser		iMessageParser;
	TInt					iFlags;
	TInt					iOverallDataSize;
	MParserObserver& 		iObserver;
	RArray<TPtrC8>			iBodyParts;	
	RMemChunk				iMsgBuf;
	RArray<TPtrC8>			iRawDataArray;
	
	__FLOG_DECLARATION_MEMBER;
	};
	
inline TBool CUpnpRequestParser::BodyComplete()
	{
	return iFlags & EBodyComplete;
	}

inline TBool CUpnpRequestParser::NotifyReleaseData()
	{
	return iFlags & ENotifyReleaseData;
	}

inline TBool CUpnpRequestParser::IsExcessData()
 	{
 	return iFlags & EExcessData;
 	}
 	
// Free up corrupted UDP data packet
void CUpnpRequestParser::DataFailed ()
	{
	if ( !iMsgBuf.IsEmpty() )
		{
		iMsgBuf.Free ();
		}
	}
		
#endif /*CUPNPREQUESTPARSER_H_*/