projects / osm / UI.git / blob
? search:


5ff92c80ea9559e38288198127b04150f61bf832
[osm/UI.git] / skyquake / plugins / composer / api / composer.js
1 /*
2 *
3 * Copyright 2016 RIFT.IO Inc
4 *
5 * Licensed under the Apache License, Version 2.0 (the "License");
6 * you may not use this file except in compliance with the License.
7 * You may obtain a copy of the License at
8 *
9 * http://www.apache.org/licenses/LICENSE-2.0
10 *
11 * Unless required by applicable law or agreed to in writing, software
12 * distributed under the License is distributed on an "AS IS" BASIS,
13 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14 * See the License for the specific language governing permissions and
15 * limitations under the License.
16 *
17 */
18
19 var request = require('request');
20 var Promise = require('bluebird');
21 var rp = require('request-promise');
22 var utils = require('../../../framework/core/api_utils/utils.js');
23 var constants = require('../../../framework/core/api_utils/constants.js');
24 var _ = require('underscore');
25 var URL = require('url');
26 var uuid = require('uuid');
27 var APIVersion = '/v1';
28 var PackageFileHandler = require('./packageFileHandler.js');
29
30 var Composer = {};
31 var FileManager = {};
32 var PackageManager = {};
33 var DataCenters = {};
34 // Catalog module methods
35 Composer.get = function(req) {
36 var api_server = req.query['api_server'];
37 var results = {}
38 return new Promise(function(resolve, reject) {
39 Promise.all([
40 rp({
41 uri: utils.confdPort(api_server) + APIVersion + '/api/config/nsd-catalog/nsd?deep',
42 method: 'GET',
43 headers: _.extend({}, constants.HTTP_HEADERS.accept.collection, {
44 'Authorization': req.get('Authorization')
45 }),
46 forever: constants.FOREVER_ON,
47 rejectUnauthorized: false,
48 resolveWithFullResponse: true
49 }),
50 rp({
51 uri: utils.confdPort(api_server) + APIVersion + '/api/config/vnfd-catalog/vnfd?deep',
52 method: 'GET',
53 headers: _.extend({}, constants.HTTP_HEADERS.accept.collection, {
54 'Authorization': req.get('Authorization')
55 }),
56 forever: constants.FOREVER_ON,
57 rejectUnauthorized: false,
58 resolveWithFullResponse: true
59 }),
60 rp({
61 uri: utils.confdPort(api_server) + APIVersion + '/api/operational/ns-instance-opdata?deep',
62 method: 'GET',
63 headers: _.extend({}, constants.HTTP_HEADERS.accept.data, {
64 'Authorization': req.get('Authorization')
65 }),
66 forever: constants.FOREVER_ON,
67 rejectUnauthorized: false,
68 resolveWithFullResponse: true
69 })
70 // Not enabled for now
71 // rp({
72 // uri: utils.confdPort(api_server) + '/api/config/pnfd-catalog/pnfd?deep',
73 // method: 'GET',
74 // headers: _.extend({},
75 // constants.HTTP_HEADERS.accept.collection,
76 // {
77 // 'Authorization': req.get('Authorization')
78 // }),
79 // forever: constants.FOREVER_ON,
80 // rejectUnauthorized: false,
81 // resolveWithFullResponse: true
82 // })
83 ]).then(function(result) {
84 var response = [{
85 "id": "GUID-1",
86 "name": "RIFT.ware™ NS Descriptors Catalog",
87 "short-name": "rift.ware-nsd-cat",
88 "description": "RIFT.ware™, an open source NFV development and deployment software platform that makes it simple to create, deploy and manage hyper-scale Virtual network functions and applications.",
89 "vendor": "RIFT.io",
90 "version": "",
91 "created-on": "",
92 "type": "nsd",
93 "meta": {
94 "icon-svg": "data:image/svg+xml,%3C%3Fxml%20version%3D%221.0%22%20encoding%3D%22iso-8859-1%22%3F%3E%0A%3C!--%20Generator%3A%20Adobe%20Illustrator%2018.0.0%2C%20SVG%20Export%20Plug-In%20.%20SVG%20Version%3A%206.00%20Build%200)%20%20--%3E%0A%3C!DOCTYPE%20svg%20PUBLIC%20%22-%2F%2FW3C%2F%2FDTD%20SVG%201.1%2F%2FEN%22%20%22http%3A%2F%2Fwww.w3.org%2FGraphics%2FSVG%2F1.1%2FDTD%2Fsvg11.dtd%22%3E%0A%3Csvg%20version%3D%221.1%22%20id%3D%22connection-icon-1%22%20xmlns%3D%22http%3A%2F%2Fwww.w3.org%2F2000%2Fsvg%22%20xmlns%3Axlink%3D%22http%3A%2F%2Fwww.w3.org%2F1999%2Fxlink%22%20x%3D%220px%22%20y%3D%220px%22%0A%09%20viewBox%3D%220%200%2050%2050%22%20style%3D%22enable-background%3Anew%200%200%2050%2050%3B%22%20xml%3Aspace%3D%22preserve%22%3E%0A%09%3Cpath%20d%3D%22M15%2030c-2.8%200-5-2.2-5-5s2.2-5%205-5%205%202.2%205%205-2.2%205-5%205zm0-8c-1.7%200-3%201.3-3%203s1.3%203%203%203%203-1.3%203-3-1.3-3-3-3z%22%2F%3E%3Cpath%20d%3D%22M35%2020c-2.8%200-5-2.2-5-5s2.2-5%205-5%205%202.2%205%205-2.2%205-5%205zm0-8c-1.7%200-3%201.3-3%203s1.3%203%203%203%203-1.3%203-3-1.3-3-3-3z%22%2F%3E%3Cpath%20d%3D%22M35%2040c-2.8%200-5-2.2-5-5s2.2-5%205-5%205%202.2%205%205-2.2%205-5%205zm0-8c-1.7%200-3%201.3-3%203s1.3%203%203%203%203-1.3%203-3-1.3-3-3-3z%22%2F%3E%3Cpath%20d%3D%22M19.007%2025.885l12.88%206.44-.895%201.788-12.88-6.44z%22%2F%3E%3Cpath%20d%3D%22M30.993%2015.885l.894%201.79-12.88%206.438-.894-1.79z%22%2F%3E%3C%2Fsvg%3E"
95 },
96 "descriptors": []
97 }, {
98 "id": "GUID-2",
99 "name": "RIFT.ware™ VNF Descriptors Catalog",
100 "short-name": "rift.ware-vnfd-cat",
101 "description": "RIFT.ware™, an open source NFV development and deployment software platform that makes it simple to create, deploy and manage hyper-scale Virtual network functions and applications.",
102 "vendor": "RIFT.io",
103 "version": "",
104 "created-on": "",
105 "type": "vnfd",
106 "meta": {
107 "icon-svg": "data:image/svg+xml,<?xml version=\"1.0\" encoding=\"utf-8\"?> <!-- Generator: Adobe Illustrator 16.0.0, SVG Export Plug-In . SVG Version: 6.00 Build 0) --> <!DOCTYPE svg PUBLIC \"-//W3C//DTD SVG 1.1//EN\" \"http://www.w3.org/Graphics/SVG/1.1/DTD/svg11.dtd\"> <svg version=\"1.1\" id=\"Layer_3\" xmlns=\"http://www.w3.org/2000/svg\" xmlns:xlink=\"http://www.w3.org/1999/xlink\" x=\"0px\" y=\"0px\" width=\"100px\" height=\"100px\" viewBox=\"0 0 100 100\" enable-background=\"new 0 0 100 100\" xml:space=\"preserve\"> <g> <path d=\"M58.852,62.447l-4.662-1.033c-0.047-3.138-0.719-6.168-1.996-9.007l3.606-2.92c0.858-0.695,0.99-1.954,0.296-2.813 l-4.521-5.584c-0.334-0.413-0.818-0.675-1.346-0.731c-0.525-0.057-1.056,0.102-1.468,0.435L45.25,43.64v0 c-2.486-1.907-5.277-3.259-8.297-4.019v-4.458c0-1.104-0.896-2-2-2H27.77c-1.104,0-2,0.896-2,2v4.461 c-3.08,0.777-5.922,2.171-8.447,4.144l-3.545-2.82c-0.415-0.33-0.94-0.479-1.472-0.422c-0.527,0.06-1.009,0.327-1.339,0.743 l-4.472,5.623c-0.688,0.864-0.544,2.123,0.32,2.81l3.642,2.896v0c-1.25,2.848-1.895,5.88-1.916,9.011l-4.666,1.078 c-1.076,0.249-1.747,1.322-1.499,2.398l1.616,7.001c0.249,1.077,1.325,1.747,2.399,1.499l4.813-1.111v0 c1.429,2.681,3.344,5.017,5.691,6.943l-2.17,4.55c-0.476,0.997-0.054,2.19,0.943,2.666l6.484,3.094 c0.271,0.129,0.566,0.195,0.861,0.195c0.226,0,0.451-0.038,0.668-0.115c0.5-0.177,0.909-0.545,1.138-1.024l2.198-4.611 c2.923,0.563,5.966,0.554,8.879-0.033l2.236,4.585c0.484,0.994,1.685,1.403,2.675,0.921l6.456-3.148 c0.992-0.484,1.405-1.682,0.921-2.674l-2.206-4.524c2.335-1.946,4.231-4.301,5.639-6.999l4.812,1.067 c1.076,0.237,2.146-0.441,2.385-1.52l1.556-7.014c0.115-0.518,0.02-1.06-0.266-1.508C59.82,62.878,59.369,62.562,58.852,62.447z M40.18,61.761c0,4.859-3.953,8.812-8.813,8.812c-4.858,0-8.811-3.953-8.811-8.812s3.952-8.812,8.811-8.812 C36.227,52.949,40.18,56.902,40.18,61.761z\"/> <path d=\"M64.268,45.324c0.746,0,1.463-0.42,1.806-1.139l1.054-2.208c1.826,0.353,3.736,0.345,5.551-0.021l1.07,2.195 c0.484,0.992,1.682,1.405,2.675,0.921l2.691-1.313c0.477-0.233,0.842-0.646,1.015-1.147c0.172-0.501,0.139-1.051-0.095-1.528 l-1.052-2.155c1.458-1.214,2.645-2.686,3.527-4.377l2.278,0.504c1.075,0.238,2.146-0.442,2.386-1.52l0.647-2.923 c0.238-1.078-0.442-2.146-1.521-2.385l-2.184-0.484c-0.028-1.962-0.449-3.857-1.248-5.632l1.673-1.355 c0.412-0.334,0.675-0.818,0.73-1.345s-0.102-1.056-0.436-1.468l-1.884-2.327c-0.697-0.859-1.957-0.99-2.813-0.295l-1.614,1.307 c-1.554-1.193-3.299-2.038-5.188-2.513v-2.039c0-1.104-0.896-2-2-2h-2.994c-1.104,0-2,0.896-2,2v2.04 c-1.927,0.486-3.703,1.358-5.28,2.592l-1.634-1.298c-0.862-0.687-2.12-0.543-2.81,0.32l-1.864,2.344 c-0.33,0.416-0.481,0.945-0.422,1.472c0.061,0.527,0.327,1.009,0.743,1.339l1.69,1.345c-0.78,1.779-1.184,3.676-1.197,5.636 l-2.189,0.505c-0.517,0.119-0.965,0.439-1.246,0.889c-0.281,0.45-0.372,0.993-0.252,1.51l0.675,2.918 c0.249,1.076,1.323,1.747,2.398,1.498l2.28-0.527c0.892,1.676,2.089,3.137,3.559,4.343l-1.035,2.17 c-0.228,0.479-0.257,1.028-0.08,1.528c0.178,0.5,0.546,0.91,1.024,1.138l2.703,1.289C63.686,45.261,63.979,45.324,64.268,45.324z M64.334,27.961c0-3.039,2.473-5.51,5.512-5.51c3.038,0,5.51,2.472,5.51,5.51c0,3.039-2.472,5.511-5.51,5.511 C66.807,33.472,64.334,31,64.334,27.961z\"/> <path d=\"M96.107,66.441l-2.182-0.484c-0.028-1.961-0.449-3.856-1.25-5.632l1.675-1.355c0.412-0.334,0.675-0.818,0.73-1.346 c0.056-0.527-0.102-1.056-0.436-1.468l-1.885-2.327c-0.695-0.859-1.956-0.99-2.813-0.295l-1.614,1.307 c-1.555-1.193-3.3-2.038-5.188-2.513v-2.039c0-1.104-0.896-2-2-2h-2.994c-1.104,0-2,0.896-2,2v2.041 c-1.929,0.486-3.706,1.358-5.282,2.592l-0.001,0l-1.631-1.298c-0.415-0.331-0.938-0.482-1.472-0.422 c-0.527,0.06-1.009,0.327-1.339,0.742l-1.863,2.343c-0.688,0.865-0.544,2.123,0.32,2.811l1.691,1.345 c-0.782,1.784-1.186,3.68-1.199,5.636l-2.188,0.505c-0.517,0.12-0.965,0.439-1.246,0.889c-0.281,0.45-0.372,0.993-0.252,1.51 l0.675,2.918c0.249,1.076,1.327,1.744,2.397,1.498l2.281-0.526c0.893,1.677,2.09,3.138,3.558,4.343h0.001l-1.035,2.168 c-0.229,0.479-0.258,1.029-0.081,1.529c0.178,0.5,0.546,0.909,1.024,1.138l2.702,1.289c0.278,0.132,0.571,0.195,0.86,0.195 c0.746,0,1.463-0.42,1.806-1.139l1.054-2.208c1.828,0.353,3.739,0.347,5.552-0.021l1.071,2.194 c0.484,0.992,1.682,1.405,2.675,0.921l2.69-1.312c0.477-0.233,0.842-0.645,1.014-1.147c0.173-0.501,0.14-1.051-0.093-1.528 l-1.052-2.155c1.459-1.215,2.645-2.688,3.525-4.377l2.278,0.505c0.52,0.116,1.061,0.02,1.508-0.266 c0.447-0.285,0.763-0.736,0.878-1.254l0.647-2.923C97.866,67.748,97.186,66.681,96.107,66.441z M85.162,66.174 c0,3.039-2.471,5.511-5.508,5.511c-3.039,0-5.512-2.472-5.512-5.511c0-3.039,2.473-5.511,5.512-5.511 C82.691,60.664,85.162,63.136,85.162,66.174z\"/> </g> </svg> "
108 },
109 "descriptors": []
110 }, {
111 "id": "GUID-3",
112 "name": "RIFT.ware™ PNF Descriptors Catalog",
113 "short-name": "rift.ware-pnfd-cat",
114 "description": "RIFT.ware™, an open source NFV development and deployment software platform that makes it simple to create, deploy and manage hyper-scale Virtual network functions and applications.",
115 "vendor": "RIFT.io",
116 "version": "",
117 "created-on": "",
118 "type": "pnfd",
119 "meta": {
120 "icon-svg": "data:image/svg+xml,<?xml version=\"1.0\" encoding=\"utf-8\"?> <!-- Generator: Adobe Illustrator 16.0.0, SVG Export Plug-In . SVG Version: 6.00 Build 0) --> <!DOCTYPE svg PUBLIC \"-//W3C//DTD SVG 1.1//EN\" \"http://www.w3.org/Graphics/SVG/1.1/DTD/svg11.dtd\"> <svg version=\"1.1\" id=\"Layer_4\" xmlns=\"http://www.w3.org/2000/svg\" xmlns:xlink=\"http://www.w3.org/1999/xlink\" x=\"0px\" y=\"0px\" width=\"100px\" height=\"100px\" viewBox=\"0 0 100 100\" enable-background=\"new 0 0 100 100\" xml:space=\"preserve\"> <path d=\"M86.334,47.444V35.759H13.666v11.686h3.561v5.111h-3.561v11.686h72.668V52.556h-4.108v-5.111H86.334z M26.628,59.454h-5.051 v-4.941h5.051V59.454z M26.628,52.404h-5.051v-4.941h5.051V52.404z M26.628,45.486h-5.051v-4.941h5.051V45.486z M34.094,59.454 h-5.051v-4.941h5.051V59.454z M34.094,52.404h-5.051v-4.941h5.051V52.404z M34.094,45.486h-5.051v-4.941h5.051V45.486z M41.452,59.454h-5.051v-4.941h5.051V59.454z M41.452,52.404h-5.051v-4.941h5.051V52.404z M41.452,45.486h-5.051v-4.941h5.051 V45.486z M48.733,59.454h-5.051v-4.941h5.051V59.454z M48.733,52.404h-5.051v-4.941h5.051V52.404z M48.733,45.486h-5.051v-4.941 h5.051V45.486z M56.2,59.454h-5.051v-4.941H56.2V59.454z M56.2,52.404h-5.051v-4.941H56.2V52.404z M56.2,45.486h-5.051v-4.941H56.2 V45.486z M63.558,59.454h-5.05v-4.941h5.05V59.454z M63.558,52.404h-5.05v-4.941h5.05V52.404z M63.558,45.486h-5.05v-4.941h5.05 V45.486z M74.858,59.312h-6.521v-3.013h6.521V59.312z M71.572,50.854c-2.875,0-5.204-2.33-5.204-5.203s2.329-5.203,5.204-5.203 s5.204,2.33,5.204,5.203S74.446,50.854,71.572,50.854z M74.858,45.618c0,1.801-1.46,3.261-3.261,3.261 c-1.8,0-3.261-1.46-3.261-3.261s1.46-3.26,3.261-3.26C73.398,42.358,74.858,43.817,74.858,45.618z\"/> </svg>"
121 },
122 "descriptors": []
123 }];
124 if (result[0].body) {
125 response[0].descriptors = JSON.parse(result[0].body).collection['nsd:nsd'];
126 if (result[2].body) {
127 var data = JSON.parse(result[2].body);
128 if (data && data["nsr:ns-instance-opdata"] && data["nsr:ns-instance-opdata"]["rw-nsr:nsd-ref-count"]) {
129 var nsdRefCountCollection = data["nsr:ns-instance-opdata"]["rw-nsr:nsd-ref-count"];
130 response[0].descriptors.map(function(nsd) {
131 if (!nsd["meta"]) {
132 nsd["meta"] = {};
133 }
134 if (typeof nsd['meta'] == 'string') {
135 nsd['meta'] = JSON.parse(nsd['meta']);
136 }
137 nsd["meta"]["instance-ref-count"] = _.findWhere(nsdRefCountCollection, {
138 "nsd-id-ref": nsd.id
139 })["instance-ref-count"];
140 });
141 }
142 }
143 };
144 if (result[1].body) {
145 response[1].descriptors = JSON.parse(result[1].body).collection['vnfd:vnfd'];
146 };
147 // if (result[2].body) {
148 // response[2].descriptors = JSON.parse(result[2].body).collection['pnfd:pnfd'];
149 // };
150 resolve({
151 statusCode: response.statusCode || 200,
152 data: JSON.stringify(response)
153 });
154 }).catch(function(error) {
155 // Todo: Need better logic than all or nothing.
156 // Right now even if one of the southbound APIs fails - all fail
157 var res = {};
158 console.log('Problem with Composer.get', error);
159 res.statusCode = error.statusCode || 500;
160 res.errorMessage = {
161 error: 'Failed to get catalogs' + error
162 };
163 reject(res);
164 });
165 });
166 };
167 Composer.delete = function(req) {
168 var api_server = req.query['api_server'];
169 var catalogType = req.params.catalogType;
170 var id = req.params.id;
171 console.log('Deleting', catalogType, id, 'from', api_server);
172 return new Promise(function(resolve, reject) {
173 request({
174 uri: utils.confdPort(api_server) + APIVersion + '/api/config/' + catalogType + '-catalog/' + catalogType + '/' + id,
175 method: 'DELETE',
176 headers: _.extend({}, constants.HTTP_HEADERS.accept.data, {
177 'Authorization': req.get('Authorization')
178 }),
179 forever: constants.FOREVER_ON,
180 rejectUnauthorized: false,
181 }, function(error, response, body) {
182 if (utils.validateResponse('Composer.delete', error, response, body, resolve, reject)) {
183 resolve({
184 statusCode: response.statusCode
185 });
186 }
187 });
188 });
189 };
190 Composer.getVNFD = function(req) {
191 var api_server = req.query['api_server'];
192 var vnfdID = req.body.data;
193 var authorization = req.get('Authorization');
194 var VNFDs = [];
195 if (typeof(vnfdID) == "object" && vnfdID.constructor.name == "Array") {
196 vnfdID.map(function(id) {
197 VNFDs.push(requestVNFD(id));
198 });
199 } else {
200 VNFDs.push(requestVNFD(vnfdID));
201 }
202 return new Promise(function(resolve, reject) {
203 Promise.all(VNFDs).then(function(data) {
204 resolve(data)
205 }).catch(function(error) {
206 // Todo: Need better logic than all or nothing.
207 // Right now even if one of the southbound APIs fails - all fail
208 var res = {};
209 console.log('Problem with Composer.getVNFD', error);
210 res.statusCode = 404;
211 res.errorMessage = {
212 error: 'Failed to get VNFDs' + error
213 };
214 reject(res);
215 });
216 });
217
218 function requestVNFD(id) {
219 return new Promise(function(resolve, reject) {
220 var url = utils.confdPort(api_server) + APIVersion + '/api/config/vnfd-catalog/vnfd' + (id ? '/' + id : '') + '?deep';
221 request({
222 uri: url,
223 method: 'GET',
224 headers: _.extend({}, constants.HTTP_HEADERS.accept.data, {
225 'Authorization': authorization
226 }),
227 forever: constants.FOREVER_ON,
228 rejectUnauthorized: false,
229 }, function(error, response, body) {
230 if (utils.validateResponse('Composer.create', error, response, body, resolve, reject)) {
231 var data;
232 //Is this still needed?
233 try {
234 data = JSON.parse(response.body)
235 } catch (e) {
236 reject({
237 statusCode: response ? response.statusCode : 400,
238 errorMessage: 'Issue parsing VNFD ' + id + 'from ' + utils.confdPort(api_server) + '/api/config/vnfd-catalog/vnfd/' + id + '?deep'
239 });
240 }
241 resolve(data);
242 }
243 });
244 });
245 }
246 };
247 Composer.create = function(req) {
248 var api_server = req.query['api_server'];
249 var catalogType = req.params.catalogType;
250 var data = req.body;
251 console.log('Creating', catalogType, 'on', api_server);
252 var jsonData = {};
253 jsonData[catalogType] = [];
254 jsonData[catalogType].push(data);
255 return new Promise(function(resolve, reject) {
256 var requestHeaders = {};
257 _.extend(requestHeaders, constants.HTTP_HEADERS.accept.data, constants.HTTP_HEADERS.content_type.data, {
258 'Authorization': req.get('Authorization')
259 });
260 request({
261 uri: utils.confdPort(api_server) + '/api/config/' + catalogType + '-catalog',
262 method: 'POST',
263 headers: requestHeaders,
264 forever: constants.FOREVER_ON,
265 rejectUnauthorized: false,
266 json: jsonData
267 }, function(error, response, body) {
268 if (utils.validateResponse('Composer.create', error, response, body, resolve, reject)) {
269 resolve({
270 statusCode: response.statusCode
271 });
272 }
273 });
274 });
275 };
276 Composer.updateSave = function(req) {
277 var api_server = req.query['api_server'];
278 var catalogType = req.params.catalogType;
279 var id = req.params.id;
280 var data = req.body;
281 console.log('Updating', catalogType, 'id', id, 'on', api_server);
282 var jsonData = {};
283 jsonData[catalogType] = {};
284 jsonData[catalogType] = data;
285 return new Promise(function(resolve, reject) {
286 var requestHeaders = {};
287 _.extend(requestHeaders, constants.HTTP_HEADERS.accept.data, constants.HTTP_HEADERS.content_type.data, {
288 'Authorization': req.get('Authorization')
289 });
290 request({
291 uri: utils.confdPort(api_server) + APIVersion + '/api/config/' + catalogType + '-catalog' + '/' + catalogType + '/' + id,
292 method: 'PUT',
293 headers: requestHeaders,
294 forever: constants.FOREVER_ON,
295 rejectUnauthorized: false,
296 json: jsonData
297 }, function(error, response, body) {
298 if (utils.validateResponse('Composer.update', error, response, body, resolve, reject)) {
299 resolve({
300 statusCode: response.statusCode
301 });
302 }
303 });
304 });
305 }
306
307 PackageManager.upload = function(req) {
308 console.log(' Uploading file', req.file.originalname, 'as', req.file.filename);
309 var api_server = req.query['api_server'];
310 // dev_download_server is for testing purposes.
311 // It is the direct IP address of the Node server where the
312 // package will be hosted.
313 var download_host = req.query['dev_download_server'];
314
315 if (!download_host) {
316 download_host = req.protocol + '://' + req.get('host');//req.api_server + ':' + utils.getPortForProtocol(req.protocol);
317 }
318
319 return new Promise(function(resolve, reject) {
320 Promise.all([
321 rp({
322 uri: utils.confdPort(api_server) + '/api/operations/package-create',
323 method: 'POST',
324 headers: _.extend({}, constants.HTTP_HEADERS.accept.collection, {
325 'Authorization': req.get('Authorization')
326 }),
327 forever: constants.FOREVER_ON,
328 rejectUnauthorized: false,
329 resolveWithFullResponse: true,
330 json: true,
331 body: {
332 input: {
333 'external-url': download_host + '/composer/upload/' + req.file.filename,
334 'package-type': 'VNFD',
335 'package-id': uuid()
336 }
337 }
338 })
339 ]).then(function(result) {
340 var data = {};
341 data['transaction_id'] = result[0].body['output']['transaction-id'];
342
343 // Add a status checker on the transaction and then to delete the file later
344 PackageFileHandler.checkCreatePackageStatusAndHandleFile(req, data['transaction_id']);
345
346 // Return status to composer UI to update the status.
347 resolve({
348 statusCode: constants.HTTP_RESPONSE_CODES.SUCCESS.OK,
349 data: data
350 });
351 }).catch(function(error) {
352 var res = {};
353 console.log('Problem with PackageManager.upload', error);
354 res.statusCode = error.statusCode || 500;
355 res.errorMessage = {
356 error: 'Failed to upload package ' + req.file.originalname + '. Error: ' + error
357 };
358 reject(res);
359 });
360 });
361 };
362
363 PackageManager.update = function(req) {
364 console.log(' Updating file', req.file.originalname, 'as', req.file.filename);
365 var api_server = req.query['api_server'];
366 // dev_download_server is for testing purposes.
367 // It is the direct IP address of the Node server where the
368 // package will be hosted.
369 var download_host = req.query['dev_download_server'];
370
371 if (!download_host) {
372 download_host = req.protocol + '://' + req.get('host');//api_server + ':' + utils.getPortForProtocol(req.protocol);
373 }
374 var input = {
375 'external-url': download_host + '/composer/update/' + req.file.filename,
376 'package-type': 'VNFD',
377 'package-id': uuid()
378 }
379 return new Promise(function(resolve, reject) {
380 Promise.all([
381 rp({
382 uri: utils.confdPort(api_server) + '/api/operations/package-update',
383 method: 'POST',
384 headers: _.extend({}, constants.HTTP_HEADERS.accept.collection, {
385 'Authorization': req.get('Authorization')
386 }),
387 forever: constants.FOREVER_ON,
388 rejectUnauthorized: false,
389 resolveWithFullResponse: true,
390 json: true,
391 body: {
392 input: input
393 }
394 })
395 ]).then(function(result) {
396 var data = {};
397 data['transaction_id'] = result[0].body['output']['transaction-id'];
398
399 // Add a status checker on the transaction and then to delete the file later
400 PackageFileHandler.checkCreatePackageStatusAndHandleFile(req, data['transaction_id'], true);
401
402 // Return status to composer UI to update the status.
403 resolve({
404 statusCode: constants.HTTP_RESPONSE_CODES.SUCCESS.OK,
405 data: data
406 });
407 }).catch(function(error) {
408 var res = {};
409 console.log('Problem with Composer.upload', error);
410 res.statusCode = error.statusCode || 500;
411 res.errorMessage = {
412 error: 'Failed to upload package ' + req.file.originalname + '. Error: ' + error
413 };
414 reject(res);
415 });
416 });
417 };
418
419 PackageManager.export = function(req) {
420 // /api/operations/package-export
421 var api_server = req.query['api_server'];
422 return new Promise(function(resolve, reject) {
423 Promise.all([
424 rp({
425 uri: utils.confdPort(api_server) + '/api/operations/package-export',
426 method: 'POST',
427 headers: _.extend({}, constants.HTTP_HEADERS.accept.collection, {
428 'Authorization': req.get('Authorization')
429 }),
430 forever: constants.FOREVER_ON,
431 rejectUnauthorized: false,
432 resolveWithFullResponse: true,
433 json: true,
434 body: { "input": req.body}
435 })
436 ]).then(function(result) {
437 var data = {};
438 resolve({
439 statusCode: constants.HTTP_RESPONSE_CODES.SUCCESS.OK,
440 data: result[0].body
441 });
442 }).catch(function(error) {
443 var res = {};
444 console.log('Problem with PackageManager.export', error);
445 res.statusCode = error.statusCode || 500;
446 res.errorMessage = {
447 error: error
448 };
449 reject(res);
450 });
451 });
452 }
453
454 PackageManager.copy = function(req) {
455 // /api/operations/package-copy
456 var api_server = req.query['api_server'];
457 return new Promise(function(resolve, reject) {
458 Promise.all([
459 rp({
460 uri: utils.confdPort(api_server) + '/api/operations/package-copy',
461 method: 'POST',
462 headers: _.extend({}, constants.HTTP_HEADERS.accept.collection, {
463 'Authorization': req.get('Authorization')
464 }),
465 forever: constants.FOREVER_ON,
466 rejectUnauthorized: false,
467 resolveWithFullResponse: true,
468 json: true,
469 body: { "input": req.body}
470 })
471 ]).then(function(result) {
472 var data = {};
473 resolve({
474 statusCode: constants.HTTP_RESPONSE_CODES.SUCCESS.OK,
475 data: result[0].body
476 });
477 }).catch(function(error) {
478 var res = {};
479 console.log('Problem with PackageManager.copy', error);
480 res.statusCode = error.statusCode || 500;
481 res.errorMessage = {
482 error: error
483 };
484 reject(res);
485 });
486 });
487 }
488
489 /**
490 * This methods retrieves the status of package operations. It takes an optional
491 * transaction id (id) this if present will return only that status otherwise
492 * an array of status' will be response.
493 */
494 PackageManager.getJobStatus = function(req) {
495 var api_server = req.query["api_server"];
496 var uri = utils.confdPort(api_server);
497 var id = req.params['id'];
498 var url = uri + '/api/operational/copy-jobs' + (id ? '/job/' + id : '');
499 return new Promise(function(resolve, reject) {
500 request({
501 url: url,
502 method: 'GET',
503 headers: _.extend({}, constants.HTTP_HEADERS.accept.data, {
504 'Authorization': req.get('Authorization')
505 }),
506 forever: constants.FOREVER_ON,
507 rejectUnauthorized: false
508 }, function(error, response, body) {
509 if (utils.validateResponse('restconfAPI.streams', error, response, body, resolve, reject)) {
510 var returnData;
511 if (id) {
512 returnData = JSON.parse(response.body)['rw-pkg-mgmt:job'];
513 } else {
514 var data = JSON.parse(response.body)['rw-pkg-mgmt:copy-jobs'];
515 returnData = (data && data.job) || [];
516 }
517 resolve({
518 statusCode: response.statusCode,
519 data: returnData
520 })
521 };
522 })
523 })
524 }
525
526 FileManager.addFile = function(req) {
527 console.log(' Uploading file', req.file.originalname, 'as', req.file.filename);
528 var api_server = req.query['api_server'];
529 var download_host = req.query['dev_download_server'];
530 var package_id = req.query['package_id'];
531 var package_type = req.query['package_type'].toUpperCase();
532 var package_path = req.query['package_path'];
533 if (!download_host) {
534 download_host = req.protocol + '://' + req.get('host');//api_server + ':' + utils.getPortForProtocol(req.protocol);
535 }
536 var input = {
537 'external-url': download_host + '/composer/upload/' + req.query['package_id'] + '/' + req.file.filename,
538 'package-type': package_type,
539 'package-id': package_id,
540 'package-path': package_path + '/' + req.file.filename
541 }
542 return new Promise(function(resolve, reject) {
543 Promise.all([
544 rp({
545 uri: utils.confdPort(api_server) + '/api/operations/package-file-add',
546 method: 'POST',
547 headers: _.extend({}, constants.HTTP_HEADERS.accept.collection, {
548 'Authorization': req.get('Authorization')
549 }),
550 forever: constants.FOREVER_ON,
551 rejectUnauthorized: false,
552 resolveWithFullResponse: true,
553 json: true,
554 body: {
555 input: input
556 }
557 })
558 ]).then(function(result) {
559 var data = {};
560 data['transaction_id'] = result[0].body['output']['task-id'];
561 resolve({
562 statusCode: constants.HTTP_RESPONSE_CODES.SUCCESS.OK,
563 data: data
564 });
565 }).catch(function(error) {
566 var res = {};
567 console.log('Problem with Composer.upload', error);
568 res.statusCode = error.statusCode || 500;
569 res.errorMessage = {
570 error: 'Failed to upload package ' + req.file.originalname + '. Error: ' + error
571 };
572 reject(res);
573 });
574 });
575 }
576
577 FileManager.get = function(req) {
578 var api_server = req.query['api_server'];
579 var type = req.query['package_type'] && req.query['package_type'].toUpperCase();
580 var id = req.query['package_id'];
581 var downloadUrl = req.query['url'];
582 var path = req.query['package_path'];
583 var payload = {
584 "input": {
585 "package-type": type,
586 "package-id": id
587 }
588 }
589 if(req.method == 'GET') {
590 if(downloadUrl && path) {
591 payload.input['external-url'] = downloadUrl;
592 payload.input['package-path'] = path;
593 return download(payload);
594 } else {
595 return list(payload);
596 }
597 }
598 if(req.method == 'DELETE') {
599 payload.input['package-path'] = path;
600 return deleteFile(payload)
601 }
602
603 function deleteFile(payload) {
604 return new Promise(function(resolve, reject) {
605 rp({
606 uri: utils.confdPort(api_server) + '/api/operations/rw-pkg-mgmt:package-file-delete',
607 method: 'POST',
608 headers: _.extend({}, constants.HTTP_HEADERS.accept.collection, {
609 'Authorization': req.get('Authorization')
610 }),
611 json: payload,
612 forever: constants.FOREVER_ON,
613 rejectUnauthorized: false,
614 resolveWithFullResponse: true
615 }).then(function(data) {
616 if (utils.validateResponse('FileManager.delete', data.error, data, data.body, resolve, reject)) {
617 resolve({
618 statusCode: data.statusCode,
619 data: data.body
620 });
621 }
622 })
623 })
624 }
625 function download(payload) {
626 return new Promise(function(resolve, reject) {
627 rp({
628 uri: utils.confdPort(api_server) + '/api/operations/rw-pkg-mgmt:package-file-add',
629 method: 'POST',
630 headers: _.extend({}, constants.HTTP_HEADERS.accept.collection, {
631 'Authorization': req.get('Authorization')
632 }),
633 json: payload,
634 forever: constants.FOREVER_ON,
635 rejectUnauthorized: false,
636 resolveWithFullResponse: true
637 }).then(function(data) {
638 if (utils.validateResponse('FileManager.get', data.error, data, data.body, resolve, reject)) {
639 resolve({
640 statusCode: data.statusCode,
641 data: data.body
642 });
643 }
644 })
645 })
646 }
647 function list(payload) {
648 return new Promise(function(resolve, reject) {
649 rp({
650 uri: utils.confdPort(api_server) + '/api/operations/get-package-endpoint',
651 method: 'POST',
652 headers: _.extend({}, constants.HTTP_HEADERS.accept.collection, {
653 'Authorization': req.get('Authorization')
654 }),
655 json: payload,
656 forever: constants.FOREVER_ON,
657 rejectUnauthorized: false,
658 resolveWithFullResponse: true
659 }).then(function(data) {
660 if (utils.validateResponse('FileManager.get', data.error, data, data.body, resolve, reject)) {
661 var endpoint = null;
662 var parsedEndpoint = null;
663 try {
664 endpoint = data.body.output.endpoint
665 } catch(e) {
666 console.log('Something went wrong with the FileManager.get data that was returned');
667 reject({});
668 }
669 parsedEndpoint = URL.parse(endpoint);
670 rp({
671 uri: api_server + ':' + parsedEndpoint.port + parsedEndpoint.path,
672 method: 'GET',
673 headers: _.extend({}, constants.HTTP_HEADERS.accept.collection, {
674 'Authorization': req.get('Authorization')
675 }),
676 forever: constants.FOREVER_ON,
677 rejectUnauthorized: false,
678 resolveWithFullResponse: true
679 }).then(function(data) {
680 if (utils.validateResponse('FileManager.get', data.error, data, data.body, resolve, reject)) {
681 resolve({
682 statusCode: data.statusCode,
683 data: data.body
684 });
685 }
686 }).catch(function(err) {
687 console.log('Failed to retrieve FileManager.list')
688 resolve(err);
689 })
690 }
691 })
692 })
693 }
694 }
695 FileManager.job = function(req) {
696 var api_server = req.query["api_server"];
697 var uri = utils.confdPort(api_server);
698 var url = '/api/operational/download-jobs';
699 var id = req.params['id'];
700 return new Promise(function(resolve, reject) {
701 request({
702 url: uri + url + '?deep',
703 method: 'GET',
704 headers: _.extend({}, constants.HTTP_HEADERS.accept.data, {
705 'Authorization': req.get('Authorization')
706 }),
707 forever: constants.FOREVER_ON,
708 rejectUnauthorized: false,
709 }, function(error, response, body) {
710 if (utils.validateResponse('restconfAPI.streams', error, response, body, resolve, reject)) {
711 var data = JSON.parse(response.body)['rw-pkg-mgmt:download-jobs'];
712 var returnData = [];
713 data && data.job.map(function(d) {
714 if(d['package-id'] == id) {
715 returnData.push(d)
716 }
717 })
718 resolve({
719 statusCode: response.statusCode,
720 data: returnData
721 })
722 };
723 })
724 })
725 }
726 module.exports = {
727 Composer:Composer,
728 FileManager: FileManager,
729 PackageManager: PackageManager
730 };