Queue Events (SSE)

// Cloud authenticates this stream, so proxy it from your server: EventSource
// cannot send an Authorization header, and a key does not belong in a bundle.
const source = new EventSource("/api/openinary/queue/events");

source.addEventListener("job:progress", (e) => {
  const { jobId, progress } = JSON.parse(e.data);
  updateProgressBar(jobId, progress);
});

source.addEventListener("job:completed", (e) => {
  const { jobId } = JSON.parse(e.data);
  markDone(jobId);
});

source.addEventListener("job:error", (e) => {
  const { jobId, error } = JSON.parse(e.data);
  console.error(`Job ${jobId} failed:`, error);
});

GET /queue/events