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

//

#ifndef __AGSENTRYMANAGER_H__

#define __AGSENTRYMANAGER_H__

#include <s32std.h>

// ---------------------- Referenced classes -----------------------------------

class CAgnEntry;

class TAgnEntryId;

class TAgnEntryIter;

class CAgnEntryManager : public CBase

/**

Manages adding,deleting and updating entries in the store.

@internalAll

@released

*/

	{

public:

	friend class TAgnEntryIter;

	enum TBufferType {ETodo,ERpt,EGeneral,EIterator};

	static CAgnEntryManager* NewL();

	~CAgnEntryManager();

	TStreamId AddEntryL(CAgnEntry& aEntry);

	TStreamId DeleteEntryL(const TAgnEntryId& aEntryId);

	CAgnEntry* FetchEntryL(const TAgnEntryId& aEntryId);

	TStreamId UpdateEntryL(CAgnEntry& aEntry,TStreamId& aNewStreamId);

	void StoreBuffersL();

	void FlushBuffersL();

	void FreeBuffers();

	inline TBool BufferedDeleting() const;

	void SetBufferedDeleting(TBool aSetting);

	TAgnEntryId NextAvailableIdL(TBufferType aBufferType);

	inline void SetStore(CStreamStore& aStore);

	inline CStreamStore& StreamStore() const;

	inline TBool BufferHasBeenStored() const;

	void Reset();

	TInt RestoreBufferL(const TStreamId& aStreamId);

	void InternalizeL(RReadStream& aStream);

	void ExternalizeL(RWriteStream& aStream) const;

	void CopyStreamIds(const CAgnEntryManager& aOriginalManager);

private:

	class TBufItem

	/**

	@internalAll

	@released

	*/

		{

	public:

		inline TBufItem() {};

		inline TBufItem(CAgnEntry* aEntry, TBool aToBeDeleted=EFalse); 

		inline TBool ToBeDeleted() const;

		inline void SetToBeDeleted(TBool aSetting);

		inline void SetEntry(CAgnEntry* aEntry);

		inline CAgnEntry* Entry() const;

	private:		

		CAgnEntry*	iEntry;

		TBool		iToBeDeleted;

		};

	typedef CArrayFixFlat<TBufItem> CBuffer;

	CAgnEntryManager();

	const CAgnEntry* operator[](TInt aIndex) const;

	void StoreBufferL(const TStreamId& aStreamId, const CBuffer* aBuffer, TBufferType aType);

	TUint FindUniqueIdPortion(const CBuffer* aBuffer);

	CAgnEntry* SearchBuffers(const TAgnEntryId& aEntryId, TInt& aPos);

	void SetBufferHasBeenStored(TBool aHasBeenStored, TBufferType aType);

	void FreeBuffer(TBufferType aBufferType);

	void DeleteEntriesInBufferFromStoreL(CBuffer* aBuffer, TInt& aNumEntriesToDelete);	

	TStreamId DoAddEntryL(CAgnEntry& aEntry, TStreamId& aCurrentStreamId, TStreamId& aNextAvailableStreamId, CBuffer* aBuffer, TBufferType aBufferType);

	TStreamId DoDeleteEntryL(CAgnEntry* aEntry, CBuffer* aBuffer, TInt& aNumEntriesToDelete, TStreamId& aNextAvailableStreamId,

							 const TStreamId& aCurrentStreamId, TBufferType aBufferType, TInt aPos);

	void StoreAndMaybeFreeBuffersL(TBool aFreeBuffers);

	CBuffer*				iGeneralBuffer;

	CBuffer*				iTodoBuffer;

	CBuffer*				iRptBuffer;	

	CBuffer*				iIteratorBuffer;

	TStreamId				iNextAvailableGeneralStreamId;

	TStreamId				iNextAvailableTodoStreamId;

	TStreamId				iNextAvailableRptStreamId;

	TStreamId				iCurrentGeneralStreamId;

	TStreamId				iCurrentTodoStreamId;

	TStreamId				iCurrentRptStreamId;

	TInt					iNumGeneralEntriesToDelete;

	TInt					iNumTodoEntriesToDelete;

	TInt					iNumRptEntriesToDelete;

	TBool					iGeneralBufferHasBeenStored;

	TBool					iTodoBufferHasBeenStored;

	TBool					iRptBufferHasBeenStored;

	TBool					iBufferHasBeenStored;

	CStreamStore*			iStore;	

	TBool					iBufferedDeleting;

	TBufferType				iLastRestored;

	mutable TBool			iUseIteratorBuffer;

	};

#include "agsentrymanager.inl"

#endif