fabro/apps/fabro-web/app/lib/query-keys.ts

export type RunGraphDirection = "LR" | "TB" | "BT" | "RL";
export type RunFileScope = "committed" | "uncommitted" | "all";
export type RunFileSelection =
  | { kind: "scope"; scope: RunFileScope }
  | { kind: "commit"; fromSha: string; toSha: string };
export type QueryKey = readonly unknown[];

const RUN_FILE_SCOPES = ["committed", "uncommitted", "all"] as const;

export function runFileScopeSelection(
  scope: RunFileScope = "committed",
): RunFileSelection {
  return { kind: "scope", scope };
}

function pathSegment(value: string): string {
  return encodeURIComponent(value);
}

function fileSelectionKey(selection: RunFileSelection): readonly unknown[] {
  return selection.kind === "scope"
    ? ["scope", selection.scope]
    : ["commit", selection.fromSha, selection.toSha];
}

export const queryKeys = {
  auth: {
    config: () => ["auth", "config"] as const,
    me: () => ["auth", "me"] as const,
    sessions: () => ["auth", "sessions"] as const,
    loginDevToken: () => ["auth", "login-dev-token"] as const,
  },
  system: {
    info: () => ["system", "info"] as const,
    integrations: () => ["system", "integrations"] as const,
    resources: () => ["system", "resources"] as const,
    attachUrl: () => "/api/v1/attach",
  },
  runs: {
    all: (filters: object = {}) =>
      ["runs", "all", filters] as const,
    page: (opts: object = {}) =>
      ["runs", "page", opts] as const,
    detail: (id: string) => ["runs", "detail", id] as const,
    state: (id: string) => ["runs", "state", id] as const,
    files: (id: string, selection: RunFileSelection = runFileScopeSelection()) =>
      ["runs", "files", id, ...fileSelectionKey(selection)] as const,
    filesAllScopes: (id: string) =>
      RUN_FILE_SCOPES.map((scope) =>
        queryKeys.runs.files(id, runFileScopeSelection(scope)),
      ),
    commits: (id: string) => ["runs", "commits", id] as const,
    stages: (id: string) => ["runs", "stages", id] as const,
    graph: (id: string, direction?: RunGraphDirection) =>
      ["runs", "graph", id, direction ?? null] as const,
    graphSource: (id: string) => ["runs", "graph-source", id] as const,
    settings: (id: string) => ["runs", "settings", id] as const,
    logs: (id: string) => ["runs", "logs", id] as const,
    artifacts: (id: string) => ["runs", "artifacts", id] as const,
    usage: (id: string) => ["runs", "usage", id] as const,
    questions: (id: string, limit = 1, offset = 0) =>
      ["runs", "questions", id, limit, offset] as const,
    /** A Petri run's stream: every `RunStreamItem` in `stream_seq` order. */
    stream: (id: string) => ["runs", "stream", id] as const,
    stageEvents: (id: string, stageId: string) =>
      ["runs", "stage-events", id, stageId] as const,
    stageContextWindow: (id: string, stageId: string) =>
      ["runs", "stage-context-window", id, stageId] as const,
    stageLog: (id: string, stageId: string, offset = 0, limit = 65_536) =>
      ["runs", "stage-log", id, stageId, offset, limit] as const,
    sandbox: (id: string) => ["runs", "sandbox", id] as const,
    sandboxFiles: (id: string, path: string, depth?: number) =>
      ["runs", "sandbox-files", id, path, depth ?? null] as const,
    sandboxFile: (id: string, path: string) =>
      ["runs", "sandbox-file", id, path] as const,
    sandboxVnc: (id: string) => ["runs", "sandbox-vnc", id] as const,
    sandboxServices: (id: string) => ["runs", "sandbox-services", id] as const,
    pullRequest: (id: string) => ["runs", "pull-request", id] as const,
    preview: (id: string) => ["runs", "preview", id] as const,
    cancel: (id: string) => ["runs", "cancel", id] as const,
    approve: (id: string) => ["runs", "approve", id] as const,
    deny: (id: string) => ["runs", "deny", id] as const,
    archive: (id: string) => ["runs", "archive", id] as const,
    unarchive: (id: string) => ["runs", "unarchive", id] as const,
    updateTitle: (id: string) => ["runs", "update-title", id] as const,
    attachUrl: (id: string) => `/api/v1/runs/${pathSegment(id)}/attach`,
  },
  workflows: {
    list: () => ["workflows", "list"] as const,
    detail: (name: string) => ["workflows", "detail", name] as const,
    runs: (name: string) => ["workflows", "runs", name] as const,
  },
  automations: {
    list: () => ["automations", "list"] as const,
    detail: (id: string) => ["automations", "detail", id] as const,
    runs: (id: string, opts: { limit?: number; offset?: number } = {}) =>
      ["automations", "runs", id, opts.limit ?? null, opts.offset ?? null] as const,
  },
  insights: {
    queries: () => ["insights", "queries"] as const,
    history: () => ["insights", "history"] as const,
  },
  settings: {
    server: () => ["settings", "server"] as const,
  },
  providers: {
    list: () => ["providers", "list"] as const,
  },
  models: {
    list: (provider: string, query: string) =>
      ["models", "list", provider, query] as const,
  },
  secrets: {
    list: () => ["secrets", "list"] as const,
  },
  variables: {
    list: () => ["variables", "list"] as const,
    detail: (name: string) => ["variables", "detail", name] as const,
  },
  environments: {
    list: () => ["environments", "list"] as const,
    detail: (id: string) => ["environments", "detail", id] as const,
  },
  mcpServers: {
    list: () => ["mcp-servers", "list"] as const,
    detail: (id: string) => ["mcp-servers", "detail", id] as const,
  },
};