gui/ngXosViews/serviceTopology/src/js/services.js

(function () {
  'use strict';

  angular.module('xos.serviceTopology')
  .service('Services', function($resource){
    return $resource('/xos/services/:id', {id: '@id'});
  })
  .service('Tenant', function($resource){
    return $resource('/xos/tenants');
  })
  .service('Slice', function($resource){
    return $resource('/xos/slices', {id: '@id'});
  })
  .service('Instances', function($resource){
    return $resource('/xos/instances', {id: '@id'});
  })
  .service('Subscribers', function($resource){
    return $resource('/xos/subscribers', {id: '@id'});
  })
  .service('ServiceRelation', function($q, lodash, Services, Tenant, Slice, Instances){

    // count the mas depth of an object
    const depthOf = (obj) => {
      var depth = 0;
      if (obj.children) {
        obj.children.forEach(function (d) {
          var tmpDepth = depthOf(d);
          if (tmpDepth > depth) {
            depth = tmpDepth
          }
        })
      }
      return 1 + depth
    };

    // find all the relation defined for a given root
    const findLevelRelation = (tenants, rootId) => {
      return lodash.filter(tenants, service => {
        return service.subscriber_service === rootId;
      });
    };

    // find all the service defined by a given array of relations
    const findLevelServices = (relations, services) => {
      const levelServices = [];
      lodash.forEach(relations, (tenant) => {
        var service = lodash.find(services, {id: tenant.provider_service});
        levelServices.push(service);
      });
      return levelServices;
    };

    const buildLevel = (tenants, services, rootService, parentName = null) => {

      const tree = {
        name: rootService.humanReadableName,
        parent: parentName,
        type: 'service',
        service: rootService,
        children: []
      };

      // build an array of unlinked services
      // these are the services that should still placed in the tree
      var unlinkedServices = lodash.difference(services, [rootService]);

      // find all relations relative to this rootElement
      const levelRelation = findLevelRelation(tenants, rootService.id);

      // find all items related to rootElement
      const levelServices = findLevelServices(levelRelation, services);

      // remove this item from the list (performance
      unlinkedServices = lodash.difference(unlinkedServices, levelServices);

      lodash.forEach(levelServices, (service) => {
        tree.children.push(buildLevel(tenants, unlinkedServices, service, rootService.humanReadableName));
      });

      // if it is the last element append internet
      if(tree.children.length === 0){
        tree.children.push({
          name: 'Internet',
          type: 'internet',
          children: []
        });
      }

      return tree;
    };

    const buildServiceTree = (services, tenants, subscriber = {id: 1, name: 'fakeSubs'}) => {

      // find the root service
      // it is the one attached to subsriber_root
      // as now we have only one root so this can work
      const rootServiceId = lodash.find(tenants, {subscriber_root: subscriber.id}).provider_service;
      const rootService = lodash.find(services, {id: rootServiceId});

      const serviceTree = buildLevel(tenants, services, rootService);

      return {
        name: subscriber.name,
        parent: null,
        type: 'subscriber',
        children: [serviceTree]
      };

    };

    const get = (subscriber) => {
      var deferred = $q.defer();
      var services, tenants;
      Services.query().$promise
      .then((res) => {
        services = res;
        return Tenant.query().$promise;
      })
      .then((res) => {
        tenants = res;
        deferred.resolve(buildServiceTree(services, tenants, subscriber));
      })
      .catch((e) => {
        throw new Error(e);
      });

      return deferred.promise;
    };

    const getServiceInterfaces = (serviceId) => {
      var deferred = $q.defer();

      var _slices;

      Slice.query({service: serviceId}).$promise
      .then((slices) => {
        _slices = slices;
        const promisesArr = slices.reduce((promises, slice) => {
          promises.push(Instances.query({slice: slice.id}).$promise);
          return promises;
        }, []);

        // TODO add networks
        // decide how, they should be manually drawn
        // as they connect more instances without parent dependencies

        return $q.all(promisesArr);
      })
      .then((instances) => {
        console.log(instances);
        // parse data to build a tree (2 level only)
        var interfaceTree = [];
        lodash.forEach(_slices, (slice, i) => {
          let current = {
            name: slice.name,
            slice: slice,
            type: 'slice',
            children: instances[i].map((instance) => {
              return {
                name: instance.humanReadableName,
                children: [],
                type: 'instance',
                instance: instance
              };

            })
          };
          interfaceTree.push(current);
        });
        console.log(interfaceTree)
        deferred.resolve(interfaceTree);
      });

      return deferred.promise;
    };

    // export APIs
    this.get = get;
    this.buildLevel = buildLevel;
    this.buildServiceTree = buildServiceTree;
    this.findLevelRelation = findLevelRelation;
    this.findLevelServices = findLevelServices;
    this.depthOf = depthOf;
    this.getServiceInterfaces = getServiceInterfaces;
  });

}());