/*

* 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:  LUID buffering

*

*/

// INCLUDE FILES

#include <nsmldebug.h>

#include "nsmldsluidbuffer.h"

#include "nsmlcliagconstants.h"

#include "nsmldshostclient.h"

#include "nsmldscontent.h"

#include "NsmlDSContentItem.h"

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

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

// CNSmlDSLUIDBuffer::CNSmlDSLUIDBuffer

// C++ constructor.

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

//

CNSmlDSLUIDBuffer::CNSmlDSLUIDBuffer( 

    CNSmlDSHostClient& aHostClient, 

    CNSmlDSContentItem& aContentItem ) : iHostClient( aHostClient ), 

                                         iContentItem( aContentItem ),

                                         iWrittenItems( 0 )

    {

    }

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

// CNSmlDSUIDBuffer::~CNSmlDSUIDBuffer

// Destructor.

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

//

CNSmlDSLUIDBuffer::~CNSmlDSLUIDBuffer()

    {

    iModificationSet.Close();

    }

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

// CNSmlDSLUIDBuffer::NextUIDL

// Gets the first UID and its modification type from the buffer. The aCmdName

// parameter is determined by the modification type.

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

//

TInt CNSmlDSLUIDBuffer::NextUIDL( TSmlDbItemUid& aLocalUID, TDes8& aCmdName )

    {

    TInt ret( KErrNone );

    switch ( iCurrState )

        {

        case EModifications:

            if ( iModificationSet.ItemCount() > 0 )

                {

                aLocalUID = iModificationSet.ItemAt( 0 ).ItemId();

                switch ( iModificationSet.ItemAt( 0 ).ModificationType() )

                    {

                    case TNSmlDbItemModification::ENSmlDbItemAdd:

                        aCmdName = KNSmlAgentAdd;

                        break;

                    case TNSmlDbItemModification::ENSmlDbItemModify:

                        aCmdName = KNSmlAgentReplace;

                        break;

                    case TNSmlDbItemModification::ENSmlDbItemDelete:

                        aCmdName = KNSmlAgentDelete;

                        break;

                    case TNSmlDbItemModification::ENSmlDbItemMove:

                        aCmdName = KNSmlAgentMove;

                        break;

                    case TNSmlDbItemModification::ENSmlDbItemSoftDelete:

                        aCmdName = KNSmlAgentSoftDelete;

                        break;

                    default:

                    	User::Leave( KErrGeneral );

                    }

                }

            else

                {

                iModificationSet.Reset();

                iCurrState = EEnd;

                ret = KErrEof;

                }

            break;

        case EEnd:

            return KErrEof;

        default:

        	User::Leave( KErrGeneral );

        }

    return ret;

    }

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

// CNSmlDSLUIDBuffer::CurrentUID

// Returns the first UID in the buffer. 

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

//

void CNSmlDSLUIDBuffer::CurrentUID( TSmlDbItemUid& aLocalUID ) const

    {

    if ( iModificationSet.ItemCount() > 0 )

        {

        aLocalUID = iModificationSet.ItemAt( 0 ).ItemId();

        }

    }

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

// CNSmlDSLUIDBuffer::ClientItemCount

// Returns the total number of UIDs (both those still in the buffer and those 

// already written).

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

//

TInt CNSmlDSLUIDBuffer::ClientItemCount() const

    {

    return iModificationSet.ItemCount() + iWrittenItems;

    }

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

// CNSmlDSLUIDBuffer::SetCurrentItemWritten

// Removes the current UID from the buffer. 

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

//

void CNSmlDSLUIDBuffer::SetCurrentItemWritten()

    {

    iModificationSet.RemoveItem( 0 );

    ++iWrittenItems;

    }

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

// CNSmlDSLUIDBuffer::FetchModificationsL

// Gets UIDs of all modified items from datastore to the buffer asynchronously.

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

//

void CNSmlDSLUIDBuffer::FetchModificationsL( TInt& aResultCode )

    {

    DBG_FILE(_S8("CNSmlDSLUIDBuffer::FetchModificationsL begins"));

    iModificationSet.Reset();

    iHostClient.AllItemsL( iModificationSet, iContentItem.iImplementationUID, 

                           *iContentItem.iStoreName, aResultCode );

    iCurrState = EModifications;

    DBG_FILE(_S8("CNSmlDSLUIDBuffer::FetchModificationsL ends"));

    }

// End of File