LOKE HTTP Kit

A set of helpers and middleware for making http servers in node

Usage

Middleware are most easily used with express

const express = require("express");

const app = express();

createLoggingMiddleware(logger: Logger)

Add http logging, can be used with loke-logger v3 or just console;

const { createLoggingMiddleware } = require("@loke/http-kit");

app.use(createLoggingMiddleware(console));

createErrorMiddleware(logger: Logger)

Add basic error formatting and logging, can be used with loke-logger v3 or just console;

const { createErrorMiddleware } = require("@loke/http-kit");

app.use(createErrorMiddleware(console));

createMetricsMiddleware()

You need to register all metrics before hand using registerMetrics

The path label will be populated based on the req.routePath, the Router class will automatically populate this for you. Or you can manually set it if you are using a different router.

Alternatively you can use the trackAllFoundPaths option to track the path of all requests that don't result in a 404. This must be used with caution as unconstrained labels can explode the number of metrics.

const { createMetricsMiddleware, registerMetrics } = require("@loke/http-kit");
const promClient = require("prom-client");

registerMetrics(promClient.register);

app.use(createMetricsMiddleware());

Class: Router

A basic router similar to the one provided by express

key differences are:

• handles async errors
• can't be nested, (can be nested inside a express use though)
• supports metrics

const { Router } = require("@loke/http-kit");

const router = new Router();

router.get("/foo/:bar", async ({ req, res, params }) => {
  // get a path param
  const foo = params.foo;

  // req, res are just the standard node/express objects
  // so this could also be `res.json({ foo })`
  res.send(`Hello, ${foo}`);
});

app.use(router.createHandler());

graceful

const { graceful } = require("@loke/http-kit");

const PORT = 8000;

async function main() {
  const server = http.createServer(app);

  const { shutdown } = graceful(server);

  server.listen(PORT);

  // Await stop signal
  await stopSignal();

  // Finish current requests then stop http server
  await shutdown();
}

const stopSignal = () =>
  new Promise((resolve) => {
    process.once("SIGINT", resolve);
    process.once("SIGTERM", resolve);
  });

main();