123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778
import {  Method,  Request as AquaRequest,  ResponseObject as AquaResponseObject,} from "./aqua.ts";import { parseBody, parseCookies, parseQuery } from "./helpers/parsing.ts";
export type Json =  | null  | string  | number  | boolean  | Json[]  | { [name: string]: Json };
export const textDecoder = new TextDecoder();export const textEncoder = new TextEncoder();
export function getFinalizedStatusCode(  res: AquaResponseObject,  fallbackStatusCode: number,): number {  return res.redirect    ? res.statusCode ?? 301    : res.statusCode ?? fallbackStatusCode;}
export function getFinalizedHeaders(res: AquaResponseObject): Headers {  const headers = new Headers(res.headers || {});
  if (res.cookies) {    for (const cookieName of Object.keys(res.cookies)) {      headers.append("Set-Cookie", `${cookieName}=${res.cookies[cookieName]}`);    }  }
  if (res.redirect) {    headers.append("Location", res.redirect);  }
  return headers;}
export async function getAquaRequestFromNativeRequest(  event: Deno.RequestEvent,  conn?: Deno.Conn,): Promise<AquaRequest> {  const { request: req } = event;  const url = new URL(req.url).pathname;  const { body, files } = parseBody(    new Uint8Array(await req.arrayBuffer()),  ) ?? { body: {}, files: {} };
  return {    _internal: {      respond(res) {        event.respondWith(          new Response(res.content, {            status: getFinalizedStatusCode(res, 200),            headers: getFinalizedHeaders(res),          }),        ).catch((_e) => {});      },    },    raw: req,    url,    body,    files,    method: req.method.toUpperCase() as Method,    headers: Object.fromEntries(req.headers),    query: req.url.includes("?") ? parseQuery(req.url) : {},    cookies: parseCookies(req.headers),    parameters: {},    matches: [],    conn,  };}