-- SONOS Play playlist, v.0.1
-------------------------------------------------------------------------------------------
---made on source of:-----------------------------------------------------------------------
-- SONOS Play stream...
-- Copyright © 2014 Jean-Christophe Vermandé
-------------------------------------------------------------------------------------------
-------------------------------------------------------------------------------------------
----------------------------------
-- User Settings
----------------------------------
ip = "192.168.1.232"
port = 1400
FileVol = 10
PlayUnlimited = "Yes" -- si <> Yes, arrêt après 30s environ
--duration =
----------------------------------
-- DO not change bellow this line
----------------------------------
--selfId = fibaro:getSelfId();
--album = fibaro:get(selfId, 'IPAddress');
--port = fibaro:get(selfId, 'TCPPort') or 1400;
currentTransportState = "";
lastTransportState = "";
currentVolume = 0;
lastVolume = 0;
ttsVolumeIsDifferent = false;
list_name = "Sonos Playlist n1" --not implemented
list_nbr = 1 -- playlist number on jffs system of SONOS, You need test it for find interesting list
uid = "RINCON_B8E937B01D4E01400" -- find by http://SONOS_IP:1400/status/upnp
--album = "1kFVHozcxeXY3MfKB3F0yw"
--album = "22j1vb0GvgRdJ1AdbHtKXT"
spotify = "6he9MFK1bEvcA4dOByFJT3"
urlencode = function(str)
if (str) then
str = string.gsub (str, "\n", "\r\n");
str = string.gsub (str, "([^%w ])", function (c) return string.format ("%%%02X", string.byte(c)) end);
str = string.gsub (str, " ", "+");
end
return str;
end
createRequestBody = function(action, schema, data)
return string.format("<u:%s xmlns:u=\"%s\">%s</u:%s>", action, schema, data, action);
end
reponseCallback = function(fnc, args)
if (fnc == nil) then
return nil;
end
return fnc(args);
end
createSocket = function()
-- Check IP and PORT before
if (ip == nil or port == nil) then
fibaro:debug("You must configure IPAddress and TCPPort first");
return;
end
local socket;
local status, err = pcall(function()
socket = net.FTcpSocket(ip, port);
socket:setReadTimeout(1000);
end);
if (status ~= nil and status ~= true) then
fibaro:debug("socket status: " .. tostring(status or ''));
end
if (err ~= nil) then
fibaro:debug("socket err: " .. tostring(err or ''));
return;
end
return socket;
end
disposeSocket = function(socket)
if (socket ~= nil) then
socket:disconnect();
socket = nil;
return true;
end
return false;
end
sendSoapMessage = function(url, service, action, args, callback, retry)
local socket = createSocket();
if (socket == nil) then
return;
end
retry = retry or 0
-- prepare data
--local url = "POST " .. url .. " HTTP/1.1";
local url = "POST " .. url .. " HTTP/1.1\r\nHOST: ".. ip ..":1400";
fibaro:debug(url)
--local udn = "X-SONOS-TARGET-UDN: uuid:RINCON_B8E937B01D4E01400" -- udn of my SONOS (not need)
local soapaction = "SOAPACTION: \"" .. service .. "#" .. action.name .. "\"";
local body = createRequestBody(action.name, action.service, tostring(args or ""));
local envelope = "<?xml version=\"1.0\" encoding=\"utf-8\"?><s:Envelope xmlns:s=\"http://schemas.xmlsoap.org/soap/envelope/\" s:encodingStyle=\"http://schemas.xmlsoap.org/soap/encoding/\"><s:Body>" .. body .. "</s:Body></s:Envelope>";
local ctl = "Content-Length: " .. string.len(envelope);
--local payload = url .. "\r\n" .. ctl .. "\r\n" .. udn .. "\r\n" .. soapaction .. "\r\n" .. "\r\n" .. envelope; -- with UDN
local payload = url .. "\r\n" .. ctl .. "\r\n" .. soapaction .. "\r\n" .. "\r\n" .. envelope;
-- write data
local bytes, errorcode = socket:write(payload);
if (errorcode == 0) then
local state, errorcode = socket:read();
if (errorcode == 0) then
if (string.len(state or "") > 0) then
-- callback
if (callback ~= nil) then
reponseCallback(callback, state);
end
-- dispose ...
disposeSocket(socket);
return true;
else
fibaro:debug("Error: Invalid response. response length: " .. string.len(state or ""));
end
else
if (retry < 5) then
fibaro:debug("retry #"..retry.." action: " .. action.name);
return sendSoapMessage(url, service, action, args, callback, (retry + 1));
else
fibaro:debug("Error: Code returned "..tostring(errorcode or ""));
end
end
elseif (errorcode == 2) then
fibaro:debug("Error: You must check your IP and PORT settings.");
else
if (retry < 5) then
fibaro:debug("retry #"..retry.." action: " .. action.name);
return sendSoapMessage(url, service, action, args, callback, (retry + 1));
else
fibaro:debug("Error: Code returned "..tostring(errorcode or ""));
end
end
-- dispose ...
disposeSocket(socket);
-- default response
return false;
end
stop = function()
return sendSoapMessage(
-- control url
"/MediaRenderer/AVTransport/Control",
-- service type
"urn:schemas-upnp-org:service:AVTransport:1",
-- action
{ name = "Stop", service = "urn:schemas-upnp-org:service:AVTransport:1" },
-- soap body data (options)
"<InstanceID>0</InstanceID><Speed>1</Speed>",
-- callback (options)
function(response)
fibaro:debug("stop sent");
end);
end
pause = function()
return sendSoapMessage(
-- control url
"/MediaRenderer/AVTransport/Control",
-- service type
"urn:schemas-upnp-org:service:AVTransport:1",
-- action
{ name = "Pause", service = "urn:schemas-upnp-org:service:AVTransport:1" },
-- soap body data (options)
"<InstanceID>0</InstanceID><Speed>1</Speed>",
-- callback (options)
function(response)
fibaro:debug("stop sent");
end);
end
pnext = function()
return sendSoapMessage(
-- control url
"/MediaRenderer/AVTransport/Control",
-- service type
"urn:schemas-upnp-org:service:AVTransport:1",
-- action
{ name = "Next", service = "urn:schemas-upnp-org:service:AVTransport:1" },
-- soap body data (options)
"<InstanceID>0</InstanceID>",
-- callback (options)
function(response)
fibaro:debug("next sent");
end);
end
pprev = function()
return sendSoapMessage(
-- control url
"/MediaRenderer/AVTransport/Control",
-- service type
"urn:schemas-upnp-org:service:AVTransport:1",
-- action
{ name = "Previous", service = "urn:schemas-upnp-org:service:AVTransport:1" },
-- soap body data (options)
"<InstanceID>0</InstanceID>",
-- callback (options)
function(response)
fibaro:debug("previous sent");
end);
end
unMute = function()
return sendSoapMessage(
-- control url
"/MediaRenderer/RenderingControl/Control",
-- service type
"urn:schemas-upnp-org:service:RenderingControl:1",
-- action
{ name = "SetMute", service = "urn:schemas-upnp-org:service:RenderingControl:1" },
-- soap body data (options)
"<InstanceID>0</InstanceID><Channel>Master</Channel><DesiredMute>0</DesiredMute>",
-- callback (options)
function(response)
fibaro:debug("unMute sent");
end);
end
play = function(duration)
return sendSoapMessage(
-- control url
"/MediaRenderer/AVTransport/Control",
-- service type
"urn:schemas-upnp-org:service:AVTransport:1",
-- action
{ name = "Play", service = "urn:schemas-upnp-org:service:AVTransport:1" },
-- soap body data (options)
"<InstanceID>0</InstanceID><Speed>1</Speed>",
-- callback (options)
function(response)
fibaro:debug("play sent");
end);
end
sseek = function()
return sendSoapMessage(
-- control url
"/MediaRenderer/AVTransport/Control",
-- service type
"urn:schemas-upnp-org:service:AVTransport:1",
-- action
{ name = "Seek", service = "urn:schemas-upnp-org:service:AVTransport:1" },
-- soap body data (options)
"<InstanceID>0</InstanceID>,<Unit>TRACK_NR</Unit>,<Target>1</Target>",
-- callback (options)
function(response)
fibaro:debug("Seek");
end);
end
sdel = function()
return sendSoapMessage(
-- control url
"/MediaRenderer/Queue/Control",
-- service type
"urn:schemas-sonos-com:service:Queue:1",
-- action
{ name = "RemoveAllTracks", service = "urn:schemas-sonos-com:service:Queue:1" },
-- soap body data (options)
"<QueueID>0</QueueID>,<UpdateID>0</UpdateID>",
-- callback (options)
function(response)
fibaro:debug("Remove");
end);
end
sonos_list = function(list_nbr)
return sendSoapMessage(
-- control url
"/MediaRenderer/AVTransport/Control",
-- service type
"urn:schemas-upnp-org:service:AVTransport:1",
-- action
{ name = "AddURIToQueue", service = "urn:schemas-upnp-org:service:AVTransport:1" },
-- soap body data (options)
"<InstanceID>0</InstanceID>,<EnqueuedURI>file:///jffs/settings/savedqueues.rsq#".. list_nbr.."</EnqueuedURI>,<EnqueuedURIMetaData><DIDL-Lite xmlns:dc="http://purl.org/dc/elements/1.1/" xmlns:upnp="urn:schemas-upnp-org:metadata-1-0/upnp/" xmlns:r="urn:schemas-rinconnetworks-com:metadata-1-0/" xmlns="urn:schemas-upnp-org:metadata-1-0/DIDL-Lite/"><item id="SQ:1" parentID="SQ:" restricted="true"><dc:title>".. list_name .."</dc:title><upnp:class>object.container.playlistContainer</upnp:class><desc id="cdudn" nameSpace="urn:schemas-rinconnetworks-com:metadata-1-0/">RINCON_AssociatedZPUDN</desc></item></DIDL-Lite></EnqueuedURIMetaData>,<DesiredFirstTrackNumberEnqueued>1</DesiredFirstTrackNumberEnqueued>,<EnqueueAsNext>1</EnqueueAsNext>",
-- callback (options)
function(response)
fibaro:debug("set sonos playlist");
end);
end
spotify_list = function(spotify) --playlist from Spotify
return sendSoapMessage(
-- control url
"/MediaRenderer/AVTransport/Control",
-- service type
"urn:schemas-upnp-org:service:AVTransport:1",
-- action
{ name = "AddURIToQueue", service = "urn:schemas-upnp-org:service:AVTransport:1" },
-- soap body data (options)
"<InstanceID>0</InstanceID>,<EnqueuedURI>x-rincon-cpcontainer:10062a6cspotify%3auser%3apdurbajlo%3aplaylist%3a"..spotify.."</EnqueuedURI>,<EnqueuedURIMetaData><DIDL-Lite xmlns:dc="http://purl.org/dc/elements/1.1/" xmlns:upnp="urn:schemas-upnp-org:metadata-1-0/upnp/" xmlns:r="urn:schemas-rinconnetworks-com:metadata-1-0/" xmlns="urn:schemas-upnp-org:metadata-1-0/DIDL-Lite/"><item id="10062a6cspotify%3auser%3apdurbajlo%3aplaylist%3a"..spotify.."" parentID="10082664playlists" restricted="true"><dc:title>Fibaro from Spotify</dc:title><upnp:class>object.container.playlistContainer</upnp:class><desc id="cdudn" nameSpace="urn:schemas-rinconnetworks-com:metadata-1-0/">SA_RINCON2311_X_#Svc2311-0-Token</desc></item></DIDL-Lite></EnqueuedURIMetaData>,<DesiredFirstTrackNumberEnqueued>2</DesiredFirstTrackNumberEnqueued>,<EnqueueAsNext>1</EnqueueAsNext>",
-- callback (options)
function(response)
fibaro:debug("set spotify playlist");
end);
end
spotify_album = function(album) --album from Spotify
return sendSoapMessage(
-- control url
"/MediaRenderer/AVTransport/Control",
-- service type
"urn:schemas-upnp-org:service:AVTransport:1",
-- action
{ name = "AddURIToQueue", service = "urn:schemas-upnp-org:service:AVTransport:1" },
-- soap body data (options)
"<InstanceID>0</InstanceID>,<EnqueuedURI>x-rincon-cpcontainer:1004206cspotify%3aalbum%3a"..album.."</EnqueuedURI>,<EnqueuedURIMetaData><DIDL-Lite xmlns:dc="http://purl.org/dc/elements/1.1/" xmlns:upnp="urn:schemas-upnp-org:metadata-1-0/upnp/" xmlns:r="urn:schemas-rinconnetworks-com:metadata-1-0/" xmlns="urn:schemas-upnp-org:metadata-1-0/DIDL-Lite/"><item id="1004206cspotify%3aalbum%3a"..album.."" parentID="100d2064your_albums" restricted="true"><dc:title>Remote</dc:title><upnp:class>object.container.album.musicAlbum</upnp:class><desc id="cdudn" nameSpace="urn:schemas-rinconnetworks-com:metadata-1-0/">SA_RINCON2311_X_#Svc2311-0-Token</desc></item></DIDL-Lite></EnqueuedURIMetaData>,<DesiredFirstTrackNumberEnqueued>2</DesiredFirstTrackNumberEnqueued>,<EnqueueAsNext>1</EnqueueAsNext>",
-- callback (options)
function(response)
fibaro:debug("set spotify album");
end);
end
setVolume = function(value)
return sendSoapMessage(
-- control url
"/MediaRenderer/RenderingControl/Control",
-- service type
"urn:schemas-upnp-org:service:RenderingControl:1",
-- action
{ name = "SetVolume", service = "urn:schemas-upnp-org:service:RenderingControl:1" },
-- soap body data (options)
"<InstanceID>0</InstanceID><Channel>Master</Channel><DesiredVolume>" .. tostring(value) .. "</DesiredVolume>",
-- callback (options)
function(response)
fibaro:debug("Volume set: " .. value);
end);
end
getVolume = function()
fibaro:log("Get volume, please wait...");
return sendSoapMessage(
-- control url
"/MediaRenderer/RenderingControl/Control",
-- service type
"urn:schemas-upnp-org:service:AVTransport:1",
-- action
{ name = "GetVolume", service = "urn:schemas-upnp-org:service:RenderingControl:1" },
-- soap body data (options)
"<InstanceID>0</InstanceID><Channel>Master</Channel>",
-- callback (options)
function(response)
currentVolume = tonumber(response:match("<CurrentVolume>(.+)</CurrentVolume>") or 0);
end);
end
getTransportState = function()
return sendSoapMessage(
-- control url
"/MediaRenderer/AVTransport/Control",
-- service type
"urn:schemas-upnp-org:service:AVTransport:1",
-- action
{ name = "GetTransportInfo", service = "urn:schemas-upnp-org:service:AVTransport:1" },
-- soap body data (options)
"<InstanceID>0</InstanceID>",
-- callback (options)
function(response)
currentTransportState = response:match("<CurrentTransportState>(.+)</CurrentTransportState>") or "";
end);
end
pause_play = function()
getTransportState()
fibaro:debug('wstrzymanie'..currentTransportState)
if currentTransportState == "PLAYING" then
pause()
end
if currentTransportState == "PAUSED_PLAYBACK" then
play()
end
end
playFile= function(volume)
return sendSoapMessage(
-- control url SOAPACTION: "urn:schemas-upnp-org:service:AVTransport:1#SetAVTransportURI"
"/MediaRenderer/AVTransport/Control",
-- service type
"urn:schemas-upnp-org:service:AVTransport:1",
-- action
{ name = "SetAVTransportURI", service = "urn:schemas-upnp-org:service:AVTransport:1" },
-- soap body data (options)
"<InstanceID>0</InstanceID>,<CurrentURI>x-rincon-queue:"..uid.."#0</CurrentURI>,<CurrentURIMetaData></CurrentURIMetaData>",
-- callback (options)
function(response)
-- retrieve current transport state
getTransportState();
lastTransportState = currentTransportState;
-- unmute before
unMute();
-- retrieve volume
getVolume();
lastVolume = currentVolume;
-- set tts volume if <> with current
if (volume ~= nil and volume ~= currentVolume) then
setVolume(volume);
ttsVolumeIsDifferent = true;
end
sseek();
play();
end);
end
-- function for call
--[[
sdel(); -- remove last query
sonos_list(1) --list_nbr = 1 -- playlist number on jffs system of SONOS, You need test it for find interesting list
spotify_list("6he9MFK1bEvcA4dOBxxxxxx") -- "6he9MFK1bEvcA4dOByFJT3" playlist from spotify
spotify_album('22j1vb0GvgRdJ1Axxxxxx') --22j1vb0GvgRdJ1AdbHtKXT album from spotify
playFile(FileVol); -- play file with volume z głośnością
pnext(); next track
pprev(); previus track
pause_play() -- swap play / pause, pause / play
stop(); -- stop
play(); -- play
pause()
Mute()
unMute()
sseek() -- seek
getTransportState() --current status of sonos
--]]
sdel(); -- remove last query
sonos_list(1) --list_nbr = 1 -- playlist number on jffs system of SONOS, You need test it for find interesting list
spotify_list("6he9MFK1bEvcA4dOByFJT3") -- "6he9MFK1bEvcA4dOByFJT3" playlist from spotify
spotify_album('22j1vb0GvgRdJ1AdbHtKXT') --22j1vb0GvgRdJ1AdbHtKXT album from spotify
playFile(FileVol); -- play file with volume z głośnością
pnext(); next track
pprev(); previus track
pause_play() -- swap play / pause, pause / play
stop(); -- stop
play(); -- play
pause()
Mute()
unMute()
sseek() -- seek
getTransportState() --current status of sonos
after last upgrade in all VD based on Jean-Christophe source is important to add port number 1400 in URL of sonos device (in my example is line 104)
