/****************************************************************************

**

** Copyright (C) 2010 Nokia Corporation and/or its subsidiary(-ies).

** All rights reserved.

** Contact: Nokia Corporation (qt-info@nokia.com)

**

** This file is part of the Qt Mobility Components.

**

** $QT_BEGIN_LICENSE:LGPL$

** No Commercial Usage

** This file contains pre-release code and may not be distributed.

** You may use this file in accordance with the terms and conditions

** contained in the Technology Preview License Agreement accompanying

** this package.

**

** GNU Lesser General Public License Usage

** Alternatively, this file may be used under the terms of the GNU Lesser

** General Public License version 2.1 as published by the Free Software

** Foundation and appearing in the file LICENSE.LGPL included in the

** packaging of this file.  Please review the following information to

** ensure the GNU Lesser General Public License version 2.1 requirements

** will be met: http://www.gnu.org/licenses/old-licenses/lgpl-2.1.html.

**

** In addition, as a special exception, Nokia gives you certain additional

** rights.  These rights are described in the Nokia Qt LGPL Exception

** version 1.1, included in the file LGPL_EXCEPTION.txt in this package.

**

** If you have questions regarding the use of this file, please contact

** Nokia at qt-info@nokia.com.

**

**

**

**

**

**

**

**

** $QT_END_LICENSE$

**

****************************************************************************/

#include "eventloggerengine_maemo_p.h"

#include "telepathyengine_maemo_p.h"

#include <QDebug>

QTM_BEGIN_NAMESPACE

Q_GLOBAL_STATIC(EventLoggerEngine,eventLoggerEngine);

EventLoggerEngine* EventLoggerEngine::instance()

{

    return eventLoggerEngine();

}

EventLoggerEngine::EventLoggerEngine(QObject *parent):QObject(parent)

{

  //    qDebug() << "EventLoggerEngine::EventLoggerEngine";

    DBusError err=DBUS_ERROR_INIT;

    active = false;

    g_type_init();

    dbus = dbus_bus_get(DBUS_BUS_SESSION, &err); // Create dummy Dbus object and

    dbus_connection_setup_with_g_main (dbus, NULL); //add it to g_mainloop because eventlogger library expects that someone alse has added session bus to g_mainloop

    el=rtcom_el_new ();

    if(!RTCOM_IS_EL(el)) qDebug() << "EventLoggerEngine::EventLoggerEngine():Could't create RTComEl\n";

    queryThread=0;

    //    queryThread.run();

    //    connect(queryThread, SIGNAL(messagesFound(const QMessageIdList &)),this, SLOT(messagesFound_(const QMessageIdList &)));

    g_signal_connect(G_OBJECT(el), "new-event", G_CALLBACK(new_event_cb),(void*)this);

}

void EventLoggerEngine::new_event_cb(RTComEl *el,int event_id,

                                    const char *local_uid,const char *remote_uid,const char *remote_ebook_uid,

                                    const char *group_uid,const char *service,EventLoggerEngine *p)

{

  Q_UNUSED(el);

  p->newEvent(event_id, local_uid,remote_uid ,remote_ebook_uid,group_uid,service);

};

void EventLoggerEngine::newEvent(int event_id,

                                const char *local_uid,const char *remote_uid,const char *remote_ebook_uid,

                                const char *group_uid,const char *service)

{

  Q_UNUSED(local_uid); Q_UNUSED(remote_uid);Q_UNUSED(remote_ebook_uid);

  Q_UNUSED(group_uid);Q_UNUSED(service);

    QMessageId id(eventIds);

    notification(event_id,service,QMessageStorePrivate::Added);

}

QMessageManager::NotificationFilterId EventLoggerEngine::registerNotificationFilter(QMessageStorePrivate& aPrivateStore,

                                                                           const QMessageFilter &filter)

{

    iListenForNotifications = true;

    ipMessageStorePrivate = &aPrivateStore;

    int filterId = ++_filterId;

    _filters.insert(filterId, filter);

    return filterId;

}

void EventLoggerEngine::unregisterNotificationFilter(QMessageManager::NotificationFilterId notificationFilterId)

{

    _filters.remove(notificationFilterId);

    if (_filters.count() == 0) {

        iListenForNotifications = false;

    }

}

QMessage EventLoggerEngine::eventToMessage(RTComElEvent & ev)

{

    QMessage message;

    if (!strcmp(ev.fld_service, "RTCOM_EL_SERVICE_SMS")) {

        message.setType(QMessage::Sms);

    } else if (!strcmp(ev.fld_service,"RTCOM_EL_SERVICE_CHAT")) {

        message.setType(QMessage::InstantMessage);

    } else {

        message.setType(QMessage::NoType);  // Other type, as exampele voice Call

    };

    message.setParentAccountId(QMessageAccountId(QString("y/Account/%1").arg(ev.fld_local_uid)));

    if (!ev.fld_is_read) {

        message.setStatus(QMessage::Read);

    };

    message.setPriority(QMessage::NormalPriority);

    message.setDate(QDateTime::fromTime_t(ev.fld_start_time));

    message.setReceivedDate(QDateTime::fromTime_t(ev.fld_start_time));

    if (ev.fld_outgoing) QMessagePrivate::setStandardFolder(message,QMessage::SentFolder);

    else

      QMessagePrivate::setStandardFolder(message,QMessage::InboxFolder);

    //    qDebug() << "event_type:"  << ev.fld_event_type << ev.fld_event_type_id << "Outgoing:" << ev.fld_outgoing << " Folder:" << message.standardFolder();

    message.setFrom(QMessageAddress(QMessageAddress::Phone, QString(ev.fld_remote_uid)));

    QMessagePrivate::setSenderName(message, QString(ev.fld_remote_uid));

    QMessageAddressList messageAddresslist;

    messageAddresslist.append(QMessageAddress(QMessageAddress::Phone, QString(ev.fld_local_uid)));

    message.setTo(messageAddresslist);

    message.setBody(QString(ev.fld_free_text));

    QMessagePrivate* privateMessage = QMessagePrivate::implementation(message);

    privateMessage->_modified = false;

    // qDebug() << "id:" << message.id().toString() << "From:" << message.from().addressee() << "Text:" << message.textContent();

    return message;

}

bool EventLoggerEngine::deleteMessage(const QMessageId& id)

{

  return status==0;

}

QMessage EventLoggerEngine::message(const QMessageId& id)

{

    QMessage message;

    // qDebug() << "EventLoggerEngine::getMessage id=" << id.toString();

    RTComElEvent ev;

    bzero(&ev,sizeof(ev));

    RTComElQuery *q=rtcom_el_query_new(el);

    RTComElIter *iter=rtcom_el_get_events(el,q);

    g_object_unref(q);

    if(iter && rtcom_el_iter_first(iter))

    {

     gboolean res=rtcom_el_iter_get_full(iter,&ev);

     if(res) {

#if 0

         printf("got event id=%d service_id=%d event_typ_id=%d\n\

local_uid=%s local_name=%s\n\

remote_uid=%s remote_name=%s remote_ebook_uid=%s\n\

channel=%s free_text=%s group_uid=%s\n\

service=%s event_type=%s\n\

additional_text=%s icon_name=%s pango_markup=%s\n",

                    ev.fld_id,ev.fld_service_id,ev.fld_event_type_id,

                    ev.fld_local_uid,ev.fld_local_name,

                    ev.fld_remote_uid,ev.fld_remote_name,ev.fld_remote_ebook_uid,

                    ev.fld_channel,ev.fld_free_text,ev.fld_group_uid,

                    ev.fld_service,ev.fld_event_type,

                    ev.fld_additional_text,ev.fld_icon_name,ev.fld_pango_markup);

#endif

         if (!strcmp(ev.fld_service, "RTCOM_EL_SERVICE_SMS")) {

             message.setType(QMessage::Sms);

         } else if (!strcmp(ev.fld_service,"RTCOM_EL_SERVICE_CHAT")) {

             message.setType(QMessage::InstantMessage);

         } else {

             message.setType(QMessage::NoType);  // Other type, as exampele voice Call

         };

         //QMessageAccount account =  TelepathyEngine::instance()->account(QMessageAccountId(QString("/y/Account%1").arg(ev.fld_local_uid)));

         message.setParentAccountId(QMessageAccountId(QString("/y/Account/%1").arg(ev.fld_local_uid)));

         if (!ev.fld_is_read) {

             message.setStatus(QMessage::Read);

         };

         message.setPriority(QMessage::NormalPriority);

         message.setDate(QDateTime::fromTime_t(ev.fld_start_time));

         message.setReceivedDate(QDateTime::fromTime_t(ev.fld_start_time));

	 if (ev.fld_outgoing) QMessagePrivate::setStandardFolder(message,QMessage::SentFolder);

	 else

	   QMessagePrivate::setStandardFolder(message,QMessage::InboxFolder);

         message.setFrom(QMessageAddress(QMessageAddress::Phone, QString(ev.fld_remote_uid)));

         QMessagePrivate::setSenderName(message, QString(ev.fld_remote_uid));

         QMessageAddressList messageAddresslist;

         messageAddresslist.append(QMessageAddress(QMessageAddress::Phone, QString(ev.fld_local_uid)));

         message.setTo(messageAddresslist);

         message.setBody(QString(ev.fld_free_text));

         QMessagePrivate* privateMessage = QMessagePrivate::implementation(message);

         privateMessage->_id = id;

         privateMessage->_modified = false;

	 //  qDebug() << "id:" << message.id().toString() << "From:" << message.from().addressee() << "Text:" << message.textContent();

     };

    };

    if(iter) g_object_unref(iter);

    //    debugMessage(message);

    return message;

}

void EventLoggerEngine::debugMessage(QMessage &message)

{

    qDebug() << "id:" << message.id().toString() << "type:" << message.type() << "size:" << message.size() << "status:" << message.status() << "priority:" << message.priority();

    qDebug() << "AccountId:" << message.parentAccountId().toString() << "StantardFolder" << message.standardFolder() << "parenFolderId:" << message.parentFolderId().toString();

    qDebug() << "Date:" << message.date() << "receivedDate:" << message.receivedDate() << "Subject:" << message.subject();

    qDebug() << "From:" << message.from().addressee();

    qDebug() << "To:" << (message.to().isEmpty() ? "**none**" : message.to().first().addressee());

    qDebug() << "Body:" <<message.textContent();

}

void EventLoggerEngine::notification(int eventId, QString service,QMessageStorePrivate::NotificationType notificationType)

{

    QMessageManager::NotificationFilterIdSet matchingFilters;

    // qDebug() << "EventLoggerEngine::notification id=" << eventId;

    // Copy the filter map to protect against modification during traversal

    QMap<int, QMessageFilter> filters(_filters);

    QMap<int, QMessageFilter>::const_iterator it = filters.begin(), end = filters.end();

    QMessage msg;

    bool messageRetrieved = false;

    for ( ; it != end; ++it) {

        const QMessageFilter &filter(it.value());

        if (filter.isEmpty()) {

            // Empty filter matches to all messages

            matchingFilters.insert(it.key());

        } else {

            QMessageFilterPrivate* privateMessageFilter = QMessageFilterPrivate::implementation(filter);

            if (!messageRetrieved && (privateMessageFilter->_field == QMessageFilterPrivate::Type)) {

                if (service == "RTCOM_EL_SERVICE_SMS") {

                    msg.setType(QMessage::Sms);

                } else if (service== "RTCOM_EL_SERVICE_CHAT") {

                    msg.setType(QMessage::InstantMessage);

                } else {

                    msg.setType(QMessage::NoType);  // Other type, as eample voice calll

                }

            }

            else if (!messageRetrieved) {

                if (msg.type() == QMessage::NoType) {

                    matchingFilters.clear();

                    break;

                } else {

                    messageRetrieved = true;

                }

            }

            if (privateMessageFilter->filter(msg)) {

                matchingFilters.insert(it.key());

            }

        }

    }

    if (matchingFilters.count() > 0) {

            ipMessageStorePrivate->messageNotification(notificationType,

                                                       matchingFilters);

        }

}

#if 0

QMessageIdList EventLoggerEngine::filterAndOrderMessages(const QMessageFilter &filter, const QMessageSortOrder& sortOrder,

                                                    QString body, QMessageDataComparator::MatchFlags matchFlags)

{

    filterAndOrderMessages(filte, sortOrder, body, matchFlags);

}

#endif

bool EventLoggerEngine::filterMessages(const QMessageFilter &filter,

                                                    const QMessageSortOrder& sortOrder,

                                                    QString body,

                                                    QMessageDataComparator::MatchFlags matchFlags)

{

  //  qDebug() << "EventLoggerEngine::filterMessages";

  if (active) {

    qWarning() << "EventLoggerEngine::filterMessages::Service is currently busy";

    return false;

  }

  active = true;

  state = QMessageService::ActiveState;

  emit stateChanged(state);

  if(!queryThread) {

    queryThread=new QueryThread();

    connect(queryThread, SIGNAL(completed()), this, SLOT(reportMatchingIds()), Qt::QueuedConnection);

  };

  queryThread->setArgs(this, filter, body, matchFlags, sortOrder, 0,0);

  queryThread->start();

    //  return queryThread.queryMessages(filter,sortOrder,body,matchFlags);

    return true;

}

void EventLoggerEngine::messagesFound_(const QMessageIdList &ids)

{

  //  qDebug() << "EventLoggerEngine::messagesFound";

  emit messagesFound(ids,true,false); // filtered but not sorted

}

void EventLoggerEngine::reportMatchingIds()

{

  //  qDebug() << "EventLoggerEngine::messagesFound" << m_ids.count();

  emit messagesFound(m_ids,true,false);

  completed();

}

void EventLoggerEngine::completed()

{

    active = false;

    state = QMessageService::FinishedState;

    emit stateChanged(state);

}

QMessageIdList EventLoggerEngine::filterAndOrderMessages(const QMessageFilter &filter,

                                                    const QMessageSortOrder& sortOrder,

                                                    QString body,

                                                    QMessageDataComparator::MatchFlags matchFlags)

{

  Q_UNUSED(body);

  Q_UNUSED(matchFlags);

  Q_UNUSED(sortOrder);

    QMessageId fId;  // Filtering id

    //    QMessageType fType;

    QDate fDate;

    RTComElEvent ev;

    QMessage message;

    const char *services[]={"RTCOM_EL_SERVICE_CHAT","RTCOM_EL_SERVICE_SMS", NULL };

    QMessageIdList idList;

    QMessageFilterPrivate* pf = QMessageFilterPrivate::implementation(filter);

#if 0

    if ((filters.count() == 1) && (pf->_field == QMessageFilterPrivate::None) && (pf->_filterList.count() == 0)) {

        if (pf->_notFilter) {

            // There is only one filter: empty ~QMessageFilter()

            // => return empty QMessageIdList

            return idList;

        } else {

            // There is only one filter: empty QMessageFilter()

            // => return all messages

            }

        }

    // Pre-filtering setup

    switch (pf->_field) {

    case QMessageFilterPrivate::Id:

    case QMessageFilterPrivate::ParentAccountId:

        {

        if (pf->_comparatorType == QMessageFilterPrivate::Equality) { // QMessageAccountId

            iNumberOfHandledFilters++;

            QMessageDataComparator::EqualityComparator cmp(static_cast<QMessageDataComparator::EqualityComparator>(pf->_comparatorValue));

            if (cmp == QMessageDataComparator::Equal) {

                QMessageAccount messageAccount = TelepathyEngine::instance()->account(QMessageAccountId(QString("/y/Account%1").arg(pf->_value.toString())));

            }

        }

       }

    }

#endif

    RTComElQuery *q=rtcom_el_query_new(el);

    rtcom_el_query_prepare(q,"service", services, RTCOM_EL_OP_IN_STRV, NULL);

    RTComElIter *iter=rtcom_el_get_events(el,q);

    g_object_unref(q);

    if(iter && rtcom_el_iter_first(iter))

       do {

         bzero(&ev,sizeof(ev));

         if(rtcom_el_iter_get_full(iter,&ev))

	   {

	     message=eventToMessage(ev);

	     // debugMessage(message);

	     if (pf->filter(message)) {

	       //   qDebug() <<"Filter :filtering match" << message.id().toString();

	       //matchingFilters.insert(it.key());

	       idList.append(message.id());

	     };

	   };

       }

       while( rtcom_el_iter_next(iter));

#if 0

    foreach(const QMessageId& id, idList) {

         	  qDebug() << "id=" << id.toString();

        }

#endif

    return idList;

}

QueryThread::QueryThread(): QThread()

{

}

void QueryThread::setArgs(EventLoggerEngine *parent, const QMessageFilter &filter, const QString &body, QMessageDataComparator::MatchFlags matchFlags, const QMessageSortOrder &sortOrder, uint limit, uint offset)

{

  _parent=parent;

  _filter=filter;

  _body=body;

  _matchFlags=matchFlags;

  _sortOrder=sortOrder;

  _limit=limit;

  _offset=offset;

}

void QueryThread::run()

{

  //  qDebug() << "QueryThread::run()";

  _parent->m_ids=EventLoggerEngine::instance()->filterAndOrderMessages(_filter,_sortOrder,_body,_matchFlags);

  //  qDebug() << "QueryThread::run() done" << _parent->m_ids.count();

  emit completed();

}

#include "moc_eventloggerengine_maemo_p.cpp"

QTM_END_NAMESPACE