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

// @file

// @internalComponent

// 

//

#ifndef __CTRANSACTION_H_

#define __CTRANSACTION_H_

// System Includes

#include <http/framework/cheadercodec.h>

#include <rmemchunk.h>

// Local Includes

#include "CRequest.h"

#include "CResponse.h"

class CTransaction : public CBase

	{

public:

	static CTransaction* NewL ( CHeaderCodec& aCodec, RStringPool& aStringPool );	

	virtual ~CTransaction ( );

	CRequest* Request ( ) const;

	CResponse* Response ( ) const;	

	inline void AddBodyPart ( RMBufChain& aData )

		{

		if ( !aData.IsEmpty () )

			iBodyParts.Append ( aData );

		}

	inline void AddBodyPart ( RMemChunk& aMemChunk )

		{

		if ( !aMemChunk.IsEmpty () )

			iMemParts.Append ( aMemChunk );

		}

	inline void FreeMemChunk ( )

		{

		if ( !iMemParts.IsEmpty () )

			iMemParts.Free();

		}

	inline void RemoveAllBodyParts ( ) 

		{

		if ( iBodyParts.IsEmpty ( ) )

			{

			return;

			}

		while ( iBodyParts.NumBufs ( ) > 0 )

			{

			iBodyParts.Remove ( );

			if ( iBodyParts.IsEmpty ( ) )

				{

				break;

				}

			}		

		}

	inline RMBufChain& BodyParts ( )

		{

		return iBodyParts;

		}

	inline RMemChunk& MemParts ( )

		{

		return iMemParts;

		}

	inline void RemoveBodyPart ()

		{

		RMBuf* mBuf = iBodyParts.Remove ();	 // Remove the first body part

		__ASSERT_DEBUG ( mBuf, User::Invariant() );

		if ( iDataLeft != KErrUnknown )

			iDataLeft -= mBuf->Length ();

		}

	inline void GetBodyPart ( TPtrC8& aData )

		{

		RMBuf* buf = iBodyParts.First ();

		aData.Set ( buf->Ptr (), buf->Length () );		

		}

	inline TBool IsLastBodyPart () const

		{

		if ( iDataLeft != KErrUnknown )

			{

			return ( ( iDataLeft - iBodyParts.First()->Length() ) == 0)	? ETrue : EFalse;			

			}

		return Complete();

		}

	inline void SetDataLeft ( TInt aDataLeft )

		{

		iDataLeft = aDataLeft;			

		}

	inline void SetComplete ()

		{

		iComplete = ETrue;		

		}

	inline TBool Complete() const

		{

		return iComplete;	

		}

	inline TInt DataLeft () const

		{

		return iDataLeft;	

		}

	inline void Reset ()

		{

		iDataLeft = KErrUnknown;

		iRequest->Reset ();

		iResponse->Reset ();

		if ( !iBodyParts.IsEmpty () )

			iBodyParts.Free ();

		iComplete = EFalse;

		}

	inline TBool CloseNeeded () const

		{

		if ( iDataLeft != KErrUnknown )

			{

			if ( iBodyParts.IsEmpty () )

				{

				return iDataLeft != 0 ? ETrue : EFalse;

				}

			else

				{

				return ( ( iDataLeft - iBodyParts.Length() ) != 0 ) ? ETrue : EFalse;

				}

			}

		return !Complete ();	

		}

protected:

	CTransaction ( );

	void ConstructL ( CHeaderCodec& aCodec, RStringPool& aStringPool );

protected:

	TInt		iDataLeft;

	CRequest* 	iRequest;

	CResponse*	iResponse;

	RMBufChain	iBodyParts;

	RMemChunk	iMemParts;

	TBool		iComplete : 1;	

	};

#endif // CTRANSACTION_H