Differential D7992 Diff 28750 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 "sink.h"
35		#include "context.h"
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		SystemvolumePlugin::~SystemvolumePlugin()
47		{}
48
49		bool SystemvolumePlugin::receivePacket(const NetworkPacket& np)
50		{
51		if (np.type() == PACKET_TYPE_SYSTEMVOLUME) {
52
53		if (QPulseAudio::Context::instance()->isValid()) {
54
55		if (np.has(QStringLiteral("requestSinks"))) {
56		sendSinkList();
57		} else if (np.has(QStringLiteral("volume"))) {
58		sinksMap[np.get<QString>(QStringLiteral("name"))]->setVolume(np.get<int>(QStringLiteral("volume")));
59		} else if (np.has(QStringLiteral("muted"))) {
60		qCDebug(KDECONNECT_PLUGIN_SYSTEMVOLUME) << "set muted" << np.get<bool>(QStringLiteral("muted"));
61		sinksMap[np.get<QString>(QStringLiteral("name"))]->setMuted(np.get<bool>(QStringLiteral("muted")));
	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		}
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		}
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		const QMap<unsigned int, QPulseAudio::Sink*> sinks = QPulseAudio::Context::instance()->sinks().data();
76		QMap<unsigned int, QPulseAudio::Sink*>::const_iterator i;
77
78		for (i = sinks.constBegin(); i != sinks.constEnd(); ++i) {
79		QPulseAudio::Sink* sink = i.value();
80		sinksMap.insert(sink->name(), sink);
81
82		connect(sink, &QPulseAudio::Sink::volumeChanged, this, [this, sink] {
83		NetworkPacket np(PACKET_TYPE_SYSTEMVOLUME);
84		np.set<int>(QStringLiteral("volume"), sink->volume());
85		np.set<QString>(QStringLiteral("name"), sink->name());
86		sendPacket(np);
87		});
88
89		connect(sink, &QPulseAudio::Sink::mutedChanged, this, [this, sink] {
90		NetworkPacket np(PACKET_TYPE_SYSTEMVOLUME);
91		np.set<bool>(QStringLiteral("muted"), sink->isMuted());
92		np.set<QString>(QStringLiteral("name"), sink->name());
93		sendPacket(np);
94		});
	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
96		QJsonObject sinkObject;
97		sinkObject.insert("name", sink->name());
98		sinkObject.insert("description", sink->description());
99		sinkObject.insert("muted", sink->isMuted());
100		sinkObject.insert("volume", sink->volume());
101		sinkObject.insert("maxVolume", QPulseAudio::Context::NormalVolume);
102
103		array.append(sinkObject);
104		}
105
106		document.setArray(array);
107
108		NetworkPacket np(PACKET_TYPE_SYSTEMVOLUME);
109		np.set<QJsonDocument>(QStringLiteral("sinkList"), document);
110		sendPacket(np);
111		}
112
113		void SystemvolumePlugin::connected()
114		{
115		const QMap<unsigned int, QPulseAudio::Sink*> sinks = QPulseAudio::Context::instance()->sinks().data();
116		QMap<unsigned int, QPulseAudio::Sink*>::const_iterator i;
117
118		for (i = sinks.constBegin(); i != sinks.constEnd(); ++i) {
119		QPulseAudio::Sink* sink = i.value();
120		sinksMap.insert(sink->name(), sink);
121		}
122		}
123
124		#include "systemvolumeplugin.moc"
125
	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?