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
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
|
/*
Copyright(c) 2017 AT&T Intellectual Property. All rights reserved.
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing,
software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and limitations under the License.
*/
/* Middleware modules */
"use strict";
const ejs = require('ejs');
const utils = require('./utils');
const logAccess = require('./logging').logAccess;
const config = process.mainModule.exports.config;
const locations = config.locations;
const logger = config.logSource.getLogger("errhandler");
/* Assign a request ID to each incoming request */
exports.assignId = function(req, res, next) {
req.dcaeReqId = utils.generateId();
next();
};
/* Error handler -- send error with JSON body */
exports.handleErrors = function(err, req, res, next) {
let status = err.status || 500;
let msg = err.message || err.body || 'unknown error'
res.status(status).type('application/json').send({status: status, message: msg });
logAccess(req, status, msg);
if (status >= 500) {
logger.error(req.dcaeReqId + " Error: " + JSON.stringify({message: msg, code: err.code, status: status}));
}
};
/* Make sure Content-Type is correct for POST and PUT */
exports.checkType = function(type){
return function(req, res, next) {
const ctype = req.header('content-type');
const method = req.method.toLowerCase();
/* Content-Type matters only for POST and PUT */
if (ctype === type || ['post','put'].indexOf(method) < 0) {
next();
}
else {
let err = new Error ('Content-Type must be \'' + type +'\'');
err.status = 415;
next (err);
}
};
};
/* Check that a JSON body has a set of properties */
exports.checkProps = function(props) {
return function (req, res, next) {
const missing = props.filter(function(p){return !utils.hasProperty(req.body,p);});
if (missing.length > 0) {
let err = new Error ('Request missing required properties: ' + missing.join(','));
err.status = 400;
next(err);
}
else {
next();
}
};
};
/* Check that there is location information for this event */
/* Appends locations to req.dcae_locations for later use */
exports.checkLocation = function(req, res, next) {
if (req.body.dcae_service_location in locations) {
req.dcae_locations = {central: locations.central, local: locations[req.body.dcae_service_location]};
next();
}
else {
let err = new Error ('"' + req.body.dcae_service_location + '" is not a supported location');
err.status = 400;
next(err);
}
};
/* Expand blueprint templates into full blueprints.
* Expects req.dcae_templates to contain templates.
* Puts expanded blueprints into req.dcae_blueprints
*/
exports.expandTemplates = function(req, res, next) {
/* Build the context for rendering the template */
let context = req.body; // start with the body of POST /events request
context.locations = req.dcae_locations; // location information from the location "map" in config file
context.dcae_shareables = req.dcae_shareables; // local shareable components
/* Expand the templates */
try {
if (req.dcae_templates) { // There won't be any templates for an undeploy
let blueprints = req.dcae_templates.map(function (template) {
//TODO possibly compute intensive- is there a better way?
return {
blueprint: ejs.render(template.template, context),
type: template.type,
deploymentId: utils.generateId() // Assign ID now, so we can return it in response
};
});
req.dcae_blueprints = blueprints;
req.dcae_templates = null; // Make they'll get garbage-collected
}
next();
}
catch (err) {
err.status = 400;
next(err);
}
};
|
