material-framework/lib/crud/controller.js

const _ = require('lodash')
const defaults = require('./defaults')
const { Op } = require('sequelize')

const crudController = (opts) => {
  opts = defaults(opts)
  const { Type } = opts

  const subset = async (req) => {
    const subset = {}
    const params = _.toPairs(req.params)
      .map(([key, value])=>({key, value}))
      .filter(({value}) => value !== opts.paramAll)
    for (let { key, value } of params) {
      const assoc = Type.associations[key]
      if (assoc) {
        subset[assoc.foreignKey] = (await assoc.target.findOne({
          parameters: ['id'],
          where: { key: value }
        })).id
      }
    }
    return subset
  }

  const list = async (req, res) => {
    // TODO Pagination (http://docs.sequelizejs.com/manual/tutorial/querying.html#pagination-limiting)
    if (req.query && req.query.q) {
      const fields = [Type.tableAttributes.name, Type.tableAttributes.tag].filter(x => x)
      if (!fields) throw new Error('Table has no searchable fields')
      const or = fields.map(field => ({
        [field.fieldName]: { [Op.like]: `%${req.query.q}%` }
      }))
      const where = { ...subset, [Op.or]: or }
      const data = (await Type.findAll({ where })).map(d => d.sanitize ? d.sanitize() : d)
      res.status(200).send(data)
    } else if (res.query && res.query.ids) {
      const ids = res.query.ids.split(',')
      const data = (await Type.findAll({where: { ...(await subset(req)), id: { [Op.in]: ids }}})).map(d => d.sanitize ? d.sanitize() : d)
      res.status(200).send(data)
    } else {
      const data = (await Type.findAll({where: { ...(await subset(req)) }})).map(d => d.sanitize ? d.sanitize() : d)
      res.status(200).send(data)
    }
  }
  const create = async (req, res) => {
    const data = (await Type.create(req.body))
    res.status(200).send(data && data.sanitize ? data.sanitize() : data)
  }
  const read = async (req, res) => {
    const data = (await Type.findOne({where: {id: req.params[opts.routeParam]}}))
    res.status(200).send(data && data.sanitize ? data.sanitize() : data)
  }
  const update = async (req, res) => {
    const data = (await Type.update(req.body, { where: { id: req.params[opts.routeParam] } }))
    res.status(200).send(data && data.sanitize ? data.sanitize() : data)
  }
  const $delete = async (req, res) => {
    const data = (await Type.destroy({ where: { id: req.params[opts.routeParam] } }))
    res.status(204).end()
  }
  const trash = async (req, res) => {
    const data = (await Type.findAll({
      model: Type,
      paranoid: false,
      where: {
        ...(await subset(req)),
        deletedAt: { [Op.ne]: null }
      }
    }))
    res.status(200).send(data && data.sanitize ? data.sanitize() : data)
  }
  const undelete = async (req, res) => {
    const data = (await Type.update({ deletedAt: null }, {
      paranoid: false,
      where: { id: req.params[opts.routeParam] }
    }))
    res.status(200).send(data && data.sanitize ? data.sanitize() : data)
  }
  // TODO: Create, Read, Update, Delete

  return {
    list,
    create,
    read,
    update,
    delete: $delete,
    trash,
    undelete
  }
}

module.exports = crudController