[vitest-pool-workers] fix: handle redirect responses in runInDurableObject

.changeset/fix-do-redirect-response.md

@@ -0,0 +1,5 @@
+---
+"@cloudflare/vitest-pool-workers": patch
+---
+
+fix: `runInDurableObject` now correctly returns redirect responses (3xx) from Durable Object callbacks instead of throwing "Expected callback for X" errors

fixtures/vitest-pool-workers-examples/durable-objects/src/index.ts

@@ -13,6 +13,10 @@ export class Counter implements DurableObject {
 	}
 
 	fetch(request: Request) {
+		const url = new URL(request.url);
+		if (url.pathname === "/redirect") {
+			return Response.redirect("https://example.com/redirected", 302);
+		}
 		this.increment();
 		return new Response(this.count.toString());
 	}

fixtures/vitest-pool-workers-examples/durable-objects/test/direct-access.test.ts

@@ -7,6 +7,22 @@ import {
 import { it } from "vitest";
 import { Counter } from "../src/";
 
+// Regression test for https://github.com/cloudflare/workers-sdk/issues/9907
+it("handles redirect responses returned from runInDurableObject callback", async ({
+	expect,
+}) => {
+	const id = env.COUNTER.idFromName("/redirect-test");
+	const stub = env.COUNTER.get(id);
+	const response = await runInDurableObject(stub, (instance: Counter) => {
+		const request = new Request("https://example.com/redirect");
+		return instance.fetch(request);
+	});
+	expect(response.status).toBe(302);
+	expect(response.headers.get("Location")).toBe(
+		"https://example.com/redirected"
+	);
+});
+
 it("increments count and allows direct access to instance/storage", async ({
 	expect,
 }) => {
@@ -32,6 +48,5 @@ it("increments count and allows direct access to instance/storage", async ({
 
 	// Check IDs can be listed
 	const ids = await listDurableObjectIds(env.COUNTER);
-	expect(ids.length).toBe(1);
-	expect(ids[0].equals(id)).toBe(true);
+	expect(ids.map((i) => i.toString())).toContain(id.toString());
 });

packages/vitest-pool-workers/src/worker/durable-objects.ts

@@ -101,6 +101,9 @@ async function runInStub<O extends DurableObject, R>(
 
 	const response = await stub.fetch("http://x", {
 		cf: { [CF_KEY_ACTION]: id },
+		// Prevent the runtime from following redirects returned by the callback,
+		// which would re-enter `maybeHandleRunRequest` with a consumed action ID.
+		redirect: "manual",
 	});
 
 	// `result` may be `undefined`