libqtappfw: bluetooth: update to rewrite of bluetooth binding

Bug-AGL: SPEC-1630
Change-Id: I705df82deefa371afa1f1d6ee57bb5457479408d
Signed-off-by: Matt Ranostay <matt.ranostay@konsulko.com>

1 files changed, 92 insertions, 81 deletions

diff --git a/bluetooth/bluetooth.cpp b/bluetooth/bluetooth.cpp
index 7ae8240..091cb26 100644
--- a/bluetooth/bluetooth.cpp
+++ b/bluetooth/bluetooth.cpp
@@ -31,6 +31,7 @@ Bluetooth::Bluetooth (QUrl &url, QObject * parent) :
 
     uuids.insert("a2dp", "0000110a-0000-1000-8000-00805f9b34fb");
     uuids.insert("avrcp", "0000110e-0000-1000-8000-00805f9b34fb");
+    uuids.insert("hfp", "0000111f-0000-1000-8000-00805f9b34fb");
 }
 
 Bluetooth::~Bluetooth()
@@ -38,14 +39,9 @@ Bluetooth::~Bluetooth()
     delete m_mloop;
 }
 
-void Bluetooth::generic_command(QString verb, QString value)
+void Bluetooth::send_command(QString verb, QJsonObject parameter)
 {
     BluetoothMessage *tmsg = new BluetoothMessage();
-    QJsonObject parameter;
-
-    if (!value.isEmpty())
-        parameter.insert("value", value);
-
     tmsg->createRequest(verb, parameter);
     m_mloop->sendMessage(tmsg);
     delete tmsg;
@@ -53,163 +49,178 @@ void Bluetooth::generic_command(QString verb, QString value)
 
 void Bluetooth::setPower(bool state)
 {
-    generic_command("power", state ? "true": "false");
-
-    m_power = state;
-
-    emit powerChanged(m_power);
+    QJsonObject parameter;
+    parameter.insert("powered", state ? "true" : "false");
+    send_command("adapter_state", parameter);
 }
 
 void Bluetooth::setDiscoverable(bool state)
 {
-    const QStringList properties { "Pairable", "Discoverable" };
-    QStringListIterator propertyIterator(properties);
+    QJsonObject parameter;
+    parameter.insert("discoverable", state ? "true" : "false");
+    send_command("adapter_state", parameter);
 
-    while (propertyIterator.hasNext()) {
-        BluetoothMessage *tmsg = new BluetoothMessage();
-        QJsonObject parameter;
+    m_discoverable = state;
 
-        parameter.insert("Property", propertyIterator.next());
-        parameter.insert("value", state ? "true" : "false");
+    emit discoverableChanged();
+}
 
-        tmsg->createRequest("set_property", parameter);
-        m_mloop->sendMessage(tmsg);
-        delete tmsg;
-    }
+void Bluetooth::discovery_command(bool state)
+{
+    QJsonObject parameter;
+    parameter.insert("discovery", state ? "true" : "false");
 
-    m_discoverable = state;
+    set_discovery_filter();
 
-    emit discoverableChanged();
+    send_command("adapter_state", parameter);
 }
 
 void Bluetooth::start_discovery()
 {
-    generic_command("start_discovery", "");
-    generic_command("discovery_result", "");
+    discovery_command(true);
+
+    // temp workaround to list already discovered devices
+    send_command("managed_objects", QJsonObject());
 }
 
 void Bluetooth::stop_discovery()
 {
-    generic_command("stop_discovery", "");
+    discovery_command(false);
 }
 
-void Bluetooth::remove_device(QString address)
+void Bluetooth::remove_device(QString device)
 {
-    generic_command("remove_device", address);
+    QJsonObject parameter;
+    parameter.insert("device", device);
+
+    send_command("remove_device", parameter);
 }
 
-void Bluetooth::pair(QString address)
+void Bluetooth::pair(QString device)
 {
-    generic_command("pair", address);
+    QJsonObject parameter;
+    parameter.insert("device", device);
+
+    send_command("pair", parameter);
 }
 
-void Bluetooth::cancel_pair(QString address)
+void Bluetooth::cancel_pair(QString device)
 {
-    generic_command("cancel_pair", address);
+    send_command("cancel_pairing", QJsonObject());
 }
 
-void Bluetooth::connect(QString address, QString uuid)
+void Bluetooth::connect(QString device, QString uuid)
 {
-    BluetoothMessage *tmsg = new BluetoothMessage();
     QJsonObject parameter;
-
     uuid = process_uuid(uuid);
-
-    parameter.insert("value", address);
+    parameter.insert("device", device);
     parameter.insert("uuid", uuid);
-    tmsg->createRequest("connect", parameter);
-    m_mloop->sendMessage(tmsg);
-    delete tmsg;
+    send_command("connect", parameter);
 }
 
-void Bluetooth::connect(QString address)
+void Bluetooth::connect(QString device)
 {
-    generic_command("connect", address);
+    QJsonObject parameter;
+    parameter.insert("device", device);
+    send_command("connect", parameter);
 }
 
-void Bluetooth::disconnect(QString address, QString uuid)
+void Bluetooth::disconnect(QString device, QString uuid)
 {
-    BluetoothMessage *tmsg = new BluetoothMessage();
     QJsonObject parameter;
-
     uuid = process_uuid(uuid);
-
-    parameter.insert("value", address);
+    parameter.insert("device", device);
     parameter.insert("uuid", uuid);
-    tmsg->createRequest("disconnect", parameter);
-    m_mloop->sendMessage(tmsg);
-    delete tmsg;
+    send_command("disconnect", parameter);
 }
 
-void Bluetooth::disconnect(QString address)
+void Bluetooth::disconnect(QString device)
 {
-    generic_command("disconnect", address);
+    QJsonObject parameter;
+    parameter.insert("device", device);
+    send_command("disconnect", parameter);
 }
 
-void Bluetooth::send_confirmation()
+void Bluetooth::send_confirmation(int pincode)
 {
-    generic_command("send_confirmation", "yes");
+    QJsonObject parameter;
+    parameter.insert("pincode", pincode);
+    send_command("confirm_pairing", parameter);
+}
+
+
+void Bluetooth::set_discovery_filter()
+{
+    QStringListIterator eventIterator(uuids.values());
+    QJsonObject parameter;
+    QJsonArray array;
+
+    while (eventIterator.hasNext())
+        array.push_back(eventIterator.next());
+
+    // send inital adapter state + discovery filter
+    parameter.insert("filter", array);
+    send_command("adapter_state", parameter);
 }
 
 void Bluetooth::onConnected()
 {
     QStringListIterator eventIterator(events);
-    BluetoothMessage *tmsg;
 
     while (eventIterator.hasNext()) {
-        tmsg = new BluetoothMessage();
         QJsonObject parameter;
         parameter.insert("value", eventIterator.next());
-        tmsg->createRequest("subscribe", parameter);
-        m_mloop->sendMessage(tmsg);
-        delete tmsg;
+        send_command("subscribe", parameter);
     }
 
-    // get initial power state
-    generic_command("power", QString());
-
     // send initial list
-    generic_command("discovery_result", "");
+    send_command("managed_objects", QJsonObject());
+
+    // get initial power state
+    send_command("adapter_state", QJsonObject());
 }
 
 void Bluetooth::onDisconnected()
 {
     QStringListIterator eventIterator(events);
-    BluetoothMessage *tmsg;
 
     while (eventIterator.hasNext()) {
-        tmsg = new BluetoothMessage();
         QJsonObject parameter;
         parameter.insert("value", eventIterator.next());
-        tmsg->createRequest("unsubscribe", parameter);
-        m_mloop->sendMessage(tmsg);
-        delete tmsg;
+        send_command("unsubscribe", parameter);
     }
 }
 
+void Bluetooth::processDeviceChangesEvent(QJsonObject data)
+{
+    QString action = data.value("action").toString();
+
+    if (action == "added")
+        emit deviceAddedEvent(data);
+    else if (action == "changed")
+        emit deviceUpdatedEvent(data);
+    else if (action == "removed")
+        emit deviceRemovedEvent(data);
+}
+
 void Bluetooth::onMessageReceived(MessageType type, Message *msg)
 {
     if (msg->isEvent() && type == BluetoothEventMessage) {
         BluetoothMessage *tmsg = qobject_cast<BluetoothMessage*>(msg);
 
-        if (tmsg->isConnectionEvent()) {
-            emit connectionEvent(tmsg->eventData());
-        } else if (tmsg->isRequestConfirmationEvent()) {
+        if (tmsg->isDeviceChangesEvent()) {
+            processDeviceChangesEvent(tmsg->eventData());
+        } else if (tmsg->isAgentEvent()) {
             emit requestConfirmationEvent(tmsg->eventData());
-        } else if (tmsg->isDeviceAddedEvent()) {
-            emit deviceAddedEvent(tmsg->eventData());
-        } else if (tmsg->isDeviceRemovedEvent()) {
-            emit deviceRemovedEvent(tmsg->eventData());
-        } else if (tmsg->isDeviceUpdatedEvent()) {
-            emit deviceUpdatedEvent(tmsg->eventData());
         }
+
     } else if (msg->isReply() && type == ResponseRequestMessage) {
         ResponseMessage *tmsg = qobject_cast<ResponseMessage*>(msg);
 
-        if (tmsg->requestVerb() == "discovery_result") {
+        if (tmsg->requestVerb() == "managed_objects") {
             emit deviceListEvent(tmsg->replyData());
-        } else if (tmsg->requestVerb() == "power") {
-            m_power = tmsg->replyData().value("power").toString() == "on";
+        } else if (tmsg->requestVerb() == "adapter_state") {
+            m_power = tmsg->replyData().value("powered").toBool();
             emit powerChanged(m_power);
         }
     }