1 files changed, 477 insertions, 0 deletions
diff --git a/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTest/mwtnTest-module/src/main/resources/mwtnTest/mwtnTest.controller.js b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTest/mwtnTest-module/src/main/resources/mwtnTest/mwtnTest.controller.js
new file mode 100644
index 00000000..e873f19c
--- /dev/null
+++ b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTest/mwtnTest-module/src/main/resources/mwtnTest/mwtnTest.controller.js
@@ -0,0 +1,477 @@
+/*
+ * @copyright 2017 highstreet technologies GmbH and others.  All rights reserved.
+ *
+ * @license 
+ * This program and the accompanying materials are made available under the
+ * terms of the Eclipse Public License v1.0 which accompanies this distribution,
+ * and is available at http://www.eclipse.org/legal/epl-v10.html
+ */
+
+define(['app/mwtnTest/mwtnTest.module',
+        'app/mwtnTest/mwtnTest.services'],
+        function(mwtnTestApp) {
+
+  mwtnTestApp.register.controller('mwtnTestCtrl', ['$scope', '$rootScope', '$mwtnLog', '$mwtnTest', '$translate', 'OnfNetworkElement', 'LogicalTerminationPoint', 
+    function($scope, $rootScope, $mwtnLog, $mwtnTest, $translate, OnfNetworkElement, LogicalTerminationPoint) {
+
+    var COMPONENT = 'mwtnTestCtrl';
+    $mwtnLog.info({component: COMPONENT, message: 'mwtnTestCtrl started!'});
+    $rootScope.section_logo = 'src/app/mwtnTest/images/mwtnTest.png'; // Add your topbar logo location here such as 'assets/images/logo_topology.gif'
+  
+    var pacTemplate = {
+        'layer-protocol': 'unknown'           
+    };
+
+    // get important infromation from yang modules
+    $mwtnTest.getModules().then(function(success){
+
+      var pacOrder = {
+        'onf-otn-odu-conditional-packages:otn-odu-connection-pac' : 2,
+        'onf-otn-odu-conditional-packages:otn-odu-termination-pac' : 1,
+        'onf-ethernet-conditional-packages:ethernet-pac' : 1,
+        'microwave-model:mw-air-interface-diversity-pac' : 1,
+        'microwave-model:mw-air-interface-hsb-end-point-pac' : 1,
+        'microwave-model:mw-air-interface-hsb-fc-switch-pac' : 2,
+        'onf-core-model-conditional-packages:holder-pac' : 3,
+        'onf-core-model-conditional-packages:connector-pac' : 4,
+        'onf-core-model-conditional-packages:equipment-pac' : 5,
+        'microwave-model:mw-ethernet-container-pac' : 6,
+        'MicrowaveModel-ObjectClasses-EthernetContainer:MW_EthernetContainer_Pac' : 7,
+        'microwave-model:mw-ethernet-container-pac' : 8,
+        'microwave-model:mw-tdm-container-pac': 9,
+        'microwave-model:mw-pure-ethernet-structure-pac': 10,
+        'microwave-model:mw-hybrid-mw-structure-pac': 11,
+        'MicrowaveModel-ObjectClasses-PureEthernetStructure:MW_PureEthernetStructure_Pac' : 12,
+        'microwave-model:mw-air-interface-pac' : 13,
+        'MicrowaveModel-ObjectClasses-AirInterface:MW_AirInterface_Pac' : 14
+      };
+
+      $scope.modules = success;
+      $scope.orderedPacs = [];
+      $scope.parts = [];
+      Object.keys(success).map(function(module){
+        Object.keys(success[module]).filter(function(key){
+          return key.endsWith('-pac') || key.endsWith('_Pac');
+        }).map(function(pacName){
+          $scope.orderedPacs.push([module, pacName].join(':'));
+          // sort 
+          $scope.orderedPacs.sort(function(a, b) {
+            if (!pacOrder[a]) console.warn(a);
+            if (!pacOrder[b]) console.warn(b);
+            if(pacOrder[a] > pacOrder[b]) return 1;
+            if(pacOrder[a] < pacOrder[b]) return -1;
+            return 0;
+          })
+
+          if (pacName === 'mw-air-interface-pac') {
+            $scope.parts = Object.keys(success[module][pacName]).filter(function(conditionalPackage){
+              return success[module][pacName][conditionalPackage]['local-name'];
+            }).map(function(conditionalPackage){
+              return success[module][pacName][conditionalPackage]['local-name'];
+            });
+          }
+        });
+      });
+    }, function(error){
+      $scope.modules = undefined;
+      $scope.orderedPacs = undefined;
+      $scope.parts = undefined;
+    });
+            
+    /**
+     * @function updateNe 
+     * A function, which updates onfNetworkElement by new data.
+     * @param {*} data New data recieved from OpenDaylight via RestConf
+     */
+    var updateNe = function(data) {
+      if (!data) return;
+      // update onfNetworkElement
+      switch ($scope.revision) {
+        case '2016-03-23':
+          $scope.onfNetworkElement = JSON.parse(JSON.stringify(data['network-element'][0]));
+          $scope.onfLtps = data['network-element'][0].ltp;
+          $scope.onfNetworkElement.ltp = undefined;
+          break;
+        case '2016-08-09':
+        case '2016-08-11':
+        case '2017-02-17':
+        case '2017-03-20':
+          // console.log(JSON.stringify(data));        
+          $scope.onfNetworkElement = new OnfNetworkElement(data['network-element']);
+          $scope.onfLtps = $scope.onfNetworkElement.getLogicalTerminationPoints();
+          // $scope.onfNetworkElement.ltp = undefined;
+          break;
+        default:
+          $mwtnLog.info({component: COMPONENT, message: ['The ONF CoreModel revision', $scope.mountpoint.onfCoreModelRevision, ' is not supported (yet)!'].join(' ')});
+          $scope.onfNetworkElement = {};
+          $scope.onfLtps = {};
+      }
+      
+      var order = $mwtnTest.layerProtocolNameOrder;
+      // update onfLTPs
+      $scope.onfLtps.sort(function(a, b){
+        if(order[a.getLayer()] < order[b.getLayer()]) return -1;
+        if(order[a.getLayer()] > order[b.getLayer()]) return 1;
+        if(a.getId() < b.getId()) return -1;
+        if(a.getId() > b.getId()) return 1;
+        return 0;
+      });
+      
+      // calculate conditional packages
+      $scope.pacs = {};
+      $scope.onfLtps.map(function(ltp) {
+        ltp.getLayerProtocols().map(
+          /**
+           * A function processing a layer-protocol object
+           * @param {LayerProtocol} lp A layer-protocol object
+           */
+          function(lp) {
+            var template = JSON.parse(JSON.stringify(pacTemplate));
+            template['layer-protocol'] = lp.getId();
+            var conditionalPackage = lp.getConditionalPackage(true);
+            // console.log(conditionalPackage);
+            if (conditionalPackage !== '') {
+              if ($scope.pacs[conditionalPackage] === undefined) {
+                // create missing pac array
+                $scope.pacs[conditionalPackage] = [];
+              }
+              $scope.pacs[conditionalPackage].push(template);
+            } else {
+              $mwtnLog.info({component: COMPONENT, message: 'No conditional package for  ' + ltp.getLabel() });
+            }
+        });
+      });
+      
+      // sort the conditional packages
+      if ($scope.orderedPacs) {
+        $scope.orderedPacs.filter(function(item){
+          return $scope.pacs[item] !== undefined;
+        }).map(function(item){
+          $scope.pacs[item].sort(function(a, b){
+            if(a['layer-protocol'] < b['layer-protocol']) return -1;
+            if(a['layer-protocol'] > b['layer-protocol']) return 1;
+            return 0;
+          });
+        });
+      }
+      data.revision = undefined;
+    };
+
+    var updateNetworkElementCurrentProblems = function(data) {
+      if (!data) return;
+      $scope.neCurrentProblems = data;
+    };
+
+    var updateLtp = function(data) {
+      $scope.onfLtps.map(function(ltp){
+        if (ltp.getData().uuid === data.data.ltp[0].uuid) {
+          ltp = new LogicalTerminationPoint(data.data.ltp[0]);
+        }
+      });
+    };
+
+    /**
+     * @deprecated since all conditaional packages are handle the same way even for
+     *             3rd and 4th PoC model - 2nd PoC model not supported any more.
+     * @param {*} lpId 
+     * @param {*} part 
+     * @param {*} data 
+     */
+    var updateAirInterface = function(lpId, part, data) {
+      // console.log(JSON.stringify(data), lpId);
+      $scope.airinterfaces.map(function(airinterface){
+        // console.log(JSON.stringify(airinterface));
+        if (airinterface['layer-protocol'] === lpId) {
+          if (Object.keys(data)[0].startsWith('air-interface')) {
+            airinterface[part] = data;            
+          } else if (part === 'Capability') {
+            // 2. PoC
+            // console.log(part, JSON.stringify(data));
+            airinterface[part] = data['mw-air-interface-pac'][0]['air-interface-capability-list'];            
+          } else if (part === 'CurrentProblems') {
+            // 2. PoC
+            // console.log(part, JSON.stringify(data));
+            airinterface[part] = data['mw-air-interface-pac'][0]['air-interface-current-problem-list'];            
+          }
+        }
+      });
+      data.revision = undefined;
+    };
+
+    /**
+     * @deprecated since all conditaional packages are handle the same way even for
+     *             3rd and 4th PoC model - 2nd PoC model not supported any more.
+     * @param {*} lpId 
+     * @param {*} part 
+     * @param {*} data 
+     */
+    var updateStructure = function(lpId, part, data) {
+      // console.log(JSON.stringify(data), lpId);
+      $scope.structures.map(function(structure){
+        // console.log(JSON.stringify(structure));
+        if (structure['layer-protocol'] === lpId) {
+          if (Object.keys(data)[0].contains('tructure')) {
+            structure[part] = data;            
+          } else if (part === 'Capability') {
+            // 2. PoC
+            // console.log(part, JSON.stringify(data));
+            structure[part] = data['mw-structure-pac'][0]['structure.capability-list'];            
+          } else if (part === 'CurrentProblems') {
+            // 2. PoC
+            // console.log(part, JSON.stringify(data));
+            structure[part] = data['mw-structure-pac'][0]['structure-current-problem-list'];            
+          }
+        }
+      });
+      data.revision = undefined;
+    };
+
+    /**
+     * @deprecated since all conditaional packages are handle the same way even for
+     *             3rd and 4th PoC model - 2nd PoC model not supported any more.
+     * @param {*} lpId 
+     * @param {*} part 
+     * @param {*} data 
+     */
+    var updateContainer = function(lpId, part, data) {
+      // console.log(JSON.stringify(data), lpId);
+      $scope.containers.map(function(container){
+        // console.log(JSON.stringify(container));
+        if (container['layer-protocol'] === lpId) {
+          if (Object.keys(data)[0].contains('ontainer') ) {
+            container[part] = data;            
+          } else if (part === 'Capability') {
+            // 2. PoC
+            // console.log(part, JSON.stringify(data));
+            container[part] = data['mw-container-pac'][0]['container-capability-list'];            
+          } else if (part === 'CurrentProblems') {
+            // 2. PoC
+            // console.log(part, JSON.stringify(data));
+            container[part] = data['mw-container-pac'][0]['container-current-problem-list'];            
+          }
+        }
+      });
+      data.revision = undefined;
+    };
+
+    /**
+     * Creates a template of a conditional packages with its subclasses
+     * @param {{pacId: string, layerProtocolId: string, partId:string}} spec - Specification object of a conditional package subclass
+     */
+    var initPac = function(spec) {
+      $scope.pacs[spec.pacId].filter(function(conditionalPackage){
+        return conditionalPackage['layer-protocol'] === spec.layerProtocolId;
+      }).map(function(pac){
+        $scope.parts.map(function(localName){
+          pac[localName] = {id:$mwtnTest.getPartGlobalId(spec, localName),localName: localName, data:'No data available'}
+        });
+      });
+    };
+
+    /**
+     * Updates an existing template of a conditional packages with its subclasses
+     * @param {{pacId: string, layerProtocolId: string, partId:string}} spec - Specification object of a conditional package subclass
+     */
+    var updateSubClassData = function(spec, data) {
+      $scope.pacs[spec.pacId].filter(function(conditionalPackage){
+        return conditionalPackage['layer-protocol'] === spec.layerProtocolId;
+      }).map(function(conditionalPackage){
+        conditionalPackage[$mwtnTest.getPartLocalId(spec)].data = data[$mwtnTest.yangify(spec.partId)];
+      });
+    };
+
+    var updatePart = function(spec, data) {
+      switch (spec.pacId) {
+        case 'ne':
+          updateNe(data);
+          break;
+        case 'neCurrentProblems':
+          updateNetworkElementCurrentProblems(data);
+        case 'clock':
+          // console.warn('yea clock', JSON.stringify(data));
+          $scope.clock = data;
+          break;
+        case 'ltp':
+          updateLtp(data);
+          break;
+        case 'airinterface':
+          console.log(JSON.stringify(spec, JSON.stringify(data)));
+          updateAirInterface(spec.layerProtocolId, spec.partId, data);
+          break;
+        case 'structure':
+          console.log(JSON.stringify(data));
+          updateStructure(spec.layerProtocolId, spec.partId, data);
+          break;
+        case 'container':
+          console.log(JSON.stringify(data));
+          updateContainer(spec.layerProtocolId, spec.partId, data);
+          break;  
+        // 3rd Poc
+        case 'MicrowaveModel-ObjectClasses-AirInterface:MW_AirInterface_Pac':
+        case 'MicrowaveModel-ObjectClasses-PureEthernetStructure:MW_PureEthernetStructure_Pac':
+        case 'MicrowaveModel-ObjectClasses-EthernetContainer:MW_EthernetContainer_Pac':
+        // 4th Poc
+        case 'microwave-model:mw-air-interface-pac':
+        case 'microwave-model:mw-air-interface-diversity-pac':
+        case 'microwave-model:mw-pure-ethernet-structure-pac':
+        case 'microwave-model:mw-hybrid-mw-structure-pac':
+        case 'microwave-model:mw-tdm-container-pac':
+        case 'microwave-model:mw-ethernet-container-pac':
+        case 'onf-ethernet-conditional-packages:ethernet-pac':
+        // Poc 4.1
+        case 'onf-otn-odu-conditional-packages:otn-odu-connection-pac':
+        case 'onf-otn-odu-conditional-packages:otn-odu-termination-pac':
+        if (!spec.partId) {
+            initPac(spec);
+          } else {
+            updateSubClassData(spec, data);
+          }
+          break;  
+      }
+    };
+    
+    // events
+    $scope.status = {ne:false};
+    $scope.spinner = {ne:false};
+    $scope.separator = $mwtnTest.separator; //'&nbsp;'
+
+    $scope.myClipboard = {
+      data : {'key': 'value'},
+      supported : true,
+      getJson : function() {
+        return JSON.stringify(this.data, null, ' ');
+      },
+      copyToClipboard : function() {
+        var message = 'Copied to clipboard! ' + this.getJson();
+        $mwtnLog.info({component: COMPONENT, message: message});
+      },
+      error : function(err) {
+        $mwtnLog.error({component: COMPONENT, message: err});
+      }
+    };
+    
+    $scope.$watch('status', function(status, oldValue) {
+      Object.keys(status).filter(function(key){
+        return $scope.networkElementId && status[key] && status[key] !== oldValue[key];
+      }).map(function(key){
+        $scope.spinner[key] = true;
+        var info = key.split($scope.separator);
+        var spec = {
+          nodeId: $scope.networkElementId,
+          revision: $scope.revision,
+          pacId: info[0],
+          layerProtocolId: info[1],
+          partId: info[2]
+        };
+        $mwtnTest.getPacParts(spec).then(function(success){
+          success = $mwtnTest.yangifyObject(success)
+          $scope.myClipboard.data = success; 
+          updatePart(spec, success);
+          $scope.spinner[key] = false;
+        }, function(error){
+          $scope.myClipboard.data = 'Opps!'; 
+          updatePart(spec, error);
+          $scope.spinner[key] = false;
+        });
+        $scope.mountpoint = $scope.mountPoints.filter(function(mountpoint){
+          return mountpoint['node-id'] === $scope.networkElementId;
+        })[0];
+        if (key === 'mountpoint') {
+          $scope.spinner['mountpoint'] = false;
+          $scope.myClipboard.data = $scope.mountpoint;
+        }
+      });
+    }, true);
+
+        // var spec = {
+        //   nodeId: $scope.networkElementId,
+        //   revision: $scope.revision,
+        //   pacId: 'clock'
+        // };
+        // $mwtnTest.getPacParts(spec).then(function(success){
+        //   $scope.collapseAll();
+        //   updatePart(spec, $mwtnTest.yangifyObject(success));
+        // }, function(error){
+        //   $scope.collapseAll();
+        //   updatePart(spec, error);
+        // });
+
+
+    $scope.collapseAll = function() {
+      // close all groups
+      Object.keys($scope.status).map(function(group){
+        $scope.status[group] = false;
+      });
+      Object.keys($scope.spinner).map(function(group){
+        $scope.spinner[group] = false;
+      });
+    };
+    
+    $scope.$watch('networkElement', function(neId, oldValue) {
+      if (neId && neId !== '' && neId !== oldValue) {
+        
+        // clear old data
+        $scope.airinterfaces = [];
+        $scope.structures = [];
+        $scope.containers = [];
+        $scope.onfLtps = [];
+        $scope.clock = undefined;
+
+        $scope.networkElementId = neId;
+        $scope.revision = $scope.mountPoints.filter(function(mountpoint){
+          return mountpoint['node-id'] === neId;
+        }).map(function(mountpoint){
+          return mountpoint.onfCoreModelRevision;
+        })[0];
+
+        // network element alarms
+        var neAlarms = $scope.mountPoints.filter(function(mountpoint){
+          return mountpoint['node-id'] === neId;
+        }).map(function(mountpoint){
+          return mountpoint.onfCapabilities.filter(function(cap){
+            return cap.module === 'MicrowaveModel-NetworkElement-CurrentProblemList' || cap.module === 'onf-core-model-conditional-packages';
+          });
+        });
+        if (neAlarms.length === 1 && neAlarms[0].length === 1 ) {
+          $translate('MWTN_LOADING').then(function (translation) {
+            $scope.neCurrentProblems = translation;
+          });
+        } else {
+          $scope.neCurrentProblems = undefined;
+        }
+        
+        var spec = {
+          nodeId: $scope.networkElementId,
+          revision: $scope.revision,
+          pacId: 'ne'
+        };
+        $mwtnTest.getPacParts(spec).then(function(success){
+          $scope.collapseAll();
+          updatePart(spec, $mwtnTest.yangifyObject(success));
+        }, function(error){
+          $scope.collapseAll();
+          updatePart(spec, error);
+        });
+
+        // ptp-clock
+        var ptpClock = $scope.mountPoints.filter(function(mountpoint){
+          return mountpoint['node-id'] === neId;
+        }).map(function(mountpoint){
+          return mountpoint.onfCapabilities.filter(function(cap){
+            return cap.module === 'onf-ptp-dataset';
+          });
+        });
+        if (ptpClock.length === 1 && ptpClock[0].length === 1 ) {
+          $translate('MWTN_LOADING').then(function (translation) {
+            $scope.clock = translation;
+          });
+        } else {
+          $scope.clock = undefined;
+        }
+        
+      }
+    });
+
+  }]);
+
+});