--- a
+++ b/src/radio_scripts/radio-paradise-get-flac.py
@@ -0,0 +1,129 @@
+#!/usr/bin/env python3
+from __future__ import print_function
+# Copyright (C) 2017-2018 J.F.Dockes
+# This program is free software; you can redistribute it and/or modify
+# it under the terms of the GNU General Public License as published by
+# the Free Software Foundation; either version 2 of the License, or
+# (at your option) any later version.
+#
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+# GNU General Public License for more details.
+#
+# You should have received a copy of the GNU General Public License
+# along with this program; if not, write to the
+# Free Software Foundation, Inc.,
+# 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
+#
+
+# Handling the Flac channel from radio-paradise. This is made of
+# 'blocks' which are multi-title periods with a single audio
+# url. Metadata should be displayed according to the elapsed time in
+# the audio (each metadata entry in the array gives the start and
+# duration for the song in mS). If metadata is re-fetched during the
+# block, it is front-truncated, more or less according to the current
+# time, and it may happen that the metadata for the song playing
+# locally is not there any more (someone starting at this point would
+# begin with the next point). The thing which does not change for
+# successive fetches of the same block is the "end_event" value. We
+# cache the first fetch for any block so that we are sure to have the
+# right metadata available when upmpdcli calls us
+
+
+import requests
+import json
+import sys
+import os
+
+tmpname = '/tmp/up-rp-pldata.json'
+
+def debug(x):
+ print("%s"%x, file=sys.stderr)
+ pass
+
+# Write new block data to cache. We always output the audio url in this case.
+def newcache(jsd):
+ global out
+ s = json.dumps(jsd,sort_keys=True, indent=4)
+ open(tmpname, 'wb').write(s.encode('utf-8'))
+ os.chmod(tmpname, 0o666)
+ out["audioUrl"] = jsd['url'] + "?src=alexa"
+
+
+# We're expecting the current elapsed playing time in mS as arg
+elapsedms = -1
+try:
+ elapsedms = int(sys.argv[1])
+except:
+ pass
+
+debug("rp-get-flac: got elapsed %d" % elapsedms)
+
+# Try to read the current cached data.
+cached = None
+try:
+ s = open(tmpname, 'rb').read().decode('utf-8', errors = 'replace')
+ cached = json.loads(s)
+except Exception as err:
+ debug("No cached data read: %s" % err)
+ pass
+
+
+r = requests.get("https://api.radioparadise.com/api/get_block",
+ params={"bitrate": "4", "info":"true"})
+r.raise_for_status()
+newjsd = r.json()
+
+out = {}
+
+# If we are currently playing, check if our cached data is still
+# relevant. If it is, it is more complete than the new data which is
+# front-truncated, so we use it, so that we can check if we are still
+# playing a track which might not be in the new list. Also if we go to
+# a new block, we output the audio URL
+if cached:
+ debug("Cached end_event %s new %s"%(cached['end_event'], newjsd['end_event']))
+if elapsedms >= 0 and cached and 'end_event' in cached and \
+ cached['end_event'] == newjsd['end_event']:
+ debug("rp-get-flac: using cached data")
+ jsd = cached
+else:
+ debug("outputting audio url because using new metadata or not playing")
+ jsd = newjsd
+ elapsedms = -1
+ newcache(jsd)
+
+currentk = None
+if elapsedms > 0:
+ songs = jsd['song']
+ for k in sorted(songs.keys()):
+ startms = songs[k]['elapsed']
+ endms = startms + songs[k]['duration']
+ debug("k %s Startms %d endms %d" % (k, startms, endms))
+ if elapsedms >= startms and elapsedms <= endms:
+ currentk = k
+ break
+
+if not currentk:
+ # Not found ?? Try to reset the thing
+ debug(("outputting audio url because current elapsed %d " + \
+ " not found in song array") % elapsedms)
+ jsd = newjsd
+ newcache(jsd)
+ out['reload'] = 3
+else:
+ songs = jsd['song']
+ out['title'] = songs[currentk]['title']
+ out['artist'] = songs[currentk]['artist']
+ out['album'] = songs[currentk]['album']
+ out['artUrl'] = 'http:%s%s' % (jsd['image_base'],
+ songs[currentk]['cover'])
+ reload = int((endms - elapsedms)/1000)
+ # Last song: reload a bit earlier so that we can queue the URL
+ if currentk == len(songs) -1 and reload > 3:
+ reload -= 2
+ out['reload'] = reload
+
+debug("%s" % json.dumps(out))
+print("%s" % json.dumps(out))