/*

* 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:

*

*/

// System includes

#include <QSqlDatabase>

#include <QFile>

#include <QDateTime>

#include <QVariant>

#include <QStringList>

#include <QSqlError>

#include <QSqlQueryModel>

#include <QSqlRecord>

// User includes

#include "radiohistorymodel_p.h"

#include "radiohistorymodel.h"

#include "radiohistoryitem.h"

#include "radiohistoryitem_p.h"

#include "radiostation.h"

#include "radiologger.h"

const char* DATABASE_NAME       = "radioplayhistory.db";

const char* DATABASE_DRIVER     = "QSQLITE";

const char* HISTORY_TABLE       = "history";

const char* SQL_CREATE_TABLE    = "CREATE TABLE history ("

                                  "id INTEGER PRIMARY KEY AUTOINCREMENT, "

                                  "artist TEXT NOT NULL, "

                                  "title TEXT NOT NULL, "

                                  "station TEXT NOT NULL, "

                                  "frequency INTEGER NOT NULL, "

                                  "tagged INTEGER NOT NULL DEFAULT 0, "

                                  "fromRds INTEGER NOT NULL DEFAULT 1, "

                                  "time TIMESTAMP NOT NULL)";

const char* SQL_ADD_ITEM         = "INSERT INTO history (artist,title,station,frequency,fromRds,time) "

                                            "VALUES ( ?,?,?,?,?,? )";

const char* SQL_SELECT_ALL       = "SELECT * FROM history ORDER BY id DESC";

const char* SQL_SELECT_TAGGED    = "SELECT * FROM history WHERE tagged=1";// ORDER BY id DESC";

const char* SQL_DELETE_ALL       = "DELETE FROM history";

//static const char* SQL_FIND_ITEM_BY_ID = "SELECT * FROM history WHERE id = ?";

const char* SQL_TOGGLE_TAG       = "UPDATE history SET tagged = ? WHERE id = ?";

#ifdef LOGGING_ENABLED

#   define GET_ERR( param ) GETSTRING( param.lastError().text() )

#   define GET_ERR_PTR( param ) GETSTRING( param->lastError().text() )

#endif // LOGGING_ENABLED

/*!

 * Static utility function to parse a frequency

 */

static  QString parseFrequency( const uint frequency )

{

    QString loc = qtTrId( "txt_rad_dblist_val_l1_mhz" );

    return loc.arg( RadioStation::parseFrequency( frequency ) );

}

/*!

 *

 */

RadioHistoryModelPrivate::RadioHistoryModelPrivate( RadioHistoryModel* model,

                                                    RadioUiEngine& uiEngine ) :

    q_ptr( model ),

    mUiEngine( uiEngine ),

    mTopItemIsPlaying( false ),

    mShowDetails( true ),

    mViewMode( ShowAll ),

    mRtItemClass( -1 )

{

}

/*!

 *

 */

RadioHistoryModelPrivate::~RadioHistoryModelPrivate()

{

    if ( mDatabase && mDatabase->isOpen() ) {

        mDatabase->close();

    }

}

/*!

 *

 */

bool RadioHistoryModelPrivate::connectToDatabase()

{

    LOG_METHOD;

    QSqlDatabase db = QSqlDatabase::addDatabase( DATABASE_DRIVER );

    if ( db.isValid() ) {

        mDatabase.reset( new QSqlDatabase( db ) );

        mDatabase->setDatabaseName( DATABASE_NAME );

        if ( !mDatabase->open() ) {

            LOG_FORMAT( "Failed to open database! error = %s", GET_ERR_PTR( mDatabase ) );

            mDatabase.reset();

            return false;

        }

        // Create the table if it does not exist

        if ( !mDatabase->tables().contains( HISTORY_TABLE ) ) {

            LOG( "RadioHistoryModelPrivate::connectToDatabase: Creating database tables." );

            QSqlQuery query;

            if ( !query.exec( SQL_CREATE_TABLE ) ) {

                LOG_FORMAT( "Database creation failed! error = %s", GET_ERR( query ) );

                mDatabase->close();

                mDatabase.reset();

                return false;

            }

        }

    } else {

        LOG_FORMAT( "Invalid database! error = %s", GET_ERR( db ) );

        return false;

    }

    mQueryModel.reset( new QSqlQueryModel() );

    setViewMode( ShowAll );

    return mQueryModel->lastError().type() == QSqlError::NoError;

}

/*!

 *

 */

void RadioHistoryModelPrivate::addItem( const QString& artist,

                                        const QString& title,

                                        const RadioStation& station,

                                        bool fromRds )

{

    LOG_FORMAT( "RadioHistoryModelPrivate::addItem. Artist: %s, Title: %s", GETSTRING( artist ), GETSTRING( title ) );

    if ( !mQueryModel ) {

        return;

    }

    mTopItemIsPlaying = true;

    QSqlQuery query = beginTransaction();

    query.prepare( SQL_ADD_ITEM );

    query.addBindValue( artist );

    query.addBindValue( title );

    query.addBindValue( station.name() );

    query.addBindValue( static_cast<int>( station.frequency() / 1000 ) );

    query.addBindValue( fromRds );

    query.addBindValue( QDateTime::currentDateTime().toTime_t() );

    commitTransaction( query, InsertRows, 0 );

}

/*!

 *

 */

int RadioHistoryModelPrivate::rowCount() const

{

    if ( !mQueryModel ) {

        return 0;

    }

    return mQueryModel->rowCount();

}

/*!

 *

 */

QVariant RadioHistoryModelPrivate::data( const int row, const int role ) const

{

    if ( mQueryModel->lastError().type() == QSqlError::NoError ) {

        QSqlRecord record = mQueryModel->record( row );

        if ( role == Qt::DisplayRole ) {

            const QString artist = record.value( RadioHistoryValue::Artist ).toString();

            const QString title = record.value( RadioHistoryValue::Title ).toString();

            const QString station = record.value( RadioHistoryValue::Station ).toString();

            const uint frequency = record.value( RadioHistoryValue::Frequency ).toUInt() * 1000;

            QStringList list;

            if ( mShowDetails ) {

                list.append( qtTrId( "txt_rad_dblist_1_2" ).arg( artist ).arg( title ) );

                QDateTime dateTime = record.value( RadioHistoryValue::Time ).toDateTime();

                const QString time = dateTime.toLocalTime().toString();

                QString name = !station.isEmpty() ? station : parseFrequency( frequency );

                list.append( qtTrId( "txt_rad_dblist_1_2" ).arg( time ).arg( name ) );

            } else {

                list.append( artist );

                list.append( title );

            }

            return list;

        } else if ( role == Qt::DecorationRole ) {

            QVariantList list;

            const bool tagged = record.value( RadioHistoryValue::Tagged ).toBool();

            if ( tagged ) {

                list.append( mTaggedIcon );

            } else {

                list.append( mNonTaggedIcon );

            }

            return list;

        }

    }

    return QVariant();

}

/*!

 *

 */

void RadioHistoryModelPrivate::removeAll()

{

    if ( !mQueryModel ) {

        return;

    }

    QSqlQuery query = beginTransaction();

    query.prepare( SQL_DELETE_ALL );

    // Commented out because rowsRemoved() seems to crash HbListView

//    commitTransaction( query, RemoveRows, 0, rowCount() - 1 );

    commitTransaction( query, NoOp, 0 );

    q_ptr->reset();

}

/*!

 *

 */

void RadioHistoryModelPrivate::setViewMode( ViewMode mode )

{

    if ( !mQueryModel ) {

        return;

    }

    mViewMode = mode;

    mQueryModel->setQuery( mode == ShowTagged ? SQL_SELECT_TAGGED : SQL_SELECT_ALL, *mDatabase );

    q_ptr->reset();

}

/*!

 *

 */

void RadioHistoryModelPrivate::toggleTagging( const RadioHistoryItem& item, const int row )

{

    QSqlQuery updateQuery = beginTransaction();

    updateQuery.prepare( SQL_TOGGLE_TAG );

    updateQuery.addBindValue( item.isTagged() ? 0 : 1 );

    updateQuery.addBindValue( item.id() );

    commitTransaction( updateQuery, ChangeData, row );

}

/*!

 *

 */

RadioHistoryItem RadioHistoryModelPrivate::itemAtIndex( const QModelIndex& index ) const

{

    LOG_METHOD;

    RadioHistoryItem item;

    QSqlRecord record = mQueryModel->record( index.row() );

    item.data_ptr()->initFromRecord( record );

    return item;

}

/*!

 *

 */

void RadioHistoryModelPrivate::refreshModel()

{

    setViewMode( mViewMode );

}

/*!

 *

 */

QSqlQuery RadioHistoryModelPrivate::beginTransaction()

{

    LOG_METHOD;

    QSqlQuery newQuery( *mDatabase );

    mDatabase->transaction();

    return newQuery;

}

/*!

 *

 */

void RadioHistoryModelPrivate::commitTransaction( QSqlQuery& query, Operation operation, int start, int end )

{

    LOG_METHOD;

    if ( end == -1 ) {

        end = start;

    }

    bool success = false;

    Q_UNUSED( success );

    if ( query.exec() ) {

        if ( operation == InsertRows ) {

            q_ptr->beginInsertRows( QModelIndex(), start, end );

        } else if ( operation == RemoveRows ) {

            q_ptr->beginRemoveRows( QModelIndex(), start, end );

        }

        success = mDatabase->commit();

        LOG_ASSERT( success, LOG_FORMAT( "Commit failed! err: %s", GET_ERR_PTR( mDatabase ) ) );

        refreshModel();

        if ( operation == InsertRows ) {

            q_ptr->endInsertRows();

            q_ptr->emitItemAdded();

        } else if ( operation == RemoveRows ) {

            q_ptr->endRemoveRows();

        } else if ( operation == ChangeData ) {

            q_ptr->reportChangedData( start );

        }

    } else {

        LOG_FORMAT( "RadioHistoryModelPrivate::commitTransaction FAILED, rolling back: error = %s", GET_ERR( query ) );

        success = mDatabase->rollback();

        LOG_ASSERT( success, LOG_FORMAT( "Rollback failed! err: %s", GET_ERR_PTR( mDatabase ) ) );

    }

}