projects
/
osm
/
UI.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Nav re-order. Profile page
[osm/UI.git]
/
skyquake
/
plugins
/
composer
/
api
/
composer.js
diff --git
a/skyquake/plugins/composer/api/composer.js
b/skyquake/plugins/composer/api/composer.js
index
a4f9bd9
..
f98020c
100644
(file)
--- a/
skyquake/plugins/composer/api/composer.js
+++ b/
skyquake/plugins/composer/api/composer.js
@@
-34,10
+34,11
@@
var DataCenters = {};
Composer.get = function(req) {
var api_server = req.query['api_server'];
var results = {}
Composer.get = function(req) {
var api_server = req.query['api_server'];
var results = {}
+ var projectPrefix = req.session.projectId ? "project-" : "";
return new Promise(function(resolve, reject) {
Promise.all([
rp({
return new Promise(function(resolve, reject) {
Promise.all([
rp({
- uri: utils.
confdPort(api_server) + APIVersion + '/api/config/nsd-catalog/nsd?deep'
,
+ uri: utils.
projectContextUrl(req, utils.confdPort(api_server) + APIVersion + '/api/config/nsd-catalog/nsd?deep')
,
method: 'GET',
headers: _.extend({}, constants.HTTP_HEADERS.accept.collection, {
'Authorization': req.session && req.session.authorization
method: 'GET',
headers: _.extend({}, constants.HTTP_HEADERS.accept.collection, {
'Authorization': req.session && req.session.authorization
@@
-47,7
+48,7
@@
Composer.get = function(req) {
resolveWithFullResponse: true
}),
rp({
resolveWithFullResponse: true
}),
rp({
- uri: utils.
confdPort(api_server) + APIVersion + '/api/config/vnfd-catalog/vnfd?deep'
,
+ uri: utils.
projectContextUrl(req, utils.confdPort(api_server) + APIVersion + '/api/config/vnfd-catalog/vnfd?deep')
,
method: 'GET',
headers: _.extend({}, constants.HTTP_HEADERS.accept.collection, {
'Authorization': req.session && req.session.authorization
method: 'GET',
headers: _.extend({}, constants.HTTP_HEADERS.accept.collection, {
'Authorization': req.session && req.session.authorization
@@
-57,7
+58,7
@@
Composer.get = function(req) {
resolveWithFullResponse: true
}),
rp({
resolveWithFullResponse: true
}),
rp({
- uri: utils.
confdPort(api_server) + APIVersion + '/api/operational/ns-instance-opdata?deep'
,
+ uri: utils.
projectContextUrl(req, utils.confdPort(api_server) + APIVersion + '/api/operational/ns-instance-opdata?deep')
,
method: 'GET',
headers: _.extend({}, constants.HTTP_HEADERS.accept.data, {
'Authorization': req.session && req.session.authorization
method: 'GET',
headers: _.extend({}, constants.HTTP_HEADERS.accept.data, {
'Authorization': req.session && req.session.authorization
@@
-121,7
+122,7
@@
Composer.get = function(req) {
"descriptors": []
}];
if (result[0].body) {
"descriptors": []
}];
if (result[0].body) {
- response[0].descriptors = JSON.parse(result[0].body).collection['nsd:nsd'];
+ response[0].descriptors = JSON.parse(result[0].body).collection[
projectPrefix +
'nsd:nsd'];
if (result[2].body) {
var data = JSON.parse(result[2].body);
if (data && data["nsr:ns-instance-opdata"] && data["nsr:ns-instance-opdata"]["rw-nsr:nsd-ref-count"]) {
if (result[2].body) {
var data = JSON.parse(result[2].body);
if (data && data["nsr:ns-instance-opdata"] && data["nsr:ns-instance-opdata"]["rw-nsr:nsd-ref-count"]) {
@@
-141,10
+142,10
@@
Composer.get = function(req) {
}
};
if (result[1].body) {
}
};
if (result[1].body) {
- response[1].descriptors = JSON.parse(result[1].body).collection['vnfd:vnfd'];
+ response[1].descriptors = JSON.parse(result[1].body).collection[
projectPrefix +
'vnfd:vnfd'];
};
// if (result[2].body) {
};
// if (result[2].body) {
- // response[2].descriptors = JSON.parse(result[2].body).collection['pnfd:pnfd'];
+ // response[2].descriptors = JSON.parse(result[2].body).collection[
projectPrefix +
'pnfd:pnfd'];
// };
resolve({
statusCode: response.statusCode || 200,
// };
resolve({
statusCode: response.statusCode || 200,
@@
-170,7
+171,7
@@
Composer.delete = function(req) {
console.log('Deleting', catalogType, id, 'from', api_server);
return new Promise(function(resolve, reject) {
request({
console.log('Deleting', catalogType, id, 'from', api_server);
return new Promise(function(resolve, reject) {
request({
- uri: utils.
confdPort(api_server) + APIVersion + '/api/config/' + catalogType + '-catalog/' + catalogType + '/' + id
,
+ uri: utils.
projectContextUrl(req, utils.confdPort(api_server) + APIVersion + '/api/config/' + catalogType + '-catalog/' + catalogType + '/' + id)
,
method: 'DELETE',
headers: _.extend({}, constants.HTTP_HEADERS.accept.data, {
'Authorization': req.session && req.session.authorization
method: 'DELETE',
headers: _.extend({}, constants.HTTP_HEADERS.accept.data, {
'Authorization': req.session && req.session.authorization
@@
-218,7
+219,7
@@
Composer.getVNFD = function(req) {
return new Promise(function(resolve, reject) {
var url = utils.confdPort(api_server) + APIVersion + '/api/config/vnfd-catalog/vnfd' + (id ? '/' + id : '') + '?deep';
request({
return new Promise(function(resolve, reject) {
var url = utils.confdPort(api_server) + APIVersion + '/api/config/vnfd-catalog/vnfd' + (id ? '/' + id : '') + '?deep';
request({
- uri: u
rl
,
+ uri: u
tils.projectContextUrl(req, url)
,
method: 'GET',
headers: _.extend({}, constants.HTTP_HEADERS.accept.data, {
'Authorization': authorization
method: 'GET',
headers: _.extend({}, constants.HTTP_HEADERS.accept.data, {
'Authorization': authorization
@@
-257,7
+258,7
@@
Composer.create = function(req) {
'Authorization': req.session && req.session.authorization
});
request({
'Authorization': req.session && req.session.authorization
});
request({
- uri: utils.
confdPort(api_server) + '/api/config/' + catalogType + '-catalog'
,
+ uri: utils.
projectContextUrl(req, utils.confdPort(api_server) + '/api/config/' + catalogType + '-catalog')
,
method: 'POST',
headers: requestHeaders,
forever: constants.FOREVER_ON,
method: 'POST',
headers: requestHeaders,
forever: constants.FOREVER_ON,
@@
-287,7
+288,7
@@
Composer.updateSave = function(req) {
'Authorization': req.session && req.session.authorization
});
request({
'Authorization': req.session && req.session.authorization
});
request({
- uri: utils.
confdPort(api_server) + APIVersion + '/api/config/' + catalogType + '-catalog' + '/' + catalogType + '/' + id
,
+ uri: utils.
projectContextUrl(req, utils.confdPort(api_server) + APIVersion + '/api/config/' + catalogType + '-catalog' + '/' + catalogType + '/' + id)
,
method: 'PUT',
headers: requestHeaders,
forever: constants.FOREVER_ON,
method: 'PUT',
headers: requestHeaders,
forever: constants.FOREVER_ON,
@@
-322,7
+323,7
@@
Composer.update = function(req) {
return new Promise(function(resolve, reject) {
Promise.all([
rp({
return new Promise(function(resolve, reject) {
Promise.all([
rp({
- uri: utils.
confdPort(api_server) + '/api/operations/package-update'
,
+ uri: utils.
projectContextUrl(req, utils.confdPort(api_server) + '/api/operations/package-update')
,
method: 'POST',
headers: _.extend({}, constants.HTTP_HEADERS.accept.collection, {
'Authorization': req.session && req.session.authorization
method: 'POST',
headers: _.extend({}, constants.HTTP_HEADERS.accept.collection, {
'Authorization': req.session && req.session.authorization
@@
-374,7
+375,7
@@
Composer.upload = function(req) {
return new Promise(function(resolve, reject) {
Promise.all([
rp({
return new Promise(function(resolve, reject) {
Promise.all([
rp({
- uri: utils.
confdPort(api_server) + '/api/operations/package-create'
,
+ uri: utils.
projectContextUrl(req, utils.confdPort(api_server) + '/api/operations/package-create')
,
method: 'POST',
headers: _.extend({}, constants.HTTP_HEADERS.accept.collection, {
'Authorization': req.session && req.session.authorization
method: 'POST',
headers: _.extend({}, constants.HTTP_HEADERS.accept.collection, {
'Authorization': req.session && req.session.authorization
@@
-436,7
+437,7
@@
Composer.addFile = function(req) {
return new Promise(function(resolve, reject) {
Promise.all([
rp({
return new Promise(function(resolve, reject) {
Promise.all([
rp({
- uri: utils.
confdPort(api_server) + '/api/operations/package-file-add'
,
+ uri: utils.
projectContextUrl(req, utils.confdPort(api_server) + '/api/operations/package-file-add')
,
method: 'POST',
headers: _.extend({}, constants.HTTP_HEADERS.accept.collection, {
'Authorization': req.session && req.session.authorization
method: 'POST',
headers: _.extend({}, constants.HTTP_HEADERS.accept.collection, {
'Authorization': req.session && req.session.authorization
@@
-474,7
+475,7
@@
Composer.exportPackage = function(req) {
return new Promise(function(resolve, reject) {
Promise.all([
rp({
return new Promise(function(resolve, reject) {
Promise.all([
rp({
- uri: utils.
confdPort(api_server) + '/api/operations/package-export'
,
+ uri: utils.
projectContextUrl(req, utils.confdPort(api_server) + '/api/operations/package-export')
,
method: 'POST',
headers: _.extend({}, constants.HTTP_HEADERS.accept.collection, {
'Authorization': req.session && req.session.authorization
method: 'POST',
headers: _.extend({}, constants.HTTP_HEADERS.accept.collection, {
'Authorization': req.session && req.session.authorization
@@
-532,7
+533,7
@@
FileManager.get = function(req) {
function deleteFile(payload) {
return new Promise(function(resolve, reject) {
rp({
function deleteFile(payload) {
return new Promise(function(resolve, reject) {
rp({
- uri: utils.
confdPort(api_server) + '/api/operations/rw-pkg-mgmt:package-file-delete'
,
+ uri: utils.
projectContextUrl(req, utils.confdPort(api_server) + '/api/operations/rw-pkg-mgmt:package-file-delete')
,
method: 'POST',
headers: _.extend({}, constants.HTTP_HEADERS.accept.collection, {
'Authorization': req.session && req.session.authorization
method: 'POST',
headers: _.extend({}, constants.HTTP_HEADERS.accept.collection, {
'Authorization': req.session && req.session.authorization
@@
-554,7
+555,7
@@
FileManager.get = function(req) {
function download(payload) {
return new Promise(function(resolve, reject) {
rp({
function download(payload) {
return new Promise(function(resolve, reject) {
rp({
- uri: utils.
confdPort(api_server) + '/api/operations/rw-pkg-mgmt:package-file-add'
,
+ uri: utils.
projectContextUrl(req, utils.confdPort(api_server) + '/api/operations/rw-pkg-mgmt:package-file-add')
,
method: 'POST',
headers: _.extend({}, constants.HTTP_HEADERS.accept.collection, {
'Authorization': req.session && req.session.authorization
method: 'POST',
headers: _.extend({}, constants.HTTP_HEADERS.accept.collection, {
'Authorization': req.session && req.session.authorization
@@
-576,7
+577,7
@@
FileManager.get = function(req) {
function list(payload) {
return new Promise(function(resolve, reject) {
rp({
function list(payload) {
return new Promise(function(resolve, reject) {
rp({
- uri: utils.
confdPort(api_server) + '/api/operations/get-package-endpoint'
,
+ uri: utils.
projectContextUrl(req, utils.confdPort(api_server) + '/api/operations/get-package-endpoint')
,
method: 'POST',
headers: _.extend({}, constants.HTTP_HEADERS.accept.collection, {
'Authorization': req.session && req.session.authorization
method: 'POST',
headers: _.extend({}, constants.HTTP_HEADERS.accept.collection, {
'Authorization': req.session && req.session.authorization
@@
-597,7
+598,7
@@
FileManager.get = function(req) {
}
parsedEndpoint = URL.parse(endpoint);
rp({
}
parsedEndpoint = URL.parse(endpoint);
rp({
- uri:
api_server + ':' + parsedEndpoint.port + parsedEndpoint.path
,
+ uri:
utils.projectContextUrl(req, api_server + ':' + parsedEndpoint.port + parsedEndpoint.path)
,
method: 'GET',
headers: _.extend({}, constants.HTTP_HEADERS.accept.collection, {
'Authorization': req.session && req.session.authorization
method: 'GET',
headers: _.extend({}, constants.HTTP_HEADERS.accept.collection, {
'Authorization': req.session && req.session.authorization
@@
-628,7
+629,7
@@
FileManager.job = function(req) {
var id = req.params['id'];
return new Promise(function(resolve, reject) {
request({
var id = req.params['id'];
return new Promise(function(resolve, reject) {
request({
- url: u
ri + url + '?deep'
,
+ url: u
tils.projectContextUrl(req, uri + url + '?deep')
,
method: 'GET',
headers: _.extend({}, constants.HTTP_HEADERS.accept.data, {
'Authorization': req.session && req.session.authorization
method: 'GET',
headers: _.extend({}, constants.HTTP_HEADERS.accept.data, {
'Authorization': req.session && req.session.authorization