A music player that connects to your cloud/distributed storage. diffuse.sh
Something went wrong. Try again.
5.5 kB · 211 lines
JavaScript
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212import * as TID from "@atcute/tid";import { ostiary, rpc } from "~/common/worker.js";import { detach as detachUtil, groupKey, isAudioFile,} from "~/components/input/common.js";import { safeDecodeURIComponent } from "~/common/utils.js";
import { buildURI, checkAccessCached, groupTracksByServer, groupUrisByServer, listFiles, parseURI, serverId, toHttpUrl,} from "./common.js";import { SCHEME } from "./constants.js";
/** * @import { InputActions as Actions, ConsultGrouping } from "@specs/components/input/types.d.ts"; * @import { Track } from "~/definitions/types.d.ts"; */
////////////////////////////////////////////// ACTIONS////////////////////////////////////////////
/** * @type {Actions['artwork']} */export async function artwork(_uri) { return null;}
/** * @type {Actions['consult']} */export async function consult(fileUriOrScheme) { if (!fileUriOrScheme.includes(":")) { return { supported: true, consult: "undetermined" }; }
const parsed = parseURI(fileUriOrScheme); if (!parsed) return { supported: true, consult: "undetermined" };
const accessible = await checkAccessCached(parsed.server); return { supported: true, consult: accessible };}
/** * @type {Actions['detach']} */export async function detach(args) { return detachUtil({ ...args,
inputScheme: SCHEME, handleFileUri: ({ fileURI, tracks }) => { const result = parseURI(fileURI); if (!result) return tracks;
const id = serverId(result.server); const groups = groupTracksByServer(tracks);
delete groups[id];
return Object.values(groups).map((g) => g.tracks).flat(1); }, });}
/** * @type {Actions['groupConsult']} */export async function groupConsult(uris) { const groups = groupUrisByServer(uris);
const promises = Object.entries(groups).map( async ([id, { server, uris }]) => { const available = await checkAccessCached(server);
/** @type {ConsultGrouping} */ const grouping = available === "yes" ? { available, scheme: SCHEME, uris } : { available, reason: "Server unreachable", scheme: SCHEME, uris };
return { key: groupKey(SCHEME, id), grouping }; }, );
const entries = (await Promise.all(promises)).map((e) => [e.key, e.grouping]); return Object.fromEntries(entries);}
/** * @type {Actions['list']} */export async function list(cachedTracks = []) { /** @type {Record<string, Record<string, Track>>} */ const cache = {};
const groups = groupTracksByServer(cachedTracks);
Object.entries(groups).forEach(([id, { tracks }]) => { tracks.forEach((track) => { const parsed = parseURI(track.uri); if (!parsed) return;
if (!cache[id]) cache[id] = {}; cache[id][safeDecodeURIComponent(parsed.path)] = track; }); });
const promises = Object.entries(groups).map( async ([id, { server, tracks: cachedServerTracks }]) => { const files = await listFiles(server);
// `listFiles` returns `null` when the root directory listing could // not be fetched at all (e.g. the server was briefly unreachable // right after a laptop wake). In that case, preserve the previously // cached tracks for this server rather than replacing them with a // single placeholder — otherwise an interrupted refresh would wipe // the user's library and cascade into an empty browser view. if (files === null) { if (cachedServerTracks.length) return cachedServerTracks;
const now = new Date().toISOString(); return [/** @type {Track} */ ({ $type: "sh.diffuse.output.track", id: TID.now(), createdAt: now, updatedAt: now, kind: "placeholder", uri: buildURI(server), })]; }
let tracks = files .filter((path) => isAudioFile(path)) .map((path) => { const cachedTrack = cache[id]?.[safeDecodeURIComponent(path)];
const trackId = cachedTrack?.id || TID.now(); const stats = cachedTrack?.stats; const tags = cachedTrack?.tags; const now = new Date().toISOString();
/** @type {Track} */ const track = { $type: "sh.diffuse.output.track", id: trackId, createdAt: cachedTrack?.createdAt ?? now, updatedAt: cachedTrack?.updatedAt ?? now, stats, tags, uri: buildURI(server, path), };
return track; });
if (!tracks.length) { const now = new Date().toISOString();
tracks = [{ $type: "sh.diffuse.output.track", id: TID.now(), createdAt: now, updatedAt: now, kind: "placeholder", uri: buildURI(server), }]; }
return tracks; }, );
return (await Promise.all(promises)).flat(1);}
/** * @type {Actions['resolve']} */export async function resolve({ uri }) { const parsed = parseURI(uri); if (!parsed || !parsed.path) return undefined;
const url = toHttpUrl(parsed.server, parsed.path); const expiresAt = Math.round(Date.now() / 1000) + 60 * 60 * 24 * 365;
return { url, expiresAt };}
////////////////////////////////////////////// ⚡️////////////////////////////////////////////
ostiary((context) => { rpc(context, { artwork, consult, detach, groupConsult, list, resolve, });});