// Copyright (c) 2006-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 "cfakeinputstream.h"
#include <utf.h>

CFakeInputStream* CFakeInputStream::NewL(CTestExecuteLogger& aLogger)
// static
	{
	return new(ELeave)CFakeInputStream(aLogger);
	}

CFakeInputStream::CFakeInputStream(CTestExecuteLogger& aLogger)
	: CActive(CActive::EPriorityStandard)
	, iLogger(aLogger)
	{
	CActiveScheduler::Add(this);
	}
		
CFakeInputStream::~CFakeInputStream()
	{
	Cancel(); 
	iInputStrings.Reset();
	}

void CFakeInputStream::Bind(MInputStreamObserver& aInputStreamObserver, TInt /*aLogId*/)
	{
	INFO_PRINTF1(_L("CFakeInputStream::Bind()"));
	iInputStreamObserver = &aInputStreamObserver;
	}
void CFakeInputStream::ReadReq(TInt aIdleTime)
	{
	aIdleTime = aIdleTime;// To avoid build errors
	INFO_PRINTF1(_L("CFakeInputStream::ReadReq()"));
	iIsReading = ETrue;
	CompleteSelf(KErrNone);
	}
void CFakeInputStream::CancelReadReq()
	{
	INFO_PRINTF1(_L("CFakeInputStream::CancelReadReq()"));
	iIsReading = EFalse;
	Cancel();
	}
TBool CFakeInputStream::IsReading()
	{
	INFO_PRINTF1(_L("CFakeInputStream::IsReading()"));
	return iIsReading;
	}
	
void CFakeInputStream::CompleteSelf(TInt aError)
	{
	TRequestStatus* status = &iStatus;
	SetActive();
	User::RequestComplete(status, aError);
	}
	
void CFakeInputStream::RunL()
	{
	if (iNextInputString < iInputStrings.Count())
		{
		TPtrC8& ptrInputString = iInputStrings[iNextInputString];
		
		HBufC16* unicodeBuffer = NULL;
		TRAPD(err,
			unicodeBuffer = CnvUtfConverter::ConvertToUnicodeFromUtf8L(ptrInputString);
		);
		if (err == KErrNone)
			{
			INFO_PRINTF2(_L("S >>> C [%S]"), unicodeBuffer);
			}
		delete unicodeBuffer;
		
		iIsReading = EFalse;
		iInputStreamObserver->ReceivedDataIndL(ptrInputString);
		++iNextInputString;
		}
		
	if (iNextInputString == iInputStrings.Count())
		{
		// No more data to deliver.
		iInputStrings.Reset();
		iNextInputString = 0;
		
		// Notify the observer if one has been set
		if (iStreamIsEmptyObserver != NULL)
			{
			// Need to reset the observer before it is called.
			MFakeInputStreamIsEmptyObserver* observer = iStreamIsEmptyObserver;
			iStreamIsEmptyObserver = NULL;
			
			observer->OnInputStreamIsEmptyL();
			}
		}
	}
	
void CFakeInputStream::DoCancel()
	{}

void CFakeInputStream::NotifyWhenStreamIsEmpty(MFakeInputStreamIsEmptyObserver& aStreamIsEmptyObserver)
	{
	ASSERT(iStreamIsEmptyObserver == NULL);	
	iStreamIsEmptyObserver = &aStreamIsEmptyObserver;
	}

void CFakeInputStream::AppendInputStringL(const TDesC8& aString)
	{
	iInputStrings.AppendL(aString);
	}

void CFakeInputStream::ResetInputStrings()
	{
	iInputStrings.Reset();
	iNextInputString = 0;
	}