feat(convenience): elysia webhook adapter (#752)

src/convenience/frameworks.ts

@@ -109,6 +109,15 @@ export type CloudflareModuleAdapter = (
     request: Request,
 ) => ReqResHandler<Response>;
 
+export type ElysiaAdapter = (ctx: {
+    body: Update;
+    headers: Record<string, string | undefined>;
+    set: {
+        headers: Record<string, string>;
+        status: number;
+    };
+}) => ReqResHandler<string>;
+
 export type ExpressAdapter = (req: {
     body: Update;
     header: (header: string) => string | undefined;
@@ -539,6 +548,33 @@ const worktop: WorktopAdapter = (req, res) => ({
     unauthorized: () => res.send(401, WRONG_TOKEN_ERROR),
 });
 
+const elysia: ElysiaAdapter = (ctx) => {
+    // @note upgrade target to use modern code?
+    // const { promise, resolve } = Promise.withResolvers<string>();
+
+    let resolve: (result: string) => void;
+    const handlerReturn = new Promise<string>((res) => resolve = res);
+
+    return {
+        // @note technically the type shouldn't be limited to Promise, because it's fine to await plain values as well
+        update: Promise.resolve(ctx.body as Update),
+        header: ctx.headers[SECRET_HEADER_LOWERCASE],
+        end() {
+            resolve("");
+        },
+        respond(json) {
+            // @note since json is passed as string here, we gotta define proper content-type
+            ctx.set.headers["content-type"] = "application/json";
+            resolve(json);
+        },
+        unauthorized() {
+            ctx.set.status = 401;
+            resolve("");
+        },
+        handlerReturn,
+    };
+};
+
 // Please open a pull request if you want to add another adapter
 export const adapters = {
     "aws-lambda": awsLambda,
@@ -547,6 +583,7 @@ export const adapters = {
     bun,
     cloudflare,
     "cloudflare-mod": cloudflareModule,
+    elysia,
     express,
     fastify,
     hono,

test/convenience/webhook.test.ts

@@ -6,6 +6,7 @@ import type {
 import type { NHttp } from "jsr:@nhttp/nhttp";
 import type { Application } from "jsr:@oak/oak";
 import type { createServer } from "node:http";
+import type { Elysia } from "npm:elysia";
 import type { Express } from "npm:@types/express";
 import type bodyParser from "npm:@types/koa-bodyparser";
 import type Koa from "npm:@types/koa";
@@ -51,6 +52,12 @@ describe("webhook", () => {
         const _res: Response = await handler(req);
     });
 
+    it("Elysia should be compatible with grammY adapter", () => {
+        const app = { post: () => {} } as unknown as Elysia;
+
+        app.post("/", webhookCallback(bot, "elysia"));
+    });
+
     it("Express should be compatible with grammY adapter", () => {
         const app = { post: () => {} } as unknown as Express;
         const handler = webhookCallback(bot, "express");