Differential D16667 Diff 44861 interfaces/remotesinksmodel.cpp

Changeset View

Standalone View

interfaces/remotesinksmodel.cpp

This file was added.

1		/**
2		* Copyright 2018 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 "remotesinksmodel.h"
22		#include "interfaces_debug.h"
23
24		#include <QDebug>
25		#include <QDBusInterface>
26
27		RemoteSinksModel::RemoteSinksModel(QObject* parent)
28		: QAbstractListModel(parent)
29		, m_dbusInterface(nullptr)
30		{
31
32		connect(this, &QAbstractItemModel::rowsInserted,
33		this, &RemoteSinksModel::rowsChanged);
34		connect(this, &QAbstractItemModel::rowsRemoved,
35		this, &RemoteSinksModel::rowsChanged);
36
37		QDBusServiceWatcher* watcher = new QDBusServiceWatcher(DaemonDbusInterface::activatedService(),
38		QDBusConnection::sessionBus(), QDBusServiceWatcher::WatchForOwnerChange, this);
39		connect(watcher, &QDBusServiceWatcher::serviceRegistered, this, &RemoteSinksModel::refreshSinkList);
40		connect(watcher, &QDBusServiceWatcher::serviceUnregistered, this, &RemoteSinksModel::clearSinks);
41		}
42
43		QHash<int, QByteArray> RemoteSinksModel::roleNames() const
44		{
45		//Role names for QML
46		QHash<int, QByteArray> names = QAbstractItemModel::roleNames();
47		names.insert(NameRole, "name");
48		names.insert(DescriptionRole, "description");
49		names.insert(MaxVolumeRole, "maxVolume");
50		names.insert(VolumeRole, "volume");
51		names.insert(MutedRole, "muted");
52
53		return names;
54		}
55
56		RemoteSinksModel::~RemoteSinksModel()
57		{
58		}
59
60		QString RemoteSinksModel::deviceId() const
61		{
62		return m_deviceId;
63		}
64
65		void RemoteSinksModel::setDeviceId(const QString& deviceId)
66		{
67		m_deviceId = deviceId;
68
69		if (m_dbusInterface) {
70		delete m_dbusInterface;
71		}
72
73		m_dbusInterface = new RemoteSystemVolumeDbusInterface(deviceId, this);
74
75		connect(m_dbusInterface, &OrgKdeKdeconnectDeviceRemotesystemvolumeInterface::sinksChanged,
76		this, &RemoteSinksModel::refreshSinkList);
77
78		connect(m_dbusInterface, &OrgKdeKdeconnectDeviceRemotesystemvolumeInterface::volumeChanged, this, [this](const QString& name, int volume) {
79		for (Sink* s: m_sinkList) {
80		if (s->name == name) {
81		s->volume = volume;
82		Q_EMIT dataChanged(index(0,0), index(m_sinkList.size() - 1, 0));
83		}
84		}
85		});
86
87		connect(m_dbusInterface, &OrgKdeKdeconnectDeviceRemotesystemvolumeInterface::mutedChanged, this, [this](const QString& name, bool muted) {
88		for (Sink* s: m_sinkList) {
89		if (s->name == name) {
90		s->muted = muted;
91		Q_EMIT dataChanged(index(0,0), index(m_sinkList.size() - 1, 0));
92		}
93		}
94		});
95
96		refreshSinkList();
97
98		Q_EMIT deviceIdChanged(deviceId);
99		}
100
101		void RemoteSinksModel::refreshSinkList()
102		{
103		if (!m_dbusInterface) {
104		return;
105		}
106
107		clearSinks();
108
	apolUnsubmitted Not Done You can clear it as it is resetting, so the view doesn't refresh twice. apol: You can clear it as it is resetting, so the view doesn't refresh twice.
109		if (!m_dbusInterface->isValid()) {
110		qCWarning(KDECONNECT_INTERFACES) << "dbus interface not valid";
111		return;
112		}
113
114		const auto cmds = QJsonDocument::fromJson(m_dbusInterface->sinks()).array();
115
116		beginResetModel();
117
118		for (auto it = cmds.constBegin(), itEnd = cmds.constEnd(); it!=itEnd; ++it) {
119		const QJsonObject cont = it->toObject();
120		Sink* sink = new Sink();
121		sink->name = cont.value(QStringLiteral("name")).toString();
122		sink->description = cont.value(QStringLiteral("description")).toString();
123		sink->maxVolume = cont.value(QStringLiteral("maxVolume")).toInt();
124		sink->volume = cont.value(QStringLiteral("volume")).toInt();
125		sink->muted = cont.value(QStringLiteral("muted")).toBool();
126
127		m_sinkList.append(sink);
128		}
129
130		endResetModel();
131		}
132
133		QVariant RemoteSinksModel::data(const QModelIndex& index, int role) const
134		{
135		if (!index.isValid()
136		\|\| index.row() < 0
137		\|\| index.row() >= m_sinkList.count())
138		{
139		return QVariant();
140		}
141
142		if (!m_dbusInterface \|\| !m_dbusInterface->isValid()) {
143		return QVariant();
144		}
145
146		Sink* sink = m_sinkList[index.row()];
147
148		switch (role) {
149		case NameRole:
150		return sink->name;
151		case DescriptionRole:
152		return sink->description;
153		case MaxVolumeRole:
154		return sink->maxVolume;
155		case VolumeRole:
156		return sink->volume;
157		case MutedRole:
158		return sink->muted;
159		default:
160		return QVariant();
161		}
162		}
163
164		int RemoteSinksModel::rowCount(const QModelIndex& parent) const
165		{
166		if (parent.isValid()) {
167		//Return size 0 if we are a child because this is not a tree
168		return 0;
169		}
170
171		return m_sinkList.count();
172		}
173
174		void RemoteSinksModel::clearSinks()
175		{
176		if (!m_sinkList.isEmpty()) {
177		beginRemoveRows(QModelIndex(), 0, m_sinkList.size() - 1);
178		qDeleteAll(m_sinkList);
179		m_sinkList.clear();
180		endRemoveRows();
181		}
182		}