radio.js

import readline from 'readline';
import chalk from 'chalk';
import { spawn } from 'child_process';
import winston from 'winston';

const radioStations = [
    { shortcut: 'c', name: '🇨🇭 Couleur 3', url: 'http://stream.srg-ssr.ch/m/couleur3/mp3_128' },
    { shortcut: 'i', name: '🇫🇷 France Info', url: 'http://icecast.radiofrance.fr/franceinfo-hifi.aac' },
    { shortcut: 'j', name: '🇫🇷 Jazz Radio', url: 'http://jazzradio.ice.infomaniak.ch/jazzradio-high.mp3' },
    { shortcut: 'n', name: '🇫🇷 Radio Nova', url: 'http://radionova.ice.infomaniak.ch/radionova-256.aac' },
    { shortcut: 'w', name: '🇨🇴 La W', url: 'https://24273.live.streamtheworld.com/WRADIOAAC.aac' },
];

const rl = readline.createInterface({
    input: process.stdin,
    output: process.stdout,
});

const logger = winston.createLogger({
    level: 'info',
    format: winston.format.combine(
        winston.format.timestamp({ format: 'YYYY-MM-DD HH:mm:ss' }),
        winston.format.printf(({ message, timestamp }) => `${timestamp}: ${message}`),
    ),
    transports: [
        new winston.transports.File({ filename: 'listening.log' }),
    ],
});

const playRadio = async (stationUrl) => {
    const ffplayProcess = spawn('ffplay', ['-nodisp', '-i', stationUrl]);

    ffplayProcess.on('close', () => {
        process.stdout.write(chalk.green('Radio playback ended.\n'));
        rl.close();
    });
};

let previousStreamTitle = '';
const getMetadata = async (station) => {
    const ffprobeProcess = spawn('ffprobe', ['-v', 'quiet', '-print_format', 'json', '-show_format', station.url]);
    const metadataChunks = [];

    ffprobeProcess.stdout.on('data', (data) => {
        metadataChunks.push(data);
    });

    ffprobeProcess.on('close', () => {
        try {
            const jsonData = Buffer.concat(metadataChunks).toString();
            const metadata = JSON.parse(jsonData);

            process.stdout.clearLine(0);
            process.stdout.cursorTo(0);
            if (metadata.format.tags !== undefined && metadata.format.tags.StreamTitle !== undefined) {
                process.stdout.write(`🎵 ${metadata.format.tags.StreamTitle}\r`);

                if (previousStreamTitle !== metadata.format.tags.StreamTitle) {
                    previousStreamTitle = metadata.format.tags.StreamTitle;
                    logger.info({ message: `[${station.name}] ${previousStreamTitle}` });
                }
            }
        } catch (error) {
            process.stdout.write('Error parsing JSON:', error);
        }
    });
};

process.stdout.write(chalk.yellow('Available radio stations:\n'));
radioStations.forEach((station) => {
    process.stdout.write(`${chalk.blue(station.shortcut)}. ${station.name}\n`);
});

rl.question(chalk.cyan('Enter the shortcut of the radio station you want to listen to: '), async (answer) => {
    const selectedStation = radioStations.find((station) => station.shortcut === answer);

    if (selectedStation) {
        process.stdout.write(chalk.green(`Now playing ${selectedStation.name}\n`));
        await playRadio(selectedStation.url);

        // Print metadata every 5 seconds.
        await getMetadata(selectedStation);
        setInterval(async () => {
            await getMetadata(selectedStation);
        }, 5_000);
    } else {
        process.stdout.write(chalk.red('Invalid station shortcut.\n'));
        rl.close();
    }
});