/*

* Copyright (c) 2004 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:    Fota adapter's DB implementation file

*

*/

// INCLUDE FILES

#include <sysutil.h>

#include <bautils.h>

#include "nsmldmfotaadapterdb.h"

#include "nsmlconstants.h"

#include "nsmldebug.h"

#ifndef __WINS__

                                    // This lowers the unnecessary compiler warning (armv5) to remark.

                                    // "Warning: #174-D: expression has no effect..." is caused by 

                                    // DBG_ARGS8 macro in no-debug builds.

#pragma diag_remark 174

#endif

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

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

//  CNSmlDmFotaAdapterDb::NewL()

//  Creates a new instance of CNSmlDmFotaAdapterDb object.

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

// 

CNSmlDmFotaAdapterDb* CNSmlDmFotaAdapterDb::NewL()

    {

    _DBG_FILE("CNSmlDmFotaAdapterDb::NewL(): begin");

    CNSmlDmFotaAdapterDb* self = CNSmlDmFotaAdapterDb::NewLC(); 

    CleanupStack::Pop( self );

    _DBG_FILE("CNSmlDmFotaAdapterDb::NewL(): end");

    return self;

    }   

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

//  CNSmlDmFotaAdapterDb::NewLC()

//  Creates a new instance of CNSmlDmFotaAdapterDb object. 

//  Pushes and leaves new instance onto CleanupStack.

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

// 

CNSmlDmFotaAdapterDb* CNSmlDmFotaAdapterDb::NewLC()

    {

    _DBG_FILE("CNSmlDmFotaAdapterDb::NewLC(): begin");

    CNSmlDmFotaAdapterDb* self = new( ELeave ) CNSmlDmFotaAdapterDb();

    CleanupStack::PushL( self );

    self->ConstructL();

    _DBG_FILE("CNSmlDmFotaAdapterDb::NewLC(): end");

    return self;

    }

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

//  CNSmlDmFotaAdapterDb::ConstructL()

//  Second phase constructor.

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

// 

void CNSmlDmFotaAdapterDb::ConstructL()

    {

    _DBG_FILE("CNSmlDmFotaAdapterDb::ConstructL(): begin");

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

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

    iFsSession.SetSessionToPrivate( KNSmlFotaAdapterDbDrive );

    TParse name;

#ifdef SYMBIAN_SECURE_DBMS

	name.Set( KNSmlFotaAdapterDbName(), NULL, NULL );

#else

    name.Set( KNSmlFotaAdapterDbName(), KNSmlDatabasesNonSecurePath, NULL );

#endif

	TInt err = iDatabase.Open( iRdbSession,

	                           name.FullName(),

	                           KNSmlDBMSSecureMDHostOneID );

    if ( err == KErrNotFound )

        {

        CreateDatabaseL( name.FullName() );

        err = iDatabase.Open( iRdbSession,

                              name.FullName(),

                              KNSmlDBMSSecureMDHostOneID );

        User::LeaveIfError( err );

        }

    else

        {

        if ( ( err == KErrEof ) || ( err == KErrCorrupt ) || 

             ( err == KErrArgument ) )

            {

            // something seriously wrong with the db, delete it and try 

            // to create new

            iRdbSession.DeleteDatabase( name.FullName(),

                                        KNSmlDMHostOnePolicyUID );

            CreateDatabaseL( name.FullName() );

            err = iDatabase.Open( iRdbSession,

                                  name.FullName(),

                                  KNSmlDBMSSecureMDHostOneID );

            }

        User::LeaveIfError( err );

        }

    User::LeaveIfError( iFwObjectTable.Open( iDatabase,

                                             KNSmlTableFwMgmtObject ) );

    iColSet = iFwObjectTable.ColSetL();

    _DBG_FILE("CNSmlDmFotaAdapterDb::ConstructL(): end");

    }

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

//  CNSmlDmFotaAdapterDb::CNSmlDmFotaAdapterDb()

//  Constructor.

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

// 

CNSmlDmFotaAdapterDb::CNSmlDmFotaAdapterDb()

    {

    _DBG_FILE("CNSmlDmFotaAdapterDb::CNSmlDmFotaAdapterDb(): begin");

    _DBG_FILE("CNSmlDmFotaAdapterDb::CNSmlDmFotaAdapterDb(): end");

    }

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

//  CNSmlDmFotaAdapterDb::~CNSmlDmFotaAdapterDb()

//  Destructor.

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

// 

CNSmlDmFotaAdapterDb::~CNSmlDmFotaAdapterDb()

    {

    _DBG_FILE("CNSmlDmFotaAdapterDb::~CNSmlDmFotaAdapterDb(): begin");

    iView.Close();

    delete iColSet;

    iFwObjectTable.Close();

    iDatabase.Close();

    iFsSession.Close();

    iRdbSession.Close();

    _DBG_FILE("CNSmlDmFotaAdapterDb::~CNSmlDmFotaAdapterDb(): ends");

    }

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

//  CNSmlDmFotaAdapterDb::AddFwObjectL()

//  Inserts new uninitialized row to FwMgmtObject table and returns its id.

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

// 

TNSmlDmFwObjectId CNSmlDmFotaAdapterDb::AddFwObjectL()

    {

    _DBG_FILE("CNSmlDmFotaAdapterDb::AddFwObjectL(): begin");

    // Check OOD before inserting new row into FwMgmtObject table

    if ( SysUtil::FFSSpaceBelowCriticalLevelL( &iFsSession, 

                                               KNSmlMaxFwMgmtObjectRowSize ) )

        {

        User::Leave( KErrDiskFull );

        }

    iDatabase.Begin();

    // Insert new row, and set finalt result to its null value

    iFwObjectTable.InsertL();

    iFwObjectTable.SetColL( iColSet->ColNo( KNSmlFwMgmtObjectResult ), 

                            KNSmlFotaNullResult );

    iFwObjectTable.PutL();

    CommitAndCompact();

    _DBG_FILE("CNSmlDmFotaAdapterDb::AddFwObjectL(): end");

    return iFwObjectTable.ColUint( iColSet->ColNo( KNSmlFwMgmtObjectId ) );

    }

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

//  CNSmlDmFotaAdapterDb::DeleteFwObjectL()

//  Deletes a row from FwMgmtObject table identified by aId. If such row is 

//  not found, returns KErrNotFound, KErrNone otherwise.

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

// 

TInt CNSmlDmFotaAdapterDb::DeleteFwObjectL( const TNSmlDmFwObjectId aId )

    {

    _DBG_FILE("CNSmlDmFotaAdapterDb::DeleteFwObjectL(): begin");

    HBufC* sql = HBufC::NewL( KNSmlDeleteFwMgmtObject().Length() + 

                              KNSmlFwMgmtObjectIntegerLength );

    sql->Des().Format( KNSmlDeleteFwMgmtObject, aId );

    iDatabase.Begin();

    TInt result = iDatabase.Execute( *sql );

    CommitAndCompact();

    delete sql;

    _DBG_FILE("CNSmlDmFotaAdapterDb::DeleteFwObjectL(): end");

    return ( result == 0 ) ? KErrNotFound : KErrNone;

    }

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

//  CNSmlDmFotaAdapterDb::GetEmptyFinalResultsL()

//  Finds all the rows in FwMgmtObject table that have null final result and

//  puts the PkgIds of those rows to aArray.

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

// 

void CNSmlDmFotaAdapterDb::GetEmptyFinalResultsL( RNSmlDmFwObjectArray& aArray )

    {

    _DBG_FILE("CNSmlDmFotaAdapterDb::GetEmptyFinalResultsL(): begin");

    aArray.Reset();

    HBufC* sql = HBufC::NewLC( KNSmlGetUnfinishedFwMgmtObjects().Length() + 

                               KNSmlFwMgmtObjectIntLength );

    sql->Des().Format( KNSmlGetUnfinishedFwMgmtObjects, KNSmlFotaNullResult );

    PrepareViewL( *sql, iView.EReadOnly );

    CleanupStack::PopAndDestroy( sql );

    while ( iView.NextL() )

        {

        // get final result and append it to aArray

        iView.GetL();

        aArray.AppendL( iView.ColUint( 

                        iColSet->ColNo( KNSmlFwMgmtObjectId ) ) );

        }

    _DBG_FILE("CNSmlDmFotaAdapterDb::GetEmptyFinalResultsL(): end");

    }

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

//  CNSmlDmFotaAdapterDb::GetEmptyFinalResultsL()

//  Finds all the rows in FwMgmtObject table that have null final result, 

//  server id equals to aServerId and management uri is not an empty string.

//  Puts the PkgIds of those rows to aArray.

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

// 

void CNSmlDmFotaAdapterDb::GetEmptyFinalResultsL( RNSmlDmFwObjectArray& aArray, 

                                                  const TDesC8& aServerId )

    {

    _DBG_FILE("CNSmlDmFotaAdapterDb::GetEmptyFinalResultsL(serverid): begin");

    aArray.Reset();

    HBufC* serverId = ConvertTo16BitLC( aServerId );

    HBufC* sql = HBufC::NewLC( 

                        KNSmlGetUnfinishedFwMgmtObjectByServerId().Length() + 

                        KNSmlFwMgmtObjectIntLength + 

                        serverId->Length() );

    sql->Des().Format( KNSmlGetUnfinishedFwMgmtObjectByServerId, 

                       KNSmlFotaNullResult, 

                       serverId );

    PrepareViewL( *sql, iView.EReadOnly );

    CleanupStack::PopAndDestroy( sql );

    CleanupStack::PopAndDestroy( serverId );

    while ( iView.NextL() )

        {

        // get final result and append it to aArray

        iView.GetL();

        aArray.AppendL( iView.ColUint( 

                        iColSet->ColNo( KNSmlFwMgmtObjectId ) ) );

        }

    _DBG_FILE("CNSmlDmFotaAdapterDb::GetEmptyFinalResultsL( serverid ): end");

    }

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

//  CNSmlDmFotaAdapterDb::PkgNameL()

//  Returns the PkgName field from FW object identified by aId. If no such 

//  object is found, returns NULL.

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

// 

HBufC8* CNSmlDmFotaAdapterDb::PkgNameL( const TNSmlDmFwObjectId aId )

    {

    return StrValueL( KNSmlFwMgmtObjectName, aId );

    }

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

//  CNSmlDmFotaAdapterDb::PkgVersionL()

//  Returns the PkgVersion field from FW object identified by aId. If no such 

//  object is found, returns NULL.

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

// 

HBufC8* CNSmlDmFotaAdapterDb::PkgVersionL( const TNSmlDmFwObjectId aId )

    {

    return StrValueL( KNSmlFwMgmtObjectVersion, aId );

    }

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

//  CNSmlDmFotaAdapterDb::PkgUrlL()

//  Returns the PkgUrl field from FW object identified by aId. If no such 

//  object is found, returns NULL.

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

// 

HBufC8* CNSmlDmFotaAdapterDb::PkgUrlL( const TNSmlDmFwObjectId aId )

    {

    return LongStrValueL( KNSmlFwMgmtObjectUrl, aId );

    }

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

//  CNSmlDmFotaAdapterDb::MgmtUriL()

//  Returns the MgmtUri field from FW object identified by aId. If no such 

//  object is found, returns NULL.

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

// 

HBufC8* CNSmlDmFotaAdapterDb::MgmtUriL( const TNSmlDmFwObjectId aId )

    {

    return StrValueL( KNSmlFwMgmtObjectMgmtUri, aId );

    }

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

//  CNSmlDmFotaAdapterDb::ProfileIdL()

//  Returns the ProfileId field from FW object identified by aId. If no such 

//  object is found, returns KErrNotFound.

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

// 

TSmlProfileId CNSmlDmFotaAdapterDb::ProfileIdL( const TNSmlDmFwObjectId aId )

    {

    return IntValueL( KNSmlFwMgmtObjectProfileId, aId );

    }

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

//  CNSmlDmFotaAdapterDb::ServerIdL()

//  Returns the ServerId field from FW object identified by aId. If no such 

//  object is found, returns NULL.

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

// 

HBufC8* CNSmlDmFotaAdapterDb::ServerIdL( const TNSmlDmFwObjectId aId )

    {

    return StrValueL( KNSmlFwMgmtObjectServerId, aId );

    }

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

//  CNSmlDmFotaAdapterDb::FinalResultL()

//  Returns the FinalResult field from FW object identified by aId. If no such 

//  object is found, returns KErrNotFound.

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

// 

TInt CNSmlDmFotaAdapterDb::FinalResultL( const TNSmlDmFwObjectId aId )

    {

    return IntValueL( KNSmlFwMgmtObjectResult, aId );

    }

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

//  CNSmlDmFotaAdapterDb::CorrelatorL()

//  Returns the Correlator field from FW object identified by aId. If no such 

//  object is found, returns NULL.

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

// 

HBufC8* CNSmlDmFotaAdapterDb::CorrelatorL( const TNSmlDmFwObjectId aId )

    {

    return StrValueL( KNSmlFwMgmtObjectCorrelator, aId );

    }

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

//  CNSmlDmFotaAdapterDb::SetPkgNameL()

//  Sets aName as the value of PkgName in FW object identified by aId. If no 

//  such object is found, returns KErrNotFound. If name is too large for the 

//  database, returns KErrOverflow.

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

// 

TInt CNSmlDmFotaAdapterDb::SetPkgNameL( const TDesC8& aName, 

                                        const TNSmlDmFwObjectId aId )

    {

    if ( aName.Length() > KFotaMaxPkgNameLength )

        {

        return KErrOverflow;

        }

    return SetStrValueL( KNSmlFwMgmtObjectName, aName, aId );

    }

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

//  CNSmlDmFotaAdapterDb::SetPkgVersionL()

//  Sets aVersion as the value of PkgVersion in FW object identified by aId.

//  If no such object is found, returns KErrNotFound. If version is too 

//  large for the database, returns KErrOverflow.

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

// 

TInt CNSmlDmFotaAdapterDb::SetPkgVersionL( const TDesC8& aVersion, 

                                           const TNSmlDmFwObjectId aId )

    {

    if ( aVersion.Length() > KFotaMaxPkgVersionLength )

        {

        return KErrOverflow;

        }

    return SetStrValueL( KNSmlFwMgmtObjectVersion, aVersion, aId );

    }

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

//  CNSmlDmFotaAdapterDb::SetPkgUrlL()

//  Sets aUrl as the value of PkgURL in FW object identified by aId. If no 

//  such object is found, returns KErrNotFound. If url is too large for the 

//  database, returns KErrOverflow.

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

// 

TInt CNSmlDmFotaAdapterDb::SetPkgUrlL( const TDesC8& aUrl, 

                                       const TNSmlDmFwObjectId aId )

    {

    if ( aUrl.Length() > KFotaMaxPkgURLLength )

        {

        return KErrOverflow;

        }

    return SetLongStrValueL( KNSmlFwMgmtObjectUrl, aUrl, aId );

    }

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

//  CNSmlDmFotaAdapterDb::SetMgmtUriL()

//  Sets aUri as the value of MgmtURI in FW object identified by aId. If no 

//  such object is found, returns KErrNotFound. If uri is too large for the 

//  database, returns KErrOverflow.

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

// 

TInt CNSmlDmFotaAdapterDb::SetMgmtUriL( const TDesC8& aUri, 

                                        const TNSmlDmFwObjectId aId )

    {

    if ( aUri.Length() > KNSmlMaxMgmtUriLength )

        {

        return KErrOverflow;

        }

    return SetStrValueL( KNSmlFwMgmtObjectMgmtUri, aUri, aId );

    }

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

//  CNSmlDmFotaAdapterDb::SetServerInfoL()

//  Sets aProfileId as the value of ProfileId and aServerId as the value of 

//  ServerId in FW object identified by aId. If no such object is found, 

//  returns KErrNotFound. If server id is too large for the database, 

//  returns KErrOverflow.

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

// 

TInt CNSmlDmFotaAdapterDb::SetServerInfoL( const TSmlProfileId aProfile, 

                                           const TDesC8& aServerId, 

                                           const TNSmlDmFwObjectId aId )

    {

    _DBG_FILE("CNSmlDmFotaAdapterDb::SetServerInfoL(): begin");

    if ( aServerId.Length() > KNSmlMaxServerIdLength )

        {

        return KErrOverflow;

        }

    HBufC* serverId = ConvertTo16BitLC( aServerId );

    TInt ret = UpdateRowL( aId );

    if ( ret == KErrNone )

        {

        // do update

        iView.SetColL( iColSet->ColNo( KNSmlFwMgmtObjectProfileId ), 

                       aProfile );

        iView.SetColL( iColSet->ColNo( KNSmlFwMgmtObjectServerId ), 

                       *serverId );

        iView.PutL();

        }

    CommitAndCompact();

    CleanupStack::PopAndDestroy( serverId );

    _DBG_FILE("CNSmlDmFotaAdapterDb::SetServerInfoL(): end");

    return ret;

    }

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

//  CNSmlDmFotaAdapterDb::SetFinalResultL()

//  Sets aResult as the value of FinalResult in FW object identified by aId.

//  If no such object is found, returns KErrNotFound.

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

// 

TInt CNSmlDmFotaAdapterDb::SetFinalResultL( const TInt aResult, 

                                            const TNSmlDmFwObjectId aId )

    {

    return SetIntValueL( KNSmlFwMgmtObjectResult, aResult, aId );

    }

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

//  CNSmlDmFotaAdapterDb::SetCorrelatorL()

//  Sets aCorrealtor as the value of Correlator in FW object identified by aId.

//  If no such object is found, returns KErrNotFound. If given correlator is 

//  too large for the database, returns KErrOverflow.

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

// 

TInt CNSmlDmFotaAdapterDb::SetCorrelatorL( const TDesC8& aCorrelator, 

                                           const TNSmlDmFwObjectId aId )

    {

    if ( aCorrelator.Length() > KNSmlMaxCorrelatorLength )

        {

        return KErrOverflow;

        }

    return SetStrValueL( KNSmlFwMgmtObjectCorrelator, aCorrelator, aId );

    }

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

//  CNSmlDmFotaAdapterDb::CreateDatabaseL()

//  Creates Fota database.

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

// 

void CNSmlDmFotaAdapterDb::CreateDatabaseL( const TDesC& aFullName )