Open Source Projects Europe

#!/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))