/*

* Copyright (c) 2009 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:  RCSE Settings Import from DBMS

*

*/

#include "rcsedbimporter.h"

#include "rcseconstants.h"

#include "crcseprofileregistry.h"

#include "crcseaudiocodecregistry.h"

#include "rcsedefaultdbnames.h"

#include "rcselogger.h"

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

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

// Default constructor

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

//

CRCSEDbImporter::CRCSEDbImporter()

    {

    }

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

// ConstructL

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

//

void CRCSEDbImporter::ConstructL()

    {

    RCSELOGSTRING( "CRCSEDbImporter::ConstructL() - IN" );

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

    RCSELOGSTRING( "CRCSEDbImporter::ConstructL() - OUT" );

    }

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

// NewL

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

//

CRCSEDbImporter* CRCSEDbImporter::NewL()

    {

    CRCSEDbImporter* self = CRCSEDbImporter::NewLC();

    CleanupStack::Pop( self );

    return self;

    }

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

// NewLC

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

//

CRCSEDbImporter* CRCSEDbImporter::NewLC()

    {

    CRCSEDbImporter* self = new( ELeave ) CRCSEDbImporter;

    CleanupStack::PushL( self );

    self->ConstructL();

    return self;

    }

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

// Destructor

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

//

CRCSEDbImporter::~CRCSEDbImporter()

    {

    ReleaseImportLock();

    iDb.Close();

    iDbSession.Close();

    iProfiles.ResetAndDestroy();

    iCodecs.ResetAndDestroy();

    iCodecIds.Close();

    }

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

// Check if imported (restored) database file exists.

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

//

TBool CRCSEDbImporter::ImportExists()

    {

    RCSELOGSTRING( "CRCSEDbImporter::ImportExists() - IN" );

    TBool profileImport( EFalse );

    TBool codecImport( EFalse );

    RDbs dbSession;

    RDbNamedDatabase db;

    TInt err( dbSession.Connect() );

    if ( KErrNone != err )

        {

        return EFalse;

        }

    else

        {

        // Check voip profiles

        err = db.Open( dbSession, KDbName, KDatabaseUID );

        db.Close();

        if ( KErrNone == err )

            {

            profileImport = ETrue;

            }

        // Check audio codecs

        err = db.Open( dbSession, KDbCodecName, KDatabaseUID );

        db.Close();

        if ( KErrNone == err )

            {

            codecImport = ETrue;

            }

        }

    dbSession.Close();

    RCSELOGSTRING2( "CRCSEDbImporter::ImportExists(%d) - OUT", 

        profileImport && codecImport );

    // Return ETrue only when both of imports exist

    return profileImport && codecImport;

    }

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

// Check if import is already running.

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

//

TBool CRCSEDbImporter::IsImportRunning()

    {

    RCSELOGSTRING( "CRCSEDbImporter::IsImportRunning() - IN" );

    TBool ret( EFalse );

    RDbs dbSession;

    RDbNamedDatabase db;

    TInt err( dbSession.Connect() );

    if ( KErrNone != err )

        {

        ret = EFalse;

        }

    else

        {

        // Check if temporary table exists

        err = db.Open( dbSession, KDbTempName, KDatabaseUID );

        db.Close();

        if ( KErrNone == err )

            {

            ret = ETrue;

            }

        }

    dbSession.Close();

    RCSELOGSTRING2( "CRCSEDbImporter::IsImportRunning(%d) - OUT", ret );

    return ret;

    }

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

// Imports RCSE entries from db file and stores them to repository.

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

//

void CRCSEDbImporter::ImportAndStoreL()

    {

    RCSELOGSTRING( "CRCSEDbImporter::ImportL() - IN" );

    SetImportLock();

    // Import settings data

    ImportVoIPProfilesL();

    ImportAudioCodecsL();

    // Store audio codecs

    StoreAudioCodecsL();

    // Update and store VoIP profiles

    UpdatePreferredCodecs();

    StoreVoIPProfilesL();

    DeleteImports();

    ReleaseImportLock();

    RCSELOGSTRING( "CRCSEDbImporter::ImportL() - OUT" );

    }

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

// Set locking data base file to prevent disturb during the import operation.

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

//

void CRCSEDbImporter::SetImportLock()

    {

    RCSELOGSTRING( "CRCSEDbImporter::SetImportLock() - IN" );

    // Create temporary db that indicates ongoing operation

    iDb.Create( iDbSession, KDbTempName, KDatabaseUID );

    iDb.Close();

    RCSELOGSTRING( "CRCSEDbImporter::SetImportLock() - OUT" );

    }

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

// Release locking data base file.

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

//

void CRCSEDbImporter::ReleaseImportLock()

    {

    RCSELOGSTRING( "CRCSEDbImporter::ReleaseImportLock() - IN" );

    // Delete temporary locking db

    TInt err( iDb.Open( iDbSession, KDbTempName, KDatabaseUID ) );

    if ( KErrNone == err )

        {

        iDb.Destroy();

        iDb.Close();

        RCSELOGSTRING( "Temporary db deleted" );

        }

    else

        {

        RCSELOGSTRING2( "Temporary db not deleted, err=%d", err );

        }

    RCSELOGSTRING( "CRCSEDbImporter::ReleaseImportLock() - OUT" );

    }

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

// Import VoIP profiles from database to array.

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

//

void CRCSEDbImporter::ImportVoIPProfilesL()

    {

    RCSELOGSTRING( "CRCSEDbImporter::ImportVoIPProfilesL() - IN" );

    User::LeaveIfError( iDb.Open( iDbSession, KDbName, KDatabaseUID ) );

    // Create sql statement

    HBufC* statement = HBufC::NewLC(

        KSQLSelectAllStatement().Length() + 

        KProfileTableName().Length() );

    statement->Des().Format( 

        KSQLSelectAllStatement, &KProfileTableName );

    // Launch query

    RDbView view;

    User::LeaveIfError( view.Prepare( iDb, *statement ) );

    CleanupClosePushL( view );

    User::LeaveIfError( view.EvaluateAll() );

    view.FirstL();

    // Browse all result rows trough

    while ( view.AtRow() )

        {

        view.GetL(); // Get the data row

        const TInt cols( view.ColCount() + 1 );

        CRCSEProfileEntry* entry = CRCSEProfileEntry::NewLC();

        // Map the data from current row to profile entry.

        for( TInt i = 1; i < cols; i++ )

            {

            MapColumnToEntryL( i, view, *entry );

            }

        iProfiles.AppendL( entry );

        CleanupStack::Pop( entry );

        view.NextL();

        }

    CleanupStack::PopAndDestroy( &view );

    CleanupStack::PopAndDestroy( statement );

    iDb.Close();

    RCSELOGSTRING( "CRCSEDbImporter::ImportVoIPProfilesL() - OUT" );

    }

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

// Import audio codecs from database to array.

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

//

void CRCSEDbImporter::ImportAudioCodecsL()

    {

    RCSELOGSTRING( "CRCSEDbImporter::ImportAudioCodecsL() - IN" );

    User::LeaveIfError( iDb.Open( iDbSession, KDbCodecName, KDatabaseUID ) );

    // Create sql statement

    HBufC* statement = HBufC::NewLC(

        KSQLSelectAllStatement().Length() + 

        KAudioCodecTableName().Length() );

    statement->Des().Format( 

        KSQLSelectAllStatement, &KAudioCodecTableName );

    // Launch query

    RDbView view;

    User::LeaveIfError( view.Prepare( iDb, *statement ) );

    CleanupClosePushL( view );

    User::LeaveIfError( view.EvaluateAll() );

    view.FirstL();

    // Browse all result rows trough

    while ( view.AtRow() )

        {

        view.GetL(); // Get the data row

        const TInt cols( view.ColCount() + 1 );

        CRCSEAudioCodecEntry* entry = CRCSEAudioCodecEntry::NewLC();

        // Map the data from current row to audio codec entry.

        for( TInt i = 1; i < cols; i++ )

            {

            MapColumnToEntryL( i, view, *entry );

            }

        // Append entry and its ID

        iCodecs.AppendL( entry );

        TRCSEIdPair idPair;

        idPair.iOldId =  entry->iCodecId;

        iCodecIds.Append( idPair );

        CleanupStack::Pop( entry );

        view.NextL();

        }

    CleanupStack::PopAndDestroy( &view );

    CleanupStack::PopAndDestroy( statement );

    iDb.Close();

    RCSELOGSTRING( "CRCSEDbImporter::ImportAudioCodecsL() - OUT" );

    }

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

// Delete imported (restored) rcse database files.

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

//

void CRCSEDbImporter::DeleteImports()

    {

    RCSELOGSTRING( "CRCSEDbImporter::DeleteImports() - IN" );

    TInt err( 0 );

    // Delete VoIP profile import

    err = iDb.Open( iDbSession, KDbName, KDatabaseUID );

    if ( KErrNone == err )

        {

        iDb.Destroy();

        iDb.Close();

        RCSELOGSTRING( "Profile import deleted" );

        }

    else

        {

        RCSELOGSTRING2( "Profile import not deleted, err=%d", err );

        }

    // Delete audio codec import

    err = iDb.Open( iDbSession, KDbCodecName, KDatabaseUID );

    if ( KErrNone == err )

        {

        iDb.Destroy();

        iDb.Close();

        RCSELOGSTRING( "Codec import deleted" );

        }

    else

        {

        RCSELOGSTRING2( "Codec import not deleted, err=%d", err );

        }

    RCSELOGSTRING( "CRCSEDbImporter::DeleteImports() - OUT" );

    }

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

// Map query result from a given column to profile entry.

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

//

void CRCSEDbImporter::MapColumnToEntryL( 

    TInt aColumnIndex, 

    const RDbView& aView, 

    CRCSEProfileEntry& aEntry )

    {

    // Get the column definition

    const TDbCol col( aView.ColDef( aColumnIndex ) );

    // Maps the values using the names of columns

    if ( col.iName == KProfileId )

        {

        aEntry.iId = aView.ColUint32( aColumnIndex );

        }   

    else if ( col.iName == KProtocolIds )

        {        

        const TDesC& ids = aView.ColDes( aColumnIndex );

        // Extracts the numbers from ids to iIds.

        GetProfileIdsFromDescriptorL( ids, aEntry.iIds );  

        }

    else if ( col.iName == KProviderName )

        {

        aEntry.iProviderName.Copy( aView.ColDes( aColumnIndex ) );

        }

    else if ( col.iName == KSettingsName )

        {

        aEntry.iSettingsName.Copy( aView.ColDes( aColumnIndex ) );

        }

    else if ( col.iName == KAutoComplete )

        {

        aEntry.iAutoComplete = static_cast<CRCSEProfileEntry::TOnOff>(

            aView.ColInt32( aColumnIndex ) );

        }

    else if ( col.iName == KEndMediaPort )

        {

        aEntry.iEndMediaPort = aView.ColInt32( aColumnIndex );

        }

    else if ( col.iName == KHoldRingBack )

        {

        aEntry.iHoldRingBack = aView.ColInt32( aColumnIndex );

        }

    else if ( col.iName == KInbandDtmf)

        {

        aEntry.iInbandDTMF = static_cast<CRCSEProfileEntry::TOnOff>( 

            aView.ColInt32( aColumnIndex ) );

        }

    else if ( col.iName == KMediaQOS )

        {

        aEntry.iMediaQOS = aView.ColInt32( aColumnIndex );

        }

    else if ( col.iName == KOutbandDtmf )

        {

        aEntry.iOutbandDTMF = static_cast<CRCSEProfileEntry::TOnOff>

            ( aView.ColInt32( aColumnIndex ) );

        }

    else if ( col.iName == KPreferredCodecs )

        {

        const TDesC& codecs = aView.ColDes( aColumnIndex );

        // Extracts the numbers from codecs to iPreferredCodecs.

        GetNumbersFromDescriptorL( codecs, aEntry.iPreferredCodecs );

        }

    else if ( col.iName == KSiqnalingQOS )

        {

        aEntry.iSiqnalingQOS = aView.ColInt32( aColumnIndex );

        }

    else if ( col.iName == KStartMediaPort )

        {

        aEntry.iStartMediaPort = aView.ColInt32( aColumnIndex );

        }

    else if ( col.iName == KCFNoAnswer )

        {

        aEntry.iCFNoAnswer = static_cast<CRCSEProfileEntry::TOnOff>

                ( aView.ColInt32( aColumnIndex ) );

        }

    else if ( col.iName == KCFBusy )

        {

        aEntry.iCFBusy = static_cast<CRCSEProfileEntry::TOnOff>

                ( aView.ColInt32( aColumnIndex ) );

        }

    else if ( col.iName == KCFUnconditional )

        {

        aEntry.iCFUnconditional = static_cast<CRCSEProfileEntry::TOnOff>(

            aView.ColInt32( aColumnIndex ) );

        }

    else if ( col.iName == KRedundancy )

        {

        aEntry.iRedundancy = static_cast<CRCSEProfileEntry::TOnOff>(

            aView.ColInt32( aColumnIndex ) );

        }

    else if ( col.iName == KSecureCallPreference )

        {

        aEntry.iSecureCallPreference = aView.ColUint32( aColumnIndex );

        }

    else if ( col.iName == KVoIPProfileLock )

        {

        aEntry.iVoIPProfileLock = aView.ColUint32( aColumnIndex );

        }

    else if ( col.iName == KAdhocAllowed )

        {

        aEntry.iAdhocAllowed = aView.ColUint32( aColumnIndex );

        }

    else if ( col.iName == KSIPServerType )

        {

        aEntry.iSIPServerType.Copy( aView.ColDes( aColumnIndex ) );

        }

    else if ( col.iName == KSBCType )

        {

        aEntry.iSBCType.Copy( aView.ColDes( aColumnIndex ) );

        }

    else if ( col.iName == KSTUNServerType )

        {

        aEntry.iSTUNServerType.Copy( aView.ColDes( aColumnIndex ) );

        }

    else if ( col.iName == KWLANAPType )

        {

        aEntry.iWLANAPType.Copy( aView.ColDes( aColumnIndex ) );

        }

    else if ( col.iName == KPSTNGatewayType )

        {

        aEntry.iPSTNGatewayType.Copy( aView.ColDes( aColumnIndex ) );

        }

    else if ( col.iName == KSecurityGatewayType )

        {

        aEntry.iSecurityGatewayType.Copy( aView.ColDes( aColumnIndex ) );

        }