Merge branch '22-handle-errors-thrown-by-a-routes-handle' into auth

Author: zefir-git

src/Server.ts

@@ -5,6 +5,7 @@ import {Authenticator} from "./auth/Authenticator.js";
 import {Request} from "./Request.js";
 import {EmptyResponse} from "./response/index.js";
 import {Response} from "./response/Response.js";
+import {ThrowableResponse} from "./response/ThrowableResponse.js";
 import {RouteRegistry} from "./routing/RouteRegistry.js";
 import {ServerErrorRegistry} from "./ServerErrorRegistry.js";
 
@@ -89,9 +90,13 @@ class Server<A> extends EventEmitter<Server.Events> {
                 await this.errors._get(ServerErrorRegistry.ErrorCodes.BAD_URL, null)._send(res);
                 return;
             }
+
             if (e instanceof Request.SocketClosedError)
                 return;
-            throw e;
+
+            this.emit("error", e as any);
+            this.errors._get(ServerErrorRegistry.ErrorCodes.INTERNAL, null)._send(res, this);
+            return;
         }
 
         for (const [key, value] of this.globalHeaders)
@@ -107,7 +112,13 @@ class Server<A> extends EventEmitter<Server.Events> {
             response = await this.routes.handle(apiRequest);
         }
         catch (e) {
-            if (e instanceof RouteRegistry.NoRouteError)
+            if (e instanceof ThrowableResponse) {
+                response = e.getResponse();
+                const cause = e.getError();
+                if (cause !== null)
+                    this.emit("error", cause);
+            }
+            else if (e instanceof RouteRegistry.NoRouteError)
                 response = this.errors._get(ServerErrorRegistry.ErrorCodes.NO_ROUTE, apiRequest);
             else {
                 this.emit("error", e as any);

src/response/ThrowableResponse.ts

@@ -0,0 +1,37 @@
+import {Response} from "./Response.js";
+
+/**
+ * An (error) response that is thrown. Will be caught by the server and sent to the client.
+ */
+export class ThrowableResponse<T extends Response> extends Error {
+    public override name = ThrowableResponse.name;
+
+    /**
+     * The response to send to the client.
+     */
+    protected readonly response: T;
+
+    /**
+     * An optional error to emit on the server’s error event.
+     */
+    protected readonly error: Error | null;
+
+    /**
+     * Create a new throwable response.
+     * @param response The response to send to the client.
+     * @param [error] An optional error to emit on the server’s error event.
+     */
+    public constructor(response: T, error?: Error) {
+        super();
+        this.response = response;
+        this.error = error ?? null;
+    }
+
+    public getResponse(): T {
+        return this.response;
+    }
+
+    public getError(): Error | null {
+        return this.error;
+    }
+}

src/response/index.ts

@@ -4,3 +4,4 @@ export * from "./EmptyResponse.js";
 export * from "./JsonResponse.js";
 export * from "./Response.js";
 export * from "./TextResponse.js";
+export * from "./ThrowableResponse.js";