From d4791f3d357634daf506fb8f91cc5332a794c421 Mon Sep 17 00:00:00 2001
From: Elizabeth Hunt <me@liz.coffee>
Date: Fri, 20 Jun 2025 14:53:38 -0700
Subject: Move to nodejs

---
 u/server/response.ts | 139 +++++++++++++++++++++++++--------------------------
 1 file changed, 68 insertions(+), 71 deletions(-)

(limited to 'u/server/response.ts')

diff --git a/u/server/response.ts b/u/server/response.ts
index 629dbb5..18d70b5 100644
--- a/u/server/response.ts
+++ b/u/server/response.ts
@@ -1,86 +1,83 @@
 import {
-  type IEither,
-  isEither,
-  type ITraceable,
-  Metric,
-  type PenguenoRequest,
-  type ServerTrace,
-} from "@emprespresso/pengueno";
+    type IEither,
+    isEither,
+    type ITraceable,
+    Metric,
+    type PenguenoRequest,
+    type ServerTrace,
+} from '@emprespresso/pengueno';
 
+export type BodyInit =
+    | ArrayBuffer
+    | AsyncIterable<Uint8Array>
+    | Blob
+    | FormData
+    | Iterable<Uint8Array>
+    | NodeJS.ArrayBufferView
+    | URLSearchParams
+    | null
+    | string;
 export type ResponseBody = object | string;
-export type TResponseInit = ResponseInit & {
-  status: number;
-  headers?: Record<string, string>;
+export type TResponseInit = Omit<ResponseInit, 'headers'> & {
+    status: number;
+    headers?: Record<string, string>;
 };
 
-const getResponse = (
-  req: PenguenoRequest,
-  opts: TResponseInit,
-): TResponseInit => {
-  return {
-    ...opts,
-    headers: {
-      ...req.baseResponseHeaders(),
-      ...opts?.headers,
-      "Content-Type":
-        (opts?.headers?.["Content-Type"] ?? "text/plain") + "; charset=utf-8",
-    },
-  };
+const getResponse = (req: PenguenoRequest, opts: TResponseInit): ResponseInit => {
+    const baseHeaders = req.baseResponseHeaders();
+    const optHeaders = opts.headers || {};
+
+    return {
+        ...opts,
+        headers: {
+            ...baseHeaders,
+            ...optHeaders,
+            'Content-Type': (optHeaders['Content-Type'] ?? 'text/plain') + '; charset=utf-8',
+        } as Record<string, string>,
+    };
 };
 
-const ResponseCodeMetrics = [0, 1, 2, 3, 4, 5].map((x) =>
-  Metric.fromName(`response.${x}xx`),
-);
-export const getResponseMetric = (status: number) => {
-  const index = Math.floor(status / 100);
-  return ResponseCodeMetrics[index] ?? ResponseCodeMetrics[5];
+const ResponseCodeMetrics = [0, 1, 2, 3, 4, 5].map((x) => Metric.fromName(`response.${x}xx`));
+export const getResponseMetrics = (status: number) => {
+    const index = Math.floor(status / 100);
+    return ResponseCodeMetrics.map((metric, i) => metric.count.withValue(i === index ? 1.0 : 0.0));
 };
 
 export class PenguenoResponse extends Response {
-  constructor(
-    req: ITraceable<PenguenoRequest, ServerTrace>,
-    msg: BodyInit,
-    opts: TResponseInit,
-  ) {
-    const responseOpts = getResponse(req.get(), opts);
-    const resMetric = getResponseMetric(opts.status);
-    req.trace.trace(resMetric.count.withValue(1.0));
-    responseOpts.headers;
-    super(msg, responseOpts);
-  }
+    constructor(req: ITraceable<PenguenoRequest, ServerTrace>, msg: BodyInit, opts: TResponseInit) {
+        const responseOpts = getResponse(req.get(), opts);
+        for (const metric of getResponseMetrics(opts.status)) {
+            req.trace.trace(metric);
+        }
+        super(msg, responseOpts);
+    }
 }
 
 export class JsonResponse extends PenguenoResponse {
-  constructor(
-    req: ITraceable<PenguenoRequest, ServerTrace>,
-    e: BodyInit | IEither<ResponseBody, ResponseBody>,
-    opts: TResponseInit,
-  ) {
-    const optsWithJsonContentType = {
-      ...opts,
-      headers: {
-        ...opts?.headers,
-        "Content-Type": "application/json",
-      },
-    };
-    if (isEither<ResponseBody, ResponseBody>(e)) {
-      super(
-        req,
-        JSON.stringify(
-          e.fold(({ isLeft, value }) =>
-            isLeft ? { error: value } : { ok: value },
-          ),
-        ),
-        optsWithJsonContentType,
-      );
-      return;
+    constructor(
+        req: ITraceable<PenguenoRequest, ServerTrace>,
+        e: BodyInit | IEither<ResponseBody, ResponseBody>,
+        opts: TResponseInit,
+    ) {
+        const optsWithJsonContentType: TResponseInit = {
+            ...opts,
+            headers: {
+                ...opts.headers,
+                'Content-Type': 'application/json',
+            },
+        };
+        if (isEither<ResponseBody, ResponseBody>(e)) {
+            super(
+                req,
+                JSON.stringify(e.fold(({ isLeft, value }) => (isLeft ? { error: value } : { ok: value }))),
+                optsWithJsonContentType,
+            );
+            return;
+        }
+        super(
+            req,
+            JSON.stringify(Math.floor(opts.status / 100) > 4 ? { error: e } : { ok: e }),
+            optsWithJsonContentType,
+        );
     }
-    super(
-      req,
-      JSON.stringify(
-        Math.floor(opts.status / 100) > 4 ? { error: e } : { ok: e },
-      ),
-      optsWithJsonContentType,
-    );
-  }
 }
-- 
cgit v1.2.3-70-g09d2