feat: add actor proxy support for HTTP fallback (#951)

Author: NathanFlurry

.github/workflows/test.yml

@@ -25,34 +25,34 @@ jobs:
     steps:
       - uses: actions/checkout@v4
 
-      # Setup Node.js
-      - name: Set up Node.js
-        uses: actions/setup-node@v4
-        with:
-          node-version: '22.14'
-          # Note: We're not using the built-in cache here because we need to use corepack
-      
-      - name: Setup Corepack
-        run: corepack enable
-      
-      - id: yarn-cache-dir-path
-        name: Get yarn cache directory path
-        run: echo "dir=$(yarn config get cacheFolder)" >> $GITHUB_OUTPUT
-      
-      - name: Cache dependencies
-        uses: actions/cache@v3
-        id: cache
-        with:
-          path: |
-            ${{ steps.yarn-cache-dir-path.outputs.dir }}
-            .turbo
-          key: ${{ runner.os }}-deps-${{ hashFiles('**/yarn.lock') }}-${{ github.sha }}
-          restore-keys: |
-            ${{ runner.os }}-deps-${{ hashFiles('**/yarn.lock') }}-
-            ${{ runner.os }}-deps-
-      
-      - name: Install dependencies
-        run: yarn install
+      # # Setup Node.js
+      # - name: Set up Node.js
+      #   uses: actions/setup-node@v4
+      #   with:
+      #     node-version: '22.14'
+      #     # Note: We're not using the built-in cache here because we need to use corepack
+      #
+      # - name: Setup Corepack
+      #   run: corepack enable
+      #
+      # - id: yarn-cache-dir-path
+      #   name: Get yarn cache directory path
+      #   run: echo "dir=$(yarn config get cacheFolder)" >> $GITHUB_OUTPUT
+      #
+      # - name: Cache dependencies
+      #   uses: actions/cache@v3
+      #   id: cache
+      #   with:
+      #     path: |
+      #       ${{ steps.yarn-cache-dir-path.outputs.dir }}
+      #       .turbo
+      #     key: ${{ runner.os }}-deps-${{ hashFiles('**/yarn.lock') }}-${{ github.sha }}
+      #     restore-keys: |
+      #       ${{ runner.os }}-deps-${{ hashFiles('**/yarn.lock') }}-
+      #       ${{ runner.os }}-deps-
+      #
+      # - name: Install dependencies
+      #   run: yarn install
 
       # - name: Run actor-core tests
       #   # TODO: Add back

CLAUDE.md

@@ -85,6 +85,9 @@ This ensures imports resolve correctly across different build environments and p
   - Extend from `ActorError` base class
   - Use `UserError` for client-safe errors
   - Use `InternalError` for internal errors
+- Don't try to fix type issues by casting to unknown or any. If you need to do this, then stop and ask me to manually intervene.
+- Write log messages in lowercase
+- Instead of returning raw HTTP responses with c.json, use or write an error in packages/actor-core/src/actor/errors.ts and throw that instead. The middleware will automatically serialize the response for you.
 
 ## Project Structure
 

examples/chat-room/scripts/cli.ts

@@ -10,7 +10,7 @@ async function main() {
 
 	// connect to chat room - now accessed via property
 	// can still pass parameters like room
-	const chatRoom = await client.chatRoom.connect(room, {
+	const chatRoom = client.chatRoom.connect(room, {
 		params: { room },
 	});
 

examples/chat-room/scripts/connect.ts

@@ -7,7 +7,7 @@ async function main() {
 	const client = createClient<App>(process.env.ENDPOINT ?? "http://localhost:6420");
 
 	// connect to chat room - now accessed via property
-	const chatRoom = await client.chatRoom.connect();
+	const chatRoom = client.chatRoom.connect();
 
 	// call action to get existing messages
 	const messages = await chatRoom.getHistory();

examples/chat-room/tests/chat-room.test.ts

@@ -6,7 +6,7 @@ test("chat room should handle messages", async (test) => {
 	const { client } = await setupTest(test, app);
 
 	// Connect to chat room
-	const chatRoom = await client.chatRoom.connect();
+	const chatRoom = client.chatRoom.connect();
 
 	// Initial history should be empty
 	const initialMessages = await chatRoom.getHistory();

examples/counter/scripts/connect.ts

@@ -5,7 +5,7 @@ import type { App } from "../actors/app";
 async function main() {
 	const client = createClient<App>(process.env.ENDPOINT ?? "http://localhost:6420");
 
-	const counter = await client.counter.connect()
+	const counter = client.counter.connect()
 
 	counter.on("newCount", (count: number) => console.log("Event:", count));
 

examples/counter/tests/counter.test.ts

@@ -4,7 +4,7 @@ import { app } from "../actors/app";
 
 test("it should count", async (test) => {
 	const { client } = await setupTest(test, app);
-	const counter = await client.counter.connect();
+	const counter = client.counter.connect();
 
 	// Test initial count
 	expect(await counter.getCount()).toBe(0);

examples/linear-coding-agent/src/server/index.ts

@@ -75,7 +75,7 @@ server.post('/api/webhook/linear', async (c) => {
     // Create or get a coding agent instance with the issue ID as a key
     // This ensures each issue gets its own actor instance
     console.log(`[SERVER] Getting actor for issue: ${issueId}`);
-    const actorClient = await client.codingAgent.connect(issueId);
+    const actorClient = client.codingAgent.connect(issueId);
 
     // Initialize the agent if needed
     console.log(`[SERVER] Initializing actor for issue: ${issueId}`);

examples/resend-streaks/tests/user.test.ts

@@ -26,7 +26,7 @@ beforeEach(() => {
 
 test("streak tracking with time zone signups", async (t) => {
 	const { client } = await setupTest(t, app);
-	const actor = await client.user.connect();
+	const actor = client.user.connect();
 
 	// Sign up with specific time zone
 	const signupResult = await actor.completeSignUp(

packages/actor-core-cli/package.json

@@ -38,6 +38,7 @@
     "bundle-require": "^5.1.0",
     "chokidar": "^4.0.3",
     "esbuild": "^0.25.1",
+    "invariant": "^2.2.4",
     "open": "^10.1.0",
     "yoga-wasm-web": "0.3.3"
   },
@@ -46,6 +47,7 @@
     "@rivet-gg/api": "^24.6.2",
     "@sentry/esbuild-plugin": "^3.2.0",
     "@sentry/node": "^9.3.0",
+    "@types/invariant": "^2",
     "@types/micromatch": "^4",
     "@types/react": "^18.3",
     "@types/semver": "^7.5.8",