path: root/src/js/radio-emulator.js

// Radio Station Emulator
//
// Kaotisk Hund - 2024
//
// @license magnet:?xt=urn:btih:0b31508aeb0634b347b8270c7bee4d411b5d4109&dn=agpl-3.0.txt AGPL v3.0
//
// A simple co-mechanism to pretend playing a live radio as it would happen for
// a radio station that mostly plays prerecoded shows.
//
// Client side implementation
// Let's remind here the structures we are waiting for:
// 1. Hash
// 2. 0
// 3. audio/ogg file
// 4. application/json file
//
// 1. Hash
// Can be an SHA512sum or SHA256sum, we don't do checks, we only ask the hash
// accompanied by what do we think it is.
//
// 2. 0
// When nothing exists on the radio station we are visiting.
//
// 3. audio/ogg file
// An audio file to play.
//
// 4. application/json file
// Could be one of the following:
//   - list
//   - show_info
//
import { makeElement } from "./arching-kaos-generator.js";
import { getSettings } from "./arching-kaos-web-ui-settings.js";
import { generateImage } from "./image-generator.js";

var debugMode = false;
const settings = getSettings();
const apiURL = settings.ak.radio.list[settings.ak.radio.active];
const version = "v0";
const listRequest = `${apiURL}/${version}/list`
const jsonRequest = `${apiURL}/${version}/application/json/`
const audioRequest = `${apiURL}/${version}/audio/ogg/`

const documentTitle = "Radio Station Emulator";
const separator = " :: ";

export function getAudioElement()
{
    return document.querySelector('#radio-player');
}

export function getCurrentTime()
{
    return document.querySelector('.current-time');
}

export function getListStarted()
{
    return document.querySelector('.started-on');
}

export function getCurrentShowHash ()
{
    return document.querySelector('.current-show-hash');
}

export function getListHash ()
{
    return document.querySelector('.list-hash');
}

export function getArtist()
{
    return document.querySelector('.artist');
}

export function getTitle()
{
    return document.querySelector('.title');
}

export function getRadioPlayer()
{
    return document.querySelector('.radio-player');
}

export function getYouAreHere ()
{
    return document.querySelector('.you-are-here');
}

export function getPlayProgress()
{
    return document.querySelector('.play-progress');
}

export function getStartsOn()
{
    return document.querySelector('.starts-on');
}

export function getShowDuration()
{
    return document.querySelectorAll('.show-duration');
}

export function getRelativeTime()
{
    return document.querySelector('.relative-time');
}

export function getListeningAt()
{
    return document.querySelector('.listening-at');
}

export function getDlProgress()
{
    return document.querySelector('.dl-progress');
}

export function getMinTimesPlayed()
{
    return document.querySelector('.min-played');
}

export function getMaxTimesPlayed()
{
    return document.querySelector('.max-played');
}

export function getListDuration()
{
    return document.querySelector('.list-duration');
}

export function getPreviouslyPlayed()
{
    return document.querySelector('.previously-played');
}

export function getShowInfo()
{
    return document.querySelector('.show-info');
}

export function getListInfo()
{
    return document.querySelector('.list-info');
}

export function getDt()
{
    return document.querySelector('.d-t');
}

export function getDeltaTime()
{
    return document.querySelector('.delta-time');
}

export function getTimeOfVisit()
{
    return document.querySelector('.time-of-visit');
}

var values = {
    delta_time: 0,
    min_times_played: 0,
    maxTimesPlayed: 0,
    Dt: 0,
    now_on_sequence: 0,
    seconds_here: 0,
    current_time: 0
}

function debugLog(message)
{
    if ( debugMode ) console.log(message);
}

function setTitleSyncing(){
    document.title = "🔃Syncing" + separator + documentTitle;
}

function setTitleMessage(message){
    document.title = message + separator + documentTitle;
}

function updateComponentsAfterIncreaseSeconds()
{
    getYouAreHere().innerText = values.seconds_here;
    getPlayProgress().value = values.current_time + values.seconds_here;
    getRelativeTime().innerText = values.current_time + values.seconds_here;
    getListeningAt().innerText = Math.floor(getAudioElement().currentTime);
}

function increaseSeconds()
{
    values.seconds_here = values.seconds_here + 1;
    updateComponentsAfterIncreaseSeconds();
    return values.seconds_here;
}
function getSecondsHere()
{
    return values.seconds_here;
}

setInterval(increaseSeconds, 1000);


function FetchJSON( url, callback, params )
{
    setTitleSyncing();
    const request = new XMLHttpRequest();
    request.addEventListener("load", ()=>{
        var json = JSON.parse(request.response);
        if(request.status !== 404){
            callback(json, params);
        } else {
            debugLog(`ERROR ${request.status} while loading ${url}`);
        }
    });
    request.addEventListener("error", ()=>{
        debugLog("An error occured. While loading: "+url+" for "+callback+".");
    });
    request.addEventListener("abort", ()=>{
        debugLog("Request aborted: "+url+" for "+callback+".");
    });
    request.open("GET", url);
    request.send();
}

function FetchAudio(url, callback)
{
    const request = new XMLHttpRequest();
    request.responseType = 'blob';
    request.addEventListener("load", ()=>{
        if(request.status === 200){
            debugLog("Got it... trying!")
            getDlProgress().value = 100;
            getAudioElement().src = URL.createObjectURL(request.response);
            callback();
            //getAudioElement().play();
            debugLog("Tried... did it work?");
        } else {
            debugLog(`ERROR ${request.status} while loading ${url}`);
        }
    });
    request.addEventListener("progress", (event)=>{
        if (event.lengthComputable)
        {
            debugLog(`Fetching: ${event.total}`);
            getDlProgress().value = (event.loaded/event.total)*100;
        }
    });
    request.addEventListener("error", ()=>{
        debugLog("An error occured. While loading: "+url);
    });
    request.addEventListener("abort", ()=>{
        debugLog("Request aborted: "+url);
    });
    request.open("GET", url);
    request.send();
}

function genericCallback(json, params)
{
    debugLog('genericCallback');
    debugLog(json);
    debugLog(params);
}

var calledLoadShowCallback = 0;

function stopHereAndReflect()
{
    return 0;
}

function updateComponentsAfterLoadShowCallback(json, listItem)
{
    setTitleMessage ( "▶️ " + json.artist + " - " + json.title );
    getCurrentShowHash().innerText = listItem.hash;
    getArtist().innerText = json.artist;
    getTitle().innerText = json.title;
    getShowDuration().forEach((element)=>{element.innerText = Math.floor(listItem.duration/1000)});
    getStartsOn().innerText = listItem.starts_on;
    getPlayProgress().max = Math.floor(listItem.duration/1000);
    getShowInfo().innerText = JSON.stringify(json, null, 2);
    getCurrentTime().innerText = values.current_time;
}

function loadShowCallback(json, params)
{
    const [ list, now_on_sequence, listItem, hash_of_list ] = params;
    debugLog('loadShowCallback');
    debugLog(json);
    debugLog(listItem);
    //debugLog(params);
    getAudioElement().load();
    FetchAudio(`${audioRequest}${json.hash}`, sync_radio);
    getAudioElement().type = json.mimetype;
    values.current_time = Math.floor((values.now_on_sequence/1000)); // - listItem.starts_on)/1000);
    updateComponentsAfterLoadShowCallback(json, listItem);
    getAudioElement().addEventListener('ended', function(){
        values.current_time = 0;
        values.seconds_here = 0;
        getCurrentTime().value = 0;
        FetchJSON(`${listRequest}`, hashCallback, [ new Date().getTime() ]);
    });
}

function preciseIncreaseVolume(value)
{
    if ( value <= 1 ) getAudioElement().volume = value;
}

function fadeInAudio()
{
    var timeSpan = 1000;
    var timeStep = 100;
    for ( var i = 0; i <= 90; i++ )
    {
        timeSpan = timeSpan + timeStep;
        var newVolume = Math.sin(i*(Math.PI/180));
        setTimeout( preciseIncreaseVolume(newVolume), timeSpan);
    }
}

export function sync_radio()
{
    var new_now = values.current_time + getSecondsHere();
    debugLog("Trying to sync @ "+ values.current_time + " + " + getSecondsHere() + " = " + new_now);
    getAudioElement().currentTime = new_now;
    getAudioElement().play();
    getAudioElement().muted = false;
    getAudioElement().volume = 0;
    fadeInAudio();
    return new_now;
}</