1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071
import * as http from 'https://deno.land/std@0.106.0/http/server.ts'import { EventEmitter } from 'https://deno.land/x/event@2.0.0/mod.ts'
import { getFreePort } from 'https://deno.land/x/free_port@v1.2.0/mod.ts'
type Events = {  error: [Error]  listening: []  request: [http.ServerRequest]  close: []}
export type ServerHandler = (req: http.ServerRequest) => void | Promise<void>
/** * Ported from `net.AddressInfo` */export type AddressInfo = {  family: string  address: string  port: number}
export class Server extends EventEmitter<Events> {  #server?: http.Server  handler?: ServerHandler
  constructor(handler?: ServerHandler) {    super()    this.handler = handler  }
  async listen(addr?: string | http.HTTPOptions) {    if (!addr) addr = { port: await getFreePort(3000) }
    try {      this.#server = http.serve(addr)    } catch (e) {      await this.emit('error', e)      throw e    }
    this.emit('listening')
    try {      for await (const req of this.#server!) {        await this.emit('request', req)        await this.handler?.(req)      }    } catch (e) {      await this.emit('error', e)      throw e    }
    return this.#server  }  address(): string | AddressInfo {    const unixAddr = this.#server?.listener.addr as Deno.UnixAddr    const netAddr = this.#server?.listener.addr as Deno.NetAddr
    if (unixAddr?.path) return unixAddr.path    else return { family: 'IPv4', address: netAddr.hostname, port: netAddr.port }  }  close() {    this.#server?.close()    this.emit('close')  }}
export const createServer = (handler?: ServerHandler) => new Server(handler)