2 Copyright (C) 2012 Intel Corporation
4 This library is free software; you can redistribute it and/or
5 modify it under the terms of the GNU Lesser General Public
6 License as published by the Free Software Foundation; either
7 version 2.1 of the License, or (at your option) any later version.
9 This library is distributed in the hope that it will be useful,
10 but WITHOUT ANY WARRANTY; without even the implied warranty of
11 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
12 Lesser General Public License for more details.
14 You should have received a copy of the GNU Lesser General Public
15 License along with this library; if not, write to the Free Software
16 Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
19 #include "bluetoothplugin.h"
20 #include "timestamp.h"
21 #include "listplusplus.h"
24 #include <boost/assert.hpp>
25 #include <boost/lexical_cast.hpp>
28 #include <QDBusConnection>
29 #include <QDBusInterface>
36 QString SPP_RECORD = "<?xml version=\"1.0\" encoding=\"UTF-8\" ?>"
38 "<attribute id=\"0x0001\">"
40 "<uuid value=\"0x1101\"/>"
43 "<attribute id=\"0x0004\">"
46 "<uuid value=\"0x0100\"/>"
49 "<uuid value=\"0x0003\"/>"
50 "<uint8 value=\"23\" name=\"channel\"/>"
54 "<attribute id=\"0x0100\">"
55 "<text value=\"COM5\" name=\"name\"/>"
59 BluetoothSinkPlugin::BluetoothSinkPlugin(AbstractRoutingEngine* re, map<string, string> config)
60 :AbstractSink(re, config)
62 new BtProfileAdaptor(this);
64 if(!QDBusConnection::systemBus().registerService("org.automotive.message.broker.bluetooth"))
65 DebugOut(DebugOut::Error)<<"Failed to register DBus service name: "<<QDBusConnection::systemBus().lastError().message().toStdString()<<endl;
67 if(!QDBusConnection::systemBus().registerObject("/org/bluez/spp", this))
68 DebugOut(DebugOut::Error)<<"Failed to register DBus object"<<endl;
70 QDBusInterface profileManagerIface("org.bluez", "/org/bluez", "org.bluez.ProfileManager1", QDBusConnection::systemBus());
73 options["Name"] = "AMB spp server";
74 options["Role"] = "server";
75 options["ServiceRecord"] = SPP_RECORD;
76 options["Channel"] = 23;
78 QDBusReply<void> reply = profileManagerIface.call("RegisterProfile", qVariantFromValue(QDBusObjectPath("/org/bluez/spp")), "00001101-0000-1000-8000-00805F9B34FB", options);
82 DebugOut(DebugOut::Error)<<"RegisterProfile call failed: "<<reply.error().message().toStdString()<<endl;
88 extern "C" AbstractSink * create(AbstractRoutingEngine* routingengine, map<string, string> config)
90 return new BluetoothSinkPlugin(routingengine, config);
94 const string BluetoothSinkPlugin::uuid()
96 return "47ec4ed0-dc45-11e3-9c1a-0800200c9a66";
99 void BluetoothSinkPlugin::propertyChanged(AbstractPropertyType *value)
104 void BluetoothSinkPlugin::release()
106 DebugOut()<<"release called."<<endl;
109 void BluetoothSinkPlugin::newConnection(string path, int fd, QVariantMap props)
111 DebugOut()<<"new Connection! Path: "<<path<<endl;
113 socket.setSocketDescriptor(fd);
115 connect(&socket, &QTcpSocket::readyRead, this, &BluetoothSinkPlugin::canHasData);
118 void BluetoothSinkPlugin::requestDisconnection(string path)
120 DebugOut()<<"requestDisconnection called. Path: "<<path<<endl;
124 void BluetoothSinkPlugin::canHasData()
126 QByteArray data = socket.readAll();
128 DebugOut()<<"data read: "<<data.constData()<<endl;
131 BtProfileAdaptor::BtProfileAdaptor(BluetoothSinkPlugin *parent)
132 :QDBusAbstractAdaptor(parent), mParent(parent)
137 void BtProfileAdaptor::Release()
142 void BtProfileAdaptor::NewConnection(QDBusObjectPath device, int fd, QVariantMap fd_properties)
144 mParent->newConnection(device.path().toStdString(), fd, fd_properties);
147 void BtProfileAdaptor::RequestDisconnection(QDBusObjectPath device)
149 mParent->requestDisconnection(device.path().toStdString());