| 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
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99 |
1x
1x
1x
1x
1x
1x
1x
| 'use strict'
const removeRelationRoute = module.exports = { }
const async = require('async')
const helper = require('./helper.js')
const router = require('../router.js')
const postProcess = require('../postProcess.js')
const responseHelper = require('../responseHelper.js')
removeRelationRoute.register = () => {
router.bindRoute({
verb: 'delete',
path: ':type/:id/relationships/:relation'
}, (request, resourceConfig, res) => {
let newResource
let theirResource
let response
async.waterfall([
callback => {
helper.verifyRequest(request, resourceConfig, res, 'update', callback)
},
callback => {
helper.verifyRequest(request, resourceConfig, res, 'find', callback)
},
callback => {
helper.checkForBody(request, callback)
},
callback => {
resourceConfig.handlers.find(request, callback)
},
(ourResource, callback) => {
theirResource = ourResource
const isMany = resourceConfig.attributes[request.params.relation]._settings.__many
const isOne = resourceConfig.attributes[request.params.relation]._settings.__one
const relationType = isMany || isOne
let theirs = request.params.data
if (!(Array.isArray(theirs))) {
theirs = [ theirs ]
}
const keys = [].concat(theirResource[request.params.relation]).map(j => j.id)
for (let i = 0; i < theirs.length; i++) {
if (relationType.indexOf(theirs[i].type) === -1) {
return callback({ // eslint-disable-line standard/no-callback-literal
status: '403',
code: 'EFORBIDDEN',
title: 'Invalid Request',
detail: `Invalid type ${theirs[i].type}`
})
}
const someId = theirs[i].id
const indexOfTheirs = keys.indexOf(someId)
if (indexOfTheirs === -1) {
return callback({ // eslint-disable-line standard/no-callback-literal
status: '403',
code: 'EFORBIDDEN',
title: 'Invalid Request',
detail: `Unknown id ${someId}`
})
}
if (isMany) {
theirResource[request.params.relation].splice(indexOfTheirs, 1)
}
}
if (!isMany) {
theirResource[request.params.relation] = null
}
helper.validate(theirResource, resourceConfig.onCreate, callback)
},
callback => {
resourceConfig.handlers.update(request, theirResource, callback)
},
(result, callback) => {
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) => {
sanitisedData = sanitisedData.relationships[request.params.relation].data
response = responseHelper._generateResponse(request, resourceConfig, sanitisedData)
postProcess.handle(request, response, callback)
}
], err => {
if (err) return helper.handleError(request, res, err)
router.sendResponse(res, response, 200)
})
})
}
|