From 3bb7b67a4e8bfa4ac820b198040d746b21d8d93d Mon Sep 17 00:00:00 2001
From: root <root@v2202607378382480008.hotsrv.de>
Date: Sat, 18 Jul 2026 03:49:47 +0200
Subject: [PATCH] fix: support L1 Workbench AgentRun activity dispatch

---
 internal/cloud/workbench-command-proxy.test.ts | 9 +++++++++
 internal/cloud/workbench-command-proxy.ts      | 6 +++++-
 2 files changed, 14 insertions(+), 1 deletion(-)
 create mode 100644 internal/cloud/workbench-command-proxy.test.ts

diff --git a/internal/cloud/workbench-command-proxy.test.ts b/internal/cloud/workbench-command-proxy.test.ts
new file mode 100644
index 00000000..298c66e3
--- /dev/null
+++ b/internal/cloud/workbench-command-proxy.test.ts
@@ -0,0 +1,9 @@
+import { expect, test } from "bun:test";
+
+import { workbenchActivityDispatchRequested } from "./workbench-command-proxy.ts";
+
+test("accepts activity dispatch header from Node and Fetch request shapes", () => {
+  expect(workbenchActivityDispatchRequested({ headers: { "x-workbench-activity-dispatch": "1" } })).toBe(true);
+  expect(workbenchActivityDispatchRequested({ headers: new Headers({ "x-workbench-activity-dispatch": "1" }) })).toBe(true);
+  expect(workbenchActivityDispatchRequested({ headers: new Headers({ "x-workbench-activity-dispatch": "0" }) })).toBe(false);
+});
diff --git a/internal/cloud/workbench-command-proxy.ts b/internal/cloud/workbench-command-proxy.ts
index 89931233..f24e1292 100644
--- a/internal/cloud/workbench-command-proxy.ts
+++ b/internal/cloud/workbench-command-proxy.ts
@@ -5,7 +5,11 @@ export function workbenchTemporalProxyEnabled(env: Record<string, string | undef
 }
 
 export function workbenchActivityDispatchRequested(request: any) {
-  return String(request.headers?.["x-workbench-activity-dispatch"] ?? "").trim() === "1";
+  const headers = request?.headers;
+  const value = typeof headers?.get === "function"
+    ? headers.get("x-workbench-activity-dispatch")
+    : headers?.["x-workbench-activity-dispatch"];
+  return String(value ?? "").trim() === "1";
 }
 
 export async function proxyWorkbenchCommandHttp(request: any, response: any, options: any, route: string) {