lib/routes/create.js
'use strict'
const createRoute = module.exports = { }
const async = require('async')
const _ = {
assign: require('lodash.assign')
}
const uuid = require('uuid')
const helper = require('./helper.js')
const router = require('../router.js')
const postProcess = require('../postProcess.js')
const responseHelper = require('../responseHelper.js')
createRoute.register = () => {
router.bindRoute({
verb: 'post',
path: ':type'
}, (request, resourceConfig, res) => {
let theirResource
let newResource
let response
async.waterfall([
callback => {
helper.verifyRequest(request, resourceConfig, res, 'create', callback)
},
callback => {
helper.verifyRequest(request, resourceConfig, res, 'find', callback)
},
callback => {
helper.checkForBody(request, callback)
},
callback => {
const theirs = request.params.data
theirResource = _.assign(
{ type: request.params.type },
(request.resourceConfig.generateId !== false) && { id: uuid.v4() },
theirs.id && { id: theirs.id },
theirs.attributes,
{ meta: theirs.meta }
)
for (const i in theirs.relationships) {
theirResource[i] = theirs.relationships[i].data
}
helper.validate(theirResource, resourceConfig.onCreate, callback)
},
callback => {
resourceConfig.handlers.create(request, theirResource, callback)
},
(result, callback) => {
newResource = result
request.params.id = newResource.id
resourceConfig.handlers.find(request, callback)
},
(result, callback) => {
newResource = result
postProcess.fetchForeignKeys(request, newResource, resourceConfig.attributes, callback)
},
callback => {
responseHelper._enforceSchemaOnObject(newResource, resourceConfig.attributes, callback)
},
(sanitisedData, callback) => {
request.route.path += `/${newResource.id}`
res.set({
'Location': `${request.route.combined}/${newResource.id}`
})
response = responseHelper._generateResponse(request, resourceConfig, sanitisedData)
postProcess.handle(request, response, callback)
}
], err => {
if (err) return helper.handleError(request, res, err)
return router.sendResponse(res, response, 201)
})
})
}