Accept ws requests

Signed-off-by: Marcos Candeia <[email protected]>

examples/cf/counter-actor/package.json

@@ -15,7 +15,7 @@
     "wrangler": "^3.91.0"
   },
   "dependencies": {
-    "@deco/actors": "npm:@jsr/deco__actors@^0.14.0-beta.8",
+    "@deco/actors": "npm:@jsr/deco__actors@^0.14.0-beta.9",
     "hono": "^4.6.12"
   }
 }

examples/cf/counter-actor/src/counter.ts

@@ -35,9 +35,13 @@ export class Counter {
     return this.watchTarget.subscribe();
   }
   chan(name: string): ChannelUpgrader<string, string> {
+    console.log("HERE");
     return (async ({ send, recv }) => {
+      console.log("HERE1");
       await send(`Hello ${name}`);
+      console.log("Sent Hello");
       for await (const str of recv()) {
+        console.log({ str });
         if (str === "PING") {
           await send("PONG");
         }

examples/cf/counter-actor/src/index.ts

@@ -6,11 +6,7 @@ export { ActorDurableObject } from "@deco/actors/cf";
 const app = new Hono<{ Bindings: Env }>();
 
 const runtime = new ActorCfRuntime([Counter]);
-const mid = withActors(runtime)
-app.use(async (ctx, next) => {
-  await mid(ctx, next);
-  console.log(await ctx.res.text())
-});
+app.use(withActors(runtime));
 
 app.get("/", (c) => c.text("Hello Cloudflare Workers!"));
 

src/actors/runtimes/cf/fetcher.ts

@@ -13,6 +13,7 @@ export class ActorCfRuntime implements ActorFetcher<Env> {
     registerActors(actorsConstructors, () => {
       const webSocketPair = new WebSocketPair();
       const [client, server] = Object.values(webSocketPair);
+      server.accept();
       return {
         socket: server,
         response: new Response(null, {