1 files changed, 76 insertions, 7 deletions
diff --git a/homescreen/src/mastervolume.cpp b/homescreen/src/mastervolume.cpp
index 9fb92a9..35b47fc 100644
--- a/homescreen/src/mastervolume.cpp
+++ b/homescreen/src/mastervolume.cpp
@@ -15,17 +15,86 @@
  */
 
 #include "mastervolume.h"
+#include <QJsonObject>
+#include <QTimer>
+#include <QtDebug>
 
-void MasterVolume::setVolume(int volume)
+MasterVolume::MasterVolume(QObject* parent)
+	: QObject(parent)
+	, m_volume{50}
 {
-	int volume_delta = volume - m_volume;
-	m_volume = volume;
-	emit sliderVolumeChanged(volume_delta);
+	connect(&m_client, SIGNAL(connected()), this, SLOT(onClientConnected()));
+	connect(&m_client, SIGNAL(disconnected()), this, SLOT(onClientDisconnected()));
+	connect(&m_client, SIGNAL(error(QAbstractSocket::SocketError)), this, SLOT(onClientError(QAbstractSocket::SocketError)));
+	connect(&m_client, SIGNAL(eventReceived(QString, const QJsonValue&)), this, SLOT(onClientEventReceived(QString, const QJsonValue&)));
+}
+
+void MasterVolume::open(const QUrl& url)
+{
+	m_url = url;
+	TryOpen();
+}
+
+qint32 MasterVolume::getVolume() const
+{
+	return m_volume;
+}
+
+void MasterVolume::setVolume(qint32 volume)
+{
+	if (m_volume != volume)
+	{
+		m_volume = volume;
+		QJsonObject arg;
+		arg.insert("action", "volume");
+		arg.insert("value", volume);
+		m_client.call("ahl-4a", "activerole", arg, [](bool, const QJsonValue&) {
+			// Nothing to do, events will update sliders
+		});
+	}
+}
 
+void MasterVolume::onClientConnected()
+{
+	// Subscribe to 4a events
+	m_client.call("ahl-4a", "subscribe", QJsonValue(), [this](bool r, const QJsonValue&) {
+		if (r) qDebug() << "MasterVolume::onClientConnected - subscribed to 4a events!";
+		else qCritical () << "MasterVolume::onClientConnected - Failed to subscribe to 4a events!";
+	});
+}
+
+void MasterVolume::onClientDisconnected()
+{
+	qDebug() << "MasterVolume::onClientDisconnected!";
+	QTimer::singleShot(1000, this, SLOT(TryOpen()));
+}
+
+void MasterVolume::onClientError(QAbstractSocket::SocketError se)
+{
+	qDebug() << "MasterVolume::onClientError: " << se;
+}
+
+void MasterVolume::onClientEventReceived(QString name, const QJsonValue& data)
+{
+	qDebug() << "MasterVolume::onClientEventReceived[" << name << "]: " << data;
+	if (name == "ahl-4a/volume_changed")
+	{
+		QJsonObject arg = data.toObject();
+		bool active = arg["active"].toBool();
+		if (active)
+		{
+			// QString role = arg["role"].toString();
+			int volume = arg["volume"].toInt();
+			if (m_volume != volume)
+			{
+				m_volume = volume;
+				emit VolumeChanged();
+			}
+		}
+	}
 }
 
-void MasterVolume::changeExternalVolume(int volume)
+void MasterVolume::TryOpen()
 {
-	m_volume = volume;
-	emit volumeChanged();
+	m_client.open(m_url);
 }