All files / lib/routes create.js

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
 
1x
 
1x
1x
 
 
1x
1x
1x
1x
1x
 
1x
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
'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.primaryKey === 'uuid') && { id: uuid.v4() },
          (request.resourceConfig.primaryKey === 'autoincrement') && { id: 'DEFAULT' },
          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)
    })
  })
}