// Copyright (c) 2002-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:
//

#include "cbodydatasupplier.h"

#include "mbodydatasupplierobserver.h"

const TInt KGranularity	= 5;

CBodyDataSupplier* CBodyDataSupplier::NewL(MBodyDataSupplierObserver& aObserver)
	{
	CBodyDataSupplier* self = new (ELeave) CBodyDataSupplier(aObserver);
	CleanupStack::PushL(self);
	self->ConstructL();
	CleanupStack::Pop(self);
	return self;
	}

CBodyDataSupplier::~CBodyDataSupplier()
	{
	if( iBodyParts )
		iBodyParts->Reset();
	delete iBodyParts;
	}

CBodyDataSupplier::CBodyDataSupplier(MBodyDataSupplierObserver& aObserver)
: CActive(CActive::EPriorityStandard), iObserver(aObserver)
	{
	CActiveScheduler::Add(this);
	}

void CBodyDataSupplier::ConstructL()
	{
	iBodyParts = new (ELeave) CDesC8ArrayFlat(KGranularity);
	}

void CBodyDataSupplier::AddBodyPartL(const TDesC8& aData)
	{
	iBodyParts->AppendL(aData);

	if( iState == EIdle )
		{
		iState = EPendingRelease;
		}
	}

void CBodyDataSupplier::SetBodySize(TInt aSize)
	{
	iOverallDataSize = aSize;
	}

TBool CBodyDataSupplier::IsChunked() const
	{
	return iOverallDataSize == KErrNotFound;
	}

void CBodyDataSupplier::CompleteSelf()
	{
	TRequestStatus* pStat = &iStatus;
	User::RequestComplete(pStat, KErrNone);
	SetActive();
	}

void CBodyDataSupplier::ResetSupplier()
	{
	Cancel();
	iState = EPendingRelease;
	iIndex = 0;
	}

/*
 *	Methods from CActive
 */

void CBodyDataSupplier::RunL()
	{
	// Move to the EPendingRelease state.
	iState = EPendingRelease;

	// Notify the observer
	iObserver.NotifyMoreData();
	}

void CBodyDataSupplier::DoCancel()
	{
	// Do nothing...
	}

/*
 *	Methods from MHTTPDataSupplier
 */

TBool CBodyDataSupplier::GetNextDataPart(TPtrC8& aDataPart)
	{
	__ASSERT_DEBUG( iState == EPendingRelease, User::Invariant() );

	aDataPart.Set(iBodyParts->MdcaPoint(iIndex));

	return ( iIndex == iBodyParts->MdcaCount()-1 );
	}

void CBodyDataSupplier::ReleaseData()
	{
	// Move onto the next part
	++iIndex;

	// Have all the parts been released?
	if( iIndex < iBodyParts->MdcaCount() )
		{
		// More to go - self-complete to notify observer and move to the 
		// EPendingNotify state.
		iState = EPendingNotify;
		CompleteSelf();
		}
	else
		{
		// All done - move to EDone state
		iState = EDone;
		}	
	}
	
TInt CBodyDataSupplier::OverallDataSize()
	{
	if( iIsChunked )
		return KErrNotFound;
	else
		return iOverallDataSize;
	}

TInt CBodyDataSupplier::Reset()
	{
	return KErrNotFound;
	}