X-Git-Url: https://osm.etsi.org/gitweb/?p=osm%2FUI.git;a=blobdiff_plain;f=skyquake%2Fplugins%2Flogging%2Fapi%2Flogging.js;h=08103d8d305de9fb0b240abb4c4aeff1ce21e5ad;hp=3ef9027d9e359e446cc20a4aaa35775c539b96a8;hb=refs%2Fchanges%2F79%2F5479%2F2;hpb=cf5edafaf6923b748a229cbd3f2422da255f5806 diff --git a/skyquake/plugins/logging/api/logging.js b/skyquake/plugins/logging/api/logging.js index 3ef9027d9..08103d8d3 100644 --- a/skyquake/plugins/logging/api/logging.js +++ b/skyquake/plugins/logging/api/logging.js @@ -43,7 +43,7 @@ var Test = {}; function buildGetRequestOptions(req, endpoint) { var headers = _.extend({}, constants.HTTP_HEADERS.accept.data, { - 'Authorization': req.get('Authorization') + 'Authorization': req.session && req.session.authorization }); var api_server = req.query["api_server"]; var requestOptions = { @@ -60,7 +60,7 @@ function buildPutRequestOptions(req, endpoint, jsonData) { var headers = _.extend({}, constants.HTTP_HEADERS.accept.data, constants.HTTP_HEADERS.content_type.data, { - 'Authorization': req.get('Authorization') + 'Authorization': req.session && req.session.authorization }); var api_server = req.query["api_server"]; var requestOptions = { @@ -79,7 +79,7 @@ function buildDeleteRequestOptions(req, endpoint) { var headers = _.extend({}, constants.HTTP_HEADERS.accept.data, constants.HTTP_HEADERS.content_type.data, { - 'Authorization': req.get('Authorization') + 'Authorization': req.session && req.session.authorization }); var api_server = req.query["api_server"]; var requestOptions = { @@ -334,14 +334,12 @@ Config.deleteDefaultSyslogSeverity = function(req) { // TODO: verify there is one key at root of data: 'default-severity' // OR just filter on the request body var Categories = req.params.nulledCategories.split(','); - var promises = []; return new Promise(function(resolve, reject) { - promises.concat(Categories.map(function(categoryName) { + return Promise.all(Categories.map(function(categoryName) { return handleDeleteRequest(req, APIVersion + '/api/config/logging/sink/syslog/filter/category/' + categoryName); - })); - return Promise.all(promises).then( + })).then( function(data) { - resolve({statusCode: data[0].statusCode, data: data[0].data}); + reject({statusCode: data[0].statusCode, data: data[0].data}); }, function(data) { reject({statusCode: data[0].statusCode, data: data[0].data}); @@ -449,7 +447,7 @@ SysLogViewer.get = function(req) { headers: _.extend({}, constants.HTTP_HEADERS.accept.data, { - 'Authorization': req.get('Authorization') + 'Authorization': req.session && req.session.authorization }), forever: foreverOn, rejectUnauthorized: false