feat: autosave draft, re-run step hook, migration 075

- Migration 075: add draft_config column to teams table
- useSaveDraft/usePublishDraft hooks for canvas autosave workflow
- useRerunStep hook for re-executing individual pipeline steps
- Extended updateTeam to accept draft_config and output_route_ids

Author: vincentgrobler

src/db/teams.ts

@@ -71,7 +71,7 @@ export async function createTeam(input: CreateTeamInput): Promise<Team> {
 /** Update a team's details */
 export async function updateTeam(
     id: string,
-    updates: Partial<Pick<Team, 'name' | 'description' | 'config' | 'mode'>>,
+    updates: Partial<Pick<Team, 'name' | 'description' | 'config' | 'mode' | 'output_route_ids' | 'draft_config'>>,
 ): Promise<Team> {
     const result = await supabase
         .from('teams')

src/hooks/useRerunStep.ts

@@ -0,0 +1,58 @@
+// SPDX-License-Identifier: AGPL-3.0-or-later
+// Copyright (C) 2026 CrewForm
+
+/**
+ * Hook for re-running a single pipeline step.
+ *
+ * Calls the task-runner endpoint to re-execute a specific step
+ * using the output of the previous step as input.
+ * Only applicable to pipeline mode.
+ */
+
+import { useMutation, useQueryClient } from '@tanstack/react-query'
+
+interface RerunStepInput {
+    runId: string
+    teamId: string
+    stepIdx: number
+}
+
+interface RerunStepResult {
+    success: boolean
+    message?: string
+}
+
+/**
+ * Re-run a single pipeline step.
+ *
+ * The task-runner will:
+ * 1. Fetch the previous step's output from team_messages
+ * 2. Re-execute the agent at stepIdx with that input
+ * 3. Write new messages for the re-run
+ * 4. Reset downstream steps to pending
+ */
+export function useRerunStep() {
+    const queryClient = useQueryClient()
+
+    return useMutation<RerunStepResult, Error, RerunStepInput>({
+        mutationFn: async ({ runId, stepIdx }) => {
+            const response = await fetch(`/api/team-runs/${runId}/steps/${stepIdx}/rerun`, {
+                method: 'POST',
+                headers: { 'Content-Type': 'application/json' },
+            })
+
+            if (!response.ok) {
+                const body = await response.json().catch(() => ({})) as { error?: string }
+                throw new Error(body.error ?? `Failed to re-run step ${stepIdx}`)
+            }
+
+            return response.json() as Promise<RerunStepResult>
+        },
+        onSuccess: (_data, variables) => {
+            // Invalidate the team run and messages queries
+            void queryClient.invalidateQueries({ queryKey: ['team-run', variables.runId] })
+            void queryClient.invalidateQueries({ queryKey: ['team-messages', variables.runId] })
+            void queryClient.invalidateQueries({ queryKey: ['team', variables.teamId] })
+        },
+    })
+}

src/hooks/useUpdateTeam.ts

@@ -7,7 +7,7 @@ import type { Team } from '@/types'
 
 interface UpdateTeamInput {
     id: string
-    updates: Partial<Pick<Team, 'name' | 'description' | 'config' | 'mode' | 'output_route_ids'>>
+    updates: Partial<Pick<Team, 'name' | 'description' | 'config' | 'mode' | 'output_route_ids' | 'draft_config'>>
 }
 
 /**
@@ -24,3 +24,34 @@ export function useUpdateTeam() {
         },
     })
 }
+
+/**
+ * Save a draft config (canvas autosave — non-destructive).
+ */
+export function useSaveDraft() {
+    const queryClient = useQueryClient()
+
+    return useMutation<Team, Error, { teamId: string; draftConfig: Team['config'] }>({
+        mutationFn: ({ teamId, draftConfig }) =>
+            updateTeam(teamId, { draft_config: draftConfig }),
+        onSuccess: (updated) => {
+            void queryClient.invalidateQueries({ queryKey: ['team', updated.id] })
+        },
+    })
+}
+
+/**
+ * Publish draft → copies draft_config to config and clears draft_config.
+ */
+export function usePublishDraft() {
+    const queryClient = useQueryClient()
+
+    return useMutation<Team, Error, { teamId: string; draftConfig: Team['config'] }>({
+        mutationFn: ({ teamId, draftConfig }) =>
+            updateTeam(teamId, { config: draftConfig, draft_config: null }),
+        onSuccess: (updated) => {
+            void queryClient.invalidateQueries({ queryKey: ['team', updated.id] })
+            void queryClient.invalidateQueries({ queryKey: ['teams', updated.workspace_id] })
+        },
+    })
+}

src/types/index.ts

@@ -133,6 +133,7 @@ export interface Team {
   description: string
   mode: TeamMode
   config: PipelineConfig | OrchestratorConfig | CollaborationConfig
+  draft_config: PipelineConfig | OrchestratorConfig | CollaborationConfig | null
   output_route_ids: string[] | null // null = all routes, [] = none, [...ids] = specific
   // Marketplace fields
   is_published: boolean

supabase/migrations/075_team_draft_config.sql

@@ -0,0 +1,9 @@
+-- Migration: 075_team_draft_config.sql
+-- Adds draft_config column for autosave/publish workflow on the canvas.
+-- When draft_config IS NOT NULL the team has unpublished canvas changes.
+
+ALTER TABLE public.teams
+  ADD COLUMN IF NOT EXISTS draft_config JSONB;
+
+COMMENT ON COLUMN public.teams.draft_config IS
+  'Draft team config from canvas autosave. NULL = no pending changes. Copy to config to publish.';