Workflow Visualizer

\n\n \n\n \n \n\n\n `;\n return c.html(html);\n});\n\n// ============================================================================\n// Export for Val Town HTTP\n// ============================================================================\n\nexport default app.fetch; // This is the entry point for HTTP vals",[],[237,510],"c554c278-d1c8-11f0-8d7b-42dde27851f2","api-server-example-local.ts","019aee26-23ab-7319-83f5-bb96aec4cd9b",["D",1764932068219],"/**\n * Example: API Server for Workflow Visualization (Local Deno Server)\n *\n * This example demonstrates how to run a local API server that:\n * 1. Sets up workflows with an API server using Hono\n * 2. Serves workflow data via REST API\n * 3. Creates and monitors workflow runs\n * 4. Serves a React-based frontend visualizer\n *\n * Run this example locally:\n * deno run --allow-all examples/api-server-example-local.ts\n *\n * Then open http://localhost:8000 to see the visualizer\n *\n * Note: For Val Town deployment, use api-server-example.http.ts instead\n */\n\nimport { Hono } from \"https://esm.sh/hono@4\";\nimport { z } from \"npm:zod@^3.23\";\nimport { createStep, createWorkflow } from \"../backend/index.ts\";\nimport { WorkflowStorage } from \"../backend/storage.ts\";\n\n// Initialize storage\nconst storage = new WorkflowStorage();\nawait storage.init();\n\n// Create Hono app\nconst app = new Hono();\n\n// Unwrap Hono errors to see original error details\napp.onError((err, c) => {\n\tthrow err;\n});\n\n// In-memory workflow registry\nconst workflows = new Map();\n\n// ============================================================================\n// Example Workflow 1: Data Processing Pipeline\n// ============================================================================\n\nconst fetchData = createStep({\n\tid: \"fetch-data\",\n\tdescription: \"Fetch data from external API\",\n\tinputSchema: z.object({ url: z.string() }),\n\toutputSchema: z.object({ data: z.array(z.record(z.unknown())) }),\n\texecute: async ({ inputData }) => {\n\t\tconsole.log(`Fetching data from ${inputData.url}...`);\n\n\t\t// Simulate API call\n\t\tawait new Promise((resolve) => setTimeout(resolve, 1000));\n\n\t\treturn {\n\t\t\tdata: [\n\t\t\t\t{ id: 1, name: \"Alice\", score: 95 },\n\t\t\t\t{ id: 2, name: \"Bob\", score: 87 },\n\t\t\t\t{ id: 3, name: \"Charlie\", score: 92 },\n\t\t\t],\n\t\t};\n\t},\n});\n\nconst processData = createStep({\n\tid: \"process-data\",\n\tdescription: \"Transform and filter data\",\n\tinputSchema: z.object({ data: z.array(z.record(z.unknown())) }),\n\toutputSchema: z.object({ processed: z.array(z.record(z.unknown())) }),\n\texecute: async ({ inputData }) => {\n\t\tconsole.log(\"Processing data...\");\n\n\t\t// Simulate processing\n\t\tawait new Promise((resolve) => setTimeout(resolve, 800));\n\n\t\tconst processed = inputData.data\n\t\t\t.filter((item: any) => item.score >= 90)\n\t\t\t.map((item: any) => ({\n\t\t\t\t...item,\n\t\t\t\tgrade: \"A\",\n\t\t\t\ttimestamp: Date.now(),\n\t\t\t}));\n\n\t\treturn { processed };\n\t},\n});\n\nconst saveResults = createStep({\n\tid: \"save-results\",\n\tdescription: \"Save processed data to database\",\n\tinputSchema: z.object({ processed: z.array(z.record(z.unknown())) }),\n\toutputSchema: z.object({ saved: z.number(), success: z.boolean() }),\n\texecute: async ({ inputData }) => {\n\t\tconsole.log(\"Saving results...\");\n\n\t\t// Simulate database save\n\t\tawait new Promise((resolve) => setTimeout(resolve, 600));\n\n\t\treturn {\n\t\t\tsaved: inputData.processed.length,\n\t\t\tsuccess: true,\n\t\t};\n\t},\n});\n\nconst dataProcessingWorkflow = createWorkflow({\n\tid: \"data-processing\",\n\tdescription: \"Fetch, process, and save data pipeline\",\n\tinputSchema: z.object({ url: z.string() }),\n\toutputSchema: z.object({ saved: z.number(), success: z.boolean() }),\n})\n\t.then(fetchData)\n\t.then(processData)\n\t.then(saveResults)\n\t.commit();\n\nworkflows.set(dataProcessingWorkflow.id, {\n\tworkflow: dataProcessingWorkflow,\n\texampleInput: { url: \"https://api.example.com/data\" },\n});\n\n// ============================================================================\n// Example Workflow 2: Email Campaign\n// ============================================================================\n\nconst fetchUsers = createStep({\n\tid: \"fetch-users\",\n\tdescription: \"Fetch users from database\",\n\tinputSchema: z.object({ segment: z.string() }),\n\toutputSchema: z.object({\n\t\tusers: z.array(\n\t\t\tz.object({ id: z.string(), email: z.string(), name: z.string() }),\n\t\t),\n\t}),\n\texecute: async ({ inputData }) => {\n\t\tconsole.log(`Fetching users in segment: ${inputData.segment}`);\n\t\tawait new Promise((resolve) => setTimeout(resolve, 700));\n\n\t\treturn {\n\t\t\tusers: [\n\t\t\t\t{ id: \"1\", email: \"alice@example.com\", name: \"Alice\" },\n\t\t\t\t{ id: \"2\", email: \"bob@example.com\", name: \"Bob\" },\n\t\t\t\t{ id: \"3\", email: \"charlie@example.com\", name: \"Charlie\" },\n\t\t\t],\n\t\t};\n\t},\n});\n\nconst generateEmails = createStep({\n\tid: \"generate-emails\",\n\tdescription: \"Generate personalized email content\",\n\tinputSchema: z.object({\n\t\tusers: z.array(\n\t\t\tz.object({ id: z.string(), email: z.string(), name: z.string() }),\n\t\t),\n\t}),\n\toutputSchema: z.object({\n\t\temails: z.array(\n\t\t\tz.object({ to: z.string(), subject: z.string(), body: z.string() }),\n\t\t),\n\t}),\n\texecute: async ({ inputData }) => {\n\t\tconsole.log(\"Generating personalized emails...\");\n\t\tawait new Promise((resolve) => setTimeout(resolve, 900));\n\n\t\tconst emails = inputData.users.map((user) => ({\n\t\t\tto: user.email,\n\t\t\tsubject: `Hello ${user.name}!`,\n\t\t\tbody: `Hi ${user.name}, we have exciting news for you...`,\n\t\t}));\n\n\t\treturn { emails };\n\t},\n});\n\nconst sendEmails = createStep({\n\tid: \"send-emails\",\n\tdescription: \"Send emails via email service\",\n\tinputSchema: z.object({\n\t\temails: z.array(\n\t\t\tz.object({ to: z.string(), subject: z.string(), body: z.string() }),\n\t\t),\n\t}),\n\toutputSchema: z.object({ sent: z.number(), failed: z.number() }),\n\texecute: async ({ inputData }) => {\n\t\tconsole.log(\"Sending emails...\");\n\t\tawait new Promise((resolve) => setTimeout(resolve, 1200));\n\n\t\treturn {\n\t\t\tsent: inputData.emails.length,\n\t\t\tfailed: 0,\n\t\t};\n\t},\n});\n\nconst emailCampaignWorkflow = createWorkflow({\n\tid: \"email-campaign\",\n\tdescription: \"Automated email campaign workflow\",\n\tinputSchema: z.object({ segment: z.string() }),\n\toutputSchema: z.object({ sent: z.number(), failed: z.number() }),\n})\n\t.then(fetchUsers)\n\t.then(generateEmails)\n\t.then(sendEmails)\n\t.commit();\n\nworkflows.set(emailCampaignWorkflow.id, {\n\tworkflow: emailCampaignWorkflow,\n\texampleInput: { segment: \"premium-users\" },\n});\n\n// ============================================================================\n// Example Workflow 3: Report Generation (with potential failure)\n// ============================================================================\n\nconst collectMetrics = createStep({\n\tid: \"collect-metrics\",\n\tdescription: \"Collect performance metrics\",\n\tinputSchema: z.object({ period: z.string() }),\n\toutputSchema: z.object({ metrics: z.record(z.number()) }),\n\texecute: async ({ inputData }) => {\n\t\tconsole.log(`Collecting metrics for period: ${inputData.period}`);\n\t\tawait new Promise((resolve) => setTimeout(resolve, 500));\n\n\t\treturn {\n\t\t\tmetrics: {\n\t\t\t\tusers: 1250,\n\t\t\t\trevenue: 45600,\n\t\t\t\tconversions: 234,\n\t\t\t},\n\t\t};\n\t},\n});\n\nconst analyzeMetrics = createStep({\n\tid: \"analyze-metrics\",\n\tdescription: \"Analyze metrics and generate insights\",\n\tinputSchema: z.object({ metrics: z.record(z.number()) }),\n\toutputSchema: z.object({\n\t\tinsights: z.array(z.string()),\n\t\ttrends: z.record(z.string()),\n\t}),\n\texecute: async ({ inputData }) => {\n\t\tconsole.log(\"Analyzing metrics...\");\n\t\tawait new Promise((resolve) => setTimeout(resolve, 800));\n\n\t\t// Randomly fail sometimes to demonstrate error handling\n\t\tif (Math.random() < 0.3) {\n\t\t\tthrow new Error(\"Analysis service temporarily unavailable\");\n\t\t}\n\n\t\treturn {\n\t\t\tinsights: [\n\t\t\t\t\"User growth increased by 15%\",\n\t\t\t\t\"Revenue trending upward\",\n\t\t\t\t\"Conversion rate improved\",\n\t\t\t],\n\t\t\ttrends: {\n\t\t\t\tusers: \"increasing\",\n\t\t\t\trevenue: \"increasing\",\n\t\t\t\tconversions: \"stable\",\n\t\t\t},\n\t\t};\n\t},\n});\n\nconst generateReport = createStep({\n\tid: \"generate-report\",\n\tdescription: \"Generate PDF report\",\n\tinputSchema: z.object({\n\t\tinsights: z.array(z.string()),\n\t\ttrends: z.record(z.string()),\n\t}),\n\toutputSchema: z.object({ reportUrl: z.string(), pages: z.number() }),\n\texecute: async ({ inputData }) => {\n\t\tconsole.log(\"Generating report...\");\n\t\tawait new Promise((resolve) => setTimeout(resolve, 1000));\n\n\t\treturn {\n\t\t\treportUrl: `https://reports.example.com/report-${Date.now()}.pdf`,\n\t\t\tpages: 12,\n\t\t};\n\t},\n});\n\nconst reportWorkflow = createWorkflow({\n\tid: \"report-generation\",\n\tdescription: \"Monthly performance report generation\",\n\tinputSchema: z.object({ period: z.string() }),\n\toutputSchema: z.object({ reportUrl: z.string(), pages: z.number() }),\n})\n\t.then(collectMetrics)\n\t.then(analyzeMetrics)\n\t.then(generateReport)\n\t.commit();\n\nworkflows.set(reportWorkflow.id, {\n\tworkflow: reportWorkflow,\n\texampleInput: { period: \"2024-11\" },\n});\n\n// ============================================================================\n// API Routes\n// ============================================================================\n\n// GET /api/workflows - List all workflows\napp.get(\"/api/workflows\", (c) => {\n\tconst workflowList = Array.from(workflows.entries()).map(\n\t\t([id, { workflow, exampleInput }]) => ({\n\t\t\tid: workflow.id,\n\t\t\tdescription: workflow.config.description,\n\t\t\tsteps: workflow.stepFlow.map((entry: any) => ({\n\t\t\t\tid: entry.step.id,\n\t\t\t\tdescription: entry.step.description,\n\t\t\t})),\n\t\t\texampleInput,\n\t\t}),\n\t);\n\treturn c.json(workflowList);\n});\n\n// GET /api/workflows/:id - Get workflow details\napp.get(\"/api/workflows/:id\", (c) => {\n\tconst workflowId = c.req.param(\"id\");\n\tconst entry = workflows.get(workflowId);\n\n\tif (!entry) {\n\t\treturn c.json({ error: \"Workflow not found\" }, 404);\n\t}\n\n\tconst { workflow, exampleInput } = entry;\n\treturn c.json({\n\t\tid: workflow.id,\n\t\tdescription: workflow.config.description,\n\t\tsteps: workflow.stepFlow.map((entry: any) => ({\n\t\t\tid: entry.step.id,\n\t\t\tdescription: entry.step.description,\n\t\t})),\n\t\texampleInput,\n\t});\n});\n\n// GET /api/workflows/:id/runs - List runs for a workflow\napp.get(\"/api/workflows/:id/runs\", async (c) => {\n\tconst workflowId = c.req.param(\"id\");\n\tconst snapshots = await storage.listRuns(workflowId);\n\tconst runs = snapshots.map((snapshot) => ({\n\t\trunId: snapshot.runId,\n\t\tworkflowId: snapshot.workflowId,\n\t\tstatus: snapshot.status,\n\t\texecutionPath: snapshot.executionPath,\n\t\tstepResults: snapshot.stepResults,\n\t\tinputData: snapshot.inputData,\n\t\tresult: snapshot.result,\n\t\terror: snapshot.error,\n\t\tcreatedAt: snapshot.timestamp,\n\t\tupdatedAt: snapshot.timestamp,\n\t}));\n\treturn c.json(runs);\n});\n\n// POST /api/workflows/:id/runs - Create a new run\napp.post(\"/api/workflows/:id/runs\", async (c) => {\n\tconst workflowId = c.req.param(\"id\");\n\tconst entry = workflows.get(workflowId);\n\n\tif (!entry) {\n\t\treturn c.json({ error: \"Workflow not found\" }, 404);\n\t}\n\n\tconst body = await c.req.json();\n\tconst { inputData } = body;\n\n\t// Create and start the run\n\tconst run = await entry.workflow.createRun();\n\n\t// Start execution in the background\n\trun.start({ inputData }).catch((error: Error) => {\n\t\tconsole.error(`Run ${run.runId} failed:`, error);\n\t});\n\n\t// Return the initial run state\n\tconst snapshot = await storage.loadSnapshot(run.runId);\n\tif (!snapshot) {\n\t\treturn c.json({ error: \"Failed to create run\" }, 500);\n\t}\n\n\treturn c.json(\n\t\t{\n\t\t\trunId: snapshot.runId,\n\t\t\tworkflowId: snapshot.workflowId,\n\t\t\tstatus: snapshot.status,\n\t\t\texecutionPath: snapshot.executionPath,\n\t\t\tstepResults: snapshot.stepResults,\n\t\t\tinputData: snapshot.inputData,\n\t\t\tresult: snapshot.result,\n\t\t\terror: snapshot.error,\n\t\t\tcreatedAt: snapshot.timestamp,\n\t\t\tupdatedAt: snapshot.timestamp,\n\t\t},\n\t\t201,\n\t);\n});\n\n// GET /api/runs/:runId - Get run details\napp.get(\"/api/runs/:runId\", async (c) => {\n\tconst runId = c.req.param(\"runId\");\n\tconst snapshot = await storage.loadSnapshot(runId);\n\n\tif (!snapshot) {\n\t\treturn c.json({ error: \"Run not found\" }, 404);\n\t}\n\n\treturn c.json({\n\t\trunId: snapshot.runId,\n\t\tworkflowId: snapshot.workflowId,\n\t\tstatus: snapshot.status,\n\t\texecutionPath: snapshot.executionPath,\n\t\tstepResults: snapshot.stepResults,\n\t\tinputData: snapshot.inputData,\n\t\tresult: snapshot.result,\n\t\terror: snapshot.error,\n\t\tcreatedAt: snapshot.timestamp,\n\t\tupdatedAt: snapshot.timestamp,\n\t});\n});\n\n// ============================================================================\n// Frontend\n// ============================================================================\n\napp.get(\"/\", (c) => {\n\tconst html = `\n\n\n \n \n Workflow Visualizer\n \n \n\n\n

\n\n \n\n \n \n\n\n `;\n\treturn c.html(html);\n});\n\n// ============================================================================\n// Start Local Server\n// ============================================================================\n\nconst PORT = 8000;\n\nconsole.log(\"\\n=======================================================\");\nconsole.log(\"Workflow API Server with Embedded Visualizer\");\nconsole.log(\"=======================================================\\n\");\nconsole.log(\"Registered workflows:\");\nconsole.log(\" - data-processing: Fetch, process, and save data\");\nconsole.log(\" - email-campaign: Automated email campaign\");\nconsole.log(\" - report-generation: Monthly report generation\\n\");\nconsole.log(\"API Endpoints:\");\nconsole.log(\" GET /api/workflows - List all workflows\");\nconsole.log(\" GET /api/workflows/:id - Get workflow details\");\nconsole.log(\" GET /api/workflows/:id/runs - List runs for workflow\");\nconsole.log(\" POST /api/workflows/:id/runs - Create new run\");\nconsole.log(\" GET /api/runs/:runId - Get run details\\n\");\nconsole.log(`Server starting on http://localhost:${PORT}`);\nconsole.log(`Open http://localhost:${PORT} to view the visualizer\\n`);\nconsole.log(\"=======================================================\\n\");\n\nDeno.serve({ port: PORT }, app.fetch);\n",[],[237,516],["D",1764932068219],[268,269,270,271,272,273,274],[237],"c554be04-d1c8-11f0-8d7b-42dde27851f2","workflow.ts","019aee26-23ab-7319-83f5-b161e39b501a",["D",1764932068219],"import type { z } from \"npm:zod@^3.23\";\nimport { ExecutionEngine } from \"./engine.ts\";\nimport { WorkflowRun } from \"./run.ts\";\nimport { WorkflowStorage } from \"./storage.ts\";\nimport type { Step, StepFlowEntry, WorkflowConfig } from \"./types.ts\";\nimport {\n\ttype VisualizationFormat,\n\ttype VisualizationOptions,\n\tvisualizeWorkflow,\n} from \"./visualize.ts\";\n\n/**\n * Workflow builder with fluent API and type inference\n */\nexport class WorkflowBuilder<\n\tTSteps extends Record>,\n\tTWorkflowId extends string,\n\tTInput,\n\tTPrevOutput,\n\tTState = unknown,\n> {\n\tconstructor(\n\t\tprivate config: WorkflowConfig,\n\t\tprivate steps: TSteps,\n\t\tprivate stepFlow: StepFlowEntry[],\n\t) {}\n\n\t/**\n\t * Add a sequential step to the workflow\n\t * The step's input must match the previous step's output\n\t */\n\tthen>(\n\t\tstep: TStep,\n\t): WorkflowBuilder<\n\t\tTSteps & Record,\n\t\tTWorkflowId,\n\t\tTInput,\n\t\tz.infer,\n\t\tTState\n\t> {\n\t\tconst newSteps = { ...this.steps, [step.id]: step } as TSteps &\n\t\t\tRecord;\n\t\tconst newStepFlow = [...this.stepFlow, { type: \"step\" as const, step }];\n\n\t\treturn new WorkflowBuilder(this.config, newSteps, newStepFlow);\n\t}\n\n\t/**\n\t * Finalize the workflow and make it executable\n\t */\n\tcommit(): Workflow {\n\t\treturn new Workflow(this.config, this.steps, this.stepFlow);\n\t}\n}\n\n/**\n * Executable workflow instance\n */\nexport class Workflow<\n\tTSteps extends Record>,\n\tTWorkflowId extends string,\n\tTInput,\n\tTOutput,\n\tTState = unknown,\n> {\n\tprivate engine: ExecutionEngine;\n\tprivate storage: WorkflowStorage;\n\n\tconstructor(\n\t\tpublic readonly config: WorkflowConfig<\n\t\t\tTWorkflowId,\n\t\t\tTInput,\n\t\t\tTOutput,\n\t\t\tTState\n\t\t>,\n\t\tpublic readonly steps: TSteps,\n\t\tpublic readonly stepFlow: StepFlowEntry[],\n\t) {\n\t\tthis.storage = new WorkflowStorage();\n\t\tthis.engine = new ExecutionEngine(this.storage);\n\t}\n\n\t/**\n\t * Initialize the workflow (creates database tables)\n\t */\n\tasync init(): Promise {\n\t\tawait this.storage.init();\n\t}\n\n\t/**\n\t * Create a new workflow run instance\n\t */\n\tasync createRun(\n\t\trunId?: string,\n\t): Promise> {\n\t\t// Initialize storage if not already done\n\t\tawait this.init();\n\n\t\tconst id = runId || crypto.randomUUID();\n\t\treturn new WorkflowRun(this, id, this.engine, this.storage);\n\t}\n\n\t/**\n\t * Get the workflow ID\n\t */\n\tget id(): TWorkflowId {\n\t\treturn this.config.id as TWorkflowId;\n\t}\n\n\t/**\n\t * Get the input schema\n\t */\n\tget inputSchema(): z.ZodSchema {\n\t\treturn this.config.inputSchema;\n\t}\n\n\t/**\n\t * Get the output schema\n\t */\n\tget outputSchema(): z.ZodSchema {\n\t\treturn this.config.outputSchema as z.ZodSchema;\n\t}\n\n\t/**\n\t * Get the state schema\n\t */\n\tget stateSchema(): z.ZodSchema | undefined {\n\t\treturn this.config.stateSchema;\n\t}\n\n\t/**\n\t * Generate a visual representation of this workflow\n\t *\n\t * @param format - The visualization format (default: \"mermaid\")\n\t * @param options - Visualization options\n\t * @returns Visualization string in the specified format\n\t *\n\t * @example\n\t * ```typescript\n\t * const diagram = workflow.visualize(\"mermaid\");\n\t * console.log(diagram);\n\t * ```\n\t */\n\tvisualize(\n\t\tformat: VisualizationFormat = \"mermaid\",\n\t\toptions: VisualizationOptions = {},\n\t): string {\n\t\treturn visualizeWorkflow(this, format, options);\n\t}\n}\n\n/**\n * Create a new workflow with strong typing\n *\n * @example\n * ```typescript\n * const workflow = createWorkflow({\n * id: 'email-campaign',\n * inputSchema: z.object({ userId: z.string() }),\n * outputSchema: z.object({ sent: z.boolean() })\n * })\n * .then(fetchUser)\n * .then(generateEmail)\n * .then(sendEmail)\n * .commit();\n * ```\n */\nexport function createWorkflow<\n\tTId extends string,\n\tTInput,\n\tTOutput,\n\tTState = unknown,\n>(\n\tconfig: WorkflowConfig,\n): WorkflowBuilder<{}, TId, TInput, TInput, TState> {\n\treturn new WorkflowBuilder(config, {}, []);\n}\n",[],[242,526],"c554b558-d1c8-11f0-8d7b-42dde27851f2","visualize.ts","019aee26-23ab-7319-83f5-adc979ec66df",["D",1764932068219],"import type { Workflow } from \"./workflow.ts\";\nimport type { WorkflowSnapshot } from \"./types.ts\";\n\n/**\n * Visualization format types\n */\nexport type VisualizationFormat = \"mermaid\" | \"json\" | \"ascii\" | \"dot\";\n\n/**\n * Options for visualization\n */\nexport interface VisualizationOptions {\n\t/** Include schema information in visualization */\n\tincludeSchemas?: boolean;\n\t/** Include step descriptions */\n\tincludeDescriptions?: boolean;\n}\n\n/**\n * Options for execution visualization\n */\nexport interface ExecutionVisualizationOptions extends VisualizationOptions {\n\t/** Highlight the current/last executed step */\n\thighlightCurrentStep?: boolean;\n\t/** Show step execution status */\n\tshowStatus?: boolean;\n\t/** Show step results */\n\tshowResults?: boolean;\n}\n\n/**\n * Visualize a workflow's structure\n *\n * @param workflow - The workflow to visualize\n * @param format - The output format (default: \"mermaid\")\n * @param options - Visualization options\n * @returns Visualization string in the specified format\n *\n * @example\n * ```typescript\n * const diagram = visualizeWorkflow(workflow, \"mermaid\");\n * console.log(diagram);\n * ```\n */\nexport function visualizeWorkflow(\n\tworkflow: Workflow,\n\tformat: VisualizationFormat = \"mermaid\",\n\toptions: VisualizationOptions = {},\n): string {\n\tswitch (format) {\n\t\tcase \"mermaid\":\n\t\t\treturn generateMermaidWorkflow(workflow, options);\n\t\tcase \"json\":\n\t\t\tthrow new Error(\"JSON format not yet implemented\");\n\t\tcase \"ascii\":\n\t\t\tthrow new Error(\"ASCII format not yet implemented\");\n\t\tcase \"dot\":\n\t\t\tthrow new Error(\"DOT format not yet implemented\");\n\t\tdefault:\n\t\t\tthrow new Error(`Unknown visualization format: ${format}`);\n\t}\n}\n\n/**\n * Visualize a workflow execution with state information\n *\n * @param workflow - The workflow being executed\n * @param snapshot - The execution snapshot\n * @param format - The output format (default: \"mermaid\")\n * @param options - Visualization options\n * @returns Visualization string in the specified format\n *\n * @example\n * ```typescript\n * const snapshot = await run.getSnapshot();\n * if (snapshot) {\n * const diagram = visualizeExecution(workflow, snapshot, \"mermaid\", {\n * highlightCurrentStep: true,\n * showStatus: true\n * });\n * console.log(diagram);\n * }\n * ```\n */\nexport function visualizeExecution(\n\tworkflow: Workflow,\n\tsnapshot: WorkflowSnapshot,\n\tformat: VisualizationFormat = \"mermaid\",\n\toptions: ExecutionVisualizationOptions = {},\n): string {\n\tswitch (format) {\n\t\tcase \"mermaid\":\n\t\t\treturn generateMermaidExecution(workflow, snapshot, options);\n\t\tcase \"json\":\n\t\t\tthrow new Error(\"JSON format not yet implemented\");\n\t\tcase \"ascii\":\n\t\t\tthrow new Error(\"ASCII format not yet implemented\");\n\t\tcase \"dot\":\n\t\t\tthrow new Error(\"DOT format not yet implemented\");\n\t\tdefault:\n\t\t\tthrow new Error(`Unknown visualization format: ${format}`);\n\t}\n}\n\n/**\n * Generate Mermaid diagram for workflow structure\n */\nfunction generateMermaidWorkflow(\n\tworkflow: Workflow,\n\toptions: VisualizationOptions,\n): string {\n\tconst lines: string[] = [];\n\tconst { includeDescriptions = true } = options;\n\n\t// Start with graph definition\n\tlines.push(\"graph TD\");\n\n\t// Add workflow title/description as comment\n\tif (workflow.config.description) {\n\t\tlines.push(` %% ${workflow.config.description}`);\n\t}\n\n\t// Start node\n\tconst startLabel = workflow.config.id;\n\tlines.push(` Start([${startLabel}])`);\n\n\t// Generate step nodes\n\tconst stepIds = workflow.stepFlow.map((entry) => entry.step.id);\n\n\tstepIds.forEach((stepId, index) => {\n\t\tconst step = workflow.steps[stepId];\n\t\tif (!step) return;\n\n\t\tconst nodeId = sanitizeNodeId(stepId);\n\t\tlet label = stepId;\n\n\t\tif (includeDescriptions && step.description) {\n\t\t\tlabel = `${stepId}
${step.description}`;\n\t\t}\n\n\t\t// Create step node\n\t\tlines.push(` ${nodeId}[${label}]`);\n\n\t\t// Connect from Start to first step, or from previous step\n\t\tif (index === 0) {\n\t\t\tlines.push(` Start --> ${nodeId}`);\n\t\t} else {\n\t\t\tconst prevNodeId = sanitizeNodeId(stepIds[index - 1]);\n\t\t\tlines.push(` ${prevNodeId} --> ${nodeId}`);\n\t\t}\n\t});\n\n\t// End node\n\tlines.push(\" End([End])\");\n\tif (stepIds.length > 0) {\n\t\tconst lastNodeId = sanitizeNodeId(stepIds[stepIds.length - 1]);\n\t\tlines.push(` ${lastNodeId} --> End`);\n\t} else {\n\t\tlines.push(\" Start --> End\");\n\t}\n\n\t// Add styling\n\tlines.push(\"\");\n\tlines.push(\" classDef default fill:#e1f5ff,stroke:#01579b,stroke-width:2px\");\n\tlines.push(\" classDef startEnd fill:#c8e6c9,stroke:#2e7d32,stroke-width:2px\");\n\tlines.push(\" class Start,End startEnd\");\n\n\treturn lines.join(\"\\n\");\n}\n\n/**\n * Generate Mermaid diagram for workflow execution with state\n */\nfunction generateMermaidExecution(\n\tworkflow: Workflow,\n\tsnapshot: WorkflowSnapshot,\n\toptions: ExecutionVisualizationOptions,\n): string {\n\tconst lines: string[] = [];\n\tconst {\n\t\tincludeDescriptions = true,\n\t\thighlightCurrentStep = true,\n\t\tshowStatus = true,\n\t\tshowResults = false,\n\t} = options;\n\n\t// Start with graph definition\n\tlines.push(\"graph TD\");\n\n\t// Add execution info as comment\n\tlines.push(` %% Workflow: ${workflow.config.id}`);\n\tlines.push(` %% Run ID: ${snapshot.runId}`);\n\tlines.push(` %% Status: ${snapshot.status}`);\n\tif (snapshot.error) {\n\t\tlines.push(` %% Error: ${snapshot.error}`);\n\t}\n\n\t// Start node\n\tconst startLabel = workflow.config.id;\n\tconst startStatus = snapshot.status !== \"running\" || snapshot.executionPath.length > 0\n\t\t? \"✓\"\n\t\t: \"●\";\n\tlines.push(` Start([${startStatus} ${startLabel}])`);\n\n\t// Generate step nodes with execution state\n\tconst stepIds = workflow.stepFlow.map((entry) => entry.step.id);\n\tconst executedStepIndices = new Set(snapshot.executionPath);\n\tconst lastExecutedIndex = snapshot.executionPath.length > 0\n\t\t? snapshot.executionPath[snapshot.executionPath.length - 1]\n\t\t: -1;\n\n\tstepIds.forEach((stepId, index) => {\n\t\tconst step = workflow.steps[stepId];\n\t\tif (!step) return;\n\n\t\tconst nodeId = sanitizeNodeId(stepId);\n\t\tconst stepResult = snapshot.stepResults[stepId];\n\t\tconst isExecuted = executedStepIndices.has(index);\n\t\tconst isCurrent = highlightCurrentStep && index === lastExecutedIndex &&\n\t\t\tsnapshot.status === \"running\";\n\n\t\t// Build label\n\t\tlet label = stepId;\n\t\tlet statusIcon = \"\";\n\n\t\tif (showStatus && stepResult) {\n\t\t\tswitch (stepResult.status) {\n\t\t\t\tcase \"success\":\n\t\t\t\t\tstatusIcon = \"✓ \";\n\t\t\t\t\tbreak;\n\t\t\t\tcase \"failed\":\n\t\t\t\t\tstatusIcon = \"✗ \";\n\t\t\t\t\tbreak;\n\t\t\t\tcase \"running\":\n\t\t\t\t\tstatusIcon = \"● \";\n\t\t\t\t\tbreak;\n\t\t\t}\n\t\t} else if (isExecuted) {\n\t\t\tstatusIcon = \"✓ \";\n\t\t} else if (isCurrent) {\n\t\t\tstatusIcon = \"● \";\n\t\t}\n\n\t\tlabel = `${statusIcon}${stepId}`;\n\n\t\tif (includeDescriptions && step.description) {\n\t\t\tlabel += `
${step.description}`;\n\t\t}\n\n\t\tif (showResults && stepResult && stepResult.status === \"failed\") {\n\t\t\tconst errorMsg = stepResult.error.message.substring(0, 50);\n\t\t\tlabel += `
${errorMsg}`;\n\t\t}\n\n\t\t// Create step node\n\t\tlines.push(` ${nodeId}[${label}]`);\n\n\t\t// Connect from Start to first step, or from previous step\n\t\tif (index === 0) {\n\t\t\tlines.push(` Start --> ${nodeId}`);\n\t\t} else {\n\t\t\tconst prevNodeId = sanitizeNodeId(stepIds[index - 1]);\n\t\t\tlines.push(` ${prevNodeId} --> ${nodeId}`);\n\t\t}\n\t});\n\n\t// End node\n\tconst endStatus = snapshot.status === \"success\"\n\t\t? \"✓\"\n\t\t: snapshot.status === \"failed\"\n\t\t? \"✗\"\n\t\t: \"○\";\n\tlines.push(` End([${endStatus} End])`);\n\tif (stepIds.length > 0) {\n\t\tconst lastNodeId = sanitizeNodeId(stepIds[stepIds.length - 1]);\n\t\tlines.push(` ${lastNodeId} --> End`);\n\t} else {\n\t\tlines.push(\" Start --> End\");\n\t}\n\n\t// Add styling based on execution state\n\tlines.push(\"\");\n\tlines.push(\" classDef default fill:#e1f5ff,stroke:#01579b,stroke-width:2px\");\n\tlines.push(\" classDef startEnd fill:#c8e6c9,stroke:#2e7d32,stroke-width:2px\");\n\tlines.push(\" classDef success fill:#c8e6c9,stroke:#2e7d32,stroke-width:2px\");\n\tlines.push(\" classDef failed fill:#ffcdd2,stroke:#c62828,stroke-width:2px\");\n\tlines.push(\" classDef running fill:#fff9c4,stroke:#f57f17,stroke-width:3px\");\n\tlines.push(\" classDef pending fill:#f5f5f5,stroke:#9e9e9e,stroke-width:1px\");\n\n\t// Apply classes\n\tlines.push(\" class Start,End startEnd\");\n\n\tstepIds.forEach((stepId, index) => {\n\t\tconst nodeId = sanitizeNodeId(stepId);\n\t\tconst stepResult = snapshot.stepResults[stepId];\n\t\tconst isExecuted = executedStepIndices.has(index);\n\t\tconst isCurrent = highlightCurrentStep && index === lastExecutedIndex &&\n\t\t\tsnapshot.status === \"running\";\n\n\t\tif (isCurrent) {\n\t\t\tlines.push(` class ${nodeId} running`);\n\t\t} else if (stepResult) {\n\t\t\tif (stepResult.status === \"success\") {\n\t\t\t\tlines.push(` class ${nodeId} success`);\n\t\t\t} else if (stepResult.status === \"failed\") {\n\t\t\t\tlines.push(` class ${nodeId} failed`);\n\t\t\t}\n\t\t} else if (!isExecuted) {\n\t\t\tlines.push(` class ${nodeId} pending`);\n\t\t}\n\t});\n\n\treturn lines.join(\"\\n\");\n}\n\n/**\n * Sanitize step ID to be a valid Mermaid node ID\n */\nfunction sanitizeNodeId(id: string): string {\n\t// Replace hyphens and special characters with underscores\n\treturn id.replace(/[^a-zA-Z0-9_]/g, \"_\");\n}\n",[],[242,533],"c554b2a6-d1c8-11f0-8d7b-42dde27851f2","019aee26-23ab-7319-83f5-abf61837f105",["D",1764932068219],"import type { z } from \"npm:zod@^3.23\";\n\n/**\n * Step execution result with status tracking\n */\nexport type StepResult =\n\t| { status: \"success\"; output: T; timestamp: number }\n\t| { status: \"failed\"; error: Error; timestamp: number }\n\t| { status: \"running\"; timestamp: number };\n\n/**\n * Step execution context provided to execute function\n */\nexport interface StepExecutionContext {\n\t/** Input data for this step */\n\tinputData: TInput;\n\n\t/** Workflow-level state (if defined) */\n\tstate?: TState;\n\n\t/** Update workflow state */\n\tsetState?: (state: TState) => void;\n\n\t/** Get the result of a previous step */\n\tgetStepResult: >(\n\t\tstep: T,\n\t) => z.infer;\n\n\t/** Get the initial workflow input data */\n\tgetInitData: () => T;\n\n\t/** Current run ID */\n\trunId: string;\n\n\t/** Current workflow ID */\n\tworkflowId: string;\n}\n\n/**\n * Step execute function signature\n */\nexport type ExecuteFunction = (\n\tcontext: StepExecutionContext,\n) => Promise | TOutput;\n\n/**\n * Step configuration\n */\nexport interface StepConfig {\n\tid: TId;\n\tdescription?: string;\n\tinputSchema: z.ZodSchema;\n\toutputSchema: z.ZodSchema;\n\tstateSchema?: z.ZodSchema;\n\texecute: ExecuteFunction;\n}\n\n/**\n * Step instance\n */\nexport interface Step {\n\tid: TId;\n\tdescription?: string;\n\tinputSchema: z.ZodSchema;\n\toutputSchema: z.ZodSchema;\n\tstateSchema?: z.ZodSchema;\n\texecute: ExecuteFunction;\n}\n\n/**\n * Workflow step entry in execution graph\n */\nexport interface StepFlowEntry {\n\ttype: \"step\";\n\tstep: Step;\n}\n\n/**\n * Workflow configuration\n */\nexport interface WorkflowConfig<\n\tTId extends string,\n\tTInput,\n\tTOutput,\n\tTState = unknown,\n> {\n\tid: TId;\n\tdescription?: string;\n\tinputSchema: z.ZodSchema;\n\toutputSchema: z.ZodSchema;\n\tstateSchema?: z.ZodSchema;\n}\n\n/**\n * Execution context tracking workflow execution state\n */\nexport interface ExecutionContext {\n\tworkflowId: string;\n\trunId: string;\n\texecutionPath: number[];\n\tstepResults: Record>;\n\tstate: TState;\n\tinputData: unknown;\n}\n\n/**\n * Workflow snapshot for persistence\n */\nexport interface WorkflowSnapshot {\n\trunId: string;\n\tworkflowId: string;\n\tstatus: \"running\" | \"success\" | \"failed\";\n\texecutionPath: number[];\n\tstepResults: Record>;\n\tstate: TState;\n\tinputData: unknown;\n\tresult?: unknown;\n\terror?: string;\n\ttimestamp: number;\n}\n",[],[242,395],"c554abb2-d1c8-11f0-8d7b-42dde27851f2","storage.ts","019aee26-23ab-7319-83f5-a77abfe2c5ef",["D",1764932068219],"import { runMigrations } from \"./migrations.ts\";\nimport type { WorkflowSnapshot } from \"./types.ts\";\n\n/**\n * SQLite-backed storage for workflow state\n */\nexport class WorkflowStorage {\n\tprivate initialized = false;\n\tprivate initPromise: Promise | null = null;\n\n\t/**\n\t * Initialize the storage (create tables)\n\t */\n\tasync init(): Promise {\n\t\tif (this.initialized) {\n\t\t\treturn;\n\t\t}\n\n\t\t// If initialization is already in progress, wait for it to complete\n\t\tif (this.initPromise) {\n\t\t\treturn this.initPromise;\n\t\t}\n\n\t\t// Start initialization and store the promise\n\t\tthis.initPromise = (async () => {\n\t\t\t// Note: In Val Town, import sqlite dynamically to avoid errors outside Val Town\n\t\t\tconst { sqlite } = await import(\"https://esm.town/v/std/sqlite\");\n\n\t\t\t// Run migrations to ensure tables are up to date\n\t\t\tawait runMigrations({ dropOldTables: false });\n\n\t\t\tawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS wrkflw_workflow_runs (\n run_id TEXT PRIMARY KEY,\n workflow_id TEXT NOT NULL,\n status TEXT NOT NULL,\n execution_path TEXT,\n step_results TEXT,\n state TEXT,\n input_data TEXT,\n result TEXT,\n error TEXT,\n created_at INTEGER DEFAULT (unixepoch()),\n updated_at INTEGER DEFAULT (unixepoch())\n )\n `);\n\n\t\t\t// Create index for querying by workflow_id\n\t\t\tawait sqlite.execute(`\n CREATE INDEX IF NOT EXISTS idx_wrkflw_workflow_runs_workflow_id\n ON wrkflw_workflow_runs(workflow_id)\n `);\n\n\t\t\t// Create index for querying by status\n\t\t\tawait sqlite.execute(`\n CREATE INDEX IF NOT EXISTS idx_wrkflw_workflow_runs_status\n ON wrkflw_workflow_runs(status)\n `);\n\n\t\t\tthis.initialized = true;\n\t\t})();\n\n\t\treturn this.initPromise;\n\t}\n\n\t/**\n\t * Save a workflow snapshot\n\t */\n\tasync saveSnapshot(snapshot: WorkflowSnapshot): Promise {\n\t\tconst { sqlite } = await import(\"https://esm.town/v/std/sqlite\");\n\n\t\tawait sqlite.execute({\n\t\t\tsql: `\n INSERT INTO wrkflw_workflow_runs (\n run_id, workflow_id, status, execution_path,\n step_results, state, input_data, result, error, updated_at\n ) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, unixepoch())\n ON CONFLICT(run_id) DO UPDATE SET\n status = excluded.status,\n execution_path = excluded.execution_path,\n step_results = excluded.step_results,\n state = excluded.state,\n result = excluded.result,\n error = excluded.error,\n updated_at = unixepoch()\n `,\n\t\t\targs: [\n\t\t\t\tsnapshot.runId,\n\t\t\t\tsnapshot.workflowId,\n\t\t\t\tsnapshot.status,\n\t\t\t\tJSON.stringify(snapshot.executionPath),\n\t\t\t\tJSON.stringify(snapshot.stepResults),\n\t\t\t\tJSON.stringify(snapshot.state),\n\t\t\t\tJSON.stringify(snapshot.inputData),\n\t\t\t\tsnapshot.result ? JSON.stringify(snapshot.result) : null,\n\t\t\t\tsnapshot.error ?? null,\n\t\t\t],\n\t\t});\n\t}\n\n\t/**\n\t * Load a workflow snapshot by run ID\n\t */\n\tasync loadSnapshot(runId: string): Promise {\n\t\tconst { sqlite } = await import(\"https://esm.town/v/std/sqlite\");\n\n\t\tconst result = await sqlite.execute({\n\t\t\tsql: `\n SELECT\n run_id, workflow_id, status, execution_path,\n step_results, state, input_data, result, error, updated_at\n FROM wrkflw_workflow_runs\n WHERE run_id = ?\n `,\n\t\t\targs: [runId],\n\t\t});\n\n\t\tif (result.rows.length === 0) {\n\t\t\treturn null;\n\t\t}\n\n\t\tconst row = result.rows[0];\n\n\t\treturn {\n\t\t\trunId: row[0] as string,\n\t\t\tworkflowId: row[1] as string,\n\t\t\tstatus: row[2] as \"running\" | \"success\" | \"failed\",\n\t\t\texecutionPath: JSON.parse(row[3] as string),\n\t\t\tstepResults: JSON.parse(row[4] as string),\n\t\t\tstate: JSON.parse(row[5] as string),\n\t\t\tinputData: JSON.parse(row[6] as string),\n\t\t\tresult: row[7] ? JSON.parse(row[7] as string) : undefined,\n\t\t\terror: row[8] as string | undefined,\n\t\t\ttimestamp: row[9] as number,\n\t\t};\n\t}\n\n\t/**\n\t * List workflow runs, optionally filtered by workflow ID\n\t */\n\tasync listRuns(workflowId?: string): Promise {\n\t\tconst { sqlite } = await import(\"https://esm.town/v/std/sqlite\");\n\n\t\tconst result = workflowId\n\t\t\t? await sqlite.execute({\n\t\t\t\t\tsql: `\n SELECT\n run_id, workflow_id, status, execution_path,\n step_results, state, input_data, result, error, updated_at\n FROM wrkflw_workflow_runs\n WHERE workflow_id = ?\n ORDER BY updated_at DESC\n `,\n\t\t\t\t\targs: [workflowId],\n\t\t\t\t})\n\t\t\t: await sqlite.execute(`\n SELECT\n run_id, workflow_id, status, execution_path,\n step_results, state, input_data, result, error, updated_at\n FROM wrkflw_workflow_runs\n ORDER BY updated_at DESC\n `);\n\n\t\treturn result.rows.map((row) => ({\n\t\t\trunId: row[0] as string,\n\t\t\tworkflowId: row[1] as string,\n\t\t\tstatus: row[2] as \"running\" | \"success\" | \"failed\",\n\t\t\texecutionPath: JSON.parse(row[3] as string),\n\t\t\tstepResults: JSON.parse(row[4] as string),\n\t\t\tstate: JSON.parse(row[5] as string),\n\t\t\tinputData: JSON.parse(row[6] as string),\n\t\t\tresult: row[7] ? JSON.parse(row[7] as string) : undefined,\n\t\t\terror: row[8] as string | undefined,\n\t\t\ttimestamp: row[9] as number,\n\t\t}));\n\t}\n\n\t/**\n\t * Delete a workflow run\n\t */\n\tasync deleteRun(runId: string): Promise {\n\t\tconst { sqlite } = await import(\"https://esm.town/v/std/sqlite\");\n\n\t\tawait sqlite.execute({\n\t\t\tsql: `DELETE FROM wrkflw_workflow_runs WHERE run_id = ?`,\n\t\t\targs: [runId],\n\t\t});\n\t}\n\n\t/**\n\t * Get workflow runs by status\n\t */\n\tasync getRunsByStatus(\n\t\tstatus: \"running\" | \"success\" | \"failed\",\n\t\tworkflowId?: string,\n\t): Promise {\n\t\tconst { sqlite } = await import(\"https://esm.town/v/std/sqlite\");\n\n\t\tconst result = workflowId\n\t\t\t? await sqlite.execute({\n\t\t\t\t\tsql: `\n SELECT\n run_id, workflow_id, status, execution_path,\n step_results, state, input_data, result, error, updated_at\n FROM wrkflw_workflow_runs\n WHERE status = ? AND workflow_id = ?\n ORDER BY updated_at DESC\n `,\n\t\t\t\t\targs: [status, workflowId],\n\t\t\t\t})\n\t\t\t: await sqlite.execute({\n\t\t\t\t\tsql: `\n SELECT\n run_id, workflow_id, status, execution_path,\n step_results, state, input_data, result, error, updated_at\n FROM wrkflw_workflow_runs\n WHERE status = ?\n ORDER BY updated_at DESC\n `,\n\t\t\t\t\targs: [status],\n\t\t\t\t});\n\n\t\treturn result.rows.map((row) => ({\n\t\t\trunId: row[0] as string,\n\t\t\tworkflowId: row[1] as string,\n\t\t\tstatus: row[2] as \"running\" | \"success\" | \"failed\",\n\t\t\texecutionPath: JSON.parse(row[3] as string),\n\t\t\tstepResults: JSON.parse(row[4] as string),\n\t\t\tstate: JSON.parse(row[5] as string),\n\t\t\tinputData: JSON.parse(row[6] as string),\n\t\t\tresult: row[7] ? JSON.parse(row[7] as string) : undefined,\n\t\t\terror: row[8] as string | undefined,\n\t\t\ttimestamp: row[9] as number,\n\t\t}));\n\t}\n}\n",[],[242,546],"c554aa9a-d1c8-11f0-8d7b-42dde27851f2","step.ts","019aee26-23ab-7319-83f5-a0036a9c4b41",["D",1764932068219],"import type { Step, StepConfig } from \"./types.ts\";\n\n/**\n * Create a workflow step with strong typing\n *\n * @example\n * ```typescript\n * const fetchUser = createStep({\n * id: 'fetch-user',\n * inputSchema: z.object({ userId: z.string() }),\n * outputSchema: z.object({ name: z.string(), email: z.string() }),\n * execute: async ({ inputData }) => {\n * const user = await db.getUser(inputData.userId);\n * return { name: user.name, email: user.email };\n * }\n * });\n * ```\n */\nexport function createStep(\n\tconfig: StepConfig,\n): Step {\n\treturn {\n\t\tid: config.id,\n\t\tdescription: config.description,\n\t\tinputSchema: config.inputSchema,\n\t\toutputSchema: config.outputSchema,\n\t\tstateSchema: config.stateSchema,\n\t\texecute: config.execute,\n\t};\n}\n",[],[242,553],"c554a7e8-d1c8-11f0-8d7b-42dde27851f2","run.ts","019aee26-23ab-7319-83f5-9fa41357f00b",["D",1764932068219],"import type { ExecutionEngine } from \"./engine.ts\";\nimport type { WorkflowStorage } from \"./storage.ts\";\nimport type { WorkflowSnapshot } from \"./types.ts\";\nimport type { Workflow } from \"./workflow.ts\";\nimport {\n\ttype ExecutionVisualizationOptions,\n\ttype VisualizationFormat,\n\tvisualizeExecution,\n} from \"./visualize.ts\";\n\n/**\n * A workflow run instance\n */\nexport class WorkflowRun {\n\tconstructor(\n\t\tprivate workflow: Workflow,\n\t\tpublic readonly runId: string,\n\t\tprivate engine: ExecutionEngine,\n\t\tprivate storage: WorkflowStorage,\n\t) {}\n\n\t/**\n\t * Start the workflow execution\n\t */\n\tasync start(params: {\n\t\tinputData: TInput;\n\t\tinitialState?: TState;\n\t}): Promise {\n\t\tconst { inputData, initialState } = params;\n\n\t\treturn await this.engine.execute({\n\t\t\tworkflow: this.workflow,\n\t\t\trunId: this.runId,\n\t\t\tinputData,\n\t\t\tinitialState,\n\t\t});\n\t}\n\n\t/**\n\t * Get the current snapshot of this run\n\t */\n\tasync getSnapshot(): Promise | null> {\n\t\treturn await this.storage.loadSnapshot(this.runId) as WorkflowSnapshot | null;\n\t}\n\n\t/**\n\t * Get the workflow ID\n\t */\n\tget workflowId(): string {\n\t\treturn this.workflow.id;\n\t}\n\n\t/**\n\t * Generate a visual representation of this workflow run's execution state\n\t *\n\t * @param format - The visualization format (default: \"mermaid\")\n\t * @param options - Visualization options\n\t * @returns Visualization string in the specified format, or null if no snapshot exists\n\t *\n\t * @example\n\t * ```typescript\n\t * const diagram = await run.visualize(\"mermaid\", {\n\t * highlightCurrentStep: true,\n\t * showStatus: true\n\t * });\n\t * if (diagram) {\n\t * console.log(diagram);\n\t * }\n\t * ```\n\t */\n\tasync visualize(\n\t\tformat: VisualizationFormat = \"mermaid\",\n\t\toptions: ExecutionVisualizationOptions = {},\n\t): Promise {\n\t\tconst snapshot = await this.getSnapshot();\n\t\tif (!snapshot) {\n\t\t\treturn null;\n\t\t}\n\t\treturn visualizeExecution(this.workflow, snapshot, format, options);\n\t}\n}\n",[],[242,560],"c5549f64-d1c8-11f0-8d7b-42dde27851f2","prebuilt-steps.ts","019aee26-23ab-7319-83f5-9bf20021cf69",["D",1764932068219],"/**\n * Prebuilt workflow steps for common tasks\n *\n * These steps provide ready-to-use functionality for:\n * - HTTP/API requests\n * - String templating\n * - Timing/delays\n * - Logging\n * - Data transformation\n */\n\nimport { z } from \"npm:zod@^3.23\";\nimport { createStep } from \"./step.ts\";\n\n// ============================================================================\n// HTTP/API Steps\n// ============================================================================\n\n/**\n * Make a GET request to a URL\n *\n * @example\n * ```typescript\n * const workflow = createWorkflow({ ... })\n * .then(httpGet)\n * .commit();\n *\n * await run.start({\n * inputData: {\n * url: 'https://api.example.com/users',\n * headers: { 'Authorization': 'Bearer token' }\n * }\n * });\n * ```\n */\nexport const httpGet = createStep({\n\tid: \"http-get\",\n\tdescription: \"Make a GET request and return the JSON response\",\n\tinputSchema: z.object({\n\t\turl: z.string().url(),\n\t\theaders: z.record(z.string()).optional(),\n\t\tqueryParams: z.record(z.string()).optional(),\n\t}),\n\toutputSchema: z.object({\n\t\tstatus: z.number(),\n\t\tdata: z.unknown(),\n\t\theaders: z.record(z.string()),\n\t}),\n\texecute: async ({ inputData }) => {\n\t\tconst { url, headers, queryParams } = inputData;\n\n\t\t// Build URL with query parameters\n\t\tconst urlObj = new URL(url);\n\t\tif (queryParams) {\n\t\t\tObject.entries(queryParams).forEach(([key, value]) => {\n\t\t\t\turlObj.searchParams.append(key, value);\n\t\t\t});\n\t\t}\n\n\t\tconst response = await fetch(urlObj.toString(), {\n\t\t\tmethod: \"GET\",\n\t\t\theaders: headers || {},\n\t\t});\n\n\t\tconst data = await response.json();\n\n\t\t// Convert Headers object to plain object\n\t\tconst responseHeaders: Record = {};\n\t\tresponse.headers.forEach((value, key) => {\n\t\t\tresponseHeaders[key] = value;\n\t\t});\n\n\t\treturn {\n\t\t\tstatus: response.status,\n\t\t\tdata,\n\t\t\theaders: responseHeaders,\n\t\t};\n\t},\n});\n\n/**\n * Make a POST request with JSON body\n *\n * @example\n * ```typescript\n * const workflow = createWorkflow({ ... })\n * .then(httpPost)\n * .commit();\n *\n * await run.start({\n * inputData: {\n * url: 'https://api.example.com/users',\n * body: { name: 'John', email: 'john@example.com' }\n * }\n * });\n * ```\n */\nexport const httpPost = createStep({\n\tid: \"http-post\",\n\tdescription: \"Make a POST request with JSON body and return the response\",\n\tinputSchema: z.object({\n\t\turl: z.string().url(),\n\t\tbody: z.unknown(),\n\t\theaders: z.record(z.string()).optional(),\n\t}),\n\toutputSchema: z.object({\n\t\tstatus: z.number(),\n\t\tdata: z.unknown(),\n\t\theaders: z.record(z.string()),\n\t}),\n\texecute: async ({ inputData }) => {\n\t\tconst { url, body, headers } = inputData;\n\n\t\tconst response = await fetch(url, {\n\t\t\tmethod: \"POST\",\n\t\t\theaders: {\n\t\t\t\t\"Content-Type\": \"application/json\",\n\t\t\t\t...headers,\n\t\t\t},\n\t\t\tbody: JSON.stringify(body),\n\t\t});\n\n\t\tconst data = await response.json();\n\n\t\t// Convert Headers object to plain object\n\t\tconst responseHeaders: Record = {};\n\t\tresponse.headers.forEach((value, key) => {\n\t\t\tresponseHeaders[key] = value;\n\t\t});\n\n\t\treturn {\n\t\t\tstatus: response.status,\n\t\t\tdata,\n\t\t\theaders: responseHeaders,\n\t\t};\n\t},\n});\n\n// ============================================================================\n// String/Template Steps\n// ============================================================================\n\n/**\n * Template string interpolation with variable substitution\n *\n * @example\n * ```typescript\n * const workflow = createWorkflow({ ... })\n * .then(template)\n * .commit();\n *\n * await run.start({\n * inputData: {\n * template: 'Hello {{name}}, your order #{{orderId}} is ready!',\n * variables: { name: 'John', orderId: '12345' }\n * }\n * });\n * // Output: { result: 'Hello John, your order #12345 is ready!' }\n * ```\n */\nexport const template = createStep({\n\tid: \"template\",\n\tdescription: \"Interpolate variables into a template string using {{variable}} syntax\",\n\tinputSchema: z.object({\n\t\ttemplate: z.string(),\n\t\tvariables: z.record(z.union([z.string(), z.number(), z.boolean()])),\n\t}),\n\toutputSchema: z.object({\n\t\tresult: z.string(),\n\t}),\n\texecute: async ({ inputData }) => {\n\t\tconst { template: templateStr, variables } = inputData;\n\n\t\tconst result = templateStr.replace(/\\{\\{(\\w+)\\}\\}/g, (match, key) => {\n\t\t\tif (key in variables) {\n\t\t\t\treturn String(variables[key]);\n\t\t\t}\n\t\t\treturn match; // Keep original if variable not found\n\t\t});\n\n\t\treturn { result };\n\t},\n});\n\n// ============================================================================\n// Utility Steps\n// ============================================================================\n\n/**\n * Delay/sleep for a specified duration\n *\n * Useful for rate limiting, waiting between API calls, or timing-sensitive workflows\n *\n * @example\n * ```typescript\n * const workflow = createWorkflow({ ... })\n * .then(delay)\n * .then(apiCall)\n * .commit();\n *\n * await run.start({\n * inputData: { durationMs: 2000 } // Wait 2 seconds\n * });\n * ```\n */\nexport const delay = createStep({\n\tid: \"delay\",\n\tdescription: \"Wait for a specified duration in milliseconds\",\n\tinputSchema: z.object({\n\t\tdurationMs: z.number().min(0).max(300000), // Max 5 minutes\n\t}),\n\toutputSchema: z.object({\n\t\tdurationMs: z.number(),\n\t\tcompletedAt: z.string(),\n\t}),\n\texecute: async ({ inputData }) => {\n\t\tconst { durationMs } = inputData;\n\n\t\tawait new Promise((resolve) => setTimeout(resolve, durationMs));\n\n\t\treturn {\n\t\t\tdurationMs,\n\t\t\tcompletedAt: new Date().toISOString(),\n\t\t};\n\t},\n});\n\n/**\n * Structured logging step\n *\n * Logs data at different levels and passes input through unchanged.\n * Useful for debugging workflow execution.\n *\n * @example\n * ```typescript\n * const workflow = createWorkflow({ ... })\n * .then(fetchData)\n * .then(logger) // Log the data for debugging\n * .then(processData)\n * .commit();\n *\n * await run.start({\n * inputData: {\n * level: 'info',\n * message: 'Processing user data',\n * data: { userId: '123' }\n * }\n * });\n * ```\n */\nexport const logger = createStep({\n\tid: \"logger\",\n\tdescription: \"Log data at different levels (debug, info, warn, error) and pass through\",\n\tinputSchema: z.object({\n\t\tlevel: z.enum([\"debug\", \"info\", \"warn\", \"error\"]).default(\"info\"),\n\t\tmessage: z.string(),\n\t\tdata: z.unknown().optional(),\n\t}),\n\toutputSchema: z.object({\n\t\tlevel: z.enum([\"debug\", \"info\", \"warn\", \"error\"]),\n\t\tmessage: z.string(),\n\t\tdata: z.unknown().optional(),\n\t\ttimestamp: z.string(),\n\t}),\n\texecute: async ({ inputData, runId, workflowId }) => {\n\t\tconst { level, message, data } = inputData;\n\t\tconst timestamp = new Date().toISOString();\n\n\t\tconst logEntry = {\n\t\t\ttimestamp,\n\t\t\tlevel,\n\t\t\tworkflowId,\n\t\t\trunId,\n\t\t\tmessage,\n\t\t\t...(data && { data }),\n\t\t};\n\n\t\t// Use appropriate console method\n\t\tswitch (level) {\n\t\t\tcase \"debug\":\n\t\t\t\tconsole.debug(logEntry);\n\t\t\t\tbreak;\n\t\t\tcase \"info\":\n\t\t\t\tconsole.info(logEntry);\n\t\t\t\tbreak;\n\t\t\tcase \"warn\":\n\t\t\t\tconsole.warn(logEntry);\n\t\t\t\tbreak;\n\t\t\tcase \"error\":\n\t\t\t\tconsole.error(logEntry);\n\t\t\t\tbreak;\n\t\t}\n\n\t\treturn {\n\t\t\tlevel,\n\t\t\tmessage,\n\t\t\tdata,\n\t\t\ttimestamp,\n\t\t};\n\t},\n});\n\n// ============================================================================\n// Data Transformation Steps\n// ============================================================================\n\n/**\n * Filter array items based on a condition\n *\n * @example\n * ```typescript\n * const workflow = createWorkflow({ ... })\n * .then(filterArray)\n * .commit();\n *\n * await run.start({\n * inputData: {\n * array: [\n * { name: 'Alice', age: 30 },\n * { name: 'Bob', age: 17 },\n * { name: 'Charlie', age: 25 }\n * ],\n * filterFn: '(item) => item.age >= 18'\n * }\n * });\n * // Output: { filtered: [{ name: 'Alice', age: 30 }, { name: 'Charlie', age: 25 }] }\n * ```\n */\nexport const filterArray = createStep({\n\tid: \"filter-array\",\n\tdescription: \"Filter array items using a JavaScript filter function (as string)\",\n\tinputSchema: z.object({\n\t\tarray: z.array(z.unknown()),\n\t\tfilterFn: z.string(), // JavaScript function as string: \"(item) => condition\"\n\t}),\n\toutputSchema: z.object({\n\t\tfiltered: z.array(z.unknown()),\n\t\toriginalCount: z.number(),\n\t\tfilteredCount: z.number(),\n\t}),\n\texecute: async ({ inputData }) => {\n\t\tconst { array, filterFn } = inputData;\n\n\t\t// Create function from string\n\t\t// Note: In production, consider security implications of eval\n\t\t// For Val Town personal automation, this provides flexibility\n\t\tconst filterFunction = eval(filterFn);\n\n\t\tconst filtered = array.filter(filterFunction);\n\n\t\treturn {\n\t\t\tfiltered,\n\t\t\toriginalCount: array.length,\n\t\t\tfilteredCount: filtered.length,\n\t\t};\n\t},\n});\n\n/**\n * Transform array items using a map function\n *\n * @example\n * ```typescript\n * const workflow = createWorkflow({ ... })\n * .then(mapArray)\n * .commit();\n *\n * await run.start({\n * inputData: {\n * array: [1, 2, 3, 4],\n * mapFn: '(item) => item * 2'\n * }\n * });\n * // Output: { mapped: [2, 4, 6, 8] }\n * ```\n */\nexport const mapArray = createStep({\n\tid: \"map-array\",\n\tdescription: \"Transform array items using a JavaScript map function (as string)\",\n\tinputSchema: z.object({\n\t\tarray: z.array(z.unknown()),\n\t\tmapFn: z.string(), // JavaScript function as string: \"(item) => transformed\"\n\t}),\n\toutputSchema: z.object({\n\t\tmapped: z.array(z.unknown()),\n\t\tcount: z.number(),\n\t}),\n\texecute: async ({ inputData }) => {\n\t\tconst { array, mapFn } = inputData;\n\n\t\t// Create function from string\n\t\tconst mapFunction = eval(mapFn);\n\n\t\tconst mapped = array.map(mapFunction);\n\n\t\treturn {\n\t\t\tmapped,\n\t\t\tcount: mapped.length,\n\t\t};\n\t},\n});\n\n/**\n * Extract specific fields from an object\n *\n * Useful for simplifying data flow between steps by removing unnecessary fields\n *\n * @example\n * ```typescript\n * const workflow = createWorkflow({ ... })\n * .then(pickFields)\n * .commit();\n *\n * await run.start({\n * inputData: {\n * object: { id: 1, name: 'Alice', email: 'alice@example.com', password: 'secret' },\n * fields: ['id', 'name', 'email']\n * }\n * });\n * // Output: { result: { id: 1, name: 'Alice', email: 'alice@example.com' } }\n * ```\n */\nexport const pickFields = createStep({\n\tid: \"pick-fields\",\n\tdescription: \"Extract specific fields from an object\",\n\tinputSchema: z.object({\n\t\tobject: z.record(z.unknown()),\n\t\tfields: z.array(z.string()),\n\t}),\n\toutputSchema: z.object({\n\t\tresult: z.record(z.unknown()),\n\t}),\n\texecute: async ({ inputData }) => {\n\t\tconst { object, fields } = inputData;\n\n\t\tconst result: Record = {};\n\n\t\tfor (const field of fields) {\n\t\t\tif (field in object) {\n\t\t\t\tresult[field] = object[field];\n\t\t\t}\n\t\t}\n\n\t\treturn { result };\n\t},\n});\n",[],[242,567],"c55492e4-d1c8-11f0-8d7b-42dde27851f2","migrations.ts","019aee26-23ab-7319-83f5-9521e3d5c69a",["D",1764932068219],"/**\n * Database migration utilities for wrkflw\n *\n * This module provides SQL migration functionality to help users\n * migrate their existing tables to the new naming scheme with wrkflw_ prefix.\n */\n\n/**\n * Migrates the old workflow_runs table to wrkflw_workflow_runs\n *\n * This function:\n * 1. Checks if the old table exists\n * 2. Creates the new table with wrkflw_ prefix\n * 3. Copies all data from the old table to the new table\n * 4. Optionally drops the old table (if dropOldTable is true)\n *\n * @param dropOldTable - Whether to drop the old table after migration (default: false for safety)\n * @returns Migration summary with row count and status\n */\nexport async function migrateWorkflowRunsTable(\n\tdropOldTable = false,\n): Promise<{ migrated: boolean; rowCount: number; message: string }> {\n\tconst { sqlite } = await import(\"https://esm.town/v/std/sqlite\");\n\n\t// Check both tables in a single query for efficiency\n\tconst tableCheck = await sqlite.execute({\n\t\tsql: `\n SELECT name FROM sqlite_master\n WHERE type='table' AND name IN ('workflow_runs', 'wrkflw_workflow_runs')\n `,\n\t\targs: [],\n\t});\n\n\tconst existingTables = tableCheck.rows.map((row) => row[0] as string);\n\tconst oldTableExists = existingTables.includes(\"workflow_runs\");\n\tconst newTableExists = existingTables.includes(\"wrkflw_workflow_runs\");\n\n\t// If new table exists and old table doesn't, migration already completed\n\tif (newTableExists && !oldTableExists) {\n\t\treturn {\n\t\t\tmigrated: false,\n\t\t\trowCount: 0,\n\t\t\tmessage:\n\t\t\t\t\"Migration already completed - using 'wrkflw_workflow_runs' table\",\n\t\t};\n\t}\n\n\t// If old table doesn't exist, nothing to migrate\n\tif (!oldTableExists) {\n\t\treturn {\n\t\t\tmigrated: false,\n\t\t\trowCount: 0,\n\t\t\tmessage: \"No migration needed - old table 'workflow_runs' does not exist\",\n\t\t};\n\t}\n\n\t// Create new table if it doesn't exist\n\tif (!newTableExists) {\n\t\tawait sqlite.execute(`\n CREATE TABLE wrkflw_workflow_runs (\n run_id TEXT PRIMARY KEY,\n workflow_id TEXT NOT NULL,\n status TEXT NOT NULL,\n execution_path TEXT,\n step_results TEXT,\n state TEXT,\n input_data TEXT,\n result TEXT,\n error TEXT,\n created_at INTEGER DEFAULT (unixepoch()),\n updated_at INTEGER DEFAULT (unixepoch())\n )\n `);\n\n\t\t// Create indexes\n\t\tawait sqlite.execute(`\n CREATE INDEX IF NOT EXISTS idx_wrkflw_workflow_runs_workflow_id\n ON wrkflw_workflow_runs(workflow_id)\n `);\n\n\t\tawait sqlite.execute(`\n CREATE INDEX IF NOT EXISTS idx_wrkflw_workflow_runs_status\n ON wrkflw_workflow_runs(status)\n `);\n\t}\n\n\t// Get row count from old table\n\tconst countResult = await sqlite.execute({\n\t\tsql: \"SELECT COUNT(*) as count FROM workflow_runs\",\n\t\targs: [],\n\t});\n\tconst rowCount = countResult.rows[0][0] as number;\n\n\t// If old table is empty, no migration needed\n\tif (rowCount === 0) {\n\t\treturn {\n\t\t\tmigrated: false,\n\t\t\trowCount: 0,\n\t\t\tmessage:\n\t\t\t\t\"No migration needed - old table 'workflow_runs' exists but is empty\",\n\t\t};\n\t}\n\n\t// Check if new table already has data\n\tconst newTableCountResult = await sqlite.execute({\n\t\tsql: \"SELECT COUNT(*) as count FROM wrkflw_workflow_runs\",\n\t\targs: [],\n\t});\n\tconst newTableRowCount = newTableCountResult.rows[0][0] as number;\n\n\t// Copy data from old table to new table\n\tconst _insertResult = await sqlite.execute(`\n INSERT OR IGNORE INTO wrkflw_workflow_runs (\n run_id, workflow_id, status, execution_path,\n step_results, state, input_data, result, error,\n created_at, updated_at\n )\n SELECT\n run_id, workflow_id, status, execution_path,\n step_results, state, input_data, result, error,\n created_at, updated_at\n FROM workflow_runs\n `);\n\n\t// Calculate how many rows were actually inserted\n\tconst finalCountResult = await sqlite.execute({\n\t\tsql: \"SELECT COUNT(*) as count FROM wrkflw_workflow_runs\",\n\t\targs: [],\n\t});\n\tconst finalRowCount = finalCountResult.rows[0][0] as number;\n\tconst rowsInserted = finalRowCount - newTableRowCount;\n\tconst rowsSkipped = rowCount - rowsInserted;\n\n\t// Build informative message\n\tlet message = \"\";\n\tif (rowsSkipped > 0) {\n\t\tmessage = `Migration completed with conflicts: inserted ${rowsInserted} new rows, skipped ${rowsSkipped} duplicate rows (conflicts detected - new table already had ${newTableRowCount} rows)`;\n\t} else {\n\t\tmessage = `Successfully migrated ${rowsInserted} rows from 'workflow_runs' to 'wrkflw_workflow_runs'`;\n\t}\n\n\t// Optionally drop old table\n\tif (dropOldTable) {\n\t\tawait sqlite.execute(\"DROP TABLE workflow_runs\");\n\t\t// Also drop old indexes if they exist\n\t\tawait sqlite.execute(\"DROP INDEX IF EXISTS idx_workflow_runs_workflow_id\");\n\t\tawait sqlite.execute(\"DROP INDEX IF EXISTS idx_workflow_runs_status\");\n\n\t\treturn {\n\t\t\tmigrated: true,\n\t\t\trowCount,\n\t\t\tmessage: `Successfully migrated ${rowCount} rows from 'workflow_runs' to 'wrkflw_workflow_runs' and dropped old table`,\n\t\t};\n\t}\n\n\treturn {\n\t\tmigrated: true,\n\t\trowCount,\n\t\tmessage: `Successfully migrated ${rowCount} rows from 'workflow_runs' to 'wrkflw_workflow_runs'. Old table preserved for safety.`,\n\t};\n}\n\n/**\n * Runs all pending migrations\n *\n * This function should be called during application initialization\n * to ensure all tables are up to date with the latest schema.\n *\n * @param options - Migration options\n * @param options.dropOldTables - Whether to drop old tables after migration\n * @returns Array of migration results\n */\nexport async function runMigrations(\n\toptions: { dropOldTables?: boolean } = {},\n): Promise> {\n\tconst results = [];\n\n\t// Run workflow_runs migration\n\tconst workflowRunsResult = await migrateWorkflowRunsTable(\n\t\toptions.dropOldTables ?? false,\n\t);\n\tresults.push(workflowRunsResult);\n\n\treturn results;\n}\n\n/**\n * Export SQL script for manual migration\n *\n * Generates SQL statements that can be run manually to migrate tables.\n *\n * **IMPORTANT**: This SQL script assumes the old `workflow_runs` table exists.\n * If you're setting up a fresh installation (no existing data), you only need\n * to create the new table - the data migration step can be skipped.\n *\n * Before running this script, verify the old table exists:\n * ```sql\n * SELECT name FROM sqlite_master WHERE type='table' AND name='workflow_runs';\n * ```\n *\n * @param dropOldTable - Whether to include DROP TABLE statements\n * @returns SQL migration script as a string\n */\nexport function generateMigrationSQL(dropOldTable = false): string {\n\tconst sql = `\n-- Migration Script: Normalize table naming to wrkflw_ prefix\n-- Generated: ${new Date().toISOString()}\n--\n-- IMPORTANT: This script is designed for migrating FROM an existing workflow_runs table.\n-- If you're setting up a fresh installation without existing data, you can skip\n-- the data migration step (Step 3) as it will have no data to copy.\n--\n-- Before running this script, you can verify if the old table exists:\n-- SELECT name FROM sqlite_master WHERE type='table' AND name='workflow_runs';\n\n-- Step 1: Create new table with wrkflw_ prefix\nCREATE TABLE IF NOT EXISTS wrkflw_workflow_runs (\n run_id TEXT PRIMARY KEY,\n workflow_id TEXT NOT NULL,\n status TEXT NOT NULL,\n execution_path TEXT,\n step_results TEXT,\n state TEXT,\n input_data TEXT,\n result TEXT,\n error TEXT,\n created_at INTEGER DEFAULT (unixepoch()),\n updated_at INTEGER DEFAULT (unixepoch())\n);\n\n-- Step 2: Create indexes for new table\nCREATE INDEX IF NOT EXISTS idx_wrkflw_workflow_runs_workflow_id\nON wrkflw_workflow_runs(workflow_id);\n\nCREATE INDEX IF NOT EXISTS idx_wrkflw_workflow_runs_status\nON wrkflw_workflow_runs(status);\n\n-- Step 3: Copy data from old table to new table\n-- NOTE: This step will fail if the 'workflow_runs' table doesn't exist.\n-- If you don't have an existing workflow_runs table, this is expected and you can\n-- ignore this step - there's no data to migrate.\nINSERT OR IGNORE INTO wrkflw_workflow_runs (\n run_id, workflow_id, status, execution_path,\n step_results, state, input_data, result, error,\n created_at, updated_at\n)\nSELECT\n run_id, workflow_id, status, execution_path,\n step_results, state, input_data, result, error,\n created_at, updated_at\nFROM workflow_runs;\n${\n\tdropOldTable\n\t\t? `\n-- Step 4: Drop old table and indexes (CAUTION: This is irreversible!)\nDROP TABLE IF EXISTS workflow_runs;\nDROP INDEX IF EXISTS idx_workflow_runs_workflow_id;\nDROP INDEX IF EXISTS idx_workflow_runs_status;\n`\n\t\t: `\n-- Step 4: Old table preserved for safety\n-- To drop the old table manually, run:\n-- DROP TABLE workflow_runs;\n-- DROP INDEX IF EXISTS idx_workflow_runs_workflow_id;\n-- DROP INDEX IF EXISTS idx_workflow_runs_status;\n`\n}\n-- Migration complete!\n`.trim();\n\n\treturn sql;\n}\n",[],[242,574],"c5549104-d1c8-11f0-8d7b-42dde27851f2","index.ts","019aee26-23ab-7319-83f5-90d41faeb6f1",["D",1764932068219],"/**\n * wrkflw - A TypeScript-first workflow engine for Val Town\n *\n * Inspired by Mastra, optimized for Val Town platform\n */\n\nexport { ExecutionEngine } from \"./engine.ts\";\nexport { WorkflowRun } from \"./run.ts\";\n// Core exports\nexport { createStep } from \"./step.ts\";\nexport { WorkflowStorage } from \"./storage.ts\";\n// Migration exports\nexport {\n\tgenerateMigrationSQL,\n\tmigrateWorkflowRunsTable,\n\trunMigrations,\n} from \"./migrations.ts\";\n// Type exports\nexport type {\n\tExecuteFunction,\n\tExecutionContext,\n\tStep,\n\tStepConfig,\n\tStepExecutionContext,\n\tStepFlowEntry,\n\tStepResult,\n\tWorkflowConfig,\n\tWorkflowSnapshot,\n} from \"./types.ts\";\nexport { createWorkflow, Workflow, WorkflowBuilder } from \"./workflow.ts\";\n\n// Prebuilt steps\nexport {\n\tdelay,\n\tfilterArray,\n\thttpGet,\n\thttpPost,\n\tlogger,\n\tmapArray,\n\tpickFields,\n\ttemplate,\n} from \"./prebuilt-steps.ts\";\n\n// Visualization exports\nexport {\n\tvisualizeExecution,\n\tvisualizeWorkflow,\n\ttype ExecutionVisualizationOptions,\n\ttype VisualizationFormat,\n\ttype VisualizationOptions,\n} from \"./visualize.ts\";\n\n// API Server exports\nexport { ApiServer, createApiServer } from \"./api-server.ts\";\n",[],[242,581],"c5548a7e-d1c8-11f0-8d7b-42dde27851f2","engine.ts","019aee26-23ab-7319-83f5-8e765f6e3a59",["D",1764932068219],"import type { WorkflowStorage } from \"./storage.ts\";\nimport type {\n\tExecutionContext,\n\tStep,\n\tStepExecutionContext,\n\tStepResult,\n} from \"./types.ts\";\nimport type { Workflow } from \"./workflow.ts\";\n\n/**\n * Execution engine that runs workflows step by step\n */\nexport class ExecutionEngine {\n\tconstructor(private storage: WorkflowStorage) {}\n\n\t/**\n\t * Execute a workflow from start to finish\n\t */\n\tasync execute(params: {\n\t\tworkflow: Workflow;\n\t\trunId: string;\n\t\tinputData: TInput;\n\t\tinitialState?: TState;\n\t}): Promise {\n\t\tconst { workflow, runId, inputData, initialState } = params;\n\n\t\t// Validate input data at runtime\n\t\tconst validatedInput = workflow.inputSchema.parse(inputData);\n\n\t\t// Initialize execution context\n\t\tconst context: ExecutionContext = {\n\t\t\tworkflowId: workflow.id,\n\t\t\trunId,\n\t\t\texecutionPath: [],\n\t\t\tstepResults: {},\n\t\t\tstate:\n\t\t\t\tinitialState ??\n\t\t\t\t(workflow.stateSchema ? ({} as TState) : undefined as unknown as TState),\n\t\t\tinputData: validatedInput,\n\t\t};\n\n\t\t// Save initial snapshot\n\t\tawait this.storage.saveSnapshot({\n\t\t\trunId,\n\t\t\tworkflowId: workflow.id,\n\t\t\tstatus: \"running\",\n\t\t\texecutionPath: context.executionPath,\n\t\t\tstepResults: context.stepResults,\n\t\t\tstate: context.state,\n\t\t\tinputData: validatedInput,\n\t\t\ttimestamp: Date.now(),\n\t\t});\n\n\t\ttry {\n\t\t\t// Execute all steps sequentially\n\t\t\tlet currentOutput: unknown = validatedInput;\n\n\t\t\tfor (let i = 0; i < workflow.stepFlow.length; i++) {\n\t\t\t\tcontext.executionPath.push(i);\n\n\t\t\t\tconst entry = workflow.stepFlow[i];\n\n\t\t\t\tif (entry.type === \"step\") {\n\t\t\t\t\tconst result = await this.executeStep(\n\t\t\t\t\t\tentry.step,\n\t\t\t\t\t\tcontext,\n\t\t\t\t\t\tcurrentOutput,\n\t\t\t\t\t);\n\n\t\t\t\t\tcontext.stepResults[entry.step.id] = result;\n\n\t\t\t\t\tif (result.status === \"failed\") {\n\t\t\t\t\t\t// Save failed state\n\t\t\t\t\t\tawait this.storage.saveSnapshot({\n\t\t\t\t\t\t\trunId,\n\t\t\t\t\t\t\tworkflowId: workflow.id,\n\t\t\t\t\t\t\tstatus: \"failed\",\n\t\t\t\t\t\t\texecutionPath: context.executionPath,\n\t\t\t\t\t\t\tstepResults: context.stepResults,\n\t\t\t\t\t\t\tstate: context.state,\n\t\t\t\t\t\t\tinputData: validatedInput,\n\t\t\t\t\t\t\terror: result.error.message,\n\t\t\t\t\t\t\ttimestamp: Date.now(),\n\t\t\t\t\t\t});\n\n\t\t\t\t\t\tthrow result.error;\n\t\t\t\t\t}\n\n\t\t\t\t\tif (result.status === \"success\") {\n\t\t\t\t\t\tcurrentOutput = result.output;\n\t\t\t\t\t}\n\n\t\t\t\t\t// Save progress after each step\n\t\t\t\t\tawait this.storage.saveSnapshot({\n\t\t\t\t\t\trunId,\n\t\t\t\t\t\tworkflowId: workflow.id,\n\t\t\t\t\t\tstatus: \"running\",\n\t\t\t\t\t\texecutionPath: context.executionPath,\n\t\t\t\t\t\tstepResults: context.stepResults,\n\t\t\t\t\t\tstate: context.state,\n\t\t\t\t\t\tinputData: validatedInput,\n\t\t\t\t\t\ttimestamp: Date.now(),\n\t\t\t\t\t});\n\t\t\t\t}\n\t\t\t}\n\n\t\t\t// Validate output\n\t\t\tconst validatedOutput = workflow.outputSchema.parse(currentOutput);\n\n\t\t\t// Save success state\n\t\t\tawait this.storage.saveSnapshot({\n\t\t\t\trunId,\n\t\t\t\tworkflowId: workflow.id,\n\t\t\t\tstatus: \"success\",\n\t\t\t\texecutionPath: context.executionPath,\n\t\t\t\tstepResults: context.stepResults,\n\t\t\t\tstate: context.state,\n\t\t\t\tinputData: validatedInput,\n\t\t\t\tresult: validatedOutput,\n\t\t\t\ttimestamp: Date.now(),\n\t\t\t});\n\n\t\t\treturn validatedOutput;\n\t\t} catch (error) {\n\t\t\t// If error wasn't already saved (e.g., validation error)\n\t\t\tawait this.storage.saveSnapshot({\n\t\t\t\trunId,\n\t\t\t\tworkflowId: workflow.id,\n\t\t\t\tstatus: \"failed\",\n\t\t\t\texecutionPath: context.executionPath,\n\t\t\t\tstepResults: context.stepResults,\n\t\t\t\tstate: context.state,\n\t\t\t\tinputData: validatedInput,\n\t\t\t\terror: error instanceof Error ? error.message : String(error),\n\t\t\t\ttimestamp: Date.now(),\n\t\t\t});\n\n\t\t\tthrow error;\n\t\t}\n\t}\n\n\t/**\n\t * Execute a single step\n\t */\n\tprivate async executeStep(\n\t\tstep: Step,\n\t\tcontext: ExecutionContext,\n\t\tinputData: unknown,\n\t): Promise> {\n\t\tconst timestamp = Date.now();\n\n\t\ttry {\n\t\t\t// Validate input data at runtime\n\t\t\tconst validatedInput = step.inputSchema.parse(inputData);\n\n\t\t\t// Build step execution context\n\t\t\tconst stepContext: StepExecutionContext = {\n\t\t\t\tinputData: validatedInput,\n\t\t\t\tstate: context.state,\n\t\t\t\tsetState: (newState: TState) => {\n\t\t\t\t\tcontext.state = newState;\n\t\t\t\t},\n\t\t\t\tgetStepResult: >(targetStep: T) => {\n\t\t\t\t\tconst result = context.stepResults[targetStep.id];\n\t\t\t\t\tif (!result) {\n\t\t\t\t\t\tthrow new Error(`Step ${targetStep.id} has not been executed yet`);\n\t\t\t\t\t}\n\t\t\t\t\tif (result.status !== \"success\") {\n\t\t\t\t\t\tthrow new Error(\n\t\t\t\t\t\t\t`Step ${targetStep.id} did not complete successfully`,\n\t\t\t\t\t\t);\n\t\t\t\t\t}\n\t\t\t\t\treturn result.output;\n\t\t\t\t},\n\t\t\t\tgetInitData: () => context.inputData as any,\n\t\t\t\trunId: context.runId,\n\t\t\t\tworkflowId: context.workflowId,\n\t\t\t};\n\n\t\t\t// Execute the step\n\t\t\tconst output = await step.execute(stepContext);\n\n\t\t\t// Validate output at runtime\n\t\t\tconst validatedOutput = step.outputSchema.parse(output);\n\n\t\t\treturn {\n\t\t\t\tstatus: \"success\",\n\t\t\t\toutput: validatedOutput,\n\t\t\t\ttimestamp,\n\t\t\t};\n\t\t} catch (error) {\n\t\t\treturn {\n\t\t\t\tstatus: \"failed\",\n\t\t\t\terror: error instanceof Error ? error : new Error(String(error)),\n\t\t\t\ttimestamp,\n\t\t\t};\n\t\t}\n\t}\n}\n",[],[242,588],"c5547106-d1c8-11f0-8d7b-42dde27851f2","api-server.ts","019aee26-23ab-7319-83f5-89b04d783661",["D",1764932068219],"import { Workflow } from \"./workflow.ts\";\nimport { WorkflowStorage } from \"./storage.ts\";\nimport { WorkflowSnapshot } from \"./types.ts\";\n\ninterface ApiWorkflowData {\n id: string;\n description?: string;\n steps: Array<{ id: string; description?: string }>;\n exampleInput?: Record;\n}\n\ninterface ApiRunData {\n runId: string;\n workflowId: string;\n status: \"running\" | \"success\" | \"failed\";\n executionPath: number[];\n stepResults: Record;\n inputData: unknown;\n result?: unknown;\n error?: string;\n createdAt: number;\n updatedAt: number;\n}\n\nexport class ApiServer {\n private workflows: Map; exampleInput?: Record }> = new Map();\n private storage: WorkflowStorage;\n\n constructor(storage: WorkflowStorage) {\n this.storage = storage;\n }\n\n registerWorkflow(\n workflow: Workflow,\n exampleInput?: Record,\n ) {\n this.workflows.set(workflow.id, { workflow: workflow as any, exampleInput });\n }\n\n private serializeWorkflow(workflowId: string): ApiWorkflowData | null {\n const entry = this.workflows.get(workflowId);\n if (!entry) return null;\n\n const { workflow, exampleInput } = entry;\n return {\n id: workflow.id,\n description: workflow.description,\n steps: workflow.steps.map((step) => ({\n id: step.id,\n description: step.description,\n })),\n exampleInput,\n };\n }\n\n private serializeRun(snapshot: WorkflowSnapshot): ApiRunData {\n return {\n runId: snapshot.runId,\n workflowId: snapshot.workflowId,\n status: snapshot.status,\n executionPath: snapshot.executionPath,\n stepResults: snapshot.stepResults,\n inputData: snapshot.inputData,\n result: snapshot.result,\n error: snapshot.error,\n createdAt: snapshot.timestamp,\n updatedAt: snapshot.timestamp,\n };\n }\n\n async handleRequest(request: Request): Promise {\n const url = new URL(request.url);\n const path = url.pathname;\n const method = request.method;\n\n // CORS headers\n const corsHeaders = {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"GET, POST, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type\",\n \"Content-Type\": \"application/json\",\n };\n\n // Handle preflight requests\n if (method === \"OPTIONS\") {\n return new Response(null, { headers: corsHeaders });\n }\n\n try {\n // GET /api/workflows - List all workflows\n if (path === \"/api/workflows\" && method === \"GET\") {\n const workflows = Array.from(this.workflows.keys()).map((id) =>\n this.serializeWorkflow(id)\n ).filter((w): w is ApiWorkflowData => w !== null);\n\n return new Response(JSON.stringify(workflows), { headers: corsHeaders });\n }\n\n // GET /api/workflows/:id - Get workflow details\n const workflowMatch = path.match(/^\\/api\\/workflows\\/([^\\/]+)$/);\n if (workflowMatch && method === \"GET\") {\n const workflowId = workflowMatch[1];\n const workflow = this.serializeWorkflow(workflowId);\n\n if (!workflow) {\n return new Response(JSON.stringify({ error: \"Workflow not found\" }), {\n status: 404,\n headers: corsHeaders,\n });\n }\n\n return new Response(JSON.stringify(workflow), { headers: corsHeaders });\n }\n\n // GET /api/workflows/:id/runs - List runs for a workflow\n const runsMatch = path.match(/^\\/api\\/workflows\\/([^\\/]+)\\/runs$/);\n if (runsMatch && method === \"GET\") {\n const workflowId = runsMatch[1];\n const snapshots = await this.storage.listRuns(workflowId);\n const runs = snapshots.map((s) => this.serializeRun(s));\n\n return new Response(JSON.stringify(runs), { headers: corsHeaders });\n }\n\n // POST /api/workflows/:id/runs - Create a new run\n if (runsMatch && method === \"POST\") {\n const workflowId = runsMatch[1];\n const entry = this.workflows.get(workflowId);\n\n if (!entry) {\n return new Response(JSON.stringify({ error: \"Workflow not found\" }), {\n status: 404,\n headers: corsHeaders,\n });\n }\n\n const body = await request.json();\n const { inputData } = body;\n\n // Create and start the run in the background\n const run = await entry.workflow.createRun();\n\n // Start execution (don't await - let it run in background)\n run.start({ inputData }).catch((error) => {\n console.error(`Run ${run.runId} failed:`, error);\n });\n\n // Return the initial run state\n const snapshot = await this.storage.loadSnapshot(run.runId);\n if (!snapshot) {\n return new Response(JSON.stringify({ error: \"Failed to create run\" }), {\n status: 500,\n headers: corsHeaders,\n });\n }\n\n return new Response(JSON.stringify(this.serializeRun(snapshot)), {\n status: 201,\n headers: corsHeaders,\n });\n }\n\n // GET /api/runs/:runId - Get run details\n const runMatch = path.match(/^\\/api\\/runs\\/([^\\/]+)$/);\n if (runMatch && method === \"GET\") {\n const runId = runMatch[1];\n const snapshot = await this.storage.loadSnapshot(runId);\n\n if (!snapshot) {\n return new Response(JSON.stringify({ error: \"Run not found\" }), {\n status: 404,\n headers: corsHeaders,\n });\n }\n\n return new Response(JSON.stringify(this.serializeRun(snapshot)), {\n headers: corsHeaders,\n });\n }\n\n // 404 for unmatched routes\n return new Response(JSON.stringify({ error: \"Not found\" }), {\n status: 404,\n headers: corsHeaders,\n });\n } catch (error) {\n console.error(\"API Error:\", error);\n return new Response(\n JSON.stringify({ error: error instanceof Error ? error.message : \"Internal server error\" }),\n {\n status: 500,\n headers: corsHeaders,\n },\n );\n }\n }\n\n async serve(port = 8000) {\n console.log(`API server starting on http://localhost:${port}`);\n\n const server = Deno.serve({ port }, (request) => this.handleRequest(request));\n\n return server;\n }\n}\n\n// Helper function to create and configure an API server\nexport function createApiServer(storage: WorkflowStorage): ApiServer {\n return new ApiServer(storage);\n}\n",[],[242,595],["D",1764932068219],[256,257,258,259,260,261,262,263,264,265,266],[242],["D",1764932068219],{"_11":12,"_93":89},{"_11":12,"_86":87,"_88":89,"_47":48,"_90":91,"_92":40},{"_29":30,"_13":26,"_20":21,"_27":28,"_31":32,"_33":34,"_79":42,"_80":81,"_82":83,"_84":14,"_85":12},"ctx",{"_72":-5,"_116":641,"_642":643,"_644":645,"_646":40,"_647":40,"_648":40,"_649":52,"_650":-5,"_651":-7,"_652":-7,"_653":56,"_654":40,"_655":40,"_656":-5,"_657":40,"_658":40,"_659":40,"_660":-5},"ENV",{"_612":613,"_614":615,"_616":26,"_617":618,"_619":620,"_621":622,"_623":624,"_625":626,"_627":628,"_629":630,"_631":632,"_633":634,"_635":636,"_637":638,"_639":640},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Branches1

Branches
1