dbusadapter.cpp

/*
 * Copyright 2014 Ruediger Gad
 * Copyright 2014 Uladzislau Vasilyeu 
 *
 * This file is part of SkippingStones.
 *
 * SkippingStones is largely based on libpebble by Liam McLoughlin
 * https://github.com/Hexxeh/libpebble
 *
 * SkippingStones is published under the same license as libpebble (as of 10-02-2014):
 *
 * Permission is hereby granted, free of charge, to any person obtaining a copy of this software
 * and associated documentation files (the "Software"), to deal in the Software without restriction,
 * including without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense,
 * and/or sell copies of the Software, and to permit persons to whom the Software is furnished to do so,
 * subject to the following conditions:
 *
 * The above copyright notice and this permission notice shall be included in all copies or
 * substantial portions of the Software.
 *
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED,
 * INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A
 * PARTICULAR PURPOSE AND NONINFRINGEMENT.
 * IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM,
 * DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE,
 * ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 *
 */

#include "dbusadapter.h"
#include <QDebug>
#include <QDBusConnection>
#include <QDBusInterface>
#include <QVariant>
#include "phonebook.h"

DbusAdapter::DbusAdapter(QObject *parent) :
    QObject(parent)
{
    QDBusConnection systemConn = QDBusConnection::systemBus();
    systemConn.connect("org.ofono", "/ril_0", "org.ofono.VoiceCallManager", "CallAdded",
                         this, SLOT(_phoneCall(QDBusMessage)));
    systemConn.connect("", "/ril_0/voicecall01", "org.ofono.VoiceCall", "PropertyChanged",
                         this, SLOT(_phoneState(QDBusMessage)));
    systemConn.connect("org.ofono", "/ril_0", "org.ofono.MessageManager", "IncomingMessage",
                         this, SLOT(_smsReceived(QDBusMessage)));

    QDBusConnection sessionConn = QDBusConnection::sessionBus();
    sessionConn.connect("", "/", "org.coderus.harbour_mitakuuluu_server", "messageReceived",
                        this, SLOT(_mitakuuluuMessageReceived(QDBusMessage)));

    qDebug() << "Setting up hack for getting notifications...";
    // The inspiration for this hack was taken from: http://stackoverflow.com/questions/22592042/qt-dbus-monitor-method-calls
    sessionConn.registerObject("/org/freedesktop/Notifications", this, QDBusConnection::ExportAllSlots);
    QString matchString = "interface='org.freedesktop.Notifications',member='Notify',type='method_call',eavesdrop='true'";
    QDBusInterface busInterface("org.freedesktop.DBus", "/org/freedesktop/DBus",
                                "org.freedesktop.DBus");
    busInterface.call("AddMatch", matchString);
    qDebug() << "Leaving constructor...";
}

uint DbusAdapter::Notify(const QString &app_name, uint replaces_id, const QString &app_icon, const QString &summary, const QString &body, const QStringList &actions, const QVariantHash &hints, int expire_timeout) {
    qDebug() << "Got notification via dbus from" << app_name;

    if (app_name == "messageserver5") {
        qDebug() << "Got notification from messageserver5, assuming e-mail.";

        emit email(hints.value("x-nemo-preview-summary", "default").toString(),
                   hints.value("x-nemo-preview-body", "default").toString(),
                   hints.value("x-nemo.email.published-messages", "default").toString());
    } else if (app_name == "commhistoryd") {
        if (summary == "" && body == "") {
            emit commhistoryd(hints.value("x-nemo-preview-summary", "default").toString(),
                              hints.value("x-nemo-preview-body", "default").toString());
        } else {
            qDebug() << "Ignoring this commhistoryd message:" << summary << ";" << body << ";" << hints;
        }
    } else {
        emit notify(app_name, summary, body);
    }
}

void DbusAdapter::_mitakuuluuMessageReceived(QDBusMessage msg) {
    qDebug() << "Mitakuuluu messageReceived:" << msg;

    QDBusArgument *arg = (QDBusArgument *) msg.arguments().at(0).data();

    if (arg->currentType() == QDBusArgument::MapType) {
        QMap<QString, QString> argMap = unpackMessage(*arg);

        qDebug() << "Extracted argument map:" << argMap;
        emit commhistoryd(argMap.value("author"), argMap.value("message"));
    }
}

void DbusAdapter::_phoneState(QDBusMessage msg) {
    qDebug() << "Got phone call state dbus message:" << msg;

    QList<QVariant> outArgs = msg.arguments();
    QVariant state = outArgs.at(0);
    if (state.canConvert(QVariant::String) && state.toString() == "State") {
        qDebug() <<"Phone Call State";
        QVariant argument = outArgs.at(1);
        const QVariant v = qvariant_cast<QDBusVariant>(argument).variant();
        if (v.canConvert(QVariant::String)) {
            if (v.toString() == "active"){
                emit phoneCallStart();
                qDebug() << v.toString();
            }
            if (v.toString() == "disconnected"){
                emit phoneCallEnd();
                qDebug() << v.toString();
            }
        }
    }else{
        qDebug() <<"No State ";
    }
}

void DbusAdapter::_phoneCall(QDBusMessage msg) {
    qDebug() << "Got phone call dbus message:" << msg;

    QDBusArgument *arg = (QDBusArgument *) msg.arguments().at(1).data();

    if (arg->currentType() == QDBusArgument::MapType) {
        QMap<QString, QString> argMap = unpackMessage(*arg);

        qDebug() << "Extracted argument map:" << argMap;

        if (argMap.value("State") == "incoming") {
            PhoneBook phonebook;
            emit phoneCall(argMap.value("LineIdentification"), phonebook.NameByPhoneNumber(argMap.value("LineIdentification")));
        }
    }
}

void DbusAdapter::_smsReceived(QDBusMessage msg) {
    qDebug() << "Got sms dbus message:" << msg;

    QDBusArgument *arg = (QDBusArgument *) msg.arguments().at(1).data();

    if (arg->currentType() == QDBusArgument::MapType) {
        QMap<QString, QString> argMap = unpackMessage(*arg);

        qDebug() << "Extracted argument map:" << argMap;
        emit smsReceived(msg.arguments().at(0).toString(), argMap.value("Sender"));
    }
}

QMap<QString, QString> DbusAdapter::unpackMessage(const QDBusArgument &arg) {
    QMap<QString, QString> argMap;

    arg.beginMap();
    while (! arg.atEnd()) {
        QString key;
        QVariant value;

        arg.beginMapEntry();
        arg >> key >> value;
        if (value.canConvert(QVariant::String)) {
            argMap.insert(key, value.toString());
        }
        arg.endMapEntry();
    }
    arg.endMap();

    return argMap;
}