// 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 "cmessagedatasupplier.h"

#include "mdatasupplierobserver.h"

CMessageDataSupplier* CMessageDataSupplier::NewL(MDataSupplierObserver& aObserver, const TDesC8& aData, TInt aBufferSize)
	{
	CMessageDataSupplier* self = new(ELeave) CMessageDataSupplier(aObserver, aData, aBufferSize);
	CleanupStack::PushL(self);
	self->ConstructL();
	CleanupStack::Pop(self);
	return self;
	}

CMessageDataSupplier::~CMessageDataSupplier()
	{
	Cancel();

	delete iBuffer;
	}

CMessageDataSupplier::CMessageDataSupplier(MDataSupplierObserver& aObserver, const TDesC8& aData, TInt aBufferSize)
: CActive(CActive::EPriorityStandard), iObserver(aObserver), iRemainingData(aData), iBufferSize(aBufferSize)
	{
	CActiveScheduler::Add(this);
	}

void CMessageDataSupplier::ConstructL()
	{
	iBuffer = HBufC8::NewL(iBufferSize);

	SetData();
	}


TBool CMessageDataSupplier::GetData(TPtrC8& aData)
	{
	aData.Set(*iBuffer);

	return iLast;
	}

void CMessageDataSupplier::ReleaseData()
	{
	iBuffer->Des().Zero();

	if( !iLast )
		CompleteSelf();
	}

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

void CMessageDataSupplier::SetData()
	{
	// Need to set the new data...
	TInt dataLength = iBufferSize;

	if( dataLength > iRemainingData.Length() )
		{
		dataLength = iRemainingData.Length();
		}
	// Copy the data...
	iBuffer->Des().Copy(iRemainingData.Left(dataLength));

	// Update the remaining data
	iRemainingData.Set(iRemainingData.Mid(dataLength));

	// Is this the last part?
	iLast = iRemainingData.Length() == 0;
	}

/*
 *	Methods from CActive
 */

void CMessageDataSupplier::RunL()
	{
	// Set the data...
	SetData();

	// Notify the observer that the data is ready
	iObserver.DataReady();
	}

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