feat(ai): add execute_workflow and get_workflow_execution_status actions

Extends data_workflows_tool with two new actions alongside list_workflows:
- execute_workflow: POST /v2/sites/:site_id/workflows/:workflow_id/execute
- get_workflow_execution_status: GET /v2/sites/.../executions/:execution_id

Also refactors fetch calls into a shared apiRequest helper.

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

Author: bertenator

src/tools/workflows.ts

@@ -10,19 +10,18 @@ import {
 
 const WEBFLOW_API_BASE = "https://api.webflow.com";
 
-async function listWorkflows(arg: {
-  site_id: string;
-  token: string;
-}): Promise<unknown> {
-  const response = await fetch(
-    `${WEBFLOW_API_BASE}/v2/sites/${arg.site_id}/workflows`,
-    {
-      headers: {
-        Authorization: `Bearer ${arg.token}`,
-        ...requestOptions.headers,
-      },
-    }
-  );
+async function apiRequest(
+  method: string,
+  path: string,
+  token: string
+): Promise<unknown> {
+  const response = await fetch(`${WEBFLOW_API_BASE}${path}`, {
+    method,
+    headers: {
+      Authorization: `Bearer ${token}`,
+      ...requestOptions.headers,
+    },
+  });
 
   if (!response.ok) {
     const error = await response.json().catch(() => ({}));
@@ -45,11 +44,11 @@ export function registerWorkflowsTools(
     {
       title: "Data Workflows Tool",
       annotations: {
-        readOnlyHint: true,
+        readOnlyHint: false,
         openWorldHint: false,
       },
       description:
-        "Data tool - Workflows tool to perform actions like listing AI workflows configured for a site.",
+        "Data tool - Workflows tool to list AI workflows, execute a workflow, and poll execution status.",
       inputSchema: {
         actions: z.array(
           z
@@ -65,11 +64,50 @@ export function registerWorkflowsTools(
                 .describe(
                   "List all AI workflows configured for a site. Returns each workflow's ID, name, active status, and template slug."
                 ),
+              // POST https://api.webflow.com/v2/sites/:site_id/workflows/:workflow_id/execute
+              execute_workflow: z
+                .object({
+                  site_id: z
+                    .string()
+                    .describe("Unique identifier for the site."),
+                  workflow_id: z
+                    .string()
+                    .describe("Unique identifier for the workflow to execute."),
+                })
+                .optional()
+                .describe(
+                  "Execute an AI workflow. The workflow must be active. Returns an execution_id to poll with get_workflow_execution_status."
+                ),
+              // GET https://api.webflow.com/v2/sites/:site_id/workflows/executions/:execution_id
+              get_workflow_execution_status: z
+                .object({
+                  site_id: z
+                    .string()
+                    .describe("Unique identifier for the site."),
+                  execution_id: z
+                    .string()
+                    .describe(
+                      "Execution ID returned by execute_workflow. Poll until isFinished is true."
+                    ),
+                })
+                .optional()
+                .describe(
+                  "Get the status of a workflow execution. Returns status, start/stop times, and isFinished."
+                ),
             })
             .strict()
-            .refine((d) => [d.list_workflows].filter(Boolean).length >= 1, {
-              message: "Provide at least one of list_workflows.",
-            })
+            .refine(
+              (d) =>
+                [
+                  d.list_workflows,
+                  d.execute_workflow,
+                  d.get_workflow_execution_status,
+                ].filter(Boolean).length >= 1,
+              {
+                message:
+                  "Provide at least one of list_workflows, execute_workflow, get_workflow_execution_status.",
+              }
+            )
         ),
       },
     },
@@ -78,10 +116,27 @@ export function registerWorkflowsTools(
       try {
         for (const action of actions) {
           if (action.list_workflows) {
-            const content = await listWorkflows({
-              site_id: action.list_workflows.site_id,
-              token: getToken(),
-            });
+            const content = await apiRequest(
+              "GET",
+              `/v2/sites/${action.list_workflows.site_id}/workflows`,
+              getToken()
+            );
+            result.push(textContent(content));
+          }
+          if (action.execute_workflow) {
+            const content = await apiRequest(
+              "POST",
+              `/v2/sites/${action.execute_workflow.site_id}/workflows/${action.execute_workflow.workflow_id}/execute`,
+              getToken()
+            );
+            result.push(textContent(content));
+          }
+          if (action.get_workflow_execution_status) {
+            const content = await apiRequest(
+              "GET",
+              `/v2/sites/${action.get_workflow_execution_status.site_id}/workflows/executions/${action.get_workflow_execution_status.execution_id}`,
+              getToken()
+            );
             result.push(textContent(content));
           }
         }