refactor: move the workflowId to a top level not catch-all

Signed-off-by: Simon Emms <simon@simonemms.com>

Author: mrsimonemms

src/lib/export/yaml.ts

@@ -89,6 +89,12 @@ export function exportToYaml(file: WorkflowFile): ExportResult {
 
   const doc: Record<string, unknown> = {
     document: exportDocument(file),
+    input: {
+      schema: {
+        format: file.input.schema.format,
+        document: file.input.schema.document,
+      },
+    },
     do: topLevelTasks,
   };
 

src/lib/i18n/messages/en.json

@@ -18,6 +18,7 @@
     "localeEn": "English (International)",
     "localeEnGb": "English (British)",
     "exportYaml": "Export YAML",
+    "editInputSchema": "Edit input schema",
     "noGraph": "No graph to display.",
     "exportDialog": "YAML export"
   },
@@ -403,6 +404,27 @@
       "bodyCount": "body ({{count}} tasks)"
     }
   },
+  "input": {
+    "pageTitle": "Editing Input Schema",
+    "backToEditor": "← Back to editor",
+    "saving": "Saving…",
+    "saved": "Saved",
+    "unsaved": "Unsaved changes",
+    "saveFailed": "Save failed",
+    "schema": {
+      "fields": "Fields",
+      "colName": "Name",
+      "colType": "Type",
+      "colRequired": "Required",
+      "addField": "+ Add field",
+      "deleteField": "Delete field",
+      "typeString": "string",
+      "typeNumber": "number",
+      "typeBoolean": "boolean",
+      "errorNameRequired": "Name is required",
+      "errorNameDuplicate": "Duplicate name"
+    }
+  },
   "validation": {
     "loop": {
       "collectionRequired": "Collection is required",

src/lib/tasks/actions.ts

@@ -73,6 +73,9 @@ export function createWorkflowFile(document: DocumentMetadata): WorkflowFile {
   };
   return {
     document,
+    input: {
+      schema: { format: 'json', document: { type: 'object', properties: {} } },
+    },
     workflows: { [id]: workflow },
     order: [id],
   };

src/lib/tasks/model.ts

@@ -41,8 +41,20 @@ export type DocumentMetadata = {
   metadata?: Record<string, unknown>;
 };
 
+// Input schema — mirrors the Zigflow DSL `input.schema:` block.
+// `document` is a raw JSON Schema object; the Studio preserves it as-is.
+export type WorkflowSchema = {
+  format: string;
+  document: Record<string, unknown>;
+};
+
+export type WorkflowInput = {
+  schema: WorkflowSchema;
+};
+
 export type WorkflowFile = {
   document: DocumentMetadata;
+  input: WorkflowInput;
   workflows: Record<string, NamedWorkflow>;
   order: string[]; // stable ordering of named workflows
 };

src/lib/tasks/parse.ts

@@ -66,6 +66,8 @@ import type {
   TryNode,
   WaitConfig,
   WorkflowFile,
+  WorkflowInput,
+  WorkflowSchema,
 } from './model';
 import { ZIGFLOW_ID_KEY } from './model';
 
@@ -121,6 +123,20 @@ export function parseWorkflowFile(
 
   const doEntries = (raw['do'] as RawEntry[]) ?? [];
 
+  // Parse input.schema — default when absent.
+  const rawInput = raw['input'] as Record<string, unknown> | undefined;
+  const rawSchema = rawInput?.['schema'] as Record<string, unknown> | undefined;
+  const schema: WorkflowSchema = rawSchema
+    ? {
+        format: String(rawSchema['format'] ?? 'json'),
+        document: (rawSchema['document'] ?? {
+          type: 'object',
+          properties: {},
+        }) as Record<string, unknown>,
+      }
+    : { format: 'json', document: { type: 'object', properties: {} } };
+  const input: WorkflowInput = { schema };
+
   const ctx: ParseCtx = { modified: false, newFormat: false };
 
   // Detect format: new format if every entry's value has a `do:` key.
@@ -133,12 +149,12 @@ export function parseWorkflowFile(
 
   if (isNewFormat) {
     ctx.newFormat = true;
-    const workflowFile = parseNewFormat(doEntries, document, ctx);
+    const workflowFile = parseNewFormat(doEntries, document, input, ctx);
     return { workflowFile, modified: ctx.modified };
   }
 
   // Old format: flat steps with hoisted sub-graph entries.
-  return parseOldFormat(doEntries, document, ctx);
+  return parseOldFormat(doEntries, document, input, ctx);
 }
 
 // ---------------------------------------------------------------------------
@@ -154,6 +170,7 @@ export function parseWorkflowFile(
 function parseNewFormat(
   doEntries: RawEntry[],
   document: DocumentMetadata,
+  input: WorkflowInput,
   ctx: ParseCtx,
 ): WorkflowFile {
   const workflows: Record<string, NamedWorkflow> = {};
@@ -182,7 +199,7 @@ function parseNewFormat(
     order.push(id);
   }
 
-  return { document, workflows, order };
+  return { document, input, workflows, order };
 }
 
 // ---------------------------------------------------------------------------
@@ -196,6 +213,7 @@ function parseNewFormat(
 function parseOldFormat(
   doEntries: RawEntry[],
   document: DocumentMetadata,
+  input: WorkflowInput,
   ctx: ParseCtx,
 ): ParseResult {
   // Build a flat map of all named entries for hoisted branch resolution.
@@ -220,6 +238,7 @@ function parseOldFormat(
 
   const workflowFile: WorkflowFile = {
     document,
+    input,
     workflows: { [workflowId]: workflow },
     order: [workflowId],
   };