diff --git a/stream/radio.liq b/stream/radio.liq index 12d5bb3..8a46fcb 100644 --- a/stream/radio.liq +++ b/stream/radio.liq @@ -217,6 +217,23 @@ radio.on_metadata( end ) +# Durée et instant de départ du morceau courant, pour la règle de scrobble du +# player (« démarré au début et écouté à ~90 % »). CAPTURÉS ICI, DANS LE THREAD +# D'HORLOGE via un on_metadata SYNCHRONE : interroger source.duration/ +# source.elapsed depuis un handler HTTP (thread harbor) entrait en contention +# avec l'horloge du crossfade pendant une transition et figeait l'antenne. On ne +# touche donc plus la source hors de son horloge : /nowplaying (web.liq) se +# contente de lire ces refs — position = temps écoulé depuis cur_started. +cur_duration = ref(0.) +cur_started = ref(time()) +radio.on_metadata( + synchronous=true, + fun(_) -> begin + cur_duration := source.duration(radio) + cur_started := time() + end +) + # --- Sortie : flux MP3 sur http://:8000/radio.mp3 --- output.harbor( %mp3(bitrate=192), diff --git a/stream/web.liq b/stream/web.liq index bbe017e..d1d6fe9 100644 --- a/stream/web.liq +++ b/stream/web.liq @@ -95,11 +95,14 @@ harbor.http.register( # /scrobble pour prouver qu'il parle bien du titre à l'antenne. # `duration`/`position` (secondes, arrondies) permettent au player de décider # d'un scrobble « écouté à 90 %, démarré au début ». duration=0 si inconnue. + # Ces valeurs sont pré-calculées dans le thread d'horloge (voir cur_duration/ + # cur_started dans radio.liq) : on ne doit JAMAIS appeler source.duration/ + # source.elapsed ici, ça figerait l'antenne pendant un crossfade. resp.json({ title=m["title"], artist=m["artist"], url=m["url"], origin=m["origin"], file=path.basename(m["filename"]), - duration=int_of_float(source.duration(radio)), - position=int_of_float(source.elapsed(radio)) + duration=int_of_float(cur_duration()), + position=int_of_float(time() - cur_started()) }) end )