Express API with Async/Await

restful.js

import express from "express";

/**
 * Takes a route handling function and returns a function
 * that wraps it after first checking that the strings in
 * `reserved` are not part of `req.body`. Used for ensuring
 * create and update requests do not overwrite server-generated
 * values.
 */
function checkReservedParams(routeHandler, ...reserved) {
  return function(req, res, next) {
    for (let reservedKey of reserved) {
      if (req.body[reservedKey]) {
        return res.status(400).json({
          error: `Cannot specify ${reservedKey} as part of request body`
        });
      }
    }

    routeHandler(req, res, next);
  }
}

/**
 * Takes a route handling function and returns
 * a function that wraps it in a `try/catch`. Caught
 * exceptions are forwarded to the `next` handler.
 */
function errorChecking(routeHandler) {
  return async function (req, res, next) {
    try {
      await routeHandler(req, res, next);
    } catch (err) {
      next(err);
    }
  }
}

/**
 * Takes a Sequelize model class and returns an Express
 * router that provides a standard set of RESTful resource
 * routes.
 */
export default function restful(model) {
  async function index(req, res, next) {
    const { offset = 0, limit = 10, orderBy = "createdAt", orderDirection = "ASC" } = req.query;
    const result = await model.findAndCountAll({
      offset, limit,
      order: [ [orderBy, orderDirection] ]
    });
    res.json({
      offset, limit, orderBy, orderDirection,
      count: result.count,
      data: result.rows
    });
  }

  async function create(req, res, next) {
    const instance = await model.create(req.body);
    res.status(201).json({data: instance});
  }

  async function get(req, res, next) {
    const instance = await model.findOne({
      where: { id: req.params.id }
    });
    if (instance) {
      res.json({data: instance});
    } else {
      res.status(404).json({error: "Not found"});
    }
  }

  async function update(req, res, next) {
    const instance = await model.findOne({
      where: { id: req.params.id }
    });
    if (instance) {
      const updated = await instance.updateAttributes(req.body);
      res.json({data: updated});
    } else {
      res.status(404).json({error: "Not found"});
    }
  }

  async function destroy(req, res, next) {
    const instance = await model.findOne({
      where: { id: req.params.id }
    });
    if (instance) {
      await instance.destroy();
      res.status(204).json({});
    } else {
      res.status(404).json({error: "Not found"});
    }
  }

  function notAllowed(req, res) {
    res.status(405).json({error: "Method not allowed"});
  }

  const router = express.Router();

  router.route("/")
    .get(errorChecking(index))
    .post(errorChecking(checkReservedParams(create, "id", "createdAt", "updatedAt")))
    .all(errorChecking(notAllowed));

  router.route("/:id")
    .get(errorChecking(get))
    .put(errorChecking(checkReservedParams(update, "id", "createdAt", "updatedAt")))
    .delete(errorChecking(destroy))
    .all(errorChecking(notAllowed));

  return router;
}

You really saved my day!