Differential D28141 Diff 82181 sensors/SensorDaemonInterface.cpp

Changeset View

Standalone View

sensors/SensorDaemonInterface.cpp

This file was added.

1		/*
2		Copyright (C) 2020 Arjen Hiemstra <ahiemstra@heimr.nl>
3
4		This library is free software; you can redistribute it and/or
5		modify it under the terms of the GNU Library General Public
6		License as published by the Free Software Foundation; either
7		version 2 of the License, or (at your option) any later version.
8
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		Library General Public License for more details.
13
14		You should have received a copy of the GNU Library General Public License
15		along with this library; see the file COPYING.LIB. If not, write to
16		the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
17		Boston, MA 02110-1301, USA.
18		*/
19
20		#include "SensorDaemonInterface_p.h"
21
22		#include <QDBusPendingCallWatcher>
23
24		#include "ksysguarddaemon.h"
25
26		using namespace KSysGuard;
27
28		class SensorDaemonInterface::Private
29		{
30		public:
31		std::unique_ptr<org::kde::KSysGuardDaemon> dbusInterface;
32
33		static const QString SensorServiceName;
34		static const QString SensorPath;
35		};
36
37		const QString SensorDaemonInterface::Private::SensorServiceName = QStringLiteral("org.kde.kstats");
38		const QString SensorDaemonInterface::Private::SensorPath = QStringLiteral("/");
39
40		SensorDaemonInterface::SensorDaemonInterface(QObject *parent)
41		: QObject(parent)
42		, d(new Private)
43		{
44		qDBusRegisterMetaType<SensorData>();
45		qDBusRegisterMetaType<SensorInfo>();
46		qDBusRegisterMetaType<SensorDataList>();
47		qDBusRegisterMetaType<SensorInfoMap>();
48
49		d->dbusInterface = std::make_unique<org::kde::KSysGuardDaemon>(Private::SensorServiceName, Private::SensorPath, QDBusConnection::sessionBus());
50
51		connect(d->dbusInterface.get(), &org::kde::KSysGuardDaemon::sensorMetaDataChanged, this, &SensorDaemonInterface::onMetaDataChanged);
52		connect(d->dbusInterface.get(), &org::kde::KSysGuardDaemon::newSensorData, this, &SensorDaemonInterface::onValueChanged);
53		connect(d->dbusInterface.get(), &org::kde::KSysGuardDaemon::sensorAdded, this, &SensorDaemonInterface::sensorAdded);
54		connect(d->dbusInterface.get(), &org::kde::KSysGuardDaemon::sensorRemoved, this, &SensorDaemonInterface::sensorRemoved);
55		}
56
57		SensorDaemonInterface::~SensorDaemonInterface()
58		{
59		}
60
61		void SensorDaemonInterface::requestMetaData(const QString &sensorId)
62		{
63		requestMetaData(QStringList{sensorId});
64		}
65
66		void SensorDaemonInterface::requestMetaData(const QStringList &sensorIds)
67		{
68		auto watcher = new QDBusPendingCallWatcher{d->dbusInterface->sensors(sensorIds), this};
69		connect(watcher, &QDBusPendingCallWatcher::finished, watcher, [this](QDBusPendingCallWatcher *self) {
70		self->deleteLater();
71
72		const QDBusPendingReply<SensorInfoMap> reply = *self;
73		if (reply.isError()) {
74		return;
75		}
76
77		const auto infos = reply.value();
78		for (auto itr = infos.begin(); itr != infos.end(); ++itr) {
79		Q_EMIT metaDataChanged(itr.key(), itr.value());
80		}
81		});
82		}
83
84		void SensorDaemonInterface::requestValue(const QString &sensorId)
85		{
86		auto watcher = new QDBusPendingCallWatcher{d->dbusInterface->sensorData({sensorId}), this};
87		connect(watcher, &QDBusPendingCallWatcher::finished, watcher, [this](QDBusPendingCallWatcher *self) {
88		self->deleteLater();
	martUnsubmitted Done also here, [this] instead of [=] mart: also here, [this] instead of [=]
89
90		const QDBusPendingReply<SensorDataList> reply = *self;
91		if (reply.isError()) {
92		return;
93		}
94
95		const auto allData = reply.value();
96		for (auto data : allData) {
97		Q_EMIT valueChanged(data.attribute, data.payload);
98		}
99		});
100		}
101
102		QDBusPendingCallWatcher *SensorDaemonInterface::allSensors() const
103		{
104		return new QDBusPendingCallWatcher{d->dbusInterface->allSensors()};
105		}
106
107		void SensorDaemonInterface::subscribe(const QString &sensorId)
108		{
109		subscribe(QStringList{sensorId});
110		}
111
112		void KSysGuard::SensorDaemonInterface::subscribe(const QStringList &sensorIds)
113		{
114		d->dbusInterface->subscribe(sensorIds);
115		}
116
117		void SensorDaemonInterface::unsubscribe(const QString &sensorId)
118		{
119		unsubscribe(QStringList{sensorId});
120		}
121
122		void KSysGuard::SensorDaemonInterface::unsubscribe(const QStringList &sensorIds)
123		{
124		d->dbusInterface->unsubscribe(sensorIds);
125		}
126
127		SensorDaemonInterface *SensorDaemonInterface::instance()
128		{
129		static SensorDaemonInterface instance;
130		return &instance;
131		}
132
133		void SensorDaemonInterface::onMetaDataChanged(const QHash<QString, SensorInfo> &metaData)
134		{
135		for (auto itr = metaData.begin(); itr != metaData.end(); ++itr) {
136		Q_EMIT metaDataChanged(itr.key(), itr.value());
137		}
138		}
139
140		void SensorDaemonInterface::onValueChanged(const SensorDataList &values)
141		{
142		for (auto entry : values) {
143		Q_EMIT valueChanged(entry.attribute, entry.payload);
144		}
145		}