/*

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

*

*/

// INCLUDE FILES

#include "CPbk2StoreConfigurationImpl.h"

// Phonebook2

#include "CPbk2StoreConfigurationMonitor.h"

#include "CPbk2DefaultSavingStoreMonitor.h"

#include <Phonebook2InternalCRKeys.h>

// Virtual Phonebook

#include <TVPbkContactStoreUriPtr.h>

#include <CVPbkContactStoreUriArray.h>

// System includes

#include <centralrepository.h>

// Debugging headers

#include <Pbk2Debug.h>

// Unnamed namespace for local definitions

namespace {

// Definition for contact initial contact store uri size

const TInt KInitialStoreUriSize = 1;

} // namespace

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

// CPbk2StoreConfigurationImpl::CPbk2StoreConfigurationImpl

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

//

CPbk2StoreConfigurationImpl::CPbk2StoreConfigurationImpl()

    {

    }

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

// CPbk2StoreConfigurationImpl::~CPbk2StoreConfigurationImpl

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

//

CPbk2StoreConfigurationImpl::~CPbk2StoreConfigurationImpl()

    {

    PBK2_DEBUG_PRINT(PBK2_DEBUG_STRING

        ("CPbk2StoreConfigurationImpl::~CPbk2StoreConfigurationImpl(0x%x)"), this);

    iObservers.Reset();

    iDefaultStoreObservers.Reset();

    delete iDefaultSavingStoreMonitor;

    delete iConfigurationMonitor;

    delete iRepository;

    }

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

// CPbk2StoreConfigurationImpl::NewL

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

//

CPbk2StoreConfigurationImpl* CPbk2StoreConfigurationImpl::NewL()

    {

    CPbk2StoreConfigurationImpl* self = new(ELeave) CPbk2StoreConfigurationImpl;

    CleanupStack::PushL(self);

    self->ConstructL();

    CleanupStack::Pop(self);

    return self;

    }

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

// CPbk2StoreConfigurationImpl::ConstructL

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

//

void CPbk2StoreConfigurationImpl::ConstructL()

    {

    PBK2_DEBUG_PRINT(PBK2_DEBUG_STRING

        ("CPbk2StoreConfigurationImpl::ConstructL(0x%x)"), this);

    iRepository = CRepository::NewL

        (TUid::Uid(KCRUidPhonebookStoreConfiguration));

    PBK2_DEBUG_PRINT(PBK2_DEBUG_STRING

        ("CPbk2StoreConfigurationImpl::ConstructL(0x%x) Repository created"), this);

    iConfigurationMonitor = CPbk2StoreConfigurationMonitor::NewL

        ( *iRepository, *this );

    iDefaultSavingStoreMonitor = CPbk2DefaultSavingStoreMonitor::NewL

        ( *iRepository, *this );

    PBK2_DEBUG_PRINT(PBK2_DEBUG_STRING

        ("CPbk2StoreConfigurationImpl::ConstructL(0x%x) end"), this);

    }

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

// CPbk2StoreConfigurationImpl::CurrentConfigurationL

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

//

CVPbkContactStoreUriArray*

        CPbk2StoreConfigurationImpl::CurrentConfigurationL() const

    {

    PBK2_DEBUG_PRINT(PBK2_DEBUG_STRING

        ("CPbk2StoreConfigurationImpl::CurrentConfigurationL(0x%x)"), this);

    CVPbkContactStoreUriArray* result = CVPbkContactStoreUriArray::NewLC();

    RArray<TUint32> configurationKeys;

    CleanupClosePushL(configurationKeys);

    iRepository->FindL(KPhonebookCurrentConfigurationPartialKey,

            KPhonebookCurrentConfigurationMask,

            configurationKeys);

    HBufC* buffer = HBufC::NewLC(KInitialStoreUriSize);

    const TInt keyCount = configurationKeys.Count();

    for (TInt i = 0; i < keyCount; ++i)

        {

        TPtr ptr = buffer->Des();

        ptr.Zero();

        TInt actualSize = 0;

        TInt ret = iRepository->Get(configurationKeys[i], ptr, actualSize);

        if (ret == KErrOverflow)

            {

            CleanupStack::PopAndDestroy(); // buffer

            buffer = HBufC::NewLC(actualSize);

            ptr.Set(buffer->Des());

            User::LeaveIfError(iRepository->Get(configurationKeys[i], ptr));

            }

        else

            {

            User::LeaveIfError(ret);

            }

        if( !result->IsIncluded( TVPbkContactStoreUriPtr( ptr ) ) )  // Only append if the uri is not yet included

            {

            result->AppendL( ptr );

            }

        }

    CleanupStack::PopAndDestroy(); // buffer

    CleanupStack::PopAndDestroy(); // configurationKeys

    CleanupStack::Pop(result); // result

    PBK2_DEBUG_PRINT(PBK2_DEBUG_STRING

        ("CPbk2StoreConfigurationImpl::CurrentConfigurationL(0x%x) end"), this);

    return result;

    }

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

// CPbk2StoreConfigurationImpl::SearchStoreConfigurationL

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

//

CVPbkContactStoreUriArray*

        CPbk2StoreConfigurationImpl::SearchStoreConfigurationL()

    {

    CVPbkContactStoreUriArray* result = CVPbkContactStoreUriArray::NewLC();

    // The default saving store shall be appended to the result array

    // as an first element, when it becomes available

    // Finally append the current Phonebook configuration for searching

    CVPbkContactStoreUriArray* currentConfiguration = CurrentConfigurationL();

    CleanupStack::PushL(currentConfiguration);

    result->AppendAllL(*currentConfiguration);

    CleanupStack::PopAndDestroy(currentConfiguration);

    CleanupStack::Pop(result);

    return result;

    }

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

// CPbk2StoreConfigurationImpl::SupportedStoreConfigurationL

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

//

CVPbkContactStoreUriArray*

        CPbk2StoreConfigurationImpl::SupportedStoreConfigurationL() const

    {

    PBK2_DEBUG_PRINT(PBK2_DEBUG_STRING

        ("CPbk2StoreConfigurationImpl::SupportedStoreConfigurationL(0x%x)"), this);

    CVPbkContactStoreUriArray* result = CVPbkContactStoreUriArray::NewLC();

    RArray<TUint32> configurationKeys;

    CleanupClosePushL( configurationKeys );

    User::LeaveIfError( iRepository->FindL(

                            KPhonebookSupportedConfigurationPartialKey,

                            KPhonebookSupportedConfigurationMask,

                            configurationKeys ) );

    HBufC* buffer = HBufC::NewLC(KInitialStoreUriSize);

    const TInt keyCount = configurationKeys.Count();

    for (TInt i = 0; i < keyCount; ++i)

        {

        TPtr ptr = buffer->Des();

        ptr.Zero();

        TInt actualSize = 0;

        TInt ret = iRepository->Get(configurationKeys[i], ptr, actualSize);

        if (ret == KErrOverflow)

            {

            CleanupStack::PopAndDestroy(); // buffer

            buffer = HBufC::NewLC(actualSize);

            ptr.Set(buffer->Des());

            User::LeaveIfError(iRepository->Get(configurationKeys[i], ptr));

            }

        else

            {

            User::LeaveIfError(ret);

            }

        result->AppendL(ptr);

        }

    CleanupStack::PopAndDestroy(); // buffer

    CleanupStack::PopAndDestroy(); // configurationKeys

    CleanupStack::Pop(result); // result

    PBK2_DEBUG_PRINT(PBK2_DEBUG_STRING

        ("CPbk2StoreConfigurationImpl::SupportedStoreConfigurationL(0x%x) end"), this);

    return result;

    }

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

// CPbk2StoreConfigurationImpl::DefaultSavingStoreL

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

//

TVPbkContactStoreUriPtr

        CPbk2StoreConfigurationImpl::DefaultSavingStoreL() const

    {

    return iDefaultSavingStoreMonitor->DefaultSavingStoreL();

    }

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

// CPbk2StoreConfigurationImpl::AddContactStoreURIL

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

//

void CPbk2StoreConfigurationImpl::AddContactStoreURIL

        (TVPbkContactStoreUriPtr aURI)

    {

    PBK2_DEBUG_PRINT(PBK2_DEBUG_STRING

        ("CPbk2StoreConfigurationImpl::AddContactStoreURIL(0x%x)"), this);

    RArray<TUint32> configurationKeys;

    CleanupClosePushL(configurationKeys);

    iRepository->FindL(

            KPhonebookCurrentConfigurationPartialKey,

            KPhonebookCurrentConfigurationMask,

            configurationKeys);

    if ( AlreadyRegisteredL( aURI, configurationKeys ) )

        {

        User::Leave( KErrAlreadyExists );

        }

    // Find the first free key starting from

    // KPhonebookCurrentConfigurationFirstKey

    TBool keyFound = EFalse;

    TUint32 newKey = KPhonebookCurrentConfigurationFirstKey;

    for (TInt i = KPhonebookCurrentConfigurationFirstKey;

        i < KPhonebookCurrentConfigurationLastKey && !keyFound; ++i)

        {

        if (configurationKeys.Find(i) == KErrNotFound)

            {

            newKey = i;

            keyFound = ETrue;

            }

        }

    if (!keyFound)

        {

        User::Leave(KErrOverflow);

        }

    TInt err = iRepository->Create(newKey, aURI.UriDes());

    User::LeaveIfError(err);

    CleanupStack::PopAndDestroy(); // configurationKeys

    PBK2_DEBUG_PRINT(PBK2_DEBUG_STRING

        ("CPbk2StoreConfigurationImpl::AddContactStoreURIL(0x%x) end"), this);

    }

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

// CPbk2StoreConfigurationImpl::RemoveContactStoreURIL

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

//

void CPbk2StoreConfigurationImpl::RemoveContactStoreURIL

        (TVPbkContactStoreUriPtr aURI)

    {

    PBK2_DEBUG_PRINT(PBK2_DEBUG_STRING

        ("CPbk2StoreConfigurationImpl::RemoveContactStoreURIL(0x%x)"), this);

    RArray<TUint32> configurationKeys;

    CleanupClosePushL(configurationKeys);

    iRepository->FindEqL(

            KPhonebookCurrentConfigurationPartialKey,

            KPhonebookCurrentConfigurationMask,

            aURI.UriDes(),

            configurationKeys);

    const TInt keyCount = configurationKeys.Count();

    for (TInt i = 0; i < keyCount; ++i)

        {

        iRepository->Delete(configurationKeys[i]);

        }

    CleanupStack::PopAndDestroy(); // configurationKeys

    PBK2_DEBUG_PRINT(PBK2_DEBUG_STRING

        ("CPbk2StoreConfigurationImpl::RemoveContactStoreURIL(0x%x) end"), this);

    }

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

// CPbk2StoreConfigurationImpl::AddObserverL

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

//

void CPbk2StoreConfigurationImpl::AddObserverL

        (MPbk2StoreConfigurationObserver& aObserver)

    {

     iObservers.Append( &aObserver );

    }

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

// CPbk2StoreConfigurationImpl::RemoveObserver

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

//

void CPbk2StoreConfigurationImpl::RemoveObserver

        (MPbk2StoreConfigurationObserver& aObserver)

    {

    TInt index = iObservers.Find(&aObserver);

    if (index != KErrNotFound)

        {

        iObservers.Remove(index);

        }

    }

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

// CPbk2StoreConfigurationImpl::AddDefaultSavingStoreObserverL

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

//

void CPbk2StoreConfigurationImpl::AddDefaultSavingStoreObserverL

        ( MPbk2DefaultSavingStoreObserver& aObserver )

    {

    TInt index = iDefaultStoreObservers.Find(&aObserver);

    if (index == KErrNotFound)

        {

        // Insert to the beginning so that the observers will get the

        // events in the order they have registere

        // This has to be done because events are sent from last to first

        // in the ConfigurationChanged function

        iDefaultStoreObservers.InsertL(&aObserver, 0);

        }

    }

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

// CPbk2StoreConfigurationImpl::RemoveDefaultSavingStoreObserver

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

//

void CPbk2StoreConfigurationImpl::RemoveDefaultSavingStoreObserver

        ( MPbk2DefaultSavingStoreObserver& aObserver )

    {

    TInt index = iDefaultStoreObservers.Find(&aObserver);

    if (index != KErrNotFound)

        {

        iDefaultStoreObservers.Remove(index);

        }

    }

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

// CPbk2StoreConfigurationImpl::AddSupportedContactStoreURIL

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

//

void CPbk2StoreConfigurationImpl::AddSupportedContactStoreURIL

        ( TVPbkContactStoreUriPtr aURI )

    {

    PBK2_DEBUG_PRINT(PBK2_DEBUG_STRING

        ("CPbk2StoreConfigurationImpl::AddSupportedContactStoreURIL(0x%x)"), this);

    RArray<TUint32> configurationKeys;

    CleanupClosePushL(configurationKeys);

    iRepository->FindL(

            KPhonebookSupportedConfigurationPartialKey,

            KPhonebookSupportedConfigurationMask,

            configurationKeys);

    if ( AlreadyRegisteredL( aURI, configurationKeys ) )

        {

        User::Leave( KErrAlreadyExists );

        }

    // Find the first free key starting from

    // KPhonebookSupportedConfigurationFirstKey

    TBool keyFound = EFalse;

    TUint32 newKey = KPhonebookSupportedConfigurationFirstKey;

    for (TInt i = KPhonebookSupportedConfigurationFirstKey;

        i < KPhonebookSupportedConfigurationLastKey && !keyFound; ++i)

        {

        if (configurationKeys.Find(i) == KErrNotFound)

            {

            newKey = i;

            keyFound = ETrue;

            }

        }

    if (!keyFound)

        {

        User::Leave(KErrOverflow);

        }

    TInt err = iRepository->Create(newKey, aURI.UriDes());

    User::LeaveIfError(err);

    CleanupStack::PopAndDestroy(); // configurationKeys

    PBK2_DEBUG_PRINT(PBK2_DEBUG_STRING

        ("CPbk2StoreConfigurationImpl::AddSupportedContactStoreURIL(0x%x) end"), this);

    }

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

// CPbk2StoreConfigurationImpl::RemoveSupportedContactStoreURIL

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

//

void CPbk2StoreConfigurationImpl::RemoveSupportedContactStoreURIL

        ( TVPbkContactStoreUriPtr aURI )

    {

    PBK2_DEBUG_PRINT(PBK2_DEBUG_STRING

        ("CPbk2StoreConfigurationImpl::RemoveSupportedContactStoreURIL(0x%x)"), this);

    RArray<TUint32> configurationKeys;

    CleanupClosePushL(configurationKeys);

    iRepository->FindEqL(

            KPhonebookSupportedConfigurationPartialKey,

            KPhonebookSupportedConfigurationMask,

            aURI.UriDes(),

            configurationKeys);

    const TInt keyCount = configurationKeys.Count();

    for (TInt i = 0; i < keyCount; ++i)

        {

        iRepository->Delete(configurationKeys[i]);

        }

    CleanupStack::PopAndDestroy(); // configurationKeys

    PBK2_DEBUG_PRINT(PBK2_DEBUG_STRING

        ("CPbk2StoreConfigurationImpl::RemoveSupportedContactStoreURIL(0x%x) end"), this);

    }

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

// CPbk2StoreConfigurationImpl::ConfigurationChanged

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

//

void CPbk2StoreConfigurationImpl::ConfigurationChanged()

    {

    for (TInt i = iObservers.Count() - 1; i >= 0; --i)

        {

        iObservers[i]->ConfigurationChanged();

        }

    for (TInt i = iObservers.Count() - 1; i >= 0; --i)

        {

        iObservers[i]->ConfigurationChangedComplete();

        }

    }

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

// CPbk2StoreConfigurationImpl::ConfigurationChangedComplete

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

//

void CPbk2StoreConfigurationImpl::ConfigurationChangedComplete()

    {

    }

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

// CPbk2StoreConfigurationImpl::SavingStoreChanged

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

//

void CPbk2StoreConfigurationImpl::SavingStoreChanged()

    {

    for (TInt i = iDefaultStoreObservers.Count() - 1; i >= 0; --i)

        {

        iDefaultStoreObservers[i]->SavingStoreChanged();

        }

    }

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

// CPbk2StoreConfigurationImpl::AlreadyRegisteredL

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

//

TBool CPbk2StoreConfigurationImpl::AlreadyRegisteredL

        ( TVPbkContactStoreUriPtr aURI, RArray<TUint32> aKeys )

    {

    TBool already = EFalse;

    HBufC* buffer = HBufC::NewLC(KInitialStoreUriSize);

    const TInt keyCount = aKeys.Count();

    for (TInt j = 0; j < keyCount; ++j)

        {

        TPtr ptr = buffer->Des();

        ptr.Zero();

        TInt actualSize = 0;

        TInt ret = iRepository->Get(aKeys[j], ptr, actualSize);

        if (ret == KErrOverflow)

            {

            CleanupStack::PopAndDestroy(); // buffer

            buffer = HBufC::NewLC(actualSize);

            ptr.Set(buffer->Des());

            User::LeaveIfError(iRepository->Get(aKeys[j], ptr));

            }

        TVPbkContactStoreUriPtr uri( *buffer );

        if ( uri.Compare( aURI,

            TVPbkContactStoreUriPtr::EContactStoreUriAllComponents ) == 0 )