Add actor error handling

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

src/actors/proxy.ts

@@ -6,15 +6,19 @@ export interface ActorsServer {
   deploymentId?: string;
 }
 
+export interface ActorsOptions {
+  server?: ActorsServer;
+  errorHandling?: Record<string, new (...args: unknown[]) => Error>;
+}
 /**
  * utilities to create and manage actors.
  */
 export const actors = {
   proxy: <TInstance extends Actor>(
     actor: ActorConstructor<TInstance> | string,
-    server?: ActorsServer | undefined,
+    options?: ActorsOptions | undefined,
   ): { id: (id: string) => Promisify<TInstance> } => {
-    const factory = (id: string) => createHttpInvoker(id, server);
+    const factory = (id: string) => createHttpInvoker(id, options);
     return create(actor, factory);
   },
 };

src/actors/proxyutil.ts

@@ -1,4 +1,4 @@
-import type { ActorsServer } from "./proxy.ts";
+import type { ActorsOptions, ActorsServer } from "./proxy.ts";
 import type { Actor, ActorConstructor } from "./runtime.ts";
 import { EVENT_STREAM_RESPONSE_HEADER, readFromStream } from "./stream.ts";
 import {
@@ -9,6 +9,7 @@ import {
 
 export const ACTOR_ID_HEADER_NAME = "x-deno-isolate-instance-id";
 export const ACTOR_ID_QS_NAME = "deno_isolate_instance_id";
+export const ACTOR_CONSTRUCTOR_NAME_HEADER = "x-error-constructor-name";
 /**
  * Promise.prototype.then onfufilled callback type.
  */
@@ -177,8 +178,9 @@ export const createHttpInvoker = <
   TChannel extends DuplexChannel<unknown, unknown>,
 >(
   actorId: string,
-  server?: ActorsServer,
+  options?: ActorsOptions,
 ): ActorInvoker<TResponse, TChannel> => {
+  const server = options?.server;
   if (!server) {
     _server ??= initServer();
   }
@@ -214,6 +216,24 @@ export const createHttpInvoker = <
           }),
         },
       );
+      if (!resp.ok) {
+        const constructorName = resp.headers.get(ACTOR_CONSTRUCTOR_NAME_HEADER);
+        const ErrorConstructor =
+          options?.errorHandling?.[constructorName ?? "Error"] ?? Error;
+        const errorParameters =
+          resp.headers.get("content-type")?.includes("application/json")
+            ? await resp.json()
+            : {
+              message: await resp.text().catch(() =>
+                `HTTP Error: ${resp.statusText}`
+              ),
+            };
+        const deserializedError = Object.assign(
+          new ErrorConstructor(),
+          errorParameters,
+        );
+        throw deserializedError;
+      }
       if (
         resp.headers.get("content-type") ===
           EVENT_STREAM_RESPONSE_HEADER

src/actors/runtime.ts

@@ -1,6 +1,7 @@
 import { type ServerSentEventMessage, ServerSentEventStream } from "@std/http";
 import { ActorError } from "./errors.ts";
 import {
+  ACTOR_CONSTRUCTOR_NAME_HEADER,
   ACTOR_ID_HEADER_NAME,
   ACTOR_ID_QS_NAME,
   type ActorInvoker,
@@ -278,6 +279,20 @@ export class ActorRuntime {
           }[err.code] ?? 500,
         });
       }
+      const constructorName = err?.constructor?.name;
+      if (constructorName) {
+        const serializedError = JSON.stringify(
+          err,
+          Object.getOwnPropertyNames(err),
+        );
+        return new Response(serializedError, {
+          status: 500,
+          headers: {
+            [ACTOR_CONSTRUCTOR_NAME_HEADER]: constructorName,
+            "content-type": "application/json",
+          },
+        });
+      }
       throw err;
     }
   }