Fix radio queue

Author: Ategon

features/radio/router.ts

@@ -47,8 +47,13 @@ export function createRadioRouter() {
       res.setHeader("Content-Type", "text/event-stream");
       res.setHeader("Cache-Control", "no-cache, no-transform");
       res.setHeader("Connection", "keep-alive");
+      res.setHeader("X-Accel-Buffering", "no");
       res.flushHeaders?.();
       addRadioClient(tenantId, res);
+      const heartbeat = setInterval(() => {
+        res.write(": heartbeat\n\n");
+      }, 25_000);
+      res.on("close", () => clearInterval(heartbeat));
       const state = await getRadioState({ tenantId: baseTenantId, station });
       res.write(`event: state\n`);
       res.write(`data: ${JSON.stringify(state)}\n\n`);

features/radio/service.ts

@@ -369,6 +369,16 @@ export async function getRadioState({
 }) {
   const normalizedTenantId = resolvedTenantId(tenantId);
   const session = await ensureRadioSession(normalizedTenantId, station);
+  const startedAtMs = session.startedAt?.getTime() ?? 0;
+  if (
+    session.currentTrackId &&
+    startedAtMs > 0 &&
+    Date.now() >= startedAtMs + session.durationSeconds * 1000
+  ) {
+    await advanceRadioIfNeeded(normalizedTenantId, false, station);
+    const advancedSession = await ensureRadioSession(normalizedTenantId, station);
+    return presentRadioState(advancedSession, actor);
+  }
   return presentRadioState(session, actor);
 }