Index: channels/radiobrowser.py ================================================================== --- channels/radiobrowser.py +++ channels/radiobrowser.py @@ -1,16 +1,18 @@ # encoding: UTF-8 # api: streamtuner2 # title: RadioBrowser # description: Community collection of stations; votes, clicks, homepage links. -# version: 0.3 +# version: 0.4 # type: channel # url: http://www.radio-browser.info/ # category: radio # priority: optional # config: -# { type=select, name=radiobrowser_cat, value=tags, select="tags|countries|languages", description=Which category types to list. } +# { name: radiobrowser_cat, type: select, value: tags, select="tags|countries|languages", description: Which category types to list. } +# { name: radiobrowser_srv, type: select, value: all, select:"all|de1|fr1|nl1|old", description: API server to utilize. } +# { name: radiobrowser_min, type: int, value: 20, description: Minimum stations to list a category/tag. } # documentation: http://www.radio-browser.info/#ui-tabs-7 # png: # iVBORw0KGgoAAAANSUhEUgAAABAAAAAMCAMAAABcOc2zAAAABGdBTUEAALGPC/xhBQAAACBjSFJNAAB6JgAAgIQAAPoAAACA6AAAdTAAAOpgAAA6mAAAF3CculE8AAACQ1BMVEWNYNOIWNFyOsZtNcFx # N8hxN8hxN8hxN8hxN8hxN8hxN8dtNcFuNcJ+Ss2NX9N6T7uNX9NxPL9jMLBtNcBkMbFqNLuCT89wRq6MXtOATc17Rsp8SMl6Rcl6RctrQqmpht1qQ6PUxex6WqnXye18XarYyu3QyNzp5u739/jh3Ojd # 2OX4+Pl7XKrYy+3i3eh8Y6Dg2+i2q8ecjrGqm8Krm8LTzN+ikbunl8D5+fl7W6rZy+7z8fTk4Or29fjAuM3Dv8rx7vTs6vHy8PTh3Ojy8PX5+fl6Wqraze75+fn5+vn6+vn6+vn6+vl6WqrMuOl1U6iR @@ -26,19 +28,19 @@ # x-service-by: segler_alex # extraction-method: json # # # Radio-Browser is a community-collected list of internet radios. -# Currently lists ≥4000 streaming stations, and tracks favourited +# Currently lists ≥25000 streaming stations, and tracks favourited # entries. Furthermore includes station homepage links! # # If you change the categories between tags/countries/languages, # please apply [Channel]→[Reload Category Tree] afterwards. # -# Also has a neat JSON API, has an excellent documentation, thus -# is quite easy to support. It's also used by Rhythmbox / VLC / -# Clementine / Kodi / RadioDroid / etc. +# Also has an awesome JSON API, has an excellent documentation, +# thus is quite pleasant to support. It's also used by Rhythmbox / +# VLC / Clementine / Kodi / RadioDroid / etc. import re import json from config import * @@ -46,86 +48,113 @@ from uikit import uikit import ahttp # API endpoints: -# http://www.radio-browser.info/webservice/json/countries -# http://www.radio-browser.info/webservice/json/languages -# http://www.radio-browser.info/webservice/json/tags -# http://www.radio-browser.info/webservice/json/stations/topclick -# http://www.radio-browser.info/webservice/json/stations/topvote -# http://www.radio-browser.info/webservice/json/stations -# http://www.radio-browser.info/webservice/json/stations/searchterm -# http://www.radio-browser.info/webservice/json/stations/bytag/searchterm +# https://de1.api.radio-browser.info/#General # # ENTRY sets: -# {"id":63,"name": "Energy Sachsen", "url":"http://www.energyradio.de/sachsen", -# "homepage":"http://www.energy.de", "favicon":"http://www.energy.de/favicon.ico", -# "tags":"Pop Dance RnB Techno","country":"Germany","subcountry":"","language":"German", -# "votes":4,"negativevotes":10}, +# { +# "stationuuid":"960e57c5-0601-11e8-ae97-52543be04c81", "name":"SRF 1", +# "url":"http://stream.srg-ssr.ch/m/drs1/mp3_128", "homepage":"http://ww.srf.ch/radio-srf-1", +# "favicon":"https://upload.wikimedia.org/wikipedia/commons/thumb/d/d3/Radio_SRF_1.svg/205px-Radio_SRF_1.svg.png", +# "tags":"srg ssr,public radio", +# "country":"Switzerland", "countrycode":"CH", "state":"", "language":"german", "votes":0, +# "lastchangetime":"2019-12-12 18:37:02", "codec":"MP3", "bitrate":128, "hls":0, "lastcheckok":1, +# "lastlocalchecktime":"2020-01-08 23:18:38", "clickcount":0, +# } # class radiobrowser (ChannelPlugin): # control flags has_search = True listformat = "pls" - titles = dict(listeners="Votes+", bitrate="Votes-", playing="Country") - base = "http://www.radio-browser.info/webservice/json/" - categories = [] + titles = dict(listeners="Votes", bitrate="Bitrate", playing="Country") + api_old = "http://www.radio-browser.info/webservice/json/" + api_url = "http://{}.api.radio-browser.info/json/" # de1, nl1, all (from conf.radiobrowser_srv) + categories = ["topvote", "topclick", "60s", "70s", "80s", "90s", "adult contemporary", "alternative", "ambient", "catholic", "chillout", "christian", "classic hits", "classic rock", "classical", "college radio", "commercial", "community radio", "country", "dance", "electronic", "folk", "hiphop", "hits", "house", "indie", "information", "jazz", "local music", "local news", "lounge", "metal", "music", "news", "noticias", "npr", "oldies", "pop", "public radio", "religion", "rock", "soul", "sport", "talk", "techno", "top 40", "university radio", "variety", "world music"] pricat = ("topvote", "topclick") catmap = { "tags": "bytag", "countries": "bycountry", "languages": "bylanguage" } + tagmap = { "tags": "tag", "countries": "country", "languages": "language" } # hook menu def init2(self, parent): if parent: uikit.add_menu([parent.streammenu, parent.streamactions], "Share in Radio-Browser", self.submit, insert=5) # votes, and tags, no countries or languages def update_categories(self): - self.categories = list(self.pricat) - for sub in [conf.radiobrowser_cat]: - cats = [] - for entry in self.api(sub): - if entry["value"] and len(entry["value"]) > 1: - cats.append(entry["value"]) - self.categories.append(sub) - self.categories.append(cats) + params = {"order":"name", "reverse":"false", "hidebroken":"true"} + self.categories = list(self.pricat) + [grp["name"] for grp in filter( + lambda grp: grp["stationcount"] >= conf.radiobrowser_min, + self.api(conf.radiobrowser_cat, params) + )] # Direct mapping def update_streams(self, cat, search=None): - if cat: - if cat in self.pricat: - data = self.api("stations/" + cat) - elif cat in ("tags", "countries", "languages"): - return [dict(genre="-", title="Placeholder category", url="offline:")] - else: - data = self.api("stations/" + self.catmap[conf.radiobrowser_cat] + "/" + cat) - elif search: - data = self.api("stations/" + search) - else: - return [] + # title search + if search: + data = self.api( + "stations/search", + {"search": search, "limit": conf.max_streams} + ) + # topclick, topvote + elif cat in self.pricat: + data = self.api( + "stations/{}/{}".format(cat, conf.max_streams), + {"limit": conf.max_streams} + ) + # empty category + #elif cat in ("tags", "countries", "languages"): + # return [ + # dict(genre="-", title="Placeholder category", url="offline:") + # ] + # search by tag, country, or language + else: + data = self.api( + "stations/search", + { + self.tagmap[conf.radiobrowser_cat]: cat, + "hidebroken": "true", + "order": "click", + "limit": conf.max_streams * 2 + } + ) + #data = self.api("stations/" + self.catmap[conf.radiobrowser_cat] + "/" + cat) + + if len(data) >= 5000: + data = data[0:5000] r = [] for e in data: r.append(dict( genre = e["tags"], url = e["url"], - format = "audio/mpeg", + format = mime_fmt(e["codec"]), title = e["name"], - homepage = e["homepage"], + homepage = ahttp.fix_url(e["homepage"]), playing = e["country"], listeners = int(e["votes"]), - bitrate = - int(e["negativevotes"]), + bitrate = int(e["bitrate"]), + favicon = e["favicon"] )) return r # fetch multiple pages - def api(self, method, params={}, post=False): - j = ahttp.get(self.base + method, params, post=post) + def api(self, method, params={}, post=False, **kwargs): + # api/srv switcheroo + if not "radiobrowser_srv" in conf: + conf.radiobrowser_srv = "all" + if conf.radiobrowser_srv == "old": + srv = self.api_old + else: + srv = self.api_url.format(conf.radiobrowser_srv) + # request + json decode + j = ahttp.get(srv + method, params, post=post, **kwargs) try: return json.loads(j, strict=False) # some entries contain invalid character encodings except: return [] @@ -152,5 +181,6 @@ # API submit j = self.api("add", data, post=1) log.SUBMIT_RBI(j) if j and "ok" in j and j["ok"] == "true" and "id" in j: self.parent.status("Submitted successfully to Radio-Browser.info, new station id #%s." % j["id"], timeout=15) +