Something went wrong. Try again.
A decentralized music tracking and discovery platform built on AT Protocol 🎵 rocksky.app
spotify atproto lastfm musicbrainz scrobbling listenbrainz
Something went wrong. Try again.
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354import { loadToken } from "lib/token";import { startMpdServer } from "../mpd/server";import { playerController } from "../tui/player";import { startHeadlessRuntime } from "../tui/runtime";import { loadSettings } from "../tui/settings";
/** * Start a Music Player Daemon protocol server. External MPD clients (mpc, * ncmpcpp, MALP, …) connect over TCP to control playback and browse the * library. The daemon owns its own headless player, so it works without the * TUI. Port/bind default to `~/.rocksky/settings.toml` `[mpd]`, overridable via * flags; a busy port falls back to the next free one. */export async function mpd(opts: { port?: string; bind?: string; output?: string;}) { const settings = loadSettings(); const port = opts.port ? parseInt(opts.port, 10) : settings.mpd.port; const bind = opts.bind ?? settings.mpd.bind; const getToken = () => loadToken();
const runtime = startHeadlessRuntime(getToken, { output: opts.output }); const server = await startMpdServer({ getToken, port, bind, log: (msg) => console.log(`[mpd] ${msg}`), });
console.log(`Rocksky MPD server listening on ${bind}:${server.port}`); if (!getToken()) { console.log( "Note: not logged in — run `rocksky login <handle>` to enable playback.", ); }
const shutdown = () => { server.close(); runtime.stop(); try { playerController.close(); } catch { // ignore audio-teardown errors } // The native audio engine keeps handles on the event loop; force a clean // exit to free the audio device. process.exit(0); }; process.on("SIGINT", shutdown); process.on("SIGTERM", shutdown);}