/*

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

*

*/

#include "logsmatchesmodel.h"

#include "logsmodel.h"

#include "logsevent.h"

#include "logslogger.h"

#include "logsengdefs.h"

#include "logsdbconnector.h"

#include "logscntfinder.h"

#include "logsdetailsmodel.h"

#include "logscall.h"

#include "logsmessage.h"

#include "logscontact.h"

#include "logseventdata.h"

#include "logsthumbnailmanager.h"

#include "logscommondata.h"

#include <hblineedit.h>

#include <QStringList>

#include <qcontactphonenumber.h>

#include <qcontactmanager.h>

Q_DECLARE_METATYPE(LogsEvent *)

Q_DECLARE_METATYPE(LogsCall *)

Q_DECLARE_METATYPE(LogsMessage *)

Q_DECLARE_METATYPE(LogsContact *)

Q_DECLARE_METATYPE(LogsDetailsModel *)

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

// 

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

//

LogsMatchesModel::LogsMatchesModel( 

        LogsAbstractModel& parentModel, LogsDbConnector& dbConnector ) 

    : LogsAbstractModel(),

      mParentModel(parentModel),

      mLogsCntFinder(0),

      mIconManager(0),

      mSearchEnabled(false),

      mResultCount(0)

{

    LOGS_QDEBUG( "logs [ENG] -> LogsMatchesModel::LogsMatchesModel()" )

    mDbConnector = &dbConnector;

    initPredictiveSearch();

    LOGS_QDEBUG( "logs [ENG] <- LogsMatchesModel::LogsMatchesModel()" )

}

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

//

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

//

LogsMatchesModel::~LogsMatchesModel()

{

    LOGS_QDEBUG( "logs [ENG] -> LogsMatchesModel::~LogsMatchesModel()" )

    delete mLogsCntFinder;

    qDeleteAll(mMatches);

	delete mIconManager;

    LOGS_QDEBUG( "logs [ENG] <- LogsMatchesModel::~LogsMatchesModel()" )

}

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

// From QAbstractItemModel

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

//

int LogsMatchesModel::rowCount(const QModelIndex & /* parent */) const

{

    return mResultCount;

}

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

// From QAbstractItemModel

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

//

QVariant LogsMatchesModel::data(const QModelIndex &index, int role) const

{

    if (!index.isValid() || index.row() >= mResultCount || index.row() < 0 ) {

        return QVariant();

    }

    LogsMatchesModelItemContainer* item = 0;

    if ( index.row() < mMatches.count() ){

        item = mMatches.at(index.row());

    } else {

        item = const_cast<LogsMatchesModel*>(this)->addSearchResult(index.row());

    }

    updateSearchResult(*item);

    if (role == Qt::DisplayRole){

        return( QVariant( item->texts() ) );

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

        return( QVariant( item->icons(index.row()) ) );

    } else if ( role == RoleDetailsModel ) {

        LOGS_QDEBUG( "logs [ENG]    LogsMatchesModel::data() RoleDetailsModel" )

        LogsDetailsModel* detailsModel = 0;

        LogsEvent* event = item->event();

        if ( event ) {

            detailsModel = new LogsDetailsModel( *mDbConnector, *event );

        }

        QVariant var = qVariantFromValue( detailsModel );

        return var;

    }

    return doGetData(role, *item);

}

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

//

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

//

QVariant LogsMatchesModel::createCall(const LogsModelItemContainer& item) const

{

    LOGS_QDEBUG( "logs [ENG] -> LogsMatchesModel::createCall()" )     

    LogsEvent* event = item.event();

    if ( event ){

        return LogsAbstractModel::createCall(item);

    }

    const LogsMatchesModelItemContainer& matchItem = 

        static_cast<const LogsMatchesModelItemContainer&>( item ); 

    LogsCall* logscall = new LogsCall(matchItem.contact(), matchItem.number());

    if (!logscall->isAllowedCallType()) {

        delete logscall;

        logscall = 0;

    }

    QVariant var = qVariantFromValue(logscall);

    LOGS_QDEBUG( "logs [ENG] <- LogsMatchesModel::createCall()" )

    return var;         

}

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

//

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

//

QVariant LogsMatchesModel::createMessage(const LogsModelItemContainer& item) const

{

    LOGS_QDEBUG( "logs [ENG] -> LogsMatchesModel::createMessage()" )   

    LogsEvent* event = item.event();

    if ( event ){

        return LogsAbstractModel::createMessage(item);

    }

    const LogsMatchesModelItemContainer& matchItem = 

        static_cast<const LogsMatchesModelItemContainer&>( item ); 

    LogsMessage* logsMessage = new LogsMessage(matchItem.contact(), matchItem.number(),matchItem.contactName());

    if (!logsMessage->isMessagingAllowed()) {

        delete logsMessage;

        logsMessage = 0;

    }

    QVariant var = qVariantFromValue(logsMessage);

    LOGS_QDEBUG( "logs [ENG] <- LogsMatchesModel::createMessage()" )

    return var;      

}

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

//

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

//

QVariant LogsMatchesModel::createContact(const LogsModelItemContainer& item) const

{

    LOGS_QDEBUG( "logs [ENG] -> LogsMatchesModel::createContact()" )

    LogsEvent* event = item.event();

    if ( event ){

        return LogsAbstractModel::createContact(item);

    }

    const LogsMatchesModelItemContainer& matchItem = 

        static_cast<const LogsMatchesModelItemContainer&>( item ); 

    LogsContact* logsContact = 

        new LogsContact(matchItem.number(), *mDbConnector, matchItem.contact());

    if ( !logsContact->isContactRequestAllowed() ) {

        delete logsContact;

        logsContact = 0;

    } else {

        connect( logsContact, SIGNAL(saveCompleted(bool)), this, SLOT(forceSearchQuery()) );

    }

    QVariant var = qVariantFromValue(logsContact);

    LOGS_QDEBUG( "logs [ENG] <- LogsMatchesModel::createContact()" )

    return var;

}

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

//

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

//

int LogsMatchesModel::predictiveSearchStatus()

{

    return mDbConnector->predictiveSearchStatus();

}

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

//

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

//

int LogsMatchesModel::setPredictiveSearch(bool enabled)

{    

    LOGS_QDEBUG( "logs [ENG] -> LogsMatchesModel::setPredictiveSearch()" )

    int err = mDbConnector->setPredictiveSearch(enabled);    

    if (!err) {

        if ((mSearchEnabled && !enabled) || (!mSearchEnabled && enabled)) {

            //in case of search is turned off, getLogMatches will only reset 

            //previous search results

            mSearchEnabled = enabled;

            forceSearchQuery();

        }

    }     

    LOGS_QDEBUG_2( "logs [ENG] <- LogsMatchesModel::setPredictiveSearch(), err: ", err )

    return err;

}

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

//

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

//

void LogsMatchesModel::queryReady()

{

	LOGS_QDEBUG( "logs [ENG] -> LogsMatchesModel::queryReady()" );

	qDeleteAll(mMatches);

    mMatches.clear();     

    // Just store number of matches at this point, real data is read only

    // once it is asked first time from model. 

    mResultCount = mLogsCntFinder->resultsCount();	

	reset();

}

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

//

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

//

void LogsMatchesModel::eventsUpdated(const QModelIndex& first, const QModelIndex& last)

{

    LOGS_QDEBUG( "logs [ENG] -> LogsMatchesModel::eventsUpdated()" );

    bool updated( false );

    QMap<LogsCntEntryHandle*, LogsEvent*>::const_iterator i;

    for (i = mSearchEvents.constBegin(); i != mSearchEvents.constEnd(); ++i){

        if ( i.value()->index() >= first.row() && i.value()->index() <= last.row() ){

            LogsCntEntry* entry = mLogsCntFinder->getEntry(*i.key());

            if ( entry ){

                updateSearchEntry(*entry, *i.value());

                updated = true;

            }

        }

    }

    if ( updated ){

        forceSearchQuery();

    }

    LOGS_QDEBUG( "logs [ENG] <- LogsMatchesModel::eventsUpdated()" );

}

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

//

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

//

void LogsMatchesModel::eventsAdded(const QModelIndex& parent, int first, int last)

{

    LOGS_QDEBUG( "logs [ENG] -> LogsMatchesModel::eventsAdded()" );

    Q_UNUSED(parent);

    readEvents(first, last);

    forceSearchQuery();

    LOGS_QDEBUG( "logs [ENG] <- LogsMatchesModel::eventsAdded()" );

}

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

//

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

//

void LogsMatchesModel::eventsRemoved(const QModelIndex& parent, int first, int last)

{

    LOGS_QDEBUG( "logs [ENG] -> LogsMatchesModel::eventsRemoved()" );

    Q_UNUSED(parent);

    bool removed( false );

    QMap<LogsCntEntryHandle*, LogsEvent*>::iterator i;

    for (i = mSearchEvents.begin(); i != mSearchEvents.end(); ++i){

        if ( i.value()->index() >= first && i.value()->index() <= last &&

             !i.value()->isInView() ){

            mLogsCntFinder->deleteEntry(*i.key());

            i = mSearchEvents.erase(i);

            removed = true;

        }

    }

    if ( removed ){

        forceSearchQuery();

    }

    LOGS_QDEBUG( "logs [ENG] <- LogsMatchesModel::eventsRemoved()" );

}

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

//

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

//

void LogsMatchesModel::initPredictiveSearch()

{

    int searchStatus = mDbConnector->predictiveSearchStatus();

    //searchStatus equal to 0 means that search should be permanently disabled

    if (searchStatus != 0) {

        mSearchEnabled = (searchStatus == 1 || searchStatus < 0);

        mLogsCntFinder = new LogsCntFinder(LogsCommonData::getInstance().contactManager());

        connect(mLogsCntFinder, SIGNAL(queryReady()),this, SLOT(queryReady()));

        connect( &mParentModel, SIGNAL(dataChanged(const QModelIndex&,const QModelIndex&)), 

                 this, SLOT(eventsUpdated(const QModelIndex&,const QModelIndex&)));

        connect( &mParentModel, SIGNAL(rowsInserted(const QModelIndex&,int,int)), 

                 this, SLOT(eventsAdded(const QModelIndex&,int,int)));

        connect( &mParentModel, SIGNAL(rowsRemoved(const QModelIndex&,int,int)), 

                 this, SLOT(eventsRemoved(const QModelIndex&,int,int)));

        connect( &mParentModel, SIGNAL(modelReset()), this, SLOT(doModelReset()));

        readEvents(0, mParentModel.rowCount());

        mIconManager = new LogsThumbIconManager();

        connect(mIconManager, SIGNAL(contactIconReady(int)),

                this, SLOT(updateContactIcon(int)));

    }

}

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

// Add result container but don't get real data yet. Get data once it is

// really needed.

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

//

LogsMatchesModelItemContainer* LogsMatchesModel::addSearchResult(int resultIndex)

{

    LogsMatchesModelItemContainer* item = new LogsMatchesModelItemContainer(

                    mParentModel, *mIconManager, resultIndex);

    mMatches.append(item);

    return item;

}

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

// Fill result container with real data if it does not yet contain it 

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

//

bool LogsMatchesModel::updateSearchResult(LogsMatchesModelItemContainer& item) const

{

    bool updated( false );

    int resIndex = item.resultIndex();

    if ( item.isNull() && resIndex >= 0 && mLogsCntFinder 

         && resIndex < mLogsCntFinder->resultsCount() ){

        const LogsCntEntry& result = mLogsCntFinder->resultAt(resIndex);

        if ( result.type() == LogsCntEntry::EntryTypeHistory ){

            LogsEvent* event = mSearchEvents.value(result.handle());

            if ( event ){

                item.setEvent(*event);  

                item.updateData(result);

                updated = true;

            }

        } else {

            item.setContact(result.contactId());     

            item.updateData(result);

            updated = true;

        }

    }

    return updated;

}

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

//

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

//

void LogsMatchesModel::readEvents(int first, int last)

{

   for ( int i = first; i < mParentModel.rowCount() && i <= last; ++i ){

        LogsEvent* event = qVariantValue<LogsEvent*>( 

                mParentModel.data( mParentModel.index(i, 0), LogsModel::RoleFullEvent ) );

        if ( event ){

            QObject* entryHandle = new QObject(this);

            LogsCntEntry* entry = new LogsCntEntry(*entryHandle, 0);

            updateSearchEntry(*entry, *event);

            mLogsCntFinder->insertEntry(i, entry);

            mSearchEvents.insert(entryHandle, event);

        }

    }

}

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

//

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

//

void LogsMatchesModel::logsMatches(const QString& pattern)

{

    // Do user inputted searches in async manner to avoid from

    // blocking next input. This also decreases amount of queries when

    // user types fast.

    getLogsMatches(pattern, true);

}

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

//

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

//

LogsContact* LogsMatchesModel::createContact(const QString& number)

{

    LogsContact* contact = new LogsContact(number, *mDbConnector);

    connect( contact, SIGNAL(saveCompleted(bool)), this, SLOT(forceSearchQuery()) );

    return contact;

}

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

//

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

//

void LogsMatchesModel::getLogsMatches(const QString& pattern, 

                                      bool async, 

                                      bool force )

{

    LOGS_QDEBUG_2( "logs [ENG] -> LogsMatchesModel::getLogsMatches(), pattern:", pattern );

    mCurrentSearchPattern = pattern;

    if ( force ){

        // Clear previous results immeditely as some data associated with results

        // might be already gone.

        doModelReset();

        mPrevSearchPattern.clear();

    }

    if ( async ){

        QMetaObject::invokeMethod(this, "doSearchQuery", Qt::QueuedConnection );

    } else {

        doSearchQuery();   

    }

    LOGS_QDEBUG( "logs [ENG] <- LogsMatchesModel::getLogsMatches()" );

}

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

//

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

//

void LogsMatchesModel::doSearchQuery()

{

    LOGS_QDEBUG( "logs [ENG] -> LogsMatchesModel::doSearchQuery()" );

    if (mCurrentSearchPattern != mPrevSearchPattern && mSearchEnabled){

        mPrevSearchPattern = mCurrentSearchPattern;

        if (mCurrentSearchPattern.length() > 0) {

            LOGS_QDEBUG( "logs [ENG]    do search" );

            mLogsCntFinder->predictiveSearchQuery( mCurrentSearchPattern );

        } else {

            // Clear old results for empty search pattern

            doModelReset();

        }

    } else {

        LOGS_QDEBUG( "logs [ENG] pattern hasn't changed or search is OFF" );

    }

    LOGS_QDEBUG( "logs [ENG] <- LogsMatchesModel::doSearchQuery()" );

}

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

//

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

//

void LogsMatchesModel::doModelReset()

{

    qDeleteAll(mMatches);

    mMatches.clear();

    mResultCount = 0;

    reset();

}

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

//

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

//

void LogsMatchesModel::forceSearchQuery()

{

    LOGS_QDEBUG( "logs [ENG] -> LogsMatchesModel::forceSearchQuery()" );

    getLogsMatches( mCurrentSearchPattern, true, true ); 

    LOGS_QDEBUG( "logs [ENG] <- LogsMatchesModel::forceSearchQuery()" );

}

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

//

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

//

void LogsMatchesModel::updateSearchEntry(LogsCntEntry& entry, LogsEvent& event)

{

    if ( event.remoteParty().length() > 0 ) {

        entry.setFirstName(event.remoteParty());

    } else if ( event.number().length() > 0 ) {

        entry.setPhoneNumber(stripPhoneNumber(event.number()));

    } else if ( event.eventType() == LogsEvent::TypeVoIPCall && event.logsEventData() ){

        if ( event.logsEventData()->isCsCompatible() ){

            entry.setPhoneNumber(stripPhoneNumber(event.logsEventData()->remoteUrl()));

        } else {

            entry.setFirstName(event.logsEventData()->remoteUrl());

        }

    }

}

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

//Update the icon for the contact with the given index (row)

//param index of the contact

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

//

void LogsMatchesModel::updateContactIcon(int index)

{

    LOGS_QDEBUG( "logs [ENG] -> LogsMatchesModel::updateContactIcon()" );

    QModelIndex modelIndex = createIndex(index, 0);

    emit dataChanged(modelIndex, modelIndex);

    LOGS_QDEBUG( "logs [ENG] <- LogsMatchesModel::updateContactIcon()" );   

}

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

//

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

//

QString LogsMatchesModel::stripPhoneNumber(const QString& phoneNumber) const

{

    if ( phoneNumber.startsWith(QLatin1Char('+')) ){

        return phoneNumber.mid(1);

    }

    return phoneNumber;

}

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

//