Differential D7992 Diff 30405 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		#include <PulseAudioQt/Maps>
37
38		K_PLUGIN_FACTORY_WITH_JSON( KdeConnectPluginFactory, "kdeconnect_systemvolume.json", registerPlugin< SystemvolumePlugin >(); )
39
40		Q_LOGGING_CATEGORY(KDECONNECT_PLUGIN_SYSTEMVOLUME, "kdeconnect.plugin.systemvolume")
41
42		SystemvolumePlugin::SystemvolumePlugin(QObject* parent, const QVariantList& args)
43		: KdeConnectPlugin(parent, args)
44		, sinksMap()
45		{
46
47		connect(&QPulseAudio::Context::instance()->sinks(), &QPulseAudio::SinkMap::added, this, [this] {
48		sendSinkList();
49		});
50
51		connect(&QPulseAudio::Context::instance()->sinks(), &QPulseAudio::SinkMap::removed, this, [this] {
52		sendSinkList();
53		});
54
55		}
56
57		SystemvolumePlugin::~SystemvolumePlugin()
58		{}
59
60		bool SystemvolumePlugin::receivePacket(const NetworkPacket& np)
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.type() == PACKET_TYPE_SYSTEMVOLUME) {
63
	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		if (QPulseAudio::Context::instance()->isValid()) {
65
66		if (np.has(QStringLiteral("requestSinks"))) {
67		sendSinkList();
68		} else if (np.has(QStringLiteral("volume"))) {
69		sinksMap[np.get<QString>(QStringLiteral("name"))]->setVolume(np.get<int>(QStringLiteral("volume")));
70		} else if (np.has(QStringLiteral("muted"))) {
	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		qCDebug(KDECONNECT_PLUGIN_SYSTEMVOLUME) << "set muted" << np.get<bool>(QStringLiteral("muted"));
72		sinksMap[np.get<QString>(QStringLiteral("name"))]->setMuted(np.get<bool>(QStringLiteral("muted")));
73		}
	mtijinkUnsubmitted Not Done Same here. mtijink: Same here.
74
75		}
76		}
77
78		return true;
79		}
80
81		void SystemvolumePlugin::sendSinkList() {
82
83		QJsonDocument document;
84		QJsonArray array;
85
86		const QMap<unsigned int, QPulseAudio::Sink*> sinks = QPulseAudio::Context::instance()->sinks().data();
87		QMap<unsigned int, QPulseAudio::Sink*>::const_iterator i;
88
89		for (i = sinks.constBegin(); i != sinks.constEnd(); ++i) {
90		QPulseAudio::Sink* sink = i.value();
91		sinksMap.insert(sink->name(), sink);
92
93		connect(sink, &QPulseAudio::Sink::volumeChanged, this, [this, sink] {
94		NetworkPacket np(PACKET_TYPE_SYSTEMVOLUME);
	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		np.set<int>(QStringLiteral("volume"), sink->volume());
96		np.set<QString>(QStringLiteral("name"), sink->name());
97		sendPacket(np);
98		});
99
100		connect(sink, &QPulseAudio::Sink::mutedChanged, this, [this, sink] {
101		NetworkPacket np(PACKET_TYPE_SYSTEMVOLUME);
102		np.set<bool>(QStringLiteral("muted"), sink->isMuted());
103		np.set<QString>(QStringLiteral("name"), sink->name());
104		sendPacket(np);
105		});
106
107		QJsonObject sinkObject;
108		sinkObject.insert("name", sink->name());
109		sinkObject.insert("description", sink->description());
110		sinkObject.insert("muted", sink->isMuted());
111		sinkObject.insert("volume", sink->volume());
112		sinkObject.insert("maxVolume", QPulseAudio::Context::NormalVolume);
113
114		array.append(sinkObject);
115		}
116
117		document.setArray(array);
118
119		NetworkPacket np(PACKET_TYPE_SYSTEMVOLUME);
120		np.set<QJsonDocument>(QStringLiteral("sinkList"), document);
121		sendPacket(np);
122		}
123
124		void SystemvolumePlugin::connected()
125		{
126		const QMap<unsigned int, QPulseAudio::Sink*> sinks = QPulseAudio::Context::instance()->sinks().data();
127		QMap<unsigned int, QPulseAudio::Sink*>::const_iterator i;
128
129		for (i = sinks.constBegin(); i != sinks.constEnd(); ++i) {
130		QPulseAudio::Sink* sink = i.value();
131		sinksMap.insert(sink->name(), sink);
132		}
	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?
133		}
134
135		#include "systemvolumeplugin.moc"
136