stonecircle/express-autoroute-json

var _ = require('lodash');
var camelcaseKeys = require('camelcase-keys');
 
var defaultSerialise = require('./serialise');
var mergeQueries = require('./helpers/mergeQueries');
 
Function `exports` has 73 lines of code (exceeds 25 allowed). Consider refactoring.
Function `exports` has a Cognitive Complexity of 10 (exceeds 5 allowed). Consider refactoring.
module.exports = function(options) {
  return function(req, res, next) {
Identical blocks of code found in 3 locations. Consider refactoring.
    return new Promise(function(resolve) {
      if (options.translateId) {
        return resolve(options.translateId(req.params.id, req));
      }
 
      return resolve(req.params.id);
    }).then(function(id) {
      var query = {};
 
      query[options.idParameter || options.update.idParameter || '_id'] = id;
 
      if (req.autorouteQuery) {
        query = mergeQueries(req.autorouteQuery, query);
      }
 
      var newModel = {};
 
      if (req.body.data.attributes) {
        _.assign(newModel, camelcaseKeys(req.body.data.attributes));
      }
 
      _.forEach(req.body.data.relationships, function(value, key) {
        if (value.data && value.data.id) {
          newModel[_.camelCase(key)] = value.data.id;
        }
        // delete relationship
        if (value.data === null) {
          newModel[_.camelCase(key)] = null;
        }
        // array relationship
        if (Array.isArray(value.data)) {
          newModel[_.camelCase(key)] = _.chain(value.data)
            .map('id')
            .compact()
            .value();
        }
      });
 
      return options.model.findOneAndUpdate(query, {
        $set: newModel,
      }, {
        new: true,
      }).then(function(updated) {
        if (!updated) {
          throw new Error('NotFound');
        }
 
        req.model = updated;
 
Similar blocks of code found in 2 locations. Consider refactoring.
        return new Promise(function(resolve) {
          if (options.translateId) {
            // reverse translate id
            return resolve(
              _.assign(updated.toJSON(), { id: req.params.id, originalId: updated.id })
            );
          }
 
          return resolve(updated);
        });
      });
    }).then(function(result) {
      return new Promise(function(resolve) {
        if (options.find.processOne) {
          return resolve(options.find.processOne(result, req));
        }
 
        return resolve(result);
      }).then(function(processedResult) {
        var serialiseFunction = _.get(options, 'find.serialise', defaultSerialise);
 
        res.json(serialiseFunction(processedResult, options, defaultSerialise));
      });
    }).then(function() {
      next();
    })
      .catch(function(err) {
        if ((err.name === 'CastError' && err.kind === 'ObjectId') || err.message === 'NotFound') {
          // could not cast the ID
          res.status(404).send({
            errors: [{
              detail: 'Not Found',
            }],
          });
        } else {
          next(err);
        }
      });
  };
};