X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=skyquake%2Fplugins%2Flogging%2Fapi%2Flogging.js;h=06c27d8c52e4442ee16241904283e7a46aa0eda8;hb=4ce407211e3fa5a8ba7a43cb0c88406e83a25bdc;hp=499a81421bb9321082fcb770d9de2ef250d2d4c8;hpb=0aadbcad27e706cedd916b4140bc621eaf46a516;p=osm%2FUI.git diff --git a/skyquake/plugins/logging/api/logging.js b/skyquake/plugins/logging/api/logging.js index 499a81421..06c27d8c5 100644 --- a/skyquake/plugins/logging/api/logging.js +++ b/skyquake/plugins/logging/api/logging.js @@ -112,10 +112,10 @@ function requestCallback(resolve, reject, transformFunc) { } else { var data = JSON.stringify(response.body); } - return resolve_with_delay(resolve, { + return resolve({ statusCode: response.statusCode, data: data - }, 0); + }); }; }; } @@ -334,17 +334,15 @@ 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: 200, data: data[0]}); + reject({statusCode: data[0].statusCode, data: data[0].data}); }, function(data) { - reject(data); + reject({statusCode: data[0].statusCode, data: data[0].data}); } ) }); @@ -369,15 +367,14 @@ Config.deleteDefaultSyslogSeverity = function(req) { Config.setAllowDuplicateEvents = function(req) { // TODO: verify there is one key at root of data: 'default-severity' // OR just filter on the request body - - if (req.body.hasOwnProperty('allowDuplicateEvents') && - typeof req.body.allowDuplicateEvents == 'boolean') { - if (req.body.allowDuplicateEvents) { - return handlePutRequest(req, APIVersion + '/api/config/logging/allow', { +console.log(req.body) + if (req.body.hasOwnProperty('allowDuplicateEvents')) { + if (req.body.allowDuplicateEvents.toUpperCase() == "TRUE") { + return handlePutRequest(req, '/api/config/logging/allow', { "duplicate": "events" }); } else { // false, remove entry from logging config - return handleDeleteRequest(req, APIVersion + '/api/config/logging/allow/duplicate'); + return handleDeleteRequest(req, '/api/config/logging/allow/duplicate'); } } else { return handleReject(statusCode=400,