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

Server listeners for snapcast

Browse Source
This commit is contained in:
James Barnsley
2018-11-05 16:33:36 +13:00
parent ffaef9d63e
commit aea1539a1e
8 changed files with 13954 additions and 10778 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
mopidy_iris/snapcast.py
View File

@ -56,7 +56,11 @@ class IrisSnapcast(object):
while self.listen:
readlist, writelist, exceptionlist = select.select([self.sock], [], [], 5)
# This loop will run constantly in the background, so we need a relatively short
# timeout as this would otherwise block the shutdown sequence
timeout = 1
readlist, writelist, exceptionlist = select.select([self.sock], [], [], timeout)
# Check if we've got any lists
if [readlist, writelist, exceptionlist] != [[], [], []]:
@ -64,7 +68,8 @@ class IrisSnapcast(object):
# Rread and print the available data on any of the read list
for socket in readlist:
message = socket.recv(1024)
# Allow a relatively large buffer size to handle large JSON payloads
message = socket.recv(8192)
try:
message = json.loads(message)

24479
mopidy_iris/static/app.js
View File

File diff suppressed because one or more lines are too long

2
mopidy_iris/static/app.js.map
View File

File diff suppressed because one or more lines are too long

190
mopidy_iris/static/app.min.css vendored
View File

File diff suppressed because one or more lines are too long

12
mopidy_iris/static/app.min.js vendored
View File

File diff suppressed because one or more lines are too long

2
mopidy_iris/static/app.min.js.map
View File

File diff suppressed because one or more lines are too long

2
mopidy_iris/static/index.html
View File

@ -98,7 +98,7 @@
// Release details
// These are automatically injected to built HTML
var build = "1541209549";
var build = "1541361367";
var version = "3.29.2";
// Construct the script tag

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

@ -394,13 +394,32 @@ const SnapcastMiddleware = (function(){
case 'SNAPCAST_EVENT_RECEIVED':
console.log(action)
// Drop the prefix
action.method = action.method.replace('snapcast_','');
switch (action.method){
case 'Client.OnConnect':
store.dispatch(snapcastActions.clientLoaded(
{
id: action.params.client.id,
name: action.params.client.name,
volume: action.params.client.volume.percent,
mute: action.params.client.volume.muted,
connected: action.params.client.connected
}
));
break;
case 'Client.OnDisconnect':
store.dispatch(snapcastActions.clientLoaded(
{
id: action.params.client.id,
connected: action.params.client.connected
}
));
break;
case 'Client.OnVolumeChanged':
store.dispatch(snapcastActions.clientLoaded(
{
@ -428,6 +447,19 @@ const SnapcastMiddleware = (function(){
}
));
break;
case 'Group.OnMute':
store.dispatch(snapcastActions.groupLoaded(
{
id: action.params.id,
mute: action.params.mute
}
));
break;
case 'Server.OnUpdate':
store.dispatch(snapcastActions.serverLoaded(action.params));
break;
}
break;