secstate/Iris
Public Access
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

Vertical slider for chrome; Polishing flex

Browse Source
This commit is contained in:
James Barnsley
2019-11-11 21:10:17 +13:00
parent 00ae8ac149
commit 0f30574e92
13 changed files with 154 additions and 129 deletions
Download Patch File Download Diff File Expand all files Collapse all files

59
src/js/services/snapcast/middleware.js
View File

@ -21,6 +21,12 @@ const SnapcastMiddleware = (function () {
console.log('Snapcast log (incoming)', message);
}
// Some messages are arrays of messages
if (Array.isArray(message)) {
message.map(messageItem => handleMessage(ws, store, messageItem));
return;
}
// Pull our ID. JSON-RPC nests the ID under the error object,
// so make sure we handle that.
// TODO: Use this as our measure of a successful response vs error
@ -56,43 +62,34 @@ const SnapcastMiddleware = (function () {
// General broadcast received
} else {
// Broadcast of an error
if (message.error !== undefined) {
store.dispatch(coreActions.handleException(
`Snapcast: ${message.error.message}`,
message,
(message.error.data !== undefined && message.error.data.description !== undefined ? message.error.data.description : null),
));
} else {
switch (message.method) {
case 'Client.OnConnect':
store.dispatch(snapcastActions.clientLoaded(message.params.client));
break;
switch (message.method) {
case 'Client.OnConnect':
store.dispatch(snapcastActions.clientLoaded(message.params.client));
break;
case 'Client.OnDisconnect':
store.dispatch(snapcastActions.clientLoaded(message.params.client));
break;
case 'Client.OnDisconnect':
store.dispatch(snapcastActions.clientLoaded(message.params.client));
break;
case 'Client.OnVolumeChanged':
case 'Client.OnVolumeChanged':
store.dispatch(snapcastActions.clientLoaded(message.params));
break;
case 'Client.OnLatencyChanged':
store.dispatch(snapcastActions.clientLoaded(message.params));
break;
break;
case 'Client.OnLatencyChanged':
store.dispatch(snapcastActions.clientLoaded(message.params));
break;
case 'Client.OnNameChanged':
store.dispatch(snapcastActions.clientLoaded(message.params));
break;
case 'Client.OnNameChanged':
store.dispatch(snapcastActions.clientLoaded(message.params));
break;
case 'Group.OnMute':
store.dispatch(snapcastActions.groupLoaded(message.params));
break;
case 'Group.OnMute':
store.dispatch(snapcastActions.groupLoaded(message.params));
break;
case 'Server.OnUpdate':
store.dispatch(snapcastActions.serverLoaded(message.param));
break;
}
case 'Server.OnUpdate':
store.dispatch(snapcastActions.serverLoaded(message.param));
break;
}
}
};