// server.js
// you should `npm i hono --save`
// and esbuild this script
import getopts from "tjs:getopts";
import ffi from "tjs:ffi";
import { Hono } from "hono";

let l = null;

const app = new Hono();

app.get("/", (c) => c.text("Hello Hono on LLRT!"));

async function handleConnection(conn) {
  const buf = new Uint8Array(1024);
  const nread = await conn.read(buf);
  const requestString = ffi.bufferToString(buf);
  const requestLines = requestString.split("\r\n");
  const requestLine = requestLines[0].split(" ");
  const headers = {};

  for (let i = 1; i < requestLines.length; i++) {
    const line = requestLines[i];
    if (line) {
      const [key, ...valueParts] = line.split(": ");
      headers[key] = valueParts.join(": ");
    }
  }

  const method = requestLine[0];
  const path = requestLine[1];
  const protocol = requestLine[2];
  const url = `http://localhost:${l.localAddress.port}${path}`;
  const request = new Request(url, {
    method,
    path,
    protocol,
    headers,
  });

  const response = await app.fetch(request);
  const body = await response.text();

  let responseHeaders = "";

  for (const [key, value] of Object.entries(response.headers)) {
    responseHeaders += `${key}: ${value}\r\n`;
  }

  const httpResponse = `HTTP/1.1 ${response.status} ${response.statusText}\r\n${responseHeaders}\r\n${body}`;

  conn.setNoDelay(true);
  await conn.write(new TextEncoder().encode(httpResponse));
  conn.close();
}

const options = getopts(tjs.args.slice(2), {
  alias: {
    listen: "l",
    port: "p",
  },
  default: {
    listen: "127.0.0.1",
    port: 1234,
  },
});

l = await tjs.listen("tcp", options.listen, options.port);

console.log(`Listening on ${l.localAddress.ip}:${l.localAddress.port}`);

for await (let conn of l) {
  handleConnection(conn);
  conn = undefined;
}