/*

* Copyright (c) 2002 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: 

*        Methods for DB recovery.

*

*/

// INCLUDE FILES

#include "CPbkDbRecovery.h"

#include "MPbkRecoveryErrorHandler.h"

#include <PbkDebug.h>

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

inline CPbkDbRecovery::CPbkDbRecovery(CContactDatabase& aDb) :

    iDb(aDb)

    {

    }

inline void CPbkDbRecovery::ConstructL()

    {

    iDbChangeNotifier = CContactChangeNotifier::NewL(iDb,this);

    // High priority is used to prevent input events getting through before

    // the recover is started

    iStarter = CIdle::NewL(CActive::EPriorityHigh);

    }

EXPORT_C CPbkDbRecovery* CPbkDbRecovery::NewL(CContactDatabase& aDb)

    {

    CPbkDbRecovery* self = new(ELeave) CPbkDbRecovery(aDb);

    CleanupStack::PushL(self);

    self->ConstructL();

    CleanupStack::Pop(self);

    return self;    

    }

CPbkDbRecovery::~CPbkDbRecovery()

    {

    delete iStarter;

    delete iDbChangeNotifier;

    }

EXPORT_C void CPbkDbRecovery::SetErrorHandler

		(MPbkRecoveryErrorHandler* aErrorHandler)

    {

    iErrorHandler = aErrorHandler;

    }

void CPbkDbRecovery::HandleDatabaseEventL(TContactDbObserverEvent aEvent)

    {

    if (aEvent.iType == EContactDbObserverEventRollback)

        {

        PBK_DEBUG_PRINT(PBK_DEBUG_STRING

			("CPbkDbRecovery::HandleDatabaseEventL(0x%x,EContactDbObserverEventRollback)"),

			this);

        StartRecovery();

        }

    }

void CPbkDbRecovery::StartRecovery()

    {

    if(iStarter->IsActive())

        {

        iStarter->Cancel();

        }

    // Start the recovery using an asynchronous callback so that the Contact

    // DB event handler is able to return before starting the recovery.

    iStarter->Start(TCallBack(CPbkDbRecovery::DoRecoveryL,this));

    }

TBool CPbkDbRecovery::DoRecoveryL()

    {

    PBK_DEBUG_PRINT(PBK_DEBUG_STRING("CPbkDbRecovery::DoRecoveryL(0x%x)"),

		this);

    TBool result = EFalse;

    TRAPD(err, iDb.RecoverL());

    PBK_DEBUG_PRINT(PBK_DEBUG_STRING

		("CPbkDbRecovery::DoRecoveryL(0x%x) recovery result=%d"), this, err);

    if (err != KErrNone)

        {

        if (iErrorHandler)

            {

            // Use error handler to determine if recovery is to be tried again

            result = iErrorHandler->HandleDbRecoveryError(err);

            }

        else

            {

            // No error handler -> just leave with the error code

            User::Leave(err);

            }

        }

    return result;

    }

TInt CPbkDbRecovery::DoRecoveryL(TAny* aSelf)

    {

    return (static_cast<CPbkDbRecovery*>(aSelf)->DoRecoveryL());

    }

// End of File