Pierre-Olivier Mercier
f4eaf8e7d1
Serve a small web page at http://<host>:8000/ (stream/index.html) from the Liquidsoap harbor, alongside the /radio.mp3 stream. It shows the track currently on air and refreshes it from a /nowplaying JSON endpoint, fed by the broadcast source's live metadata — accurate even though the ingest daemon runs a track ahead (prefetch). Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>
93 lines
3.3 KiB
Text
93 lines
3.3 KiB
Text
#!/usr/bin/liquidsoap
|
|
|
|
# radieo — couche diffusion.
|
|
# La source principale est pilotée par le daemon d'ingestion via GET /next.
|
|
# Le dossier /cache sert de secours quand le daemon n'a rien à proposer
|
|
# (daemon indisponible, file momentanément vide…). Si tout est vide : silence.
|
|
# Le harbor sert aussi une petite page web (/) et le titre courant (/nowplaying).
|
|
|
|
# --- Journalisation : tout sur la sortie standard (pratique en conteneur) ---
|
|
settings.log.stdout := true
|
|
settings.log.file := false
|
|
settings.log.level := 3
|
|
|
|
# --- Harbor : écoute sur toutes les interfaces du conteneur ---
|
|
settings.harbor.bind_addrs := ["0.0.0.0"]
|
|
|
|
# URL du daemon d'ingestion (nom de service résolu par docker-compose).
|
|
ingest_url = "http://ingest:8080/next"
|
|
|
|
# Callback appelé par request.dynamic pour obtenir le prochain morceau.
|
|
# Renvoie une requête à jouer, ou null si rien n'est disponible (→ secours).
|
|
def next_track() =
|
|
resp = http.get(ingest_url, timeout=5.0)
|
|
body = string.trim(resp)
|
|
if resp.status_code == 200 and body != "" then
|
|
request.create(body)
|
|
else
|
|
null
|
|
end
|
|
end
|
|
|
|
# Source principale : pilotée par le daemon. prefetch=1 pour anticiper le
|
|
# prochain morceau ; retry_delay pour ne pas marteler le daemon en cas de vide.
|
|
main = request.dynamic(next_track, prefetch=1, retry_delay=1.0)
|
|
|
|
# Filtre du secours : ne garder que les vrais fichiers audio et ignorer les
|
|
# fichiers cachés (.gitkeep, téléchargements .part en cours). Évite que le
|
|
# décodeur ne tente — et logue en erreur — des fichiers non-audio.
|
|
audio_ext = [".mp3", ".flac", ".ogg", ".opus", ".m4a", ".aac", ".wav"]
|
|
def audio_only(r) =
|
|
u = string.case(lower=true, request.uri(r))
|
|
base = path.basename(u)
|
|
is_audio = list.exists(fun(e) -> string.contains(suffix=e, u), audio_ext)
|
|
is_audio and not string.contains(prefix=".", base)
|
|
end
|
|
|
|
# Secours : le cache local, joué en aléatoire, rechargé quand il change.
|
|
backup = playlist(
|
|
mode="randomize", reload_mode="watch", check_next=audio_only, "/cache"
|
|
)
|
|
|
|
# fallback préfère la source principale et bascule sur le cache si elle n'a
|
|
# rien de prêt. track_sensitive=true : on ne coupe pas un morceau en cours.
|
|
radio = fallback(track_sensitive=true, [main, backup])
|
|
|
|
# Transition douce entre les morceaux : fondu enchaîné de 3 s. La fin du
|
|
# morceau courant se fond dans le début du suivant.
|
|
radio = crossfade(duration=3.0, fade_in=3.0, fade_out=3.0, radio)
|
|
|
|
# mksafe garantit un flux continu : silence plutôt que plantage si tout est vide.
|
|
radio = mksafe(radio)
|
|
|
|
# --- Métadonnées « en cours de lecture » -----------------------------------
|
|
# On mémorise les dernières métadonnées vues sur le flux réellement diffusé.
|
|
now_playing = ref([])
|
|
radio.on_metadata(synchronous=false, fun(m) -> now_playing := m)
|
|
|
|
# --- Sortie : flux MP3 sur http://<hote>:8000/radio.mp3 ---
|
|
output.harbor(
|
|
%mp3(bitrate=192),
|
|
port=8000,
|
|
mount="radio.mp3",
|
|
radio
|
|
)
|
|
|
|
# --- Page web et API de lecture (mêmes port/harbor que le flux) ---
|
|
home_html = file.contents("/etc/liquidsoap/index.html")
|
|
|
|
harbor.http.register(
|
|
port=8000, method="GET", "/",
|
|
fun(_, resp) -> begin
|
|
resp.content_type("text/html; charset=utf-8")
|
|
resp.html(home_html)
|
|
end
|
|
)
|
|
|
|
harbor.http.register(
|
|
port=8000, method="GET", "/nowplaying",
|
|
fun(_, resp) -> begin
|
|
m = now_playing()
|
|
resp.json({title=m["title"], artist=m["artist"]})
|
|
end
|
|
)
|