Function JobQueue

web/src/app/JobQueue.tsx:20–224

({
  accessToken,
  onOpenResult,
  collapsible = true,
  defaultCollapsed = true,
  title = "Job queue",
  onInProgressChange,
}: {
  accessToken: string | null;
  onOpenResult?: (id: string) => void;
  collapsible?: boolean;
  defaultCollapsed?: boolean;
  title?: string;
  onInProgressChange?: (inProgress: boolean) => void;
})

};

export function JobQueue({
  accessToken,
  onOpenResult,
  collapsible = true,
  defaultCollapsed = true,
  title = "Job queue",
  onInProgressChange,
}: {
  accessToken: string | null;
  onOpenResult?: (id: string) => void;
  collapsible?: boolean;
  defaultCollapsed?: boolean;
  title?: string;
  onInProgressChange?: (inProgress: boolean) => void;
}) {
  const [jobs, setJobs] = useState<Job[]>([]);
  const [loading, setLoading] = useState(false);

  const refresh = async () => {
    if (!accessToken) return;
    try {
      setLoading(true);
      const url = new URL("/api/review/jobs", import.meta.env.VITE_API_URL);
      const res = await fetch(url, {
        headers: { Authorization: `Bearer ${accessToken}` },
      });
      if (!res.ok) return;
      const json = await res.json();
      setJobs(json as Job[]);
    } finally {
      setLoading(false);
    }
  };

  useEffect(() => {
    if (!accessToken) return;
    // Single refresh on mount/token change
    void refresh();
  }, [accessToken]);

  // Notify parent when any job is queued or running
  useEffect(() => {
    const anyInProgress = jobs.some(
      (j) => j.status === "Queued" || j.status === "Running"
    );
    onInProgressChange?.(anyInProgress);
  }, [jobs, onInProgressChange]);

  // (count callback removed)

  const canCancel = (j: Job) => j.status === "Queued";

  const cancel = async (id: string) => {
    if (!accessToken) return;
    const url = new URL(
      `/api/review/${id}/cancel`,
      import.meta.env.VITE_API_URL
    );