fix(stormkit): properly send buffer responses

src/runtime/entries/stormkit.ts

@@ -3,53 +3,56 @@ import "#internal/nitro/virtual/polyfill";
 import { nitroApp } from "../app";
 import { normalizeLambdaOutgoingBody } from "#internal/nitro/utils.lambda";
 
-interface StormkitEvent {
+type StormkitEvent = {
   url: string; // e.g. /my/path, /my/path?with=query
   path: string;
   method: string;
   body?: string;
   query?: Record<string, Array<string>>;
   headers?: Record<string, string>;
   rawHeaders?: Array<string>;
-}
+};
 
-export interface StormkitResult {
+type StormkitResponse = {
+  headers?: Record<string, string>;
+  body?: string;
+  buffer?: string;
   statusCode: number;
-  headers?: { [header: string]: boolean | number | string } | undefined;
-  body?: string | undefined;
-}
+  errorMessage?: string;
+  errorStack?: string;
+};
 
-export const handler: Handler<StormkitEvent, StormkitResult> = async function (
-  event,
-  context
-) {
-  const method = event.method || "get";
+export const handler: Handler<StormkitEvent, StormkitResponse> =
+  async function (event, context) {
+    const response = await nitroApp.localCall({
+      event,
+      url: event.url,
+      context,
+      headers: event.headers,
+      method: event.method || "GET",
+      query: event.query,
+      body: event.body,
+    });
 
-  const r = await nitroApp.localCall({
-    event,
-    url: event.url,
-    context,
-    headers: event.headers, // TODO: Normalize headers
-    method,
-    query: event.query,
-    body: event.body,
-  });
+    const normalizedBody = normalizeLambdaOutgoingBody(
+      response.body,
+      response.headers
+    );
 
-  // TODO: Handle cookies with lambda v1 or v2 ?
-  return {
-    statusCode: r.status,
-    headers: normalizeOutgoingHeaders(r.headers),
-    body: normalizeLambdaOutgoingBody(r.body, r.headers),
+    return <StormkitResponse>{
+      statusCode: response.status,
+      headers: normalizeOutgoingHeaders(response.headers),
+      [normalizedBody === response.body ? "body" : "buffer"]: normalizedBody,
+    };
   };
-};
 
 function normalizeOutgoingHeaders(
   headers: Record<string, number | string | string[] | undefined>
-) {
+): Record<string, string> {
   return Object.fromEntries(
     Object.entries(headers).map(([k, v]) => [
       k,
-      Array.isArray(v) ? v.join(",") : v!,
+      Array.isArray(v) ? v.join(",") : String(v),
     ])
   );
 }