/*

* Copyright (c) 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 <centralrepository.h>

#include "datadepository.h"

CDataDepository::CDataDepository( CRepository* aRepository )

    {

    iRepository = aRepository;

    }

CDataDepository::~CDataDepository( )

    {

    }

CDataDepository* CDataDepository::NewL( CRepository* aRepository )

    {

    CDataDepository* self = CDataDepository::NewLC( aRepository );

    CleanupStack::Pop(self);

    return self;

    }

CDataDepository* CDataDepository::NewLC( CRepository* aRepository )

    {

    CDataDepository* self = new( ELeave ) CDataDepository( aRepository );

    CleanupStack::PushL( self );

    //self->ConstructL( );

    return self;

    }

TUint32 CDataDepository::CreateNewTableKeyL( TUint aTableMask, TUint32 aFieldMask ) const

    {

    TUint32 newKey = 0;

    RArray< TUint32 > keys;

    CleanupClosePushL( keys );

    TInt err = iRepository->FindL( aTableMask,

                                   aFieldMask,

                                   keys );

    TInt keyCount = keys.Count( );

    if ( err == KErrNotFound )

        {

        newKey = aFieldMask + 1;

        }

    else

        {

        User::LeaveIfError( err );

        if ( keyCount == 0 )

            {

            newKey = aFieldMask + 1;

            }

        else

            {

            // Find the biggest key and increment it by one

            keys.SortUnsigned( );

            TUint32 maxKey = aTableMask ^ keys[ keys.Count() - 1 ];  

            newKey = aFieldMask + 1 + maxKey;

            }

        }

    newKey |= aFieldMask; 

    newKey ^= aFieldMask;

    CleanupStack::PopAndDestroy( &keys );

    return newKey;

    }

TUint32 CDataDepository::CreateNewServerKeyL( TUint aTableMask, TUint32 aFieldMask ) const

    {

    const TUint32 KSubKeyMask = 0xff0fffff;

    TUint32 newKey = 0;

    RArray< TUint32 > keys;

    CleanupClosePushL( keys );

    TInt err = iRepository->FindL( aTableMask,

                                   aFieldMask,

                                   keys );

    TInt keyCount = keys.Count( );

    if ( err == KErrNotFound )

        {

        newKey = aFieldMask + 1;

        }

    else

        {

        User::LeaveIfError( err );

        if ( keyCount == 0 )

            {

            newKey = aFieldMask + 1;

            }

        else

            {

            //remove setting keys related to same server

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

                {

                keys[i] &= KSubKeyMask;

                }

            for ( TInt j( 0 ); j < keys.Count() - 1; j++ )

                {

                for ( TInt i( j + 1 ); i < keys.Count(); )

                    {

                    if ( keys[ j ] == keys[ i ] )

                        {

                        keys.Remove( i );

                        }

                    else

                        {

                        i++;

                        }

                    }

                }

            // Find the biggest key and increment it by one

            keys.SortUnsigned( );

            TUint32 maxKey = aTableMask ^ keys[ keys.Count() - 1 ];  

            newKey = aFieldMask + 1 + maxKey;

            }

        }

    newKey |= aFieldMask; 

    newKey ^= aFieldMask;

    CleanupStack::PopAndDestroy( &keys );

    return newKey;

    }

void CDataDepository::StoreL( const TUint32 aKey, const TInt aData )

    {

    User::LeaveIfError(

        iRepository->StartTransaction(

            CRepository::EConcurrentReadWriteTransaction ) );

    iRepository->CleanupCancelTransactionPushL( );

    TInt tmp = 0;

    if ( iRepository->Get( aKey,tmp ) == KErrNone )

        {

        // Update existing value

        User::LeaveIfError( iRepository->Set( aKey, aData ) );

        }

    else

        {

        // Create new value

        User::LeaveIfError( iRepository->Create( aKey, aData ) );

        } 

    TUint32 dummy;

    User::LeaveIfError( iRepository->CommitTransaction( dummy ) );

    CleanupStack::Pop( ); // transaction

    }   

void CDataDepository::StoreL( const TUint32 aKey, const TDesC8& aData )

    {

    User::LeaveIfError(

            iRepository->StartTransaction(

                CRepository::EConcurrentReadWriteTransaction ) );

    iRepository->CleanupCancelTransactionPushL( );

    TBuf8< 1 > tmp;

    TInt err = iRepository->Get( aKey,tmp );

    if ( err == KErrNone || err == KErrOverflow )

        {

        // Update existing value

        User::LeaveIfError( iRepository->Set( aKey, aData ) );

        }

    else

        {

        // Create new value

        User::LeaveIfError( iRepository->Create( aKey, aData ) );

        }

    TUint32 dummy;

    User::LeaveIfError( iRepository->CommitTransaction( dummy ) );

    CleanupStack::Pop( ); // transaction

    }

TInt CDataDepository::Read( const TUint32 aKey, TInt& aData )

    {

    TInt err = KErrNotFound;

    if ( iRepository->Get( aKey, aData ) == KErrNone )

        {

        err = KErrNone;

        }

    return err;

    }

TInt CDataDepository::ReadL( const TUint32 aKey, HBufC8** aData )

    {

    TInt err = KErrNotFound;

    TBuf8< 1 > tmp;

    TInt actualLength = 0;

    TInt status = iRepository->Get( aKey,tmp,actualLength );

    if ( ( status == KErrNone || status == KErrOverflow) && ( actualLength > 0 ) )

        {

        err = KErrNone;

        HBufC8* buf = HBufC8::NewL( actualLength );

        CleanupStack::PushL( buf );

        TPtr8 ptr( buf->Des( ) );

        User::LeaveIfError( iRepository->Get( aKey,ptr ) );

        *aData = buf; 

        CleanupStack::Pop( buf );

        }

    else

        {

        *aData = KNullDesC8( ).AllocL( );

        }

    return err;    

    }       

TInt CDataDepository::EraseL( TUint32 aTableMask, TUint32 aFieldTypeMask )

    {

    //find KDomain names

    RArray< TUint32 > keys;

    CleanupClosePushL( keys );

    TInt err = iRepository->FindL( aTableMask,

                                   aFieldTypeMask,

                                   keys );

    if( err == KErrNone ) 

        {

        TInt count = keys.Count( );

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

            {

            //delete setting

            TUint32 key = keys[ i ];

            iRepository->Delete( keys[ i ] );	

            }

        }

    CleanupStack::PopAndDestroy( &keys );

    return err;

    }