/*
* 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:  Sources
*
*/


// INCLUDE FILES
#include <s32strm.h>

#include <nsmldebug.h>
#include <nsmlchangefinder.h>

#ifndef __WINS__
// This lowers the unnecessary compiler warning (armv5) to remark.
// "Warning:  #174-D: expression has no effect..." is caused by 
// DBG_ARGS8 macro in no-debug builds.
#pragma diag_remark 174
#endif

// ============================ MEMBER FUNCTIONS ===============================

// -----------------------------------------------------------------------------
// CNSmlChangeFinder::NewL
// Two-phased constructor.
// -----------------------------------------------------------------------------
//
EXPORT_C CNSmlChangeFinder* CNSmlChangeFinder::NewL( MSmlSyncRelationship& aSyncRelationship, TKeyArrayFix aKey, TBool& aHasHistory, TInt aStreamUid )
	{
	_DBG_FILE("CNSmlChangeFinder::NewL(): begin");
	CNSmlChangeFinder* self = new (ELeave) CNSmlChangeFinder(aSyncRelationship, aKey, aStreamUid);
	CleanupStack::PushL(self);
	self->ConstructL( aHasHistory );
	CleanupStack::Pop(); // self
	_DBG_FILE("CNSmlChangeFinder::NewL(): end");
	return self;
	}

// -----------------------------------------------------------------------------
// CNSmlChangeFinder::CNSmlChangeFinder
// C++ default constructor.
// -----------------------------------------------------------------------------
//
CNSmlChangeFinder::CNSmlChangeFinder( MSmlSyncRelationship& aSyncRelationship, TKeyArrayFix aKey, TInt aStreamUid ) : iSyncRelationship(aSyncRelationship), iKey(aKey), iStreamUid(aStreamUid)
	{
	_DBG_FILE("CNSmlChangeFinder::CNSmlChangeFinder(): begin");
	_DBG_FILE("CNSmlChangeFinder::CNSmlChangeFinder(): end");
	}

// -----------------------------------------------------------------------------
// CNSmlChangeFinder::ConstructL
// Symbian 2nd phase constructor.
// -----------------------------------------------------------------------------
//
void CNSmlChangeFinder::ConstructL( TBool& aHasHistory )
	{
	_DBG_FILE("CNSmlChangeFinder::ConstructL(): begin");
	iOldSnapshot = new (ELeave) CArrayFixSeg<TNSmlSnapshotItem>(sizeof(TNSmlSnapshotItem));
	iCurrentSnapshot = new (ELeave) CArrayFixSeg<TNSmlSnapshotItem>(sizeof(TNSmlSnapshotItem));
	TUid uid = {iStreamUid};
	iDataStoreUid = KErrNotFound;
		
	aHasHistory = iSyncRelationship.IsStreamPresentL(uid);
	
	if (aHasHistory)
	    {
	    // Open stream for reading
	    RReadStream readStream;
        iSyncRelationship.OpenReadStreamLC(readStream, uid);
        
        // Read snapshot from the stream
        TNSmlSnapshotItem item;
        TInt itemCount(readStream.ReadInt32L());
        for (TInt i = 0; i < itemCount; ++i)
            {
            readStream >> item;
            iOldSnapshot->InsertIsqL(item, iKey);
            }
            
        // Read store UID from the stream
        readStream.ReadL( ( TUint8* ) &iDataStoreUid, 8 );
        iOldSnapshot->Compress();
        
        CleanupStack::PopAndDestroy(); // readStream
	    }
	
	
	_DBG_FILE("CNSmlChangeFinder::ConstructL(): end");
	}

// -----------------------------------------------------------------------------
// CNSmlChangeFinder::~CNSmlChangeFinder
// -----------------------------------------------------------------------------
//
EXPORT_C CNSmlChangeFinder::~CNSmlChangeFinder()
	{
	_DBG_FILE("CNSmlChangeFinder::~CNSmlChangeFinder(): begin");
	delete iOldSnapshot;
	delete iCurrentSnapshot;
	_DBG_FILE("CNSmlChangeFinder::~CNSmlChangeFinder(): end");
	}

// -----------------------------------------------------------------------------
// CNSmlChangeFinder::CloseL
// -----------------------------------------------------------------------------
//
EXPORT_C void CNSmlChangeFinder::CloseL()
	{
	_DBG_FILE("CNSmlChangeFinder::CloseL(): begin");
		
	TUid uid = {iStreamUid};
	RWriteStream writeStream;
	
	// Open stream for writing
    iSyncRelationship.OpenWriteStreamLC(writeStream, uid);
	
	// Write the snapshot to the stream
    TInt itemCount = iOldSnapshot->Count();
    writeStream.WriteInt32L(itemCount);
    for (TInt i = 0; i < itemCount; ++i)
        {
        writeStream << iOldSnapshot->At(i);
        }
        
    // Write store UID to the stream
    writeStream.WriteL( ( TUint8* ) &iDataStoreUid, 8 );
    writeStream.CommitL();
    
    CleanupStack::PopAndDestroy(); // writeStream
	
	_DBG_FILE("CNSmlChangeFinder::CloseL(): end");
	}

// -----------------------------------------------------------------------------
// CNSmlChangeFinder::ResetL
// -----------------------------------------------------------------------------
//
EXPORT_C void CNSmlChangeFinder::ResetL()
	{
	_DBG_FILE("CNSmlChangeFinder::ResetL(): begin");
	iOldSnapshot->Reset();
	if ( iCurrentSnapshot )
		{
		iCurrentSnapshot->Reset();
		}

    // When called after reseting old snapshot, CloseL() externalizes the empty snaphot
    // to used stream.
    CloseL();
    	
	_DBG_FILE("CNSmlChangeFinder::ResetL(): end");
	}

// -----------------------------------------------------------------------------
// CNSmlChangeFinder::FindChangedItemsL
// -----------------------------------------------------------------------------
//
EXPORT_C void CNSmlChangeFinder::FindChangedItemsL( CNSmlDataItemUidSet& aChangedUids )
	{
	_DBG_FILE("CNSmlChangeFinder::FindChangedItemsL(): begin");
	TNSmlSnapshotItem current;
	TInt index;

	aChangedUids.Reset();
	for ( TInt i = 0; i < iCurrentSnapshot->Count(); i++ )
		{
		current = iCurrentSnapshot->At(i);

		// Is this also found in old snapshot?
		if ( !iOldSnapshot->FindIsq(current, iKey, index) )
			{
			// It is -> has it been changed?
			TNSmlSnapshotItem old = iOldSnapshot->At(index);
			if ( current.Compare(old) > 0 && current.SoftDelete() == EFalse )
				{
				// Yep -> add to list
				User::LeaveIfError(aChangedUids.AddItem(current.ItemId()));
				}
			}
		}

	DBG_ARGS(_S("CNSmlChangeFinder::FindChangedItemsL(): Number of changes = %d"), aChangedUids.ItemCount());

	_DBG_FILE("CNSmlChangeFinder::FindChangedItemsL(): end");
	}

// -----------------------------------------------------------------------------
// CNSmlChangeFinder::FindDeletedItemsL
// -----------------------------------------------------------------------------
//
EXPORT_C void CNSmlChangeFinder::FindDeletedItemsL( CNSmlDataItemUidSet& aDeletedUids )
	{
	_DBG_FILE("CNSmlChangeFinder::FindDeletedItemsL(): begin");
	TNSmlSnapshotItem old;
	TInt index;
	
	aDeletedUids.Reset();
	for ( TInt i = 0; i < iOldSnapshot->Count(); i++ )
		{
		old = iOldSnapshot->At(i);
		// Does this old item appear in current snapshot?
		if ( iCurrentSnapshot->FindIsq(old, iKey, index) )
			{
			// No -> add to list
			User::LeaveIfError(aDeletedUids.AddItem(old.ItemId()));
			}
		}
	
	DBG_ARGS(_S("CNSmlChangeFinder::FindDeletedItemsL(): Number of changes = %d"), aDeletedUids.ItemCount());

	_DBG_FILE("CNSmlChangeFinder::FindDeletedItemsL(): end");
	}

// -----------------------------------------------------------------------------
// CNSmlChangeFinder::FindNewItems
// -----------------------------------------------------------------------------
//
EXPORT_C void CNSmlChangeFinder::FindNewItemsL( CNSmlDataItemUidSet& aNewUids )
	{
	_DBG_FILE("CNSmlChangeFinder::FindNewItemsL(): begin");
	TNSmlSnapshotItem current;
	TInt index;

	aNewUids.Reset();
	for ( TInt i = 0; i < iCurrentSnapshot->Count(); i++ )
		{
		current = iCurrentSnapshot->At(i);
		
		// Is this also found in old snapshot?
		if ( iOldSnapshot->FindIsq(current, iKey, index) )
			{
			// No -> add to list
			User::LeaveIfError(aNewUids.AddItem(current.ItemId()));
			}
		}

	DBG_ARGS(_S("CNSmlChangeFinder::FindNewItemsL(): Number of changes = %d"), aNewUids.ItemCount());
	
	_DBG_FILE("CNSmlChangeFinder::FindNewItemsL(): end");
	}

// -----------------------------------------------------------------------------
// CNSmlChangeFinder::FindMovedItemsL
// -----------------------------------------------------------------------------
//
EXPORT_C void CNSmlChangeFinder::FindMovedItemsL( CNSmlDataItemUidSet& aMovedUids )
	{
	_DBG_FILE("CNSmlChangeFinder::FindMovedItemsL(): begin");
	TNSmlSnapshotItem current;
	TInt index;

	aMovedUids.Reset();
	
	for ( TInt i = 0; i < iCurrentSnapshot->Count(); i++ )
		{
		current = iCurrentSnapshot->At(i);

		// Is this also found in old snapshot?
		if ( !iOldSnapshot->FindIsq(current, iKey, index) )
			{
			// It is -> has it been changed?
			TNSmlSnapshotItem old = iOldSnapshot->At(index);
			if ( current.Compare(old) == 0 && current.ParentId() != old.ParentId() )
				{
				// Yep -> add to list
				User::LeaveIfError(aMovedUids.AddItem(current.ItemId()));
				}
			}
		}

	DBG_ARGS(_S("CNSmlChangeFinder::FindMovedItemsL(): Number of changes = %d"), aMovedUids.ItemCount());

	_DBG_FILE("CNSmlChangeFinder::FindMovedItemsL(): end");
	}
	
// -----------------------------------------------------------------------------
// CNSmlChangeFinder::FindSoftDeletedItemsL
// -----------------------------------------------------------------------------
//
EXPORT_C void CNSmlChangeFinder::FindSoftDeletedItemsL( CNSmlDataItemUidSet& aSoftDeletedUids )
	{
	_DBG_FILE("CNSmlChangeFinder::FindSoftDeletedItemsL(): begin");
	TNSmlSnapshotItem current;
	TInt index;

	aSoftDeletedUids.Reset();
	
	for ( TInt i = 0; i < iCurrentSnapshot->Count(); i++ )
		{
		current = iCurrentSnapshot->At(i);

		// Is this also found in old snapshot?
		if ( !iOldSnapshot->FindIsq(current, iKey, index) )
			{
			// It is -> has it been changed?
			TNSmlSnapshotItem old = iOldSnapshot->At(index);
			if ( current.SoftDelete() && !old.SoftDelete() )
				{
				// Yes -> add to list
				User::LeaveIfError(aSoftDeletedUids.AddItem(current.ItemId()));
				}
			}
		}

	DBG_ARGS(_S("CNSmlChangeFinder::FindSoftDeletedItemsL(): Number of changes = %d"), aSoftDeletedUids.ItemCount());

	_DBG_FILE("CNSmlChangeFinder::FindSoftDeletedItemsL(): end");
	}

// -----------------------------------------------------------------------------
// CNSmlChangeFinder::ItemAddedL
// -----------------------------------------------------------------------------
//
EXPORT_C void CNSmlChangeFinder::ItemAddedL( const TNSmlSnapshotItem& aItem )
	{
	_DBG_FILE("CNSmlChangeFinder::ItemAddedL(): begin");
	iOldSnapshot->InsertIsqL(aItem, iKey);
	iOldSnapshot->Compress();
	_DBG_FILE("CNSmlChangeFinder::ItemAddedL(): end");
	}

// -----------------------------------------------------------------------------
// CNSmlChangeFinder::ItemDeleted
// -----------------------------------------------------------------------------
//
EXPORT_C void CNSmlChangeFinder::ItemDeleted( const TNSmlSnapshotItem& aItem )
	{
	_DBG_FILE("CNSmlChangeFinder::ItemDeleted(): begin");
	TInt index;
	if ( !iOldSnapshot->FindIsq(aItem, iKey, index) )
		{
		iOldSnapshot->Delete(index);
		iOldSnapshot->Compress();
		}
	_DBG_FILE("CNSmlChangeFinder::ItemDeleted(): end");
	}

// -----------------------------------------------------------------------------
// CNSmlChangeFinder::ItemUpdatedL
// -----------------------------------------------------------------------------
//
EXPORT_C void CNSmlChangeFinder::ItemUpdatedL( const TNSmlSnapshotItem& aItem )
	{
	_DBG_FILE("CNSmlChangeFinder::ItemUpdatedL(): begin");
	TInt index;
	if ( !iOldSnapshot->FindIsq(aItem, iKey, index) )
		{
		iOldSnapshot->At(index) = aItem;
		}
	else
		{
		iOldSnapshot->InsertIsqL(aItem, iKey);
		iOldSnapshot->Compress();
		}
	_DBG_FILE("CNSmlChangeFinder::ItemUpdatedL(): end");
	}

// -----------------------------------------------------------------------------
// CNSmlChangeFinder::ItemMovedL
// -----------------------------------------------------------------------------
//
EXPORT_C void CNSmlChangeFinder::ItemMovedL( const TNSmlSnapshotItem& aItem )
	{
	_DBG_FILE("CNSmlChangeFinder::ItemMovedL(): begin");
	TInt index;
	if ( !iOldSnapshot->FindIsq(aItem, iKey, index) )
		{
		iOldSnapshot->At(index) = aItem;
		}
	else
		{
		iOldSnapshot->InsertIsqL(aItem, iKey);
		iOldSnapshot->Compress();
		}
	_DBG_FILE("CNSmlChangeFinder::ItemMovedL(): end");
	}
	
// -----------------------------------------------------------------------------
// CNSmlChangeFinder::ItemSoftDeletedL
// -----------------------------------------------------------------------------
//
EXPORT_C void CNSmlChangeFinder::ItemSoftDeletedL( const TNSmlSnapshotItem& aItem )
	{
	_DBG_FILE("CNSmlChangeFinder::ItemSoftDeletedL(): begin");
	TInt index;
	if ( !iOldSnapshot->FindIsq(aItem, iKey, index) )
		{
		iOldSnapshot->At(index) = aItem;
		}
	else
		{
		iOldSnapshot->InsertIsqL(aItem, iKey);
		iOldSnapshot->Compress();
		}
	_DBG_FILE("CNSmlChangeFinder::ItemSoftDeletedL(): end");
	}

// -----------------------------------------------------------------------------
// CNSmlChangeFinder::CommitChangesL
// -----------------------------------------------------------------------------
//
EXPORT_C void CNSmlChangeFinder::CommitChangesL()
	{
	_DBG_FILE("CNSmlChangeFinder::CommitChangesL(): begin");
	iOldSnapshot->Reset();
	for ( TInt i = 0; i < iCurrentSnapshot->Count(); i++ )
		{
		iOldSnapshot->InsertIsqL( iCurrentSnapshot->At( i ), iKey );
		}
	_DBG_FILE("CNSmlChangeFinder::CommitChangesL(): end");
	}

// -----------------------------------------------------------------------------
// CNSmlChangeFinder::CommitChangesL
// -----------------------------------------------------------------------------
//
EXPORT_C void CNSmlChangeFinder::CommitChangesL( const MSmlDataItemUidSet& aUids )
	{
	_DBG_FILE("CNSmlChangeFinder::CommitChangesL(): begin");
	
	for ( TInt i = 0; i < aUids.ItemCount(); i++ )
		{
		TSmlDbItemUid itemId = aUids.ItemAt( i );
		TNSmlSnapshotItem temp( itemId );
		TInt indexOld( -1 );
		TInt indexNew( -1 );
		if ( !iOldSnapshot->FindIsq( temp, iKey, indexOld) )
			{
			if ( !iCurrentSnapshot->FindIsq(temp, iKey, indexNew) )
				{
				// Replace, moved or softdeleted
				iOldSnapshot->At(indexOld) = iCurrentSnapshot->At( indexNew );
				}
			else
				{
				// Delete
				iOldSnapshot->Delete(indexOld);
				}
			}
		else
			{
			// Add
			if ( !iCurrentSnapshot->FindIsq(temp, iKey, indexNew) )
			    {
			    iOldSnapshot->InsertIsqL( iCurrentSnapshot->At( indexNew ), iKey );
			    }
			}
		}
	_DBG_FILE("CNSmlChangeFinder::CommitChangesL(): end");
	}

// -----------------------------------------------------------------------------
// CNSmlChangeFinder::SetNewSnapshot
// -----------------------------------------------------------------------------
//
EXPORT_C void CNSmlChangeFinder::SetNewSnapshot( CArrayFixSeg<TNSmlSnapshotItem>* aNewSnapshot )
	{
	_DBG_FILE("CNSmlChangeFinder::SetNewSnapshot(): begin");
#ifdef __NSML_DEBUG__
	_DBG_FILE("CNSmlChangeFinder::SetNewSnapshot(): old snapshot");
	TNSmlSnapshotItem item;
	TInt i;

	for ( i = 0; i < iOldSnapshot->Count(); i++ )
		{
		TBuf8<80> b;
		item = iOldSnapshot->At(i);
		b = _L8("UID = ");
		b.AppendNum( item.ItemId() );
		b.Append(_L8(" LastMod(as Int64) = "));
		b.AppendNum(item.LastChangedDate().Int64());
		_DBG_FILE(b.PtrZ());
		}

	_DBG_FILE("CNSmlChangeFinder::SetNewSnapshot(): new snapshot");
	for ( i = 0; i < aNewSnapshot->Count(); i++ )
		{
		TBuf8<80> b;
		item = aNewSnapshot->At(i);
		b = _L8("UID = ");
		b.AppendNum( item.ItemId() );
		b.Append(_L8(" LastMod(as Int64) = "));
		b.AppendNum(item.LastChangedDate().Int64());
		_DBG_FILE(b.PtrZ());
		}
#endif //__NSML_DEBUG__
	delete iCurrentSnapshot;
	iCurrentSnapshot = aNewSnapshot;
	_DBG_FILE("CNSmlChangeFinder::SetNewSnapshot(): end");
	}
	
// -----------------------------------------------------------------------------
// CNSmlChangeFinder::DataStoreUid
// -----------------------------------------------------------------------------
//
EXPORT_C TInt64 CNSmlChangeFinder::DataStoreUid() const
	{
	_DBG_FILE("CNSmlChangeFinder::DataStoreUid(): begin");
	_DBG_FILE("CNSmlChangeFinder::DataStoreUid(): end");
	return iDataStoreUid;
	}

// -----------------------------------------------------------------------------
// CNSmlChangeFinder::SetDataStoreUid
// -----------------------------------------------------------------------------
//
EXPORT_C void CNSmlChangeFinder::SetDataStoreUid( TInt64 aUid )
	{
	_DBG_FILE("CNSmlChangeFinder::SetDataStoreUid(): begin");
	iDataStoreUid = aUid;
	_DBG_FILE("CNSmlChangeFinder::SetDataStoreUid(): end");
	}


// End of File