feat(workflows): LLM workflow tool — saved multi-step agent pipelines with compiled, shareable outputs

apps/app/src/app/lib/openwork-server.ts

@@ -17,6 +17,7 @@ export type OpenworkServerCapabilities = {
   plugins: { read: boolean; write: boolean };
   mcp: { read: boolean; write: boolean };
   commands: { read: boolean; write: boolean };
+  workflows?: { read: boolean; write: boolean };
   config: { read: boolean; write: boolean };
   sandbox?: { enabled: boolean; backend: "none" | "docker" | "container" };
   proxy?: { opencode: boolean };
@@ -444,6 +445,47 @@ export type OpenworkInboxUploadResult = {
   bytes: number;
 };
 
+export type OpenworkWorkflowStep = {
+  name: string;
+  prompt: string;
+  agent?: string;
+  model?: string;
+};
+
+export type OpenworkWorkflowItem = {
+  slug: string;
+  name: string;
+  description?: string;
+  inputs: string[];
+  steps: OpenworkWorkflowStep[];
+  outputDir: string;
+  createdAt: number;
+  updatedAt: number;
+};
+
+export type OpenworkWorkflowRunStatus = "pending" | "running" | "completed" | "failed";
+
+export type OpenworkWorkflowRun = {
+  id: string;
+  workflowSlug: string;
+  workflowName: string;
+  status: OpenworkWorkflowRunStatus;
+  sessionId?: string;
+  outputDir: string;
+  createdAt: number;
+  updatedAt: number;
+};
+
+export type OpenworkWorkflowUpsertPayload = {
+  name: string;
+  slug?: string;
+  description?: string;
+  inputs?: string[];
+  steps: Array<{ name?: string; prompt: string; agent?: string; model?: string }>;
+  /** Co-editing guard: server rejects with 409 when the workflow changed since this timestamp. */
+  baseUpdatedAt?: number | null;
+};
+
 export type OpenworkUserEnvItem = {
   key: string;
   updatedAt: number;
@@ -1430,6 +1472,60 @@ export function createOpenworkServerClient(options: { baseUrl: string; token?: s
         hostToken,
         method: "DELETE",
       }),
+
+    listWorkflows: (workspaceId: string) =>
+      requestJson<{ items: OpenworkWorkflowItem[] }>(
+        baseUrl,
+        `/workspace/${encodeURIComponent(workspaceId)}/workflows`,
+        { token, hostToken },
+      ),
+    getWorkflow: (workspaceId: string, slug: string) =>
+      requestJson<{ item: OpenworkWorkflowItem }>(
+        baseUrl,
+        `/workspace/${encodeURIComponent(workspaceId)}/workflows/${encodeURIComponent(slug)}`,
+        { token, hostToken },
+      ),
+    upsertWorkflow: (workspaceId: string, payload: OpenworkWorkflowUpsertPayload) =>
+      requestJson<{ item: OpenworkWorkflowItem; items: OpenworkWorkflowItem[] }>(
+        baseUrl,
+        `/workspace/${encodeURIComponent(workspaceId)}/workflows`,
+        { token, hostToken, method: "POST", body: payload },
+      ),
+    deleteWorkflow: (workspaceId: string, slug: string) =>
+      requestJson<{ ok: boolean }>(
+        baseUrl,
+        `/workspace/${encodeURIComponent(workspaceId)}/workflows/${encodeURIComponent(slug)}`,
+        { token, hostToken, method: "DELETE" },
+      ),
+    listAllWorkflowRuns: (workspaceId: string) =>
+      requestJson<{ items: OpenworkWorkflowRun[] }>(
+        baseUrl,
+        `/workspace/${encodeURIComponent(workspaceId)}/workflow-runs`,
+        { token, hostToken },
+      ),
+    listWorkflowRuns: (workspaceId: string, slug: string) =>
+      requestJson<{ items: OpenworkWorkflowRun[] }>(
+        baseUrl,
+        `/workspace/${encodeURIComponent(workspaceId)}/workflows/${encodeURIComponent(slug)}/runs`,
+        { token, hostToken },
+      ),
+    createWorkflowRun: (workspaceId: string, slug: string) =>
+      requestJson<{ run: OpenworkWorkflowRun; prompt: string }>(
+        baseUrl,
+        `/workspace/${encodeURIComponent(workspaceId)}/workflows/${encodeURIComponent(slug)}/runs`,
+        { token, hostToken, method: "POST", body: {} },
+      ),
+    updateWorkflowRun: (
+      workspaceId: string,
+      slug: string,
+      runId: string,
+      payload: { status?: OpenworkWorkflowRunStatus; sessionId?: string },
+    ) =>
+      requestJson<{ run: OpenworkWorkflowRun }>(
+        baseUrl,
+        `/workspace/${encodeURIComponent(workspaceId)}/workflows/${encodeURIComponent(slug)}/runs/${encodeURIComponent(runId)}`,
+        { token, hostToken, method: "PATCH", body: payload },
+      ),
     uploadInbox: async (workspaceId: string, file: File, options?: { path?: string }) => {
       const id = workspaceId.trim();
       if (!id) throw new Error("workspaceId is required");

apps/app/src/app/types.ts

@@ -187,6 +187,7 @@ export const SETTINGS_TAB_VALUES = [
   "cloud-workers",
   "cloud-providers",
   "skills",
+  "workflows",
   "extensions",
   "environment",
   "advanced",

apps/app/src/react-app/domains/settings/shell/settings-page.tsx

@@ -18,6 +18,7 @@ import {
   Store,
   Terminal,
   UserCircle,
+  Workflow,
   Wrench,
   Zap,
 } from "lucide-react";
@@ -75,6 +76,8 @@ export function getSettingsTabIcon(tab: SettingsTab) {
       return CloudCog;
     case "skills":
       return Sparkles;
+    case "workflows":
+      return Workflow;
     case "extensions":
       return Puzzle;
     case "environment":
@@ -114,6 +117,8 @@ export function getSettingsTabLabel(tab: SettingsTab) {
       return t("settings.tab_cloud_providers");
     case "skills":
       return t("settings.tab_skills");
+    case "workflows":
+      return "Workflows";
     case "extensions":
       return t("settings.tab_extensions");
     case "environment":
@@ -155,6 +160,8 @@ export function getSettingsTabDescription(tab: SettingsTab) {
       return t("settings.tab_description_cloud_providers");
     case "skills":
       return t("settings.tab_description_skills");
+    case "workflows":
+      return "Repeatable multi-step agent runs with saved prompts and outputs";
     case "extensions":
       return t("settings.tab_description_extensions");
     case "environment":
@@ -177,7 +184,7 @@ export function getSettingsTabDescription(tab: SettingsTab) {
 }
 
 export function getWorkspaceSettingsTabs(): SettingsTab[] {
-  return ["preferences", "permissions", "extensions", "advanced"];
+  return ["preferences", "permissions", "workflows", "extensions", "advanced"];
 }
 
 export function getGlobalSettingsTabs(developerMode: boolean): SettingsTab[] {