mirror of
https://github.com/linuxdeepin/dde-dock.git
synced 2025-06-03 00:15:21 +00:00
1fe8ddfcac
在刚开机时，蓝牙插件在获取适配器信息时，可能在将检测到的设备ID与已存在的设备列表比较时，将检测到的ID存入QMap，但是没有存入对象， 后面仅通过判断ID时，认为适配器已经加入QMap中，就不再加入设备对象，后面在判断对象是否为空的地方，都直接返回了，导致信号连接没有触发。 Log: 修复任务栏蓝牙插件设备列表无法刷新的问题。 Bug: https://pms.uniontech.com/zentao/bug-view-57913.html Change-Id: If43ae449e378fde23649eba2fd4208a4d01b375d
305 lines
10 KiB
C++
305 lines
10 KiB
C++
/*
|
|
* Copyright (C) 2016 ~ 2018 Deepin Technology Co., Ltd.
|
|
*
|
|
* Author: zhaolong <zhaolong@uniontech.com>
|
|
*
|
|
* Maintainer: zhaolong <zhaolong@uniontech.com>
|
|
*
|
|
*
|
|
* This program is free software: you can redistribute it and/or modify
|
|
* it under the terms of the GNU General Public License as published by
|
|
* the Free Software Foundation, either version 3 of the License, or
|
|
* any later version.
|
|
*
|
|
* This program is distributed in the hope that it will be useful,
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
* GNU General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU General Public License
|
|
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
*/
|
|
|
|
#include "adaptersmanager.h"
|
|
#include "adapter.h"
|
|
#include "device.h"
|
|
|
|
#include <QDBusInterface>
|
|
#include <QDBusReply>
|
|
#include <QJsonDocument>
|
|
#include <QJsonArray>
|
|
|
|
AdaptersManager::AdaptersManager(QObject *parent)
|
|
: QObject(parent)
|
|
, m_bluetoothInter(new DBusBluetooth("com.deepin.daemon.Bluetooth",
|
|
"/com/deepin/daemon/Bluetooth",
|
|
QDBusConnection::sessionBus(),
|
|
this))
|
|
, m_defaultAdapterState(false)
|
|
{
|
|
connect(m_bluetoothInter, &DBusBluetooth::AdapterAdded, this, &AdaptersManager::addAdapter);
|
|
connect(m_bluetoothInter, &DBusBluetooth::AdapterRemoved, this, &AdaptersManager::removeAdapter);
|
|
connect(m_bluetoothInter, &DBusBluetooth::AdapterPropertiesChanged, this, &AdaptersManager::onAdapterPropertiesChanged);
|
|
connect(m_bluetoothInter, &DBusBluetooth::DeviceAdded, this, &AdaptersManager::addDevice);
|
|
connect(m_bluetoothInter, &DBusBluetooth::DeviceRemoved, this, &AdaptersManager::removeDevice);
|
|
connect(m_bluetoothInter, &DBusBluetooth::DevicePropertiesChanged, this, &AdaptersManager::onDevicePropertiesChanged);
|
|
|
|
#ifdef QT_DEBUG
|
|
connect(m_bluetoothInter, &DBusBluetooth::RequestAuthorization, this, [](const QDBusObjectPath & in0) {
|
|
qDebug() << "request authorization: " << in0.path();
|
|
});
|
|
|
|
connect(m_bluetoothInter, &DBusBluetooth::RequestPasskey, this, [](const QDBusObjectPath & in0) {
|
|
qDebug() << "request passkey: " << in0.path();
|
|
});
|
|
|
|
connect(m_bluetoothInter, &DBusBluetooth::RequestPinCode, this, [](const QDBusObjectPath & in0) {
|
|
qDebug() << "request pincode: " << in0.path();
|
|
});
|
|
|
|
connect(m_bluetoothInter, &DBusBluetooth::DisplayPasskey, this, [](const QDBusObjectPath & in0, uint in1, uint in2) {
|
|
qDebug() << "request display passkey: " << in0.path() << in1 << in2;
|
|
});
|
|
|
|
connect(m_bluetoothInter, &DBusBluetooth::DisplayPinCode, this, [](const QDBusObjectPath & in0, const QString & in1) {
|
|
qDebug() << "request display pincode: " << in0.path() << in1;
|
|
});
|
|
#endif
|
|
|
|
QDBusInterface *inter = new QDBusInterface("com.deepin.daemon.Bluetooth",
|
|
"/com/deepin/daemon/Bluetooth",
|
|
"com.deepin.daemon.Bluetooth",
|
|
QDBusConnection::sessionBus());
|
|
QDBusReply<QString> reply = inter->call(QDBus::Block, "GetAdapters");
|
|
const QString replyStr = reply.value();
|
|
QJsonDocument doc = QJsonDocument::fromJson(replyStr.toUtf8());
|
|
QJsonArray arr = doc.array();
|
|
|
|
for (int index = 0; index < arr.size(); index++) {
|
|
auto *adapter = new Adapter(this);
|
|
adapterAdd(adapter, arr[index].toObject());
|
|
m_defaultAdapterState |= adapter->powered();
|
|
}
|
|
}
|
|
|
|
void AdaptersManager::setAdapterPowered(const Adapter *adapter, const bool &powered)
|
|
{
|
|
if (!adapter)
|
|
return;
|
|
|
|
QDBusObjectPath path(adapter->id());
|
|
QDBusPendingCall call = m_bluetoothInter->SetAdapterPowered(path, powered);
|
|
|
|
if (powered) {
|
|
QDBusPendingCallWatcher *watcher = new QDBusPendingCallWatcher(call, this);
|
|
connect(watcher, &QDBusPendingCallWatcher::finished, [this, call, adapter] {
|
|
if (!call.isError()) {
|
|
QDBusObjectPath dPath(adapter->id());
|
|
m_bluetoothInter->SetAdapterDiscoverableTimeout(dPath, 60 * 5);
|
|
m_bluetoothInter->SetAdapterDiscoverable(dPath, true);
|
|
m_bluetoothInter->RequestDiscovery(dPath);
|
|
} else {
|
|
qWarning() << call.error().message();
|
|
}
|
|
});
|
|
} else {
|
|
QDBusPendingCall call = m_bluetoothInter->ClearUnpairedDevice();
|
|
QDBusPendingCallWatcher *watcher = new QDBusPendingCallWatcher(call, this);
|
|
connect(watcher, &QDBusPendingCallWatcher::finished, [ = ] {
|
|
if (call.isError())
|
|
qWarning() << call.error().message();
|
|
});
|
|
}
|
|
}
|
|
|
|
void AdaptersManager::connectDevice(Device *device, Adapter *adapter)
|
|
{
|
|
if (device) {
|
|
QDBusObjectPath path(device->id());
|
|
switch (device->state()) {
|
|
case Device::StateUnavailable: {
|
|
m_bluetoothInter->ConnectDevice(path, QDBusObjectPath(adapter->id()));
|
|
qDebug() << "connect to device: " << device->name();
|
|
}
|
|
break;
|
|
case Device::StateAvailable:
|
|
break;
|
|
case Device::StateConnected: {
|
|
m_bluetoothInter->DisconnectDevice(path);
|
|
qDebug() << "disconnect device: " << device->name();
|
|
}
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
bool AdaptersManager::defaultAdapterInitPowerState()
|
|
{
|
|
return m_defaultAdapterState;
|
|
}
|
|
|
|
int AdaptersManager::adaptersCount()
|
|
{
|
|
return m_adapters.size();
|
|
}
|
|
|
|
void AdaptersManager::onAdapterPropertiesChanged(const QString &json)
|
|
{
|
|
const QJsonDocument doc = QJsonDocument::fromJson(json.toUtf8());
|
|
const QJsonObject obj = doc.object();
|
|
const QString id = obj["Path"].toString();
|
|
QDBusObjectPath dPath(id);
|
|
|
|
if (!m_adapters.contains(id)) {
|
|
return;
|
|
}
|
|
|
|
Adapter *adapter = const_cast<Adapter *>(m_adapters[id]);
|
|
if (adapter) {
|
|
inflateAdapter(adapter, obj);
|
|
}
|
|
}
|
|
|
|
void AdaptersManager::onDevicePropertiesChanged(const QString &json)
|
|
{
|
|
const QJsonDocument doc = QJsonDocument::fromJson(json.toUtf8());
|
|
const QJsonObject obj = doc.object();
|
|
for (const Adapter *constAdapter : m_adapters) {
|
|
auto adapter = const_cast<Adapter *>(constAdapter);
|
|
if (adapter)
|
|
adapter->updateDevice(obj);
|
|
}
|
|
}
|
|
|
|
void AdaptersManager::addAdapter(const QString &json)
|
|
{
|
|
const QJsonDocument doc = QJsonDocument::fromJson(json.toUtf8());
|
|
auto adapter = new Adapter(this);
|
|
adapterAdd(adapter, doc.object());
|
|
}
|
|
|
|
void AdaptersManager::removeAdapter(const QString &json)
|
|
{
|
|
QJsonDocument doc = QJsonDocument::fromJson(json.toUtf8());
|
|
QJsonObject obj = doc.object();
|
|
const QString id = obj["Path"].toString();
|
|
|
|
if (!m_adapters.contains(id)) {
|
|
return;
|
|
}
|
|
|
|
const Adapter *result = m_adapters[id];
|
|
Adapter *adapter = const_cast<Adapter *>(result);
|
|
if (adapter) {
|
|
m_adapters.remove(id);
|
|
emit adapterDecreased(adapter);
|
|
adapter->deleteLater();
|
|
}
|
|
}
|
|
|
|
void AdaptersManager::addDevice(const QString &json)
|
|
{
|
|
const QJsonDocument doc = QJsonDocument::fromJson(json.toUtf8());
|
|
const QJsonObject obj = doc.object();
|
|
const QString adapterId = obj["AdapterPath"].toString();
|
|
const QString deviceId = obj["Path"].toString();
|
|
|
|
if (!m_adapters.contains(adapterId)) {
|
|
return;
|
|
}
|
|
|
|
const Adapter *result = m_adapters[adapterId];
|
|
Adapter *adapter = const_cast<Adapter *>(result);
|
|
if (adapter) {
|
|
const Device *result1 = adapter->deviceById(deviceId);
|
|
Device *device = const_cast<Device *>(result1);
|
|
if (!device) {
|
|
adapter->addDevice(obj);
|
|
}
|
|
}
|
|
}
|
|
|
|
void AdaptersManager::removeDevice(const QString &json)
|
|
{
|
|
QJsonDocument doc = QJsonDocument::fromJson(json.toUtf8());
|
|
QJsonObject obj = doc.object();
|
|
const QString adapterId = obj["AdapterPath"].toString();
|
|
const QString deviceId = obj["Path"].toString();
|
|
|
|
if (!m_adapters.contains(adapterId)) {
|
|
return;
|
|
}
|
|
|
|
const Adapter *result = m_adapters[adapterId];
|
|
Adapter *adapter = const_cast<Adapter *>(result);
|
|
if (adapter) {
|
|
adapter->removeDevice(deviceId);
|
|
}
|
|
}
|
|
|
|
void AdaptersManager::adapterAdd(Adapter *adapter, const QJsonObject &adpterObj)
|
|
{
|
|
if (!adapter)
|
|
return;
|
|
|
|
inflateAdapter(adapter, adpterObj);
|
|
QDBusObjectPath dPath(adpterObj["Path"].toString());
|
|
QDBusPendingCall call = m_bluetoothInter->GetDevices(dPath);
|
|
QDBusPendingCallWatcher *watcher = new QDBusPendingCallWatcher(call, this);
|
|
connect(watcher, &QDBusPendingCallWatcher::finished, [this, adapter, call, watcher] {
|
|
if (adapter) {
|
|
if (!call.isError()) {
|
|
QDBusReply<QString> reply = call.reply();
|
|
const QString replyStr = reply.value();
|
|
QJsonDocument doc = QJsonDocument::fromJson(replyStr.toUtf8());
|
|
adapter->initDevicesList(doc);
|
|
emit this->adapterIncreased(adapter);
|
|
} else {
|
|
qWarning() << call.error().message();
|
|
}
|
|
}
|
|
delete watcher;
|
|
});
|
|
|
|
QString id = adapter->id();
|
|
if (!id.isEmpty()) {
|
|
if (!m_adapters.contains(id)) {
|
|
m_adapters[id] = adapter;
|
|
} else if (m_adapters[id] == nullptr) {
|
|
m_adapters[id] = adapter;
|
|
}
|
|
}
|
|
}
|
|
|
|
void AdaptersManager::inflateAdapter(Adapter *adapter, const QJsonObject &adapterObj)
|
|
{
|
|
if (!adapter)
|
|
return;
|
|
|
|
const QString path = adapterObj["Path"].toString();
|
|
const QString alias = adapterObj["Alias"].toString();
|
|
const bool powered = adapterObj["Powered"].toBool();
|
|
const bool discovering = adapterObj["Discovering"].toBool();
|
|
|
|
adapter->setId(path);
|
|
adapter->setName(alias);
|
|
adapter->setPowered(powered);
|
|
adapter->setDiscover(discovering);
|
|
}
|
|
|
|
void AdaptersManager::adapterRefresh(const Adapter *adapter)
|
|
{
|
|
QDBusObjectPath dPath(adapter->id());
|
|
m_bluetoothInter->SetAdapterDiscoverableTimeout(dPath, 60 * 5);
|
|
m_bluetoothInter->SetAdapterDiscoverable(dPath, true);
|
|
m_bluetoothInter->RequestDiscovery(dPath);
|
|
}
|
|
|
|
void AdaptersManager::disconnectDevice(Device *device)
|
|
{
|
|
if (device) {
|
|
QDBusObjectPath path(device->id());
|
|
m_bluetoothInter->DisconnectDevice(path);
|
|
}
|
|
}
|