Skip to content

Instantly share code, notes, and snippets.

@ebaynaud
Forked from leofmds/create.js
Created December 6, 2017 16:26
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save ebaynaud/70117fc17442bf483f61e5740a307f5c to your computer and use it in GitHub Desktop.
Save ebaynaud/70117fc17442bf483f61e5740a307f5c to your computer and use it in GitHub Desktop.
/**
* Module dependencies
*/
var actionUtil = require('sails/lib/hooks/blueprints/actionUtil');
/**
* Create Record
*
* post /:modelIdentity
*
* An API call to find and return a single model instance from the data adapter
* using the specified criteria. If an id was specified, just the instance with
* that unique id will be returned.
*
* Optional:
* @param {String} callback - default jsonp callback param (i.e. the name of the js function returned)
* @param {*} * - other params will be used as `values` in the create
*/
module.exports = function createRecord (req, res) {
var Model = actionUtil.parseModel(req);
// Create data object (monolithic combination of all parameters)
// Omit the blacklisted params (like JSONP callback param, etc.)
var data = actionUtil.parseValues(req);
// Create new instance of model using data from params
Model.create(data).exec(function created (err, newInstance) {
// Differentiate between waterline-originated validation errors
// and serious underlying issues. Respond with badRequest if a
// validation error is encountered, w/ validation info.
if (err) return res.negotiate(err);
// If we have the pubsub hook, use the model class's publish method
// to notify all subscribers about the created item
if (req._sails.hooks.pubsub) {
if (req.isSocket) {
Model.subscribe(req, newInstance);
Model.introduce(newInstance);
}
Model.publishCreate(newInstance, !req.options.mirror && req);
}
// Custom query to populate created record
var Q = Model.findOne(newInstance.id);
Q = actionUtil.populateEach(Q, req);
Q.exec(function foundAgain (err, populatedRecord) {
if (err) return res.serverError(err);
if (!populatedRecord) return res.serverError('Could not find record after creating!');
res.created(populatedRecord);
});
});
};
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment