// bufferbase.cpp
// 
// Copyright (c) 2009 - 2010 Accenture. All rights reserved.
// This component and the accompanying materials are made available
// under the terms of the "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:
// Accenture - Initial contribution
//
#include "bufferbase.h"
#include "filebuffer.h" // for CFileBlock::CountNewLines

CFedBufferBase::CFedBufferBase()
	: CActive(EPriorityStandard), iRefCount(1)
	{
	}

TInt CFedBufferBase::RefCount() const
	{
	return iRefCount;
	}

void CFedBufferBase::IncRef()
	{
	iRefCount++;
	}

TInt CFedBufferBase::DecRef()
	{
	iRefCount--;
	TInt refCount = iRefCount;
	if (refCount == 0) delete this; 
	return refCount;
	}

void StaticDecRef(TAny* aPtr)
	{
	static_cast<CFedBufferBase*>(aPtr)->DecRef();
	}

void CFedBufferBase::PushL()
	{
	CleanupStack::PushL(TCleanupItem(&StaticDecRef, this));
	}

void CFedBufferBase::DoCancel()
	{
	ASSERT(EFalse);
	}

void CFedBufferBase::RunL()
	{
	ASSERT(EFalse);
	}

TInt CFedBufferBase::FindClientRequest(MSharedCacheClient& aClient)
	{
	TPtrC dummy;
	TRange dummyRange;
	TInt dummyLine;
	return iClientRequests.FindInUnsignedKeyOrder(TClientRequest(&aClient, dummy, dummyRange, dummyLine));
	}

TInt CFedBufferBase::RegisterClient(MSharedCacheClient& aClient, TPtrC& aDes, TRange& aRange, TInt& aRangeStartLineNumber)
	{
	TInt err = iClientRequests.InsertInUnsignedKeyOrder(TClientRequest(&aClient, aDes, aRange, aRangeStartLineNumber));
	return err;
	}

void CFedBufferBase::UnregisterClient(MSharedCacheClient& aClient)
	{
	TInt res = FindClientRequest(aClient);
	if (res >= 0) iClientRequests.Remove(res);
	}

CFedBufferBase::~CFedBufferBase()
	{
	ASSERT(iRefCount == 0); // Otherwise someone has deleted us directly rather than going through the reference counting
	iClientRequests.Reset();
	}

void CFedBufferBase::InsertTextL(TInt /*aDocumentPosition*/, const TDesC& /*aText*/)
	{
	User::Leave(KErrNotSupported);
	}

void CFedBufferBase::DeleteTextL(TRange /*aRange*/)
	{
	User::Leave(KErrNotSupported);
	}

void CFedBufferBase::SaveL(const TDesC& /*aNewName*/, TBool /*aReplace*/)
	{
	User::Leave(KErrNotSupported);
	}

TBool CFedBufferBase::Modified() const
	{
	return EFalse;
	}

TBool CFedBufferBase::Editable() const
	{
	return EFalse;
	}

TBool CFedBufferBase::IsOpen() const
	{
	return EFalse;
	}

///////

CConstDataBuffer::CConstDataBuffer(const TDesC& aTitle, const TDesC& aText)
: iTitle(aTitle), iText(aText)
	{
	}

CConstDataBuffer::CConstDataBuffer(const TDesC& aTitle, HBufC* aTextPtr)
	: iTitle(aTitle), iText(*aTextPtr), iOwnedTextPtr(aTextPtr)
	{
	}

CConstDataBuffer::~CConstDataBuffer()
	{
	delete iOwnedTextPtr;
	}

const TDesC& CConstDataBuffer::Title() const
	{
	return iTitle;
	}

TDelimiterType CConstDataBuffer::DelimiterType() const
	{
	return EDelimLF;
	}

TEncodingType CConstDataBuffer::Encoding() const
	{
	return EEncodingUtf16Native;
	}

TInt CConstDataBuffer::GetData(MSharedCacheClient& aClient, TInt aDocumentPosition)
	{
	TInt idx = FindClientRequest(aClient);
	if (idx < 0)
		{
		return idx;
		}

	TClientRequest& client = iClientRequests[idx];
	ASSERT(aDocumentPosition >= 0);

	client.iRange = TRange(aDocumentPosition, iText.Length()-aDocumentPosition);
	client.iDes.Set(iText.Mid(aDocumentPosition));
	TInt lines = KMaxTInt;
	CFileBlock::CountNewLines(iText.Left(aDocumentPosition), lines, KMaxTInt);
	client.iRangeStartLineNumber = lines;
	return KErrNone;
	}

TInt CConstDataBuffer::SeekFromOffset(MSharedCacheClient& aClient, TInt aOffset, TInt aNumLinesFromOffset, TInt aLineLength)
	{
	TInt idx = FindClientRequest(aClient);
	if (idx < 0)
		{
		return idx;
		}
	TClientRequest& client = iClientRequests[idx];

	TInt lineDelta = aNumLinesFromOffset;
	TInt bufPos = -1;
	if (lineDelta > 0)
		{
		TPtrC ptr = iText.Mid(aOffset);
		bufPos = CFileBlock::CountNewLines(ptr, lineDelta, aLineLength);
		if (bufPos == KErrNotFound)
			{
			aOffset = 0;
			ptr.Set(iText);
			lineDelta = -1;
			bufPos = CFileBlock::CountNewLines(ptr, lineDelta, aLineLength);
			}
		}
	else
		{
		lineDelta--;
		TPtrC ptr = iText.Left(aOffset);
		aOffset = 0;
		bufPos = CFileBlock::CountNewLines(ptr, lineDelta, aLineLength);
		if (bufPos == KErrNotFound) bufPos = 0;
		}
	

	client.iDes.Set(iText.Mid(bufPos+aOffset));
	client.iRange = TRange(bufPos + aOffset, client.iDes.Length());
	TInt lines = KMaxTInt;
	CFileBlock::CountNewLines(iText.Left(bufPos + aOffset), lines, KMaxTInt);
	client.iRangeStartLineNumber = lines;
	return KErrNone;
	}

TBool CConstDataBuffer::DocumentPositionIsEof(TInt aDocumentPosition) const
	{
	return (aDocumentPosition == iText.Length());
	}

TInt CConstDataBuffer::Find(TInt aStartingPosition, const TDesC& aSearchString, TBool aBackwards)
	{
	ASSERT(!aBackwards);
	TInt res = iText.Mid(aStartingPosition).Find(aSearchString);
	if (res >= 0) res += aStartingPosition;
	return res;
	}