blob: d8dfaf3cfe47a8f317bdc831383f3f40943fa8c9 [file] [log] [blame]
Matteo Scandolo8a64fa42016-01-21 11:21:03 -08001(function () {
2 'use strict';
3
Matteo Scandolo04564952016-02-24 11:22:48 -08004 angular.module('xos.diagnostic')
Matteo Scandolo8a64fa42016-01-21 11:21:03 -08005 .service('Services', function($resource){
Matteo Scandolof16b3792016-01-21 14:23:28 -08006 return $resource('/xos/services/:id', {id: '@id'});
7 })
8 .service('Tenant', function($resource){
Matteo Scandolo51031482016-02-17 13:54:11 -08009 return $resource('/xos/tenants', {id: '@id'}, {
10 queryVsgInstances: {
11 method: 'GET',
12 isArray: true,
13 interceptor: {
14 response: (res) => {
15
16 // NOTE
17 // Note that VCPETenant is now VSGTenant.
18
19 let instances = [];
20
21 angular.forEach(res.data, (tenant) => {
22 let info = JSON.parse(tenant.service_specific_attribute);
23 if(info && info.instance_id){
24 instances.push(info.instance_id);
25 }
26 });
27
28 return instances;
29 }
30 }
Matteo Scandolo45fba732016-02-22 14:53:44 -080031 },
32 getSubscriberTag: {
33 method: 'GET',
34 isArray: true,
35 interceptor: {
36 response: (res) => {
37 // NOTE we should receive only one vOLT tenant here
38 return JSON.parse(res.data[0].service_specific_attribute);
39 }
40 }
Matteo Scandolo51031482016-02-17 13:54:11 -080041 }
42 });
43 })
44 .service('Ceilometer', function($http, $q, Instances) {
45
46 /**
47 * Get stats for a single instance
48 */
49 this.getInstanceStats = (instanceUuid) => {
50 let deferred = $q.defer();
51
Matteo Scandolof0d6e692016-02-24 11:14:01 -080052 $http.get('/xoslib/xos-instance-statistics', {params: {'instance-uuid': instanceUuid}})
Matteo Scandolo51031482016-02-17 13:54:11 -080053 .then((res) => {
54 deferred.resolve(res.data);
55 })
56 .catch((e) => {
57 deferred.reject(e);
58 })
59
60 return deferred.promise;
61 };
62
63 /**
64 * Collect stats for an array of instances
65 */
66 this.getInstancesStats = (instances) => {
67 let deferred = $q.defer();
68 let instancePromises = [];
69 let instanceList = [];
70
71 // retrieve instance details
72 instances.forEach((instanceId) => {
73 instancePromises.push(Instances.get({id: instanceId}).$promise);
74 });
75
76 // get all instance data
77 $q.all(instancePromises)
78 .then((_instanceList) => {
79 instanceList = _instanceList;
80 let promises = [];
81 // foreach instance query stats
82 instanceList.forEach((instance) => {
83 promises.push(this.getInstanceStats(instance.instance_uuid));
84 });
85 return $q.all(promises);
86 })
87 .then(stats => {
88 // augment instance with stats information
89 instanceList.map((instance, i) => {
90 instance.stats = stats[i];
91 });
92 deferred.resolve(instanceList);
93 })
94 .catch(deferred.reject);
95
96 return deferred.promise;
97 };
Matteo Scandolof0d6e692016-02-24 11:14:01 -080098
99 this.getContainerStats = (containerName) => {
100 const deferred = $q.defer();
101
102 let res = {};
103
104 $http.get('/xoslib/meterstatistics', {params: {'resource': containerName}})
105 .then((containerStats) => {
106 res.stats = containerStats.data;
107 return $http.get('/xoslib/meterstatistics', {params: {'resource': `${containerName}-eth0`}})
108 })
109 .then((portStats) => {
110 res.port = {
111 eth0: portStats.data
112 };
113 return $http.get('/xoslib/meterstatistics', {params: {'resource': `${containerName}-eth1`}})
114 })
115 .then((portStats) => {
116 res.port.eth1 = portStats.data;
117 deferred.resolve(res);
118 })
119 .catch((e) => {
120 deferred.reject(e);
121 })
122
123 return deferred.promise;
124 }
Matteo Scandolof16b3792016-01-21 14:23:28 -0800125 })
Matteo Scandolo06f45d62016-01-21 15:38:06 -0800126 .service('Slice', function($resource){
127 return $resource('/xos/slices', {id: '@id'});
128 })
129 .service('Instances', function($resource){
Matteo Scandolo51031482016-02-17 13:54:11 -0800130 return $resource('/xos/instances/:id', {id: '@id'});
Matteo Scandolo170d3be2016-02-11 08:58:04 -0800131 })
132 .service('Node', function($resource, $q, Instances){
133 return $resource('/xos/nodes', {id: '@id'}, {
134 queryWithInstances: {
135 method: 'GET',
136 isArray: true,
137 interceptor: {
138 response: function(res){
139
140 // TODO update the API to include instances in nodes
141 // http://stackoverflow.com/questions/14573102/how-do-i-include-related-model-fields-using-django-rest-framework
142
143 const deferred = $q.defer();
144
145 let requests = [];
146
147 angular.forEach(res.data, (node) => {
148 requests.push(Instances.query({node: node.id}).$promise);
149 })
150
151 $q.all(requests)
152 .then((list) => {
153 res.data.map((node, i) => {
154 node.instances = list[i];
155 return node;
156 });
Matteo Scandolo170d3be2016-02-11 08:58:04 -0800157 deferred.resolve(res.data);
158 })
159
160 return deferred.promise;
161 }
162 }
163 }
164 });
Matteo Scandolo06f45d62016-01-21 15:38:06 -0800165 })
Matteo Scandolo7547f042016-02-09 09:13:30 -0800166 .service('Subscribers', function($resource, $q, SubscriberDevice){
Matteo Scandolod4ea8772016-03-01 15:20:29 -0800167 return $resource('/xoslib/cordsubscriber/:id', {id: '@id'}, {
Matteo Scandolo6c6e5942016-03-02 10:59:46 -0800168 update: {
169 method: 'PUT',
170 isArray: false
171 },
Matteo Scandolo7547f042016-02-09 09:13:30 -0800172 queryWithDevices: {
173 method: 'GET',
174 isArray: true,
175 interceptor: {
176 response: function(res){
Matteo Scandolo219b1a72016-02-09 11:19:22 -0800177
178 /**
179 * For each subscriber retrieve devices and append them
180 */
181
Matteo Scandolo45fba732016-02-22 14:53:44 -0800182 let deferred = $q.defer();
Matteo Scandolo7547f042016-02-09 09:13:30 -0800183
184 let requests = [];
185
186 angular.forEach(res.data, (subscriber) => {
Matteo Scandolo219b1a72016-02-09 11:19:22 -0800187 requests.push(SubscriberDevice.query({id: subscriber.id}).$promise);
Matteo Scandolo7547f042016-02-09 09:13:30 -0800188 })
189
190 $q.all(requests)
191 .then((list) => {
Matteo Scandolo7e67a9a2016-02-16 16:33:26 -0800192
193 // adding devices
194
Matteo Scandolo7547f042016-02-09 09:13:30 -0800195 res.data.map((subscriber, i) => {
196 subscriber.devices = list[i];
Matteo Scandolo9fe01af2016-02-09 16:01:49 -0800197 subscriber.type = 'subscriber';
198
199 subscriber.devices.map(d => d.type = 'device')
200
Matteo Scandolo7547f042016-02-09 09:13:30 -0800201 return subscriber;
202 });
Matteo Scandolo219b1a72016-02-09 11:19:22 -0800203
Matteo Scandolo9fe01af2016-02-09 16:01:49 -0800204 // faking to have 2 subscriber
Matteo Scandolofd468582016-02-16 16:03:43 -0800205 // res.data.push(angular.copy(res.data[0]));
Matteo Scandolo9fe01af2016-02-09 16:01:49 -0800206
Matteo Scandolo7547f042016-02-09 09:13:30 -0800207 deferred.resolve(res.data);
208 })
209
210 return deferred.promise;
211 }
212 }
Matteo Scandolo45fba732016-02-22 14:53:44 -0800213 },
214 getWithDevices: {
215 method: 'GET',
216 isArray: false,
217 interceptor: {
218 response: (res) => {
219 let d = $q.defer();
220
221 SubscriberDevice.query({id: res.data.id}).$promise
222 .then(devices => {
223 devices.map(d => d.type = 'device');
224 res.data.devices = devices;
225 res.data.type = 'subscriber';
Matteo Scandolo45fba732016-02-22 14:53:44 -0800226 d.resolve(res.data);
227 })
228 .catch(err => {
229 d.reject(err);
230 });
231
232 return d.promise;
233 }
234 }
Matteo Scandolo7547f042016-02-09 09:13:30 -0800235 }
236 });
237 })
238 .service('SubscriberDevice', function($resource){
239 return $resource('/xoslib/rs/subscriber/:id/users/', {id: '@id'});
Matteo Scandoloff7df762016-01-22 16:36:34 -0800240 })
Matteo Scandolofe307b12016-05-17 14:29:01 -0700241 .service('ServiceRelation', function($q, _, Services, Tenant, Slice, Instances){
Matteo Scandolof16b3792016-01-21 14:23:28 -0800242
Matteo Scandolof2c99012016-01-25 10:10:38 -0800243 // count the mas depth of an object
244 const depthOf = (obj) => {
245 var depth = 0;
246 if (obj.children) {
247 obj.children.forEach(function (d) {
248 var tmpDepth = depthOf(d);
249 if (tmpDepth > depth) {
250 depth = tmpDepth
251 }
252 })
253 }
254 return 1 + depth
255 };
256
Matteo Scandolof16b3792016-01-21 14:23:28 -0800257 // find all the relation defined for a given root
258 const findLevelRelation = (tenants, rootId) => {
Matteo Scandolofe307b12016-05-17 14:29:01 -0700259 return _.filter(tenants, service => {
Matteo Scandolof16b3792016-01-21 14:23:28 -0800260 return service.subscriber_service === rootId;
261 });
262 };
263
Matteo Scandoloc9ebd922016-01-28 12:02:57 -0800264 const findSpecificInformation = (tenants, rootId) => {
Matteo Scandolofe307b12016-05-17 14:29:01 -0700265 var tenants = _.filter(tenants, service => {
Matteo Scandoloc9ebd922016-01-28 12:02:57 -0800266 return service.provider_service === rootId && service.subscriber_tenant;
267 });
268
269 var info;
270
271 tenants.forEach((tenant) => {
272 if(tenant.service_specific_attribute){
273 info = JSON.parse(tenant.service_specific_attribute);
274 }
275 });
276
277 return info;
278 };
279
Matteo Scandolof16b3792016-01-21 14:23:28 -0800280 // find all the service defined by a given array of relations
281 const findLevelServices = (relations, services) => {
282 const levelServices = [];
Matteo Scandolofe307b12016-05-17 14:29:01 -0700283 _.forEach(relations, (tenant) => {
284 var service = _.find(services, {id: tenant.provider_service});
Matteo Scandolof16b3792016-01-21 14:23:28 -0800285 levelServices.push(service);
286 });
287 return levelServices;
288 };
289
Matteo Scandolo012dddb2016-02-22 16:53:22 -0800290 const buildLevel = (tenants, services, rootService, rootTenant, parentName = null) => {
Matteo Scandolof16b3792016-01-21 14:23:28 -0800291
Matteo Scandolof16b3792016-01-21 14:23:28 -0800292 // build an array of unlinked services
293 // these are the services that should still placed in the tree
Matteo Scandolofe307b12016-05-17 14:29:01 -0700294 var unlinkedServices = _.difference(services, [rootService]);
Matteo Scandolof16b3792016-01-21 14:23:28 -0800295
296 // find all relations relative to this rootElement
297 const levelRelation = findLevelRelation(tenants, rootService.id);
Matteo Scandolof16b3792016-01-21 14:23:28 -0800298 // find all items related to rootElement
299 const levelServices = findLevelServices(levelRelation, services);
300
301 // remove this item from the list (performance
Matteo Scandolofe307b12016-05-17 14:29:01 -0700302 unlinkedServices = _.difference(unlinkedServices, levelServices);
Matteo Scandolof16b3792016-01-21 14:23:28 -0800303
Matteo Scandoloc9ebd922016-01-28 12:02:57 -0800304 rootService.service_specific_attribute = findSpecificInformation(tenants, rootService.id);
305
Matteo Scandolo384ff562016-03-07 17:58:34 -0800306 if(rootService.humanReadableName === 'service_vbng'){
307 rootService.humanReadableName = 'service_vrouter'
308 }
309
Matteo Scandoloc9ebd922016-01-28 12:02:57 -0800310 const tree = {
311 name: rootService.humanReadableName,
312 parent: parentName,
313 type: 'service',
314 service: rootService,
Matteo Scandolo012dddb2016-02-22 16:53:22 -0800315 tenant: rootTenant,
Matteo Scandoloc9ebd922016-01-28 12:02:57 -0800316 children: []
317 };
318
Matteo Scandolofe307b12016-05-17 14:29:01 -0700319 _.forEach(levelServices, (service) => {
Matteo Scandolo930e4fd2016-03-07 16:41:25 -0800320 if(service.humanReadableName === 'service_ONOS_vBNG' || service.humanReadableName === 'service_ONOS_vOLT'){
321 // remove ONOSes from service chart
322 return;
323 }
Matteo Scandolofe307b12016-05-17 14:29:01 -0700324 let tenant = _.find(tenants, {subscriber_tenant: rootTenant.id, provider_service: service.id});
Matteo Scandolo012dddb2016-02-22 16:53:22 -0800325 tree.children.push(buildLevel(tenants, unlinkedServices, service, tenant, rootService.humanReadableName));
Matteo Scandolof16b3792016-01-21 14:23:28 -0800326 });
327
Matteo Scandolof2c99012016-01-25 10:10:38 -0800328 // if it is the last element append internet
329 if(tree.children.length === 0){
330 tree.children.push({
Matteo Scandolo9fe01af2016-02-09 16:01:49 -0800331 name: 'Router',
332 type: 'router',
Matteo Scandolof2c99012016-01-25 10:10:38 -0800333 children: []
334 });
335 }
336
Matteo Scandolof16b3792016-01-21 14:23:28 -0800337 return tree;
338 };
339
Matteo Scandolo77d8fa02016-02-16 17:43:00 -0800340 const buildSubscriberServiceTree = (services, tenants, subscriber = {id: 1, name: 'fakeSubs'}) => {
Matteo Scandolof16b3792016-01-21 14:23:28 -0800341
342 // find the root service
343 // it is the one attached to subsriber_root
344 // as now we have only one root so this can work
Matteo Scandolofe307b12016-05-17 14:29:01 -0700345 const rootTenant = _.find(tenants, {subscriber_root: subscriber.id});
346 const rootService = _.find(services, {id: rootTenant.provider_service});
Matteo Scandolof16b3792016-01-21 14:23:28 -0800347
Matteo Scandolo012dddb2016-02-22 16:53:22 -0800348 const serviceTree = buildLevel(tenants, services, rootService, rootTenant);
Matteo Scandolof16b3792016-01-21 14:23:28 -0800349
Matteo Scandoloff7df762016-01-22 16:36:34 -0800350 return {
Matteo Scandolod4ea8772016-03-01 15:20:29 -0800351 name: subscriber.name || subscriber.humanReadableName,
Matteo Scandoloff7df762016-01-22 16:36:34 -0800352 parent: null,
Matteo Scandolof2c99012016-01-25 10:10:38 -0800353 type: 'subscriber',
Matteo Scandoloff7df762016-01-22 16:36:34 -0800354 children: [serviceTree]
355 };
356
Matteo Scandolof16b3792016-01-21 14:23:28 -0800357 };
358
Matteo Scandolo77d8fa02016-02-16 17:43:00 -0800359 // applying domain knowledge to build the global service tree
360 const buildServiceTree = (services, tenants) => {
361
362 // TODO refactor
363 const buildChild = (services, tenants, currentService) => {
Matteo Scandolo45fba732016-02-22 14:53:44 -0800364
Matteo Scandolo384ff562016-03-07 17:58:34 -0800365 if(currentService.humanReadableName === 'service_vbng'){
366 currentService.humanReadableName = 'service_vrouter'
367 }
368
Matteo Scandolo45fba732016-02-22 14:53:44 -0800369 const response = {
370 type: 'service',
371 name: currentService.humanReadableName,
372 service: currentService
373 };
374
Matteo Scandolofe307b12016-05-17 14:29:01 -0700375 let tenant = _.find(tenants, {subscriber_service: currentService.id});
Matteo Scandolo77d8fa02016-02-16 17:43:00 -0800376 if(tenant){
Matteo Scandolofe307b12016-05-17 14:29:01 -0700377 let next = _.find(services, {id: tenant.provider_service});
Matteo Scandolo45fba732016-02-22 14:53:44 -0800378 response.children = [buildChild(services, tenants, next)];
Matteo Scandolo77d8fa02016-02-16 17:43:00 -0800379 }
380 else {
Matteo Scandolo45fba732016-02-22 14:53:44 -0800381 response.children = [
Matteo Scandolo77d8fa02016-02-16 17:43:00 -0800382 {
383 name: 'Router',
384 type: 'router',
385 children: []
386 }
387 ]
388 }
Matteo Scandolo77d8fa02016-02-16 17:43:00 -0800389 delete currentService.id; // conflict with d3
Matteo Scandolo45fba732016-02-22 14:53:44 -0800390 return response;
Matteo Scandolo77d8fa02016-02-16 17:43:00 -0800391 }
Matteo Scandolo70ac2162016-02-24 15:40:22 -0800392
Matteo Scandolofe307b12016-05-17 14:29:01 -0700393 let baseService = _.find(services, {id: 3});
Matteo Scandolo70ac2162016-02-24 15:40:22 -0800394
395 if(!angular.isDefined(baseService)){
396 console.error('Missing Base service!');
397 return;
398 }
Matteo Scandolo77d8fa02016-02-16 17:43:00 -0800399
400 const baseData = {
401 name: 'Subscriber',
402 type: 'subscriber',
403 parent: null,
404 children: [buildChild(services, tenants, baseService)]
405 };
Matteo Scandolo77d8fa02016-02-16 17:43:00 -0800406 return baseData;
407 };
408
409 const getBySubscriber = (subscriber) => {
Matteo Scandolof16b3792016-01-21 14:23:28 -0800410 var deferred = $q.defer();
411 var services, tenants;
412 Services.query().$promise
413 .then((res) => {
414 services = res;
415 return Tenant.query().$promise;
416 })
417 .then((res) => {
418 tenants = res;
Matteo Scandolo77d8fa02016-02-16 17:43:00 -0800419 deferred.resolve(buildSubscriberServiceTree(services, tenants, subscriber));
Matteo Scandolof16b3792016-01-21 14:23:28 -0800420 })
421 .catch((e) => {
422 throw new Error(e);
423 });
424
425 return deferred.promise;
Matteo Scandolof2c99012016-01-25 10:10:38 -0800426 };
Matteo Scandoloff7df762016-01-22 16:36:34 -0800427
Matteo Scandolo77d8fa02016-02-16 17:43:00 -0800428 const get = () => {
429 var deferred = $q.defer();
430 var services, tenants;
431 Services.query().$promise
432 .then((res) => {
433 services = res;
434 return Tenant.query({kind: 'coarse'}).$promise;
435 })
436 .then((res) => {
437 tenants = res;
438 deferred.resolve(buildServiceTree(services, tenants));
439 })
440 .catch((e) => {
441 throw new Error(e);
442 });
443
444 return deferred.promise;
445 }
446
Matteo Scandolof2c99012016-01-25 10:10:38 -0800447 // export APIs
Matteo Scandolo5bf04572016-01-25 17:36:08 -0800448 return {
449 get: get,
Matteo Scandolo5bf04572016-01-25 17:36:08 -0800450 buildServiceTree: buildServiceTree,
Matteo Scandolo77d8fa02016-02-16 17:43:00 -0800451 getBySubscriber: getBySubscriber,
452 buildLevel: buildLevel,
453 buildSubscriberServiceTree: buildSubscriberServiceTree,
Matteo Scandolo5bf04572016-01-25 17:36:08 -0800454 findLevelRelation: findLevelRelation,
455 findLevelServices: findLevelServices,
456 depthOf: depthOf,
Matteo Scandoloc9ebd922016-01-28 12:02:57 -0800457 findSpecificInformation: findSpecificInformation
Matteo Scandolo5bf04572016-01-25 17:36:08 -0800458 }
Matteo Scandolo8a64fa42016-01-21 11:21:03 -0800459 });
460
461}());