Something went wrong. Try again.
Scratch space for learning atproto app development
Something went wrong. Try again.
1.7 kB · 59 lines
TypeScript
at main
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960import { Request, Response } from 'express'import { createHttpTerminator } from 'http-terminator'import { once } from 'node:events'import type { IncomingMessage, RequestListener, ServerResponse,} from 'node:http'import { createServer } from 'node:http'
export type NextFunction = (err?: unknown) => void
export type Middleware< Req extends IncomingMessage = IncomingMessage, Res extends ServerResponse = ServerResponse,> = (req: Req, res: Res, next: NextFunction) => void
export type Handler< Req extends IncomingMessage = IncomingMessage, Res extends ServerResponse = ServerResponse,> = (req: Req, res: Res) => unknown | Promise<unknown>/** * Wraps a request handler middleware to ensure that `next` is called if it * throws or returns a promise that rejects. */export function handler< Req extends IncomingMessage = Request, Res extends ServerResponse = Response,>(fn: Handler<Req, Res>): Middleware<Req, Res> { return async (req, res, next) => { try { await fn(req, res) } catch (err) { next(err) } }}
/** * Create an HTTP server with the provided request listener, ensuring that it * can bind the listening port, and returns a termination function that allows * graceful termination of HTTP connections. */export async function startServer( requestListener: RequestListener, { port, gracefulTerminationTimeout, }: { port?: number; gracefulTerminationTimeout?: number } = {},) { const server = createServer(requestListener) const { terminate } = createHttpTerminator({ gracefulTerminationTimeout, server, }) server.listen(port) await once(server, 'listening') return { server, terminate }}