// The status bar (spec §9): the proposal whose source is the current
// bookmark, with its checks, refreshed on the hub's event stream.

import * as vscode from "vscode";
import { HubAuth } from "./auth";
import type { HubRepo } from "./proposals";

export class ChecksBar implements vscode.Disposable {
  private readonly item = vscode.window.createStatusBarItem(vscode.StatusBarAlignment.Left, 40);
  private timer: NodeJS.Timeout | undefined;

  constructor(
    private readonly auth: HubAuth,
    private readonly repos: () => Promise<HubRepo[]>,
  ) {
    this.item.command = "oxygenhub.openProposal";
  }

  async refresh(): Promise<void> {
    const repos = await this.repos();
    for (const repo of repos) {
      const bookmark = repo.handle.currentBookmark;
      if (!bookmark) {
        continue;
      }
      try {
        const list = await this.auth.clientFor(repo.base).proposals(repo.owner, repo.name);
        const p = list.find((x) => x.source.kind === "bookmark" && x.source.bookmark === bookmark && x.state === "open");
        if (p) {
          const checks = await this.auth.clientFor(repo.base).proposalChecks(repo.owner, repo.name, p.number);
          const passed = checks.filter((c) => c.status === "passed").length;
          const failed = checks.filter((c) => c.status === "failed").length;
          const running = checks.filter((c) => c.status === "running" || c.status === "queued").length;
          const glyph = failed ? "$(error)" : running ? "$(sync~spin)" : checks.length ? "$(pass)" : "$(git-pull-request)";
          this.item.text = `${glyph} #${p.number}${checks.length ? ` ${passed}/${checks.length}` : ""}`;
          this.item.tooltip = `${p.title}\n${p.landable ? "ready to land" : p.blockers.join("\n")}`;
          this.item.command = { title: "Open", command: "oxygenhub.openProposal", arguments: [{ kind: "proposal", repo, p }] };
          this.item.show();
          return;
        }
      } catch {
        // Not signed in or unreachable: nothing to show.
      }
    }
    this.item.hide();
  }

  /** Poll on the configured interval; the hub's SSE stream needs a browser-grade EventSource, so the bar polls instead. */
  start(): void {
    const seconds = vscode.workspace.getConfiguration("oxygenhub").get<number>("autoRefresh") ?? 60;
    if (this.timer) {
      clearInterval(this.timer);
    }
    if (seconds > 0) {
      this.timer = setInterval(() => void this.refresh(), seconds * 1000);
    }
    void this.refresh();
  }

  dispose(): void {
    if (this.timer) {
      clearInterval(this.timer);
    }
    this.item.dispose();
  }
}