X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=skyquake%2Fplugins%2Faccounts%2Fapi%2Faccounts.js;h=cc34f390d120e79a5e524092cd5a5ea9e1822440;hb=96b7649b2db9ab306a20b43db5f77b6111d746ed;hp=83e841e6263829ccf9d47cb6d5c3fb03e7093716;hpb=b78fbe20fd7d976b3e15abb2387b4e329a5ea918;p=osm%2FUI.git diff --git a/skyquake/plugins/accounts/api/accounts.js b/skyquake/plugins/accounts/api/accounts.js index 83e841e62..cc34f390d 100644 --- a/skyquake/plugins/accounts/api/accounts.js +++ b/skyquake/plugins/accounts/api/accounts.js @@ -28,7 +28,7 @@ var ConfigAgent = require('./config_agent/configAgent') var Accounts = {}; var nameSpace = { cloud: 'cloud', - sdn: 'sdn-account', + sdn: 'sdn', 'config-agent': 'config-agent' }; Accounts.get = function(req) { @@ -85,11 +85,7 @@ function getAccount(req) { var id = req.params.id || req.params.name; var requestHeaders = {}; var type = nameSpace[req.params.type]; - var url = utils.confdPort(api_server) + '/api/operational/' + type; - //SDN model doesn't follow convention - if (type != 'sdn-account') { - url += '/account'; - } + var url = utils.confdPort(api_server) + '/api/operational/' + type + '/account'; if (id) { url += '/' + id; } @@ -97,12 +93,12 @@ function getAccount(req) { _.extend( requestHeaders, id ? constants.HTTP_HEADERS.accept.data : constants.HTTP_HEADERS.accept.collection, { - 'Authorization': req.get('Authorization') + 'Authorization': req.session && req.session.authorization } ); request({ - url: url + '?deep', + url: utils.projectContextUrl(req, url + '?deep'), type: 'GET', headers: requestHeaders, forever: constants.FOREVER_ON, @@ -112,16 +108,12 @@ function getAccount(req) { var data; var objKey = 'rw-' + type + ':account'; //SDN model doesn't follow convention - if (type == 'sdn-account') { - objKey = 'rw-sdn:sdn-account'; - } if (utils.validateResponse(type.toUpperCase() + '.get', error, response, body, resolve, reject)) { try { data = JSON.parse(response.body); if (!id) { data = data.collection; } - data = data[objKey] } catch (e) { console.log('Problem with "' + type.toUpperCase() + '.get"', e); @@ -152,27 +144,14 @@ function updateAccount(req) { var url = utils.confdPort(api_server) + '/api/config/' + type; var method = 'POST' if (!id) { - if (type == 'sdn-account') { - createData = { - 'sdn-account': Array.isArray(data) ? data : [data] - } - } else { - createData = { - 'account': Array.isArray(data) ? data : [data] - } + createData = { + 'account': Array.isArray(data) ? data : [data] } console.log('Creating ' + type + ' account: ', createData); } else { method = 'PUT'; - if (type == 'sdn-account') { - url += '/' + id; - createData['rw-sdn:sdn-account'] = Array.isArray(data) ? data : [data]; - - } else { - url += '/account/' + id; - createData['rw-' + type + ':account'] = Array.isArray(data) ? data : [data]; - } - //createData = createData[0]; + url += '/account/' + id; + createData['rw-' + type + ':account'] = Array.isArray(data) ? data : [data]; } @@ -181,10 +160,10 @@ function updateAccount(req) { _.extend(requestHeaders, constants.HTTP_HEADERS.accept.data, constants.HTTP_HEADERS.content_type.data, { - 'Authorization': req.get('Authorization') + 'Authorization': req.session && req.session.authorization }); request({ - url: url, + url: utils.projectContextUrl(req, url), method: method, headers: requestHeaders, forever: constants.FOREVER_ON, @@ -210,19 +189,15 @@ function deleteAccount(req) { var requestHeaders = {}; var createData = {}; var url = utils.confdPort(api_server) + '/api/config/' + type; - if (type == 'sdn-account') { - url += '/' + id; - } else { - url += '/account/' + id; - } + url += '/account/' + id; return new Promise(function(resolve, reject) { _.extend(requestHeaders, constants.HTTP_HEADERS.accept.data, constants.HTTP_HEADERS.content_type.data, { - 'Authorization': req.get('Authorization') + 'Authorization': req.session && req.session.authorization }); request({ - url: url, + url: utils.projectContextUrl(req, url), method: 'DELETE', headers: requestHeaders, forever: constants.FOREVER_ON, @@ -263,13 +238,13 @@ function refreshAccountConnectionStatus (req) { var headers = _.extend({}, constants.HTTP_HEADERS.accept.data, constants.HTTP_HEADERS.content_type.data, { - 'Authorization': req.get('Authorization') + 'Authorization': req.session && req.session.authorization } ); return new Promise(function(resolve, reject) { request({ - uri: utils.confdPort(api_server) + '/api/operations/' + rpcInfo[Type].rpc, + uri: utils.projectContextUrl(req, utils.confdPort(api_server) + '/api/operations/' + rpcInfo[Type].rpc), method: 'POST', headers: headers, forever: constants.FOREVER_ON,