Add common hono proxy and bump minor minor version.

2 files changed, 72 insertions, 0 deletions

diff --git a/lib/server/hono/index.ts b/lib/server/hono/index.ts
new file mode 100644
index 0000000..9bcd868
--- /dev/null
+++ b/lib/server/hono/index.ts
@@ -0,0 +1 @@
+export * from './proxy';
diff --git a/lib/server/hono/proxy.ts b/lib/server/hono/proxy.ts
new file mode 100644
index 0000000..f729819
--- /dev/null
+++ b/lib/server/hono/proxy.ts
@@ -0,0 +1,71 @@
+import {
+    BaseRequest,
+    Either,
+    IEither,
+    LogMetricTraceable,
+    Metric,
+    PenguenoRequest,
+    Server,
+    Signals,
+    TraceUtil,
+} from '@emprespresso/pengueno';
+
+import { serve, ServerType } from '@hono/node-server';
+import { Hono } from 'hono';
+
+const AppLifetimeMetric = Metric.fromName('HonoAppLifetime').asResult();
+const AppRequestMetric = Metric.fromName('HonoAppRequest');
+
+export class HonoProxy {
+    private readonly app = LogMetricTraceable.of(new Hono())
+        .flatMap(TraceUtil.withTrace(`AppId = ${crypto.randomUUID()}`))
+        .flatMap(TraceUtil.withMetricTrace(AppLifetimeMetric));
+
+    constructor(private readonly server: Server) {}
+
+    public async serve(port: number, hostname: string): Promise<IEither<Error, void>> {
+        return this.app
+            .map((tApp) =>
+                Either.fromFailable<Error, ServerType>(() => {
+                    const app = tApp.get();
+                    app.all('*', async (c) =>
+                        tApp
+                            .flatMap(TraceUtil.withMetricTrace(AppRequestMetric))
+                            .move(<BaseRequest>c.req)
+                            .flatMap((tRequest) => PenguenoRequest.from(tRequest))
+                            .map((req) => this.server.serve(req))
+                            .map(
+                                TraceUtil.promiseify((tResponse) => {
+                                    tResponse.trace.trace(AppRequestMetric.count.withValue(1.0));
+                                    return new Response(tResponse.get().body(), tResponse.get());
+                                }),
+                            )
+                            .get(),
+                    );
+                    return serve({
+                        fetch: (_r) => app.fetch(_r),
+                        port,
+                        hostname,
+                    });
+                }),
+            )
+            .peek(TraceUtil.traceResultingEither())
+            .peek((tServe) =>
+                tServe
+                    .get()
+                    .mapRight(() =>
+                        tServe.trace.trace(
+                            `haii im still listening at http://${hostname}:${port} ~uwu dont think i forgot`,
+                        ),
+                    ),
+            )
+            .map((tEitherServer) =>
+                tEitherServer
+                    .get()
+                    .mapRight((server) => tEitherServer.move(server))
+                    .flatMapAsync((tServer) => Signals.awaitClose(tServer)),
+            )
+            .peek(TraceUtil.promiseify(TraceUtil.traceResultingEither(AppLifetimeMetric)))
+            .get();
+    }
+}