/*

* Copyright (c) 2002-2008 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:  This class implements the Accessory Policy DB interface.

*

*/

// INCLUDE FILES

#include "AccPolicyDB.h"

#include "AccPolicyDBNames.h"

#include "AccPolCapabilityStorage.h"

#include "acc_debug.h"

#include <AccPolSubblockNameArray.h>

#include <AccPolCommonNameValuePairs.h>

#include <AccPolGIDHeader.h>

// EXTERNAL DATA STRUCTURES

// EXTERNAL FUNCTION PROTOTYPES

// CONSTANTS

_LIT( KSQLSelect, "SELECT " );

_LIT( KSQLFrom, " FROM " );

_LIT( KSQLAsterisk, " * " );

_LIT( KSQLWhere, " WHERE " );

_LIT( KSQLEquals, " = ");

_LIT( KSQLAnd, " AND ");

// MACROS

// LOCAL CONSTANTS AND MACROS

// MODULE DATA STRUCTURES

// LOCAL FUNCTION PROTOTYPES

// FORWARD DECLARATIONS

// ============================= LOCAL FUNCTIONS ===============================

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

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

// CAccPolicyDB::CAccPolicyDB

// C++ default constructor can NOT contain any code, that

// might leave.

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

//

CAccPolicyDB::CAccPolicyDB()

    {

    }

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

// CAccPolicyDB::ConstructL

// Symbian 2nd phase constructor can leave.

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

//

void CAccPolicyDB::ConstructL()

    {

    COM_TRACE_( "[ACCPOLICYDB] CAccPolicyDB::ConstructL()" );

    User::LeaveIfError( iFsSession.Connect() );

    COM_TRACE_( "[ACCPOLICYDB] CAccPolicyDB::ConstructL() return void" );

    }

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

// CAccPolicyDB::NewL

// Two-phased constructor.

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

//

EXPORT_C CAccPolicyDB* CAccPolicyDB::NewL()

    {

    API_TRACE_( "[ACCPOLICYDB] CAccPolicyDB::NewL()" );

    CAccPolicyDB* self = new( ELeave ) CAccPolicyDB;

    CleanupStack::PushL( self );

    self->ConstructL();

    CleanupStack::Pop( self );

    API_TRACE_( "[ACCPOLICYDB] CAccPolicyDB::NewL() return" );

    return self;

    }

// Destructor

EXPORT_C CAccPolicyDB::~CAccPolicyDB()

    {

    API_TRACE_( "[ACCPOLICYDB] CAccPolicyDB::~CAccPolicyDB()" );

    iView.Close();

    CloseDB();

    iFsSession.Close();

    API_TRACE_( "[ACCPOLICYDB] CAccPolicyDB::~CAccPolicyDB() return void" );

    }

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

// CAccPolicyDB::OpenDBL

// Opens the database

// (other items were commented in a header).

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

//

EXPORT_C void CAccPolicyDB::OpenDBL()

    {

    API_TRACE_( "[ACCPOLICYDB] CAccPolicyDB::OpenDBL()" );

    TInt       err( KErrNone );

    TFileName  romFullPath;

    TDriveName zDrive = TDriveUnit( EDriveZ ).Name();

    romFullPath.Append( zDrive );

    romFullPath.Append( KDBPath );

    err = iDb.Open(iFsSession, romFullPath, KAccDbSecureFormat(), RDbNamedDatabase::EReadOnly );

    COM_TRACE_1( "[ACCPOLICYDB] CAccPolicyDB::OpenDBL - Open DB: %d", err);

    User::LeaveIfError( err );

    API_TRACE_( "[ACCPOLICYDB] CAccPolicyDB::OpenDBL - return void" );    

    }

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

// CAccPolicyDB::CloseDB

// Closes the database connection

// (other items were commented in a header).

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

//

EXPORT_C void CAccPolicyDB::CloseDB()

    {

    API_TRACE_( "[ACCPOLICYDB] CAccPolicyDB::CloseDB()" );

    iDb.Close();

    API_TRACE_( "[ACCPOLICYDB] CAccPolicyDB::CloseDB() return void" );

    }

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

// CAccPolicyDB::FindGIDIntL

// Search if DeviceID has a GIDInteger defined in DB

// (other items were commented in a header).

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

//

EXPORT_C void CAccPolicyDB::FindGIDIntL(

    const TUint64& aDeviceID,

    TDes8& aGIDInt )

    {

    API_TRACE_( "[ACCPOLICYDB] CAccPolicyDB::FindGIDIntL()" );

    TInt res( 0 );

    iSQL = KSQLSelect;

    iSQL.Append( KACCDBGIDIntGIDCol );

    iSQL.Append( KSQLFrom );

    iSQL.Append( KACCDBGIDIntTable );

    iSQL.Append( KSQLWhere );

    iSQL.Append( KACCDBGIDIntDeviceIDCol );

    iSQL.Append( KSQLEquals );

    iSQL.AppendNum( aDeviceID );

    iView.Close();

    iView.Prepare( iDb, TDbQuery( iSQL ) );

    if ( iView.Unevaluated() )

        {

        iView.EvaluateAll();

        }

#ifdef _DEBUG

    TRAPD( firstLErr, res = iView.FirstL() )

    COM_TRACE_1( "[ACCPOLICYDB] CAccPolicyDB::FindGIDIntL firstLErr: %d", firstLErr );

    User::LeaveIfError( firstLErr );

#else

    res = iView.FirstL();

#endif // _DEBUG

    if ( res ) // Check if found a hit

        {

        COM_TRACE_( "[ACCPOLICYDB] CAccPolicyDB::FindGIDIntL() A GIDInt for this Device ID was found" );

        RDbColReadStream in;

        CDbColSet* colSet = iView.ColSetL();

        CleanupStack::PushL( colSet );

        TDbColNo col = colSet->ColNo( KACCDBGIDIntGIDCol );

        iView.GetL();

        in.OpenL( iView, col );

        in.PushL();

        in.ReadL( aGIDInt, iView.ColLength( col ) );

        in.Pop();

        in.Close();

        CleanupStack::PopAndDestroy( colSet );

        }

    iView.Reset();

    iView.Close();

    API_TRACE_( "[ACCPOLICYDB] CAccPolicyDB::FindGIDIntL() return void" );

    }

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

// CAccPolicyDB::FindGIDIntL

// Search if DeviceID has a GIDInteger defined in DB

// (other items were commented in a header).

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

//

EXPORT_C void CAccPolicyDB::FindGIDIntL(

    const TUint64& aDeviceID,

    TDes8& aGIDInt,

    TAccGIDtype aType )

    {

    API_TRACE_( "[ACCPOLICYDB] CAccPolicyDB::FindGIDIntL()" );

    TInt res( 0 );

    iSQL = KSQLSelect;

    iSQL.Append( KACCDBGIDIntGIDCol );

    iSQL.Append( KSQLFrom );

    iSQL.Append( KACCDBGIDIntTable );

    iSQL.Append( KSQLWhere );

    iSQL.Append( KACCDBGIDIntDeviceIDCol );

    iSQL.Append( KSQLEquals );

    iSQL.AppendNum( aDeviceID );

    iSQL.Append( KSQLAnd );

    iSQL.Append( KACCDBGIDIntKeyIDCol );

    iSQL.Append( KSQLEquals );

    iSQL.AppendNum( aType );

    iView.Close();

    iView.Prepare( iDb, TDbQuery( iSQL ) );

    if ( iView.Unevaluated() )

        {

        iView.EvaluateAll();

        }

#ifdef _DEBUG

    TRAPD( firstLErr, res = iView.FirstL() )

    COM_TRACE_1( "[ACCPOLICYDB] CAccPolicyDB::FindGIDIntL firstLErr: %d", firstLErr );

    User::LeaveIfError( firstLErr );

#else

    res = iView.FirstL();

#endif // _DEBUG

    if ( res ) // Check if found a hit

        {

        COM_TRACE_( "[ACCPOLICYDB] CAccPolicyDB::FindGIDIntL() A GIDInt for this Device ID was found" );

        RDbColReadStream in;

        CDbColSet* colSet = iView.ColSetL();

        CleanupStack::PushL( colSet );

        TDbColNo col = colSet->ColNo( KACCDBGIDIntGIDCol );

        iView.GetL();

        in.OpenL( iView, col );

        in.PushL();

        in.ReadL( aGIDInt, iView.ColLength( col ) );

        in.Pop();

        in.Close();

        CleanupStack::PopAndDestroy( colSet );

        }

    iView.Reset();

    iView.Close();

    API_TRACE_( "[ACCPOLICYDB] CAccPolicyDB::FindGIDIntL() return void" );

    }    

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

// CAccPolicyDB::ReadAllCriticalCapabilitiesL

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

//

EXPORT_C TInt CAccPolicyDB::ReadAllCriticalCapabilitiesL()

    {

    API_TRACE_( "[ACCPOLICYDB] CAccPolicyDB::ReadAllCriticalCapabilitiesL()" );

    iSQL = KSQLSelect;

    iSQL.Append( KSQLAsterisk );

    iSQL.Append( KSQLFrom );

    iSQL.Append( KACCDBCapRulesTable );

    iView.Close();

    iView.Prepare( iDb, TDbQuery( iSQL ) );

    if ( iView.Unevaluated() )

        {

        iView.EvaluateAll();

        }

	API_TRACE_1( "[ACCPOLICYDB] CAccPolicyDB::ReadAllCriticalCapabilitiesL - return %d ", iView.CountL() );        

	return iView.CountL();

    }

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

// CAccPolicyDB::GetNextCriticalCapabilityL

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

//

EXPORT_C void CAccPolicyDB::GetNextCriticalCapabilityL( 

    TUint32& aName, 

    TInt32& aValue )

    {    

    API_TRACE_( "[ACCPOLICYDB] CAccPolicyDB::GetNextCriticalCapabilityL()" );

    TBuf8<KSBMaxValueLength> bufValue;

    if ( iView.NextL() ) // Check if found a hit

        {  

        RDbColReadStream in;

        CDbColSet* colSet = iView.ColSetL();

        CleanupStack::PushL( colSet );

        TDbColNo col = colSet->ColNo( KACCDBCapRulesName );

        iView.GetL();

        in.OpenL( iView, col );

        in.PushL();

        aName = in.ReadUint32L();

        in.Pop();

        in.Close();

        col = colSet->ColNo( KACCDBCapRulesValue );       

        iView.GetL();

        in.OpenL( iView, col );

        in.PushL();        

        in.ReadL( bufValue, iView.ColLength( col ) );        

        TLex8 lex( bufValue);

        User::LeaveIfError( lex.Val( aValue ) );        

        in.Pop();

        in.Close();

        CleanupStack::PopAndDestroy( colSet );        

        }

     else

     	{

    	iView.Reset();

    	iView.Close(); 	

     	}

    API_TRACE_2( "[ACCPOLICYDB] CAccPolicyDB::GetNextCriticalCapabilityL - name=0x%x value=%d - return void", aName, aValue );

    }

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

// CAccPolicyDB::

// 

// (other items were commented in a header).

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

//

EXPORT_C TInt CAccPolicyDB::FilterGIDByTypeL(

    TAccGIDtype aType)

    {

	API_TRACE_( "[ACCPOLICYDB] CAccPolicyDB::FilterGIDByType()" );

    iSQL = KSQLSelect;

    iSQL.Append( KSQLAsterisk );

    iSQL.Append( KSQLFrom );

    iSQL.Append( KACCDBGIDIntTable );

    iSQL.Append( KSQLWhere );

    iSQL.Append( KACCDBGIDIntKeyIDCol );

    iSQL.Append( KSQLEquals );

    iSQL.AppendNum( aType );

    iView.Close();

    iView.Prepare( iDb, TDbQuery( iSQL ) );

    if ( iView.Unevaluated() )

        {

        iView.EvaluateAll();

        }

	API_TRACE_( "[ACCPOLICYDB] CAccPolicyDB::FilterGIDByType() return " );        

	return iView.CountL();

    }

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

// CAccPolicyDB::

// 

// (other items were commented in a header).

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

//

EXPORT_C void CAccPolicyDB::GetNextGIDL(

    TUint64& aHWDeviceID,

    TDes8& aGIDInt )

    {

	API_TRACE_( "[ACCPOLICYDB] CAccPolicyDB::GetNextGID()" );

    if ( iView.NextL() ) // Check if found a hit

        {      

        RDbColReadStream in;

        CDbColSet* colSet = iView.ColSetL();

        CleanupStack::PushL( colSet );

        TDbColNo col = colSet->ColNo( KACCDBGIDIntDeviceIDCol );

        iView.GetL();

        in.OpenL( iView, col );

        in.PushL();

        aHWDeviceID = in.ReadInt32L();

        in.Pop();

        in.Close();

        col = colSet->ColNo( KACCDBGIDIntGIDCol );       

        iView.GetL();

        in.OpenL( iView, col );

        in.PushL();

        in.ReadL( aGIDInt, iView.ColLength( col ) );

        in.Pop();

        in.Close();

        CleanupStack::PopAndDestroy( colSet );        

        }

     else

     	{

    	iView.Reset();

    	iView.Close(); 	

     	}

    API_TRACE_( "[ACCPOLICYDB] CAccPolicyDB::GetNextGID() return void" );

    }

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

// CAccPolicyDB::

// 

// (other items were commented in a header).

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

//

EXPORT_C void CAccPolicyDB::GetSelectionsL(

    TUint32 ruleIndex,

    TUint32& aSelectionListBitMask,

    TBool aGetAllDeviceTypes )

    {

    API_TRACE_2( "[ACCPOLICYDB] CAccPolicyDB::GetSelectionsL(rule index=%d GetAll=%d)", ruleIndex, aGetAllDeviceTypes );

    iSQL = KSQLSelect;

    if( !aGetAllDeviceTypes )

        {        

        iSQL.Append( KSQLAsterisk );

        iSQL.Append( KSQLFrom );

        iSQL.Append( KACCDBSelectionTable );

        iSQL.Append( KSQLWhere );

        iSQL.Append( KACCDBSelectionIndex );

        iSQL.Append( KSQLEquals );

        iSQL.AppendNum( ruleIndex );

        }

    else

        {        

        iSQL.Append( KSQLAsterisk );

        iSQL.Append( KSQLFrom );

        iSQL.Append( KACCDBSelectionTable );

        }

    iView.Close();

    iView.Prepare( iDb, TDbQuery( iSQL ) );

    if ( iView.Unevaluated() )

        {

        iView.EvaluateAll();

        }

	if ( iView.FirstL() ) // Check if found a hit

        {

        RDbColReadStream in;

        CDbColSet* colSet = iView.ColSetL();

        CleanupStack::PushL( colSet );

        TDbColNo col = colSet->ColNo( KACCDBCapSelectionValue ); // Ordinal position of value column

        while( !iView.AtEnd() )

            {

			TUint32 value;

            iView.GetL();

            in.OpenL( iView, col );

            in.PushL();

            value = in.ReadUint32L();

            in.Pop();

            in.Close();

            iView.NextL();

			User::LeaveIfError( value );

            aSelectionListBitMask = aSelectionListBitMask | value;

            }

        CleanupStack::PopAndDestroy( colSet );

        COM_TRACE_1( "[ACCPOLICYDB] CAccPolicyDB::GetSelectionsL() - selection list = 0b%b", aSelectionListBitMask );

        }

    else

        {

        COM_TRACE_( "[ACCPOLICYDB] CAccPolicyDB::GetSelectionsL() - No values(s) specified for this rule" );

        }

    iView.Reset();

    iView.Close();

    API_TRACE_( "[ACCPOLICYDB] CAccPolicyDB::GetSelectionsL() - return" );    

    }

//  End of File