import type { Hono } from "hono"
import { createBunWebSocket } from "hono/bun"
import type { Adapter, FetchApp, Opts } from "./adapter"

function listen(app: FetchApp, opts: Opts, websocket?: ReturnType<typeof createBunWebSocket>["websocket"]) {
  const start = (port: number) => {
    try {
      if (websocket) {
        return Bun.serve({ fetch: app.fetch, hostname: opts.hostname, idleTimeout: 0, websocket, port })
      }
      return Bun.serve({ fetch: app.fetch, hostname: opts.hostname, idleTimeout: 0, port })
    } catch {
      return
    }
  }
  const server = opts.port === 0 ? (start(4096) ?? start(0)) : start(opts.port)
  if (!server) {
    throw new Error(`Failed to start server on port ${opts.port}`)
  }
  if (!server.port) {
    throw new Error(`Failed to resolve server address for port ${opts.port}`)
  }
  return {
    port: server.port,
    stop(close?: boolean) {
      return Promise.resolve(server.stop(close))
    },
  }
}

export const adapter: Adapter = {
  create(app: Hono) {
    const ws = createBunWebSocket()
    return {
      upgradeWebSocket: ws.upgradeWebSocket,
      listen: (opts) => Promise.resolve(listen(app, opts, ws.websocket)),
    }
  },
  createFetch(app) {
    return {
      listen: (opts) => Promise.resolve(listen(app, opts)),
    }
  },
}