/*

* Copyright (c) 2005 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:  DS notepad mods fetcher

*

*/

// INCLUDE FILES

#include <s32strm.h>

#include <nsmlsnapshotitem.h>

#include <nsmlchangefinder.h>

#include "NSmlNotepadModsFetcher.h"

#include "nsmlnotepadDatabase.h"

#include "nsmlnotepadlogging.h"

const TInt KNullId=-1;

// ------------------------------------------------------------------------------------------------

// CNSmlNotepadModsFetcher::NewL

// ------------------------------------------------------------------------------------------------

//

CNSmlNotepadModsFetcher* CNSmlNotepadModsFetcher::NewL( TBool& aSnapshotRegistered, 

														CNSmlNotepadDatabase* aNpdDb, 

														TKeyArrayFix& aKey, 

														CNSmlChangeFinder& aChangeFinder ) 

	{

	_NOTEPAD_DBG_FILE("CNSmlNotepadModsFetcher::NewL(): begin");

	CNSmlNotepadModsFetcher* self = NewLC(aSnapshotRegistered,aNpdDb,aKey,aChangeFinder);

	CleanupStack::Pop(self);

	_NOTEPAD_DBG_FILE("CNSmlNotepadModsFetcher::NewL(): end");

	return self;

	}

// ------------------------------------------------------------------------------------------------

// CNSmlNotepadModsFetcher::NewLC

// ------------------------------------------------------------------------------------------------

//

CNSmlNotepadModsFetcher* CNSmlNotepadModsFetcher::NewLC( TBool& aSnapshotRegistered, 

														CNSmlNotepadDatabase* aNpdDb, 

														TKeyArrayFix& aKey, 

														CNSmlChangeFinder& aChangeFinder )

	{

	_NOTEPAD_DBG_FILE("CNSmlNotepadModsFetcher::NewLC(): begin");

	CNSmlNotepadModsFetcher* self = new (ELeave) CNSmlNotepadModsFetcher(aSnapshotRegistered,aNpdDb,aKey,aChangeFinder);

	CleanupStack::PushL( self );

	self->ConstructL();

	_NOTEPAD_DBG_FILE("CNSmlNotepadDataProvider::NewLC(): end");

	return self;

	}	

// ------------------------------------------------------------------------------------------------

// CNSmlNotepadModsFetcher::CNSmlNotepadModsFetcher

// ------------------------------------------------------------------------------------------------

//

CNSmlNotepadModsFetcher::CNSmlNotepadModsFetcher( TBool& aSnapshotRegistered, 

												CNSmlNotepadDatabase* aNpdDb, 

												TKeyArrayFix& aKey, 

												CNSmlChangeFinder& aChangeFinder ) :

	CActive( EPriorityLow ), iSnapshotRegistered( aSnapshotRegistered ), iNpdDb( aNpdDb ), iKey( aKey ), iChangeFinder( aChangeFinder )

	{

	_NOTEPAD_DBG_FILE("CNSmlNotepadModsFetcher::CNSmlNotepadModsFetcher(): begin");

	CActiveScheduler::Add( this );

	iBeginning = ETrue;

	_NOTEPAD_DBG_FILE("CNSmlNotepadModsFetcher::CNSmlNotepadModsFetcher(): end");

	}

// ------------------------------------------------------------------------------------------------

// CNSmlNotepadModsFetcher::ConstructL

// ------------------------------------------------------------------------------------------------

//

void CNSmlNotepadModsFetcher::ConstructL()

	{

	_NOTEPAD_DBG_FILE("CNSmlNotepadModsFetcher::ConstructL: begin");

	iSnapshot = new (ELeave) CArrayFixSeg<TNSmlSnapshotItem>(KNSmlSnapshotSmallSize);

	_NOTEPAD_DBG_FILE("CNSmlNotepadModsFetcher::ConstructL: end");

	}

// ------------------------------------------------------------------------------------------------

// CNSmlNotepadModsFetcher::~CNSmlNotepadModsFetcher

// ------------------------------------------------------------------------------------------------

//

CNSmlNotepadModsFetcher::~CNSmlNotepadModsFetcher()

	{

	_NOTEPAD_DBG_FILE("CNSmlNotepadModsFetcher::~CNSmlNotepadModsFetcher(): begin");

	if(IsActive())

		Cancel();

	if(iSnapshot)

	{

		iSnapshot->Reset();

		delete iSnapshot;

		iSnapshot=NULL;	

	}

	_NOTEPAD_DBG_FILE("CNSmlNotepadModsFetcher::~CNSmlNotepadModsFetcher(): end");

	}

// ------------------------------------------------------------------------------------------------

// CNSmlNotepadModsFetcher::FetchModificationsL

// ------------------------------------------------------------------------------------------------

//

TInt CNSmlNotepadModsFetcher::FetchModificationsL( TRequestStatus& aStatus )

	{

	_NOTEPAD_DBG_FILE("CNSmlNotepadModsFetcher::FetchModificationsL(): begin");

	iCallerStatus = &aStatus;

	*iCallerStatus = KRequestPending;

	if(!iSnapshot)

	{

		iSnapshot = new (ELeave) CArrayFixSeg<TNSmlSnapshotItem>( KNSmlSnapshotSize );

	}

	SetActive();

	TRequestStatus* status = &iStatus;

	User::RequestComplete( status, KErrNone );

	_NOTEPAD_DBG_FILE("CNSmlNotepadModsFetcher::FetchModificationsL(): end");

	return KErrNone;

	}

// ------------------------------------------------------------------------------------------------

// CNSmlNotepadModsFetcher::Reset()

// ------------------------------------------------------------------------------------------------

//	

void CNSmlNotepadModsFetcher::Reset()

{

	iBeginning = ETrue;

}

// ------------------------------------------------------------------------------------------------

// CNSmlNotepadModsFetcher::FetchNextChunkL

// ------------------------------------------------------------------------------------------------	

//

void CNSmlNotepadModsFetcher::FetchNextChunkL()

	{

	_NOTEPAD_DBG_FILE("CNSmlNotepadModsFetcher::RunL(): end");

	if ( iSnapshotRegistered )

	{

		_NOTEPAD_DBG_FILE("CNSmlNotepadModsFetcher::FetchNextChunkL: if snapshotregistered");

		iEnd = ETrue;

	}

	else

	{

		iEnd = EFalse;

		TInt id;

		if ( iBeginning )

		{

				_NOTEPAD_DBG_FILE("CNSmlNotepadModsFetcher::FetchNextChunkL: callinf firstl");

			id = iNpdDb->FirstL();

			iBeginning = EFalse;

		}

		else

		{

				_NOTEPAD_DBG_FILE("CNSmlNotepadModsFetcher::FetchNextChunkL: calling nextl");

			id = iNpdDb->NextL();

		}

		if ( id == KNullId )

		{

				_NOTEPAD_DBG_FILE("CNSmlNotepadModsFetcher::FetchNextChunkL: invalid id");

			iEnd = ETrue;

		}

		else

		{

				_NOTEPAD_DBG_FILE("CNSmlNotepadModsFetcher::FetchNextChunkL: reading item from db");

			CNpdItem* item = CNpdItem::NewLC();

			TInt err;

			TRAP(err,iNpdDb->GetNoteL( id,*item ));

			if( err == KErrNone )

			{

				_NOTEPAD_DBG_FILE("CNSmlNotepadModsFetcher::FetchNextChunkL: item read successful");

				TNSmlSnapshotItem snap( item->Key() );

				snap.SetLastChangedDate( item->LastModified() );

				iSnapshot->InsertIsqL( snap, iKey );

				iCurrentSnapshotCounter++;

				if ( iCurrentSnapshotCounter > KNSmlSnapshotItemCount )

				{

					iSnapshot->Compress();

					iCurrentSnapshotCounter = 0;

				}

			}

			CleanupStack::PopAndDestroy(item); // item

		}

		if ( iEnd  )

		{

			_NOTEPAD_DBG_FILE("CNSmlNotepadModsFetcher::FetchNextChunkL: end item");

			iChangeFinder.SetNewSnapshot( iSnapshot ); // changefinder takes ownership

			iSnapshot = NULL;

			iSnapshotRegistered = ETrue;

		}

	}

	if ( iEnd )

		{

		User::RequestComplete( iCallerStatus, KErrNone ); // CNSmlContactsModsFetcher

		}

		_NOTEPAD_DBG_FILE("CNSmlNotepadModsFetcher::FetchNextChunkL: end");

	}

// ------------------------------------------------------------------------------------------------

// CNSmlNotepadModsFetcher::RunL

// ------------------------------------------------------------------------------------------------	

//

void CNSmlNotepadModsFetcher::RunL()

	{

	_NOTEPAD_DBG_FILE("CNSmlNotepadModsFetcher::RunL(): begin");

	FetchNextChunkL();

	if ( !iEnd )

		{

		SetActive();

		TRequestStatus* status = &iStatus;

		User::RequestComplete( status, KErrNone );

		}

	_NOTEPAD_DBG_FILE("CNSmlNotepadModsFetcher::RunL(): end");

	}

// ------------------------------------------------------------------------------------------------

// CNSmlNotepadModsFetcher::DoCancel

// ------------------------------------------------------------------------------------------------	

//

void CNSmlNotepadModsFetcher::DoCancel()

	{

	_NOTEPAD_DBG_FILE("CNSmlNotepadModsFetcher::DoCancel(): begin");

	User::RequestComplete( iCallerStatus, KErrCancel );

	iEnd = ETrue;

	_NOTEPAD_DBG_FILE("CNSmlNotepadModsFetcher::DoCancel(): end");

	}

// End of File