// Copyright (c) 2001-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:
// System includes
// Local includes
// 
//

// Class signatures
#include "cwspfiledatasupplier.h"


// Constants used in this file
_LIT(KFileSystemRoot,"C:\\");
const TInt KChunkSize = 64;

/** Implementation of class 'CWspFileDataSupplier'.
*/


CWspFileDataSupplier* CWspFileDataSupplier::NewL()
	{
	CWspFileDataSupplier* me = new(ELeave)CWspFileDataSupplier();
	CleanupStack::PushL(me);
	me->ConstructL();
	CleanupStack::Pop(me);
	return me;
	}

CWspFileDataSupplier* CWspFileDataSupplier::NewL(const TDesC& aFileName)
	{
	CWspFileDataSupplier* me = new(ELeave)CWspFileDataSupplier();
	CleanupStack::PushL(me);
	me->ConstructL(aFileName);
	CleanupStack::Pop(me);
	return me;
	}

CWspFileDataSupplier::~CWspFileDataSupplier()
	{
	delete iBuffer;
	iFileHnd.Close();
	iFileSrvHnd.Close();
	}

void CWspFileDataSupplier::CleanUp(TAny* aDataSupplierItem)
	{
	delete STATIC_CAST(CWspFileDataSupplier*, aDataSupplierItem);
	}

void CWspFileDataSupplier::SetFileL(const TDesC& aFileName)
	{
	// Close any already open file
	if (iFileOpen)
		{
		iFileHnd.Close();
		iFileOpen = EFalse;
		}

	// Parse the name of the new file and open it
	iParsedFileName.Set(KFileSystemRoot, &aFileName, NULL);
	User::LeaveIfError(iFileHnd.Open(iFileSrvHnd, iParsedFileName.FullName(), EFileRead));
	iFileOpen = ETrue;

	// Read from the request body file
	TPtr8 bufferPtr = iBuffer->Des();

	// Read initially into the dynamic buffer.  If we haven't hit the
	// end of file, then read more into a local buffer and append to the
	// dynamic one, expanding and reallocating where necessary
	TInt err = iFileHnd.Read(bufferPtr);
	TBuf8<KChunkSize> chunk;
	TBool done = EFalse;
	while (!done)
		{
		// If it's not at EOF, then the read should have been successful with no error
		User::LeaveIfError(err);

		// Read some more... detect EOF
		err = iFileHnd.Read(chunk);
		done = (chunk.Length() == 0);
		if ((err == KErrNone) && !done)
			{
			// Determine whether we need to grow the dynamic buffer
			if (chunk.Length() > (bufferPtr.MaxLength() - bufferPtr.Length()))
				{
				HBufC8* oldbuffer = iBuffer;
				iBuffer = oldbuffer->ReAllocL(oldbuffer->Length() + KChunkSize);
				bufferPtr = iBuffer->Des();
				}

			// Append from the local buffer
			bufferPtr.Append(chunk);
			}
		}
	}

TBool CWspFileDataSupplier::GetNextDataPart(TPtrC8& aDataPart)
	{
	__ASSERT_ALWAYS(iFileOpen, User::Invariant());
	// Return the data in one chunk
	aDataPart.Set(*iBuffer);
	return ETrue;
	}

void CWspFileDataSupplier::ReleaseData()
	{
	__ASSERT_ALWAYS(iFileOpen, User::Invariant());
	// Clear out the submit buffer
	TPtr8 bufferPtr = iBuffer->Des();
	bufferPtr.Zero();
	}

TInt CWspFileDataSupplier::OverallDataSize()
	{
	__ASSERT_ALWAYS(iFileOpen, User::Invariant());
	return iBuffer->Length();
	}

TInt CWspFileDataSupplier::Reset()
	{
	__ASSERT_ALWAYS(iFileOpen, User::Invariant());
	return KErrNotSupported;
	}

CWspFileDataSupplier::CWspFileDataSupplier()
	{
	}

void CWspFileDataSupplier::ConstructL()
	{
	// Connect to the fileserver
	User::LeaveIfError(iFileSrvHnd.Connect());

	// Make a buffer to hold chunks taken from the file
	iBuffer = HBufC8::NewMaxL(KChunkSize);
	}

void CWspFileDataSupplier::ConstructL(const TDesC& aFileName)
	{
	// General set-up first
	ConstructL();

	// Open the specified file
	SetFileL(aFileName);
	}