SFC topology
[groupbasedpolicy.git] / groupbasedpolicy-ui / module / src / main / resources / gbp / common / gbp.controller.js
index 0b6d52cb93794bcc4017f12cada0cc7ada33b0f9..cb04cc439c2a993a5e671af3e0ee9ec800d09b60 100644 (file)
-define(['app/gbp/common/gbp.service'], function () {
+define(['app/gbp/common/gbp.service', 'app/gbp/resolved-policy/resolved-policy.service'], function () {
     'use strict';
 
     angular.module('app.gbp').controller('RootGbpCtrl', RootGbpCtrl);
 
-    RootGbpCtrl.$inject = ['$state', '$scope', 'RootGbpService'];
+    RootGbpCtrl.$inject = ['$state', '$rootScope', '$scope', '$filter', '$mdDialog', 'RootGbpService',
+        'TenantListService', 'EpgListService', 'ResolvedPolicyService', 'NextTopologyService', 'EndpointsListService'];
 
-    function RootGbpCtrl($state, $scope, RootGbpService) {
+    function RootGbpCtrl($state, $rootScope, $scope, $filter, $mdDialog, RootGbpService,
+        TenantListService, EpgListService, ResolvedPolicyService, NextTopologyService, EndpointsListService) {
         /* properties */
-        $scope.stateUrl = null;
+        $scope.apiType = 'operational';
+        $scope.activeObject = null;
+        $scope.endpoints = EndpointsListService.createList();
+        $scope.rootTenant = null;
+        $scope.rootTenants = TenantListService.createList();
+        $scope.resolvedPolicy = {};
+        $scope.selectedNode = {};
+        $scope.sidePanelObject = {};
         $scope.sidePanelPage = false;
+        $scope.sidePanelPageEndpoint = false;
+        $scope.stateUrl = null;
+        $scope.topologyData = {nodes: [], links: []};
+        $scope.viewPath = 'src/app/gbp/';
+
+        var resolvedPolicies = ResolvedPolicyService.createObject();
+        resolvedPolicies.get(fillTopologyData);
 
         /* methods */
+        $scope.fillTopologyData = fillTopologyData;
+        $scope.broadcastFromRoot = broadcastFromRoot;
         $scope.closeSidePanel = closeSidePanel;
+        $scope.openSfcDialog = openSfcDialog;
         $scope.openSidePanel = openSidePanel;
+        $scope.setRootTenant = setRootTenant;
+        $scope.toggleExpanded = toggleExpanded;
+        $scope.openSidePanelContract = openSidePanelContract;
+        $scope.openSidePanelChild = openSidePanelChild;
+        $scope.deselectEpg = deselectEpg;
+        $scope.deselectContract = deselectContract;
+        $scope.openSidePanelTpl = openSidePanelTpl;
+        $scope.getObjectsCount = getObjectsCount;
+        $scope.expandAll = expandAll;
+        $scope.collapseAll = collapseAll;
+        $scope.highlightNode = highlightNode;
+        $scope.highlightLink = highlightLink;
+        $scope.fadeAll = fadeAll;
+        $scope.rootOpenEndpointDialog = rootOpenEndpointDialog;
+        $scope.rootDeleteEndpointDialog = rootDeleteEndpointDialog;
+        $scope.getEndpointsList = getEndpointsList;
 
         RootGbpService.setMainClass();
-        console.log('RootGbpCtrl initialized');
+        init();
 
         /* implementations */
+
         /**
-         * Sets '$scope.sidePanelPage' to false. This variable is watched in index.tpl.html template
-         * and opens/closes side panel
+         *
+         * @param eventName
+         * @param val
+         */
+        function broadcastFromRoot(eventName, val) {
+            $scope.$broadcast(eventName, val);
+        }
+
+        /**
+         *
          */
         function closeSidePanel() {
-            $scope.sidePanelPage = false;
+            if($scope.sidePanelPage) {
+                $scope.sidePanelPage = false;
+                $scope.fadeAll();
+            }
+        }
+
+        /**
+         *
+         * @param arr
+         */
+        function collapseAll(arr) {
+            arr.forEach(function(element) {
+                element.expanded = false;
+            });
+        }
+
+        /**
+         *
+         * @param source
+         * @param target
+         * @param contract
+         * @param tenant
+         * @returns {{id: string, source: *, target: *, tenant: *}}
+         */
+        function createLink( source, target, contract, tenant) {
+            return {
+                'id': generateLinkId(contract, source, target),
+                'source': source,
+                'target': target,
+                'tenant': tenant,
+            };
+        }
+
+        /**
+         *
+         * @param nodeName
+         * @param tenantId
+         * @returns {{id: *, tenantId: *, node-id: *, label: *}}
+         */
+        function createNode(nodeName, tenantId) {
+            return {
+                'id': nodeName,
+                'tenantId' : tenantId,
+                'node-id': nodeName,
+                'label': nodeName,
+            };
+        }
+
+        /**
+         *
+         */
+        function deselectContract() {
+            $scope.fadeAll();
+            $scope.sidePanelPage = 'resolved-policy/contract-sidepanel';
+
+            var obj = Object.keys($scope.resolvedPolicy).map(function(k) {
+                var obj = $scope.resolvedPolicy[k];
+                obj.linkId = k;
+
+                return obj;
+            });
+
+            $scope.sidePanelObject = obj;
+            $scope.selectedNode = null;
+            $scope.activeObject = 'contract';
+        }
+
+        /**
+         *
+         */
+        function deselectEpg() {
+            $scope.fadeAll();
+            var elements;
+
+            $scope.sidePanelPage = 'resolved-policy/epg-sidepanel';
+            elements = EpgListService.createList();
+            elements.get($scope.apiType, $scope.rootTenant);
+            $scope.sidePanelObject = elements;
+            $scope.selectedNode = null;
+            $scope.activeObject = 'epg';
+        }
+
+        /**
+         *
+         * @param arr
+         */
+        function expandAll(arr) {
+            arr.forEach(function(element) {
+                element.expanded = true;
+            });
+        }
+
+        /**
+         *
+         */
+        function fadeAll() {
+            $rootScope.nxTopology && NextTopologyService.fadeInAllLayers($rootScope.nxTopology);
+        }
+
+        /**
+         *
+         * @param data
+         */
+        function fillResolvedPolicy(data) {
+            if(data['policy-rule-group-with-endpoint-constraints']) {
+                processPolicyRuleGroupWithEpConstraints(
+                    data['policy-rule-group-with-endpoint-constraints'],
+                    data['provider-epg-id'],
+                    data['consumer-epg-id']);
+            }
+
+        }
+
+        /**
+         *
+         */
+        function fillTopologyData() {
+            if($scope.rootTenant) {
+                var topoData = {nodes: [], links: [],},
+                    filteredResolvedPolicies = $filter('filter')(resolvedPolicies.data, {
+                        'consumer-tenant-id': $scope.rootTenant,
+                        'provider-tenant-id': $scope.rootTenant
+                    });
+
+
+                filteredResolvedPolicies && filteredResolvedPolicies.forEach(function(rp) {
+                    if(rp['consumer-tenant-id'] === $scope.rootTenant) {
+                        topoData.nodes.push(createNode(rp['consumer-epg-id'], rp['consumer-tenant-id']));
+                    }
+                    topoData.nodes.push(createNode(rp['provider-epg-id'], rp['provider-tenant-id']));
+
+                    fillResolvedPolicy(rp);
+                    topoData.links = getContracts(rp);
+                });
+
+                $scope.topologyData = topoData;
+                $scope.topologyLoaded = true;
+            }
+        }
+
+        /**
+         *
+         * @param contractId
+         * @param providerEpgId
+         * @param consumerEpgId
+         * @returns {string}
+         */
+        function generateLinkId(contractId, providerEpgId, consumerEpgId) {
+            return contractId + '_' + providerEpgId + '_' + consumerEpgId;
+        }
+
+        /**
+         *
+         * @param data
+         * @returns {Array}
+         */
+        function getContracts(data) {
+            var retVal = [];
+
+            if( data['policy-rule-group-with-endpoint-constraints'] &&
+                data['policy-rule-group-with-endpoint-constraints'][0]['policy-rule-group']) {
+                data['policy-rule-group-with-endpoint-constraints'][0]['policy-rule-group'].forEach(function(prg) {
+                    retVal.push(
+                        createLink(
+                            data['provider-epg-id'],
+                            data['consumer-epg-id'],
+                            prg['contract-id'],
+                            prg['tenant-id']
+                        )
+                    )
+                });
+            }
+
+            return retVal;
+        }
+
+        /**
+         *
+         * @param obj
+         * @returns {*}
+         */
+        function getObjectsCount(obj) {
+            if(obj)
+                return Object.keys(obj).length;
+            else
+                return 0;
+        }
+
+        /**
+         *
+         * @param node
+         */
+        function highlightNode(node) {
+            NextTopologyService.highlightNode($rootScope.nxTopology, node);
+        }
+
+        /**
+         *
+         * @param link
+         */
+        function highlightLink(link) {
+            NextTopologyService.highlightLink($rootScope.nxTopology, link);
+        }
+
+        /**
+         *
+         */
+        function init() {
+            $scope.rootTenants.clearData();
+            $scope.rootTenants.get('config');
+        }
+
+        /**
+         *
+         * @param chainName
+         */
+        function openSfcDialog(chainName) {
+            $mdDialog.show({
+                clickOutsideToClose: true,
+                controller: 'SfcTopologyController',
+                preserveScope: true,
+                templateUrl: $scope.viewPath + 'sfc/dialog-sfc-topology.tpl.html',
+                parent: angular.element(document.body),
+                scope: $scope,
+                locals: {
+                    chainName: chainName,
+                },
+            });
+        }
+
+
+        /**
+         * Sets '$scope.sidePanelPage' to true. This variable is watched in index.tpl.html template
+         * and opens/closes side panel
+         */
+        function openSidePanel(page, object, cbk) {
+            if(object.constructor.name == 'Epg') {
+                $scope.endpoints.clearData();
+                $scope.endpoints.getByEpg(object.data.id);
+                $scope.activeObject = 'epg';
+            }
+            else
+                $scope.activeObject = 'contract';
+
+            var samePage = page === $scope.sidePanelPage;
+
+            $scope.selectedNode = object;
+
+            $scope.sidePanelCbk = cbk;
+            $scope.sidePanelPage = page;
+            $scope.sidePanelObject = object;
+
+            if ( samePage &&  $scope.sidePanelCbk) {
+                $scope.sidePanelCbk();
+            }
+        }
+
+        /**
+         *
+         * @param idElement
+         */
+        function openSidePanelContract(idElement) {
+            var obj = $filter('filter')(Object.keys($scope.resolvedPolicy).map(function(k) {
+                var obj = $scope.resolvedPolicy[k];
+                obj.linkId = k;
+
+                return obj;
+            }), {'contract-id': idElement});
+
+            $scope.sidePanelPage = 'resolved-policy/contract-sidepanel';
+            $scope.sidePanelObject = obj[0];
+            $scope.selectedNode = obj[0];
+            $scope.activeObject = 'contract';
+
+            NextTopologyService.highlightLink($rootScope.nxTopology, obj[0].linkId);
+        }
+
+        /**
+         * .
+         * @param index
+         * @param type
+         */
+        function openSidePanelChild(index, type) {
+            switch(type) {
+            case 'subject':
+                $scope.sidePanelPage = 'resolved-policy/subject-sidepanel';
+                $scope.subjectIndex = index;
+                break;
+            case 'clause':
+                $scope.sidePanelPage = 'resolved-policy/clause-sidepanel';
+                $scope.clauseIndex = index;
+                break;
+            case 'rule':
+                $scope.sidePanelPage = 'resolved-policy/rule-sidepanel';
+                $scope.ruleIndex = index;
+                break;
+            }
+        }
+
+        /**
+         *
+         * @param tpl
+         */
+        function openSidePanelTpl(tpl) {
+            switch(tpl) {
+            case 'contract':
+                $scope.sidePanelPage = 'resolved-policy/contract-sidepanel';
+                break;
+            case 'subject':
+                $scope.sidePanelPage = 'resolved-policy/subject-sidepanel';
+                break;
+            case 'clause':
+                $scope.sidePanelPage = 'resolved-policy/clause-sidepanel';
+                break;
+            case 'rule':
+                $scope.sidePanelPage = 'resolved-policy/rule-sidepanel';
+                break;
+            }
+        }
+
+        /**
+         *
+         * @param data
+         * @param providerEpgId
+         * @param consumerEpgId
+         */
+        function processPolicyRuleGroupWithEpConstraints(data, providerEpgId, consumerEpgId) {
+            data.forEach(function(element) {
+                element['policy-rule-group'].forEach(function(el) {
+                    var linkId = generateLinkId(el['contract-id'], providerEpgId, consumerEpgId);
+
+                    $scope.resolvedPolicy = {};
+
+                    if(!$scope.resolvedPolicy.hasOwnProperty(linkId)) {
+                        $scope.resolvedPolicy[linkId] = {
+                            'contract-id': el['contract-id'],
+                            'subjects': {},
+                        };
+                    }
+
+                    if(!$scope.resolvedPolicy[linkId].subjects.hasOwnProperty(el['subject-name'])) {
+                        $scope.resolvedPolicy[linkId].subjects[el['subject-name']] = {'resolved-rule': []};
+                    }
+
+                    $scope.resolvedPolicy[linkId].subjects[el['subject-name']]['resolved-rule'].push(el['resolved-rule']);
+                });
+            });
+        }
+
+        /**
+         *
+         */
+        function setRootTenant() {
+            $scope.broadcastFromRoot('ROOT_TENANT_CHANGED');
+
+            if($scope.stateUrl.startsWith('/resolved-policy')) {
+                fillTopologyData();
+                if($scope.sidePanelPage) {
+                    if($scope.activeObject == 'epg')
+                        deselectEpg();
+                    else if($scope.activeObject == 'contract')
+                        deselectContract();
+                }
+            }
         }
 
         /**
@@ -32,14 +439,60 @@ define(['app/gbp/common/gbp.service'], function () {
          */
         function setStateUrl() {
             $scope.stateUrl = $state.current.url;
+            closeSidePanel();
+
+            if($scope.stateUrl.startsWith('/resolved-policy')) {
+                fillTopologyData();
+            }
         }
 
         /**
-         * Sets '$scope.sidePanelPage' to true. This variable is watched in index.tpl.html template
-         * and opens/closes side panel
+         *
+         * @param element
          */
-        function openSidePanel() {
-            $scope.sidePanelPage = true;
+        function toggleExpanded(element) {
+            if(typeof element !== 'string') {
+                if(element.expanded)
+                    element.expanded = false;
+                else
+                    element.expanded = true;
+            }
+        }
+
+        function rootOpenEndpointDialog(operation, endpointData) {
+            $scope.disableKeyFieldsEditing = operation === 'edit';
+            $mdDialog.show({
+                clickOutsideToClose: true,
+                controller: 'AddEndpointController',
+                preserveScope: true,
+                templateUrl: $scope.viewPath + 'endpoints/dialog-add-endpoint.tpl.html',
+                parent: angular.element(document.body),
+                scope: $scope,
+                locals: {
+                    endpoint: endpointData,
+                },
+            });
+        }
+
+        function rootDeleteEndpointDialog(endpointData) {
+            var confirm = $mdDialog.confirm()
+                .title('Delete endpoint')
+                .textContent('Do you want to delete endpoint?')
+                .ok('Delete')
+                .cancel('Cancel');
+
+            $mdDialog.show(confirm).then(function () {
+                endpointData.deleteEndpoint(function () {
+                    getEndpointsList();
+                });
+            }, function () {
+
+            });
+        }
+
+        function getEndpointsList() {
+            $scope.endpoints.clearData();
+            $scope.endpoints.getByEpg($scope.selectedNode.data.id);
         }
 
         /* event listeners */
@@ -47,6 +500,5 @@ define(['app/gbp/common/gbp.service'], function () {
          * Event fired after content loaded, setStateUrl function is called to fill stateUrl method
          */
         $scope.$on('$viewContentLoaded', setStateUrl);
-
     }
 });