Differential D28141 Diff 79072 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), d(new Private)
42		{
43		qDBusRegisterMetaType<SensorData>();
44		qDBusRegisterMetaType<SensorInfo>();
45		qDBusRegisterMetaType<SensorDataList>();
46		qDBusRegisterMetaType<SensorInfoMap>();
47
48		d->dbusInterface = std::make_unique<org::kde::KSysGuardDaemon>(Private::SensorServiceName, Private::SensorPath, QDBusConnection::sessionBus());
49
50		connect(d->dbusInterface.get(), &org::kde::KSysGuardDaemon::sensorMetaDataChanged, this, &SensorDaemonInterface::onMetaDataChanged);
51		connect(d->dbusInterface.get(), &org::kde::KSysGuardDaemon::newSensorData, this, &SensorDaemonInterface::onValueChanged);
52		connect(d->dbusInterface.get(), &org::kde::KSysGuardDaemon::sensorAdded, this, &SensorDaemonInterface::sensorAdded);
53		connect(d->dbusInterface.get(), &org::kde::KSysGuardDaemon::sensorRemoved, this, &SensorDaemonInterface::sensorRemoved);
54		}
55
56		SensorDaemonInterface::~SensorDaemonInterface()
57		{
58		}
59
60		void SensorDaemonInterface::requestMetaData(const QString &sensorId)
61		{
62		requestMetaData(QStringList{sensorId});
63		}
64
65		void SensorDaemonInterface::requestMetaData(const QStringList& sensorIds)
66		{
67		auto watcher = new QDBusPendingCallWatcher{d->dbusInterface->sensors(sensorIds), this};
68		connect(watcher, &QDBusPendingCallWatcher::finished, watcher, [=](QDBusPendingCallWatcher *self) {
69		self->deleteLater();
70
71		const QDBusPendingReply<SensorInfoMap> reply = *self;
72		if (reply.isError()) {
73		return;
74		}
75
76		const auto infos = reply.value();
77		for (auto itr = infos.begin(); itr != infos.end(); ++itr) {
78		Q_EMIT metaDataChanged(itr.key(), itr.value());
79		}
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, [=](QDBusPendingCallWatcher *self) {
	martUnsubmitted Done also here, [this] instead of [=] mart: also here, [this] instead of [=]
88		self->deleteLater();
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		}