const fs = require("fs"); const path = require("path"); const uti = require("util"); const exec = uti.promisify(require("child_process").exec); const Koa = require("koa"); const koaPug = require("koa-pug"); const koaRouter = require("koa-router"); const fetch = require("node-fetch"); const config = require("./config"); const util = require("../shared/util"); async function getRadioStatus() { try { let status = await fetch('http://radio.arav.home/status-json.xsl').then(r => r.json()); return { server_start_iso8601: status.icestats.server_start_iso8601, server_start_date: util.datetime(status.icestats.server_start_iso8601, util.post_date_format), song: `${status.icestats.source.artist} - ${status.icestats.source.title}`, listener_peak: status.icestats.source.listener_peak, listeners: status.icestats.source.listeners } } catch { return { server_start_iso8601: "n/a", server_start_date: "n/a", song: "n/a", listener_peak: "n/a", listeners: "n/a" } } } async function getLastSongs(count=11) { const { stdout, stderr } = await exec(`tail -n ${count} /var/log/icecast/playlist.log | awk -F '|' '{ print $4 }'`); let songs = stdout.trim().split("\n"); songs.pop(); for (let i = 0; i < songs.length; ++i) songs[i] = songs[i].split(' - '); return songs; } function setRoutes() { return koaRouter().get('/', async ctx => { await ctx.render('index', { title: "/ Radio", description: "Internet-radio broadcasting from under my desk.", main_site: util.getServiceByHost(ctx.header.host), radio_status: await getRadioStatus(), last_songs: await getLastSongs() }); }) .get('/filelist', async ctx => { ctx.type = 'text/html'; ctx.body = fs.readFileSync( path.join(__dirname, '/static/radio_filelist.html')); }) .get('/playlist', async ctx => { ctx.attachment('radio.arav.top.m3u'); ctx.body = fs.readFileSync( path.join(__dirname, '/static/assets/files/radio.arav.top.m3u')); }) .get('/stats', async ctx => { ctx.body = await getRadioStatus(); }) .get('/lastplayed', async ctx => { ctx.body = await getLastSongs(); }); } const app = new Koa(); const pug = new koaPug({ viewPath: path.join(__dirname, "views"), locals: { moment: util.datetime }, app: app }); app.proxy = true; app .use(setRoutes().routes()) .listen(config.port, config.host);