Differential D7992 Diff 30866 plugins/systemvolume/systemvolumeplugin.cpp

Changeset View

Standalone View

plugins/systemvolume/systemvolumeplugin.cpp

This file was added.

1		/**
2		* Copyright 2017 Nicolas Fella <nicolas.fella@gmx.de>
3		*
4		* This program is free software; you can redistribute it and/or
5		* modify it under the terms of the GNU General Public License as
6		* published by the Free Software Foundation; either version 2 of
7		* the License or (at your option) version 3 or any later version
8		* accepted by the membership of KDE e.V. (or its successor approved
9		* by the membership of KDE e.V.), which shall act as a proxy
10		* defined in Section 14 of version 3 of the license.
11		*
12		* This program is distributed in the hope that it will be useful,
13		* but WITHOUT ANY WARRANTY; without even the implied warranty of
14		* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
15		* GNU General Public License for more details.
16		*
17		* You should have received a copy of the GNU General Public License
18		* along with this program. If not, see <http://www.gnu.org/licenses/>.
19		*/
20
21		#include "systemvolumeplugin.h"
22
23		#include <KPluginFactory>
24
25		#include <QDebug>
26		#include <QLoggingCategory>
27		#include <QProcess>
28		#include <QJsonArray>
29		#include <QJsonDocument>
30		#include <QJsonObject>
31
32		#include <core/device.h>
33
34		#include <PulseAudioQt/Sink>
35		#include <PulseAudioQt/Context>
36
37		K_PLUGIN_FACTORY_WITH_JSON( KdeConnectPluginFactory, "kdeconnect_systemvolume.json", registerPlugin< SystemvolumePlugin >(); )
38
39		Q_LOGGING_CATEGORY(KDECONNECT_PLUGIN_SYSTEMVOLUME, "kdeconnect.plugin.systemvolume")
40
41		SystemvolumePlugin::SystemvolumePlugin(QObject* parent, const QVariantList& args)
42		: KdeConnectPlugin(parent, args)
43		, sinksMap()
44		{}
45
46		bool SystemvolumePlugin::receivePacket(const NetworkPacket& np)
47		{
48
49		if (!PulseAudioQt::Context::instance()->isValid())
50		return false;
51
52		if (np.has(QStringLiteral("requestSinks"))) {
53		sendSinkList();
54		} else {
55
56		QString name = np.get<QString>(QStringLiteral("name"));
57
58		if (sinksMap.contains(name)) {
59		if (np.has(QStringLiteral("volume"))) {
60		sinksMap[name]->setVolume(np.get<int>(QStringLiteral("volume")));
61		}
	davidedmundsonUnsubmitted Done You can find Qt pulseaudio code in the plasma-pa repo. davidedmundson: You can find Qt pulseaudio code in the plasma-pa repo.
	nicolasfellaAuthorUnsubmitted Done Thanks, will take a look at it nicolasfella: Thanks, will take a look at it
62		if (np.has(QStringLiteral("muted"))) {
63		sinksMap[name]->setMuted(np.get<bool>(QStringLiteral("muted")));
	mtijinkUnsubmitted Not Done Do we need to check the packet type here? We already know it's destined for this plugin. mtijink: Do we need to check the packet type here? We already know it's destined for this plugin.
64		}
65		}
66		}
67		return true;
68		}
69
70		void SystemvolumePlugin::sendSinkList() {
	mtijinkUnsubmitted Not Done Needs a check to see if the requested sink still exists. mtijink: Needs a check to see if the requested sink still exists.
71
72		QJsonDocument document;
73		QJsonArray array;
	mtijinkUnsubmitted Not Done Same here. mtijink: Same here.
74
75		sinksMap.clear();
76
77		for (PulseAudioQt::Sink* sink : PulseAudioQt::Context::instance()->sinks()) {
78		sinksMap.insert(sink->name(), sink);
79
80		connect(sink, &PulseAudioQt::Sink::volumeChanged, this, [this, sink] {
81		NetworkPacket np(PACKET_TYPE_SYSTEMVOLUME);
82		np.set<int>(QStringLiteral("volume"), sink->volume());
83		np.set<QString>(QStringLiteral("name"), sink->name());
84		sendPacket(np);
85		});
86
87		connect(sink, &PulseAudioQt::Sink::mutedChanged, this, [this, sink] {
88		NetworkPacket np(PACKET_TYPE_SYSTEMVOLUME);
89		np.set<bool>(QStringLiteral("muted"), sink->isMuted());
90		np.set<QString>(QStringLiteral("name"), sink->name());
91		sendPacket(np);
92		});
93
94		QJsonObject sinkObject;
	mtijinkUnsubmitted Not Done What happens if we already had that sink? Do we connect to this signal twice? mtijink: What happens if we already had that sink? Do we connect to this signal twice?
95		sinkObject.insert("name", sink->name());
96		sinkObject.insert("description", sink->description());
97		sinkObject.insert("muted", sink->isMuted());
98		sinkObject.insert("volume", sink->volume());
99		sinkObject.insert("maxVolume", PulseAudioQt::Context::NormalVolume);
100
101		array.append(sinkObject);
102		}
103
104		document.setArray(array);
105
106		NetworkPacket np(PACKET_TYPE_SYSTEMVOLUME);
107		np.set<QJsonDocument>(QStringLiteral("sinkList"), document);
108		sendPacket(np);
109		}
110
111		void SystemvolumePlugin::connected()
112		{
113		connect(PulseAudioQt::Context::instance(), &PulseAudioQt::Context::sinkAdded, this, [this] {
114		sendSinkList();
115		});
116
117		connect(PulseAudioQt::Context::instance(), &PulseAudioQt::Context::sinkRemoved, this, [this] {
118		sendSinkList();
119		});
120
121		for (PulseAudioQt::Sink* sink : PulseAudioQt::Context::instance()->sinks()) {
122		sinksMap.insert(sink->name(), sink);
123		}
124		}
125
126		#include "systemvolumeplugin.moc"
127
	mtijinkUnsubmitted Not Done This code doesn't connect to the signals, so that's not correct, right? mtijink: This code doesn't connect to the signals, so that's not correct, right?