allow receiving responses to commands in watchconnector

* the skeleton is in place for watchconnector to allow query->response
  messages. I've used call/cc style because it is impossible to make
  QBluetoothSocket synchronous (waitForReadyRead() is a no-op)

* remove watchcommands, instead create musicmanager to listen for the
  music endpoint. The other (simpler) endpoints are now listened in
  watchconnector itself. hangupAll() slot is moved to voicecallmanager.

* instead of emitting signals for each received message, listeners
  can now register for receiving messages targeted towards a given
  endpoint

* when reading from bluetoothsocket, properly handle short reads

* remove useless 'watch' namespace

* create appmanager, which mantains a database of installed apps
  (installed on the phone, that is; watch installed apps will come
  later)

* all the *Managers are now instantiated by the main Manager itself

* introduce Unpacker helper class for decoding watch messages

* implement getAppbankStatus and getAppbankUuids messages and response
  parsers

* remove file logging for now (20MB is bad for eMMC!)

* use dbus object path /org/pebbled instead of /

1 files changed, 97 insertions, 0 deletions

diff --git a/daemon/musicmanager.cpp b/daemon/musicmanager.cpp
new file mode 100644
index 0000000..abea715
--- /dev/null
+++ b/daemon/musicmanager.cpp
@@ -0,0 +1,97 @@
+#include <QtDBus>
+#include "musicmanager.h"
+
+MusicManager::MusicManager(WatchConnector *watch, QObject *parent)
+    : QObject(parent), watch(watch)
+{
+    watch->setEndpointHandler(WatchConnector::watchMUSIC_CONTROL, [this](const QByteArray& data) {
+        musicControl(WatchConnector::MusicControl(data.at(0)));
+        return true;
+    });
+}
+
+void MusicManager::onMprisMetadataChanged(QVariantMap metadata)
+{
+    QString track = metadata.value("xesam:title").toString();
+    QString album = metadata.value("xesam:album").toString();
+    QString artist = metadata.value("xesam:artist").toString();
+    logger()->debug() << __FUNCTION__ << track << album << artist;
+    watch->sendMusicNowPlaying(track, album, artist);
+}
+
+void MusicManager::musicControl(WatchConnector::MusicControl operation)
+{
+    logger()->debug() << "Operation:" << operation;
+
+    QString mpris = parent()->property("mpris").toString();
+    if (mpris.isEmpty()) {
+        logger()->debug() << "No mpris interface active";
+        return;
+    }
+
+    QString method;
+
+    switch(operation) {
+    case WatchConnector::musicPLAY_PAUSE:
+        method = "PlayPause";
+        break;
+    case WatchConnector::musicPAUSE:
+        method = "Pause";
+        break;
+    case WatchConnector::musicPLAY:
+        method = "Play";
+        break;
+    case WatchConnector::musicNEXT:
+        method = "Next";
+        break;
+    case WatchConnector::musicPREVIOUS:
+        method = "Previous";
+        break;
+    case WatchConnector::musicVOLUME_UP:
+    case WatchConnector::musicVOLUME_DOWN: {
+        QDBusConnection bus = QDBusConnection::sessionBus();
+        QDBusReply<QDBusVariant> VolumeReply = bus.call(
+                    QDBusMessage::createMethodCall(mpris, "/org/mpris/MediaPlayer2", "org.freedesktop.DBus.Properties", "Get")
+                    << "org.mpris.MediaPlayer2.Player" << "Volume");
+        if (VolumeReply.isValid()) {
+            double volume = VolumeReply.value().variant().toDouble();
+            if (operation == WatchConnector::musicVOLUME_UP) {
+                volume += 0.1;
+            }
+            else {
+                volume -= 0.1;
+            }
+            logger()->debug() << "Setting volume" << volume;
+            QDBusError err = QDBusConnection::sessionBus().call(
+                        QDBusMessage::createMethodCall(mpris, "/org/mpris/MediaPlayer2", "org.freedesktop.DBus.Properties", "Set")
+                        << "org.mpris.MediaPlayer2.Player" << "Volume" << QVariant::fromValue(QDBusVariant(volume)));
+            if (err.isValid()) {
+                logger()->error() << err.message();
+            }
+        } else {
+            logger()->error() << VolumeReply.error().message();
+        }
+        }
+        return;
+    case WatchConnector::musicGET_NOW_PLAYING:
+        onMprisMetadataChanged(parent()->property("mprisMetadata").toMap());
+        return;
+
+    case WatchConnector::musicSEND_NOW_PLAYING:
+        logger()->warn() << "Operation" << operation << "not supported";
+        return;
+    }
+
+    if (method.isEmpty()) {
+        logger()->error() << "Requested unsupported operation" << operation;
+        return;
+    }
+
+    logger()->debug() << operation << "->" << method;
+
+    QDBusError err = QDBusConnection::sessionBus().call(
+                QDBusMessage::createMethodCall(mpris, "/org/mpris/MediaPlayer2", "org.mpris.MediaPlayer2.Player", method));
+    if (err.isValid()) {
+        logger()->error() << err.message();
+    }
+}