fabro/apps/fabro-web/app/lib/query-keys.ts
Bryan Helmkamp 87516c25ce
feat(automations): wire UI to API and auto-start runs from API trigger
Make the Automations area in the web UI functional end-to-end against the
real Automation API, and fix the backend so runs created by an automation's
API trigger actually start instead of sitting in Submitted forever.

Web:
- Reveal the Automations nav tab outside demo mode; drop the now-empty
  demoOnly mechanism.
- List page: render via listAutomations (was workflows mock data); wire
  ellipsis menu to Edit and Delete, with ConfirmDialog + If-Match revision.
  Move Create Automation into the toolbar, switch the trigger select to a
  shared FilterButton, hide the redundant page-header title via a new
  hideTitle handle flag.
- Play button on each card fires createAutomationRun with spinner + toast
  and navigates to the new run.
- New automation form: drop the dead Goal panel and hardcoded repository
  list, post to createAutomation with real triggers.
- Edit automation: new /automations/:id/edit route reusing a shared
  AutomationFormFields component, PUT via replaceAutomation with If-Match.
- Show page: rebuild like a run detail page — breadcrumb, title, chips
  (enabled status, repo+ref, workflow, schedule), Edit + Run actions
  (Run hits createAutomationRun), and a Runs panel using RunsListView
  with URL-driven search/sort/pagination/column-picker like the Children
  sub-tab. Drop the obsolete Definition/Diagram/Runs child routes.

Backend (fabro-server):
- create_automation_run now calls lifecycle::queue_run_start after the
  run is persisted, so the run transitions Submitted → Runnable and the
  scheduler picks it up. Logs a warn and returns the created response if
  start fails (no worse than the prior always-stuck behavior).
- queue_run_start in lifecycle.rs is promoted to pub(super) so sibling
  handlers can reuse it.

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>
2026-05-28 20:24:09 -04:00

120 lines
5 KiB
TypeScript

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,
billing: (id: string) => ["runs", "billing", id] as const,
questions: (id: string, limit = 1, offset = 0) =>
["runs", "questions", id, limit, offset] as const,
events: (id: string, limit = 1000) => ["runs", "events", id, limit] 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,
retry: (id: string) => ["runs", "retry", 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,
},
};