diff options
| author |   demx8as6 <martin.skorupski@highstreet-technologies.com> | 2018-07-10 18:07:44 +0200 |
|---|---|---|
| committer |   Timoney, Dan (dt5972) <dt5972@att.com> | 2018-07-11 16:30:28 -0400 |
| commit | 27fb2d06608fbb070ae2c15a5580a4f5b2423d15 (patch) | |
| tree | ccd717991b4e556b67f1fd2cacb345b4d174b41f /sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology | |
| parent | 60315525ab5e7c12a9f47c409092e8dba6ad656d (diff) | |
Add seed code for sdnr app based on ONF Centennial
At this point in time all the Carbon code from ONF Centennial is added to ONAP.
Later it needs to be refactored and modified for ODL Oxygen.
Change-Id: Iff85dd940c05c3827f1c4e6f9542ecd060c58a46
Issue-ID: SDNC-374
Signed-off-by: demx8as6 <martin.skorupski@highstreet-technologies.com>
Diffstat (limited to 'sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology')
33 files changed, 6967 insertions, 0 deletions
diff --git a/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-bundle/pom.xml b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-bundle/pom.xml new file mode 100644 index 00000000..c1639dcb --- /dev/null +++ b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-bundle/pom.xml @@ -0,0 +1,117 @@ +<?xml version="1.0" encoding="UTF-8"?> +<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" + xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> + <modelVersion>4.0.0</modelVersion> + <parent> + <artifactId>mwtnTopology</artifactId> + <groupId>com.highstreet.technologies.odl.dlux</groupId> + <version>0.5.1-SNAPSHOT</version> + </parent> + <artifactId>mwtnTopology-bundle</artifactId> + <name>${prefix} ${project.artifactId}</name> + <packaging>bundle</packaging> + <dependencies> + <dependency> + <groupId>org.osgi</groupId> + <artifactId>org.osgi.core</artifactId> + <version>${osgi.core.version}</version> + </dependency> + <dependency> + <groupId>org.osgi</groupId> + <artifactId>org.osgi.compendium</artifactId> + <version>${osgi.core.version}</version> + </dependency> + <dependency> + <groupId>org.apache.felix</groupId> + <artifactId>org.osgi.compendium</artifactId> + <version>${apache.felix.compendium}</version> + </dependency> + <dependency> + <groupId>org.opendaylight.dlux</groupId> + <artifactId>loader</artifactId> + <version>${dlux.loader.version}</version> + </dependency> + <dependency> + <groupId>com.highstreet.technologies.odl.dlux</groupId> + <artifactId>mwtnTopology-module</artifactId> + <version>0.5.1-SNAPSHOT</version> + </dependency> + </dependencies> + <build> + <resources> + <resource> + <directory>target/generated-resources</directory> + </resource> + <resource> + <directory>src/main/resources</directory> + </resource> + </resources> + <plugins> + <plugin> + <groupId>org.apache.maven.plugins</groupId> + <artifactId>maven-dependency-plugin</artifactId> + <version>2.6</version> + <executions> + <!--loader Resources --> + <execution> + <id>unpack-loader-resources</id> + <goals> + <goal>unpack-dependencies</goal> + </goals> + <phase>generate-resources</phase> + <configuration> + <outputDirectory>${project.build.directory}/generated-resources</outputDirectory> + <groupId>com.highstreet.technologies.odl.dlux</groupId> + <includeArtifactIds>mwtnTopology-module</includeArtifactIds> + <excludes>META-INF\/**</excludes> + <excludeTransitive>true</excludeTransitive> + <ignorePermissions>false</ignorePermissions> + </configuration> + </execution> + </executions> + </plugin> + <plugin> + <groupId>org.apache.felix</groupId> + <artifactId>maven-bundle-plugin</artifactId> + <extensions>true</extensions> + <configuration> + <instructions> + <Import-Package>org.osgi.service.http, + org.osgi.framework;version="1.0.0", + org.opendaylight.dlux.loader + </Import-Package> + <Export-Package></Export-Package> + </instructions> + </configuration> + </plugin> + + <!-- <plugin> + <artifactId>maven-resources-plugin</artifactId> + <version>3.0.1</version> + <executions> + <execution> + <id>copy-resources</id> + <!- - here the phase you need - -> + <phase>package</phase> + <goals> + <goal>copy-resources</goal> + </goals> + <configuration> + <outputDirectory>../../deploy</outputDirectory> + <resources> + <resource> + <directory>target</directory> + <includes> + <include>${project.artifactId}-${project.version}.jar</include> + </includes> + <filtering>true</filtering> + </resource> + </resources> + </configuration> + </execution> + </executions> + </plugin> --> + + </plugins> + </build> +</project> diff --git a/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-bundle/src/main/resources/OSGI-INF/blueprint/blueprint.xml b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-bundle/src/main/resources/OSGI-INF/blueprint/blueprint.xml new file mode 100644 index 00000000..a5cfcfc2 --- /dev/null +++ b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-bundle/src/main/resources/OSGI-INF/blueprint/blueprint.xml @@ -0,0 +1,19 @@ +<blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0"> + <reference id="httpService" availability="mandatory" activation="eager" interface="org.osgi.service.http.HttpService"/> + <reference id="loader" availability="mandatory" activation="eager" interface="org.opendaylight.dlux.loader.DluxModuleLoader"/> + + <bean id="bundle" init-method="initialize" destroy-method="clean" class="org.opendaylight.dlux.loader.DluxModule"> + <property name="httpService" ref="httpService"/> + <property name="loader" ref="loader"/> + <property name="moduleName" value="mwtnTopology"/> + <property name="url" value="/src/app/mwtnTopology"/> + <property name="directory" value="/mwtnTopology"/> + <property name="requireJs" value="app/mwtnTopology/mwtnTopology.module"/> + <property name="angularJs" value="app.mwtnTopology"/> + <property name="cssDependencies"> + <list> + <value>src/app/mwtnTopology/mwtnTopology-custom.css</value> + </list> + </property> + </bean> +</blueprint>
\ No newline at end of file diff --git a/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/pom.xml b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/pom.xml new file mode 100644 index 00000000..1eb8126c --- /dev/null +++ b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/pom.xml @@ -0,0 +1,14 @@ +<?xml version="1.0" encoding="UTF-8"?> +<project + xmlns="http://maven.apache.org/POM/4.0.0" + xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> + <modelVersion>4.0.0</modelVersion> + <parent> + <artifactId>mwtnTopology</artifactId> + <groupId>com.highstreet.technologies.odl.dlux</groupId> + <version>0.5.1-SNAPSHOT</version> + </parent> + <artifactId>mwtnTopology-module</artifactId> + <name>${prefix} ${project.artifactId}</name> + <packaging>jar</packaging> +</project>
\ No newline at end of file diff --git a/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/doc/mwtnTopology.builinfo.md b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/doc/mwtnTopology.builinfo.md new file mode 100755 index 00000000..594b8e26 --- /dev/null +++ b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/doc/mwtnTopology.builinfo.md @@ -0,0 +1,39 @@ +# Buildinfo
+
+Ausgehend vom Verzeichnis:
+SDN-Projects-Boron/code/ux
+
+ll => pom.xml muss vorhanden sein.
+
+## manuelles Builden
+
+Die Schritte 1, 5 und 6 sind während des Buildens notwendig, die anderen Schritte sind zu Kontrollzwecken und zum starten / Stoppen vom Karaf Server
+
+1. Für den Compilevorgang der eigenen Komponenten:
+ - `cd ~/SDN-Projects-Boron/code`
+ - `mvn clean install -DskipTests`
+ - `cp -R ~/.m2/repository/com/highstreet $ODL_KARAF_HOME/system/com`
+2. Zum beenden von Karaf:
+ - ctrl+d in der Shell, auf der Karaf läuft.
+ - `sudo $ODL_KARAF_HOME/bin/client -u karaf "shutdown --force"`, wenn man nicht in der passenden Shell ist
+3. Starten von Karaf:
+ - `cd $ODL_KARAF_HOME`
+ - `./bin/karaf`
+4. Zum gucken, welche Module installiert sind (von highstreet, grep):
+ - `bundle:list | grep mwtn`
+5. Bundles deinstallieren (Funktioniert nur innerhalb der Karaf Shell)
+ - `bundle:uninstall "ONF :: Wireless :: mwtnCommons-bundle" "ONF :: Wireless :: mwtnTopology-bundle"`
+6. (geänderte) Bundles installieren (Funktioniert nur innerhalb der Karaf Shell)
+ - `bundle:install -s mvn:com.highstreet.technologies.odl.dlux/mwtnCommons-bundle/0.4.0-SNAPSHOT mvn:com.highstreet.technologies.odl.dlux/mwtnTopology-bundle/0.4.0-SNAPSHOT`
+
+## GIT:
+
+Abrufen:
+- `cd ~/SDN-Projects-Boron/code/ux/mwtnTopology/mwtnTopology-module/src/main/resources`
+- `git pull`
+
+Einchecken:
+- `git add doc/*.md`
+- `git status` (Kontrolle der einzucheckenden Dateien)
+- `git commit` (Ist der eincheckvorgang an sich (lokaler GitServer))
+- `git push` (Übertragen aller Commits zum zentralen Server)
diff --git a/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/doc/mwtnTopology.fs.md b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/doc/mwtnTopology.fs.md new file mode 100755 index 00000000..861306c2 --- /dev/null +++ b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/doc/mwtnTopology.fs.md @@ -0,0 +1,78 @@ +# mwtnTopology - Functional Specification
+
+## Beschreibung
+
+Das mwtnTopology Control zeichnet eine Karte mit Hilfe eines austauschbaren Kartendienstes
+Dabei wird die Satellitendarstellung verwendet (wenn möglich), sonst wird die Kartendarstellung gewählt.
+Über dem Kartenlayer soll ein Vectorlayer mit Informationen zu Mobilfunkmasten und zugehörigen Richtfunkstrecken dargestellt werden.
+Die Karte soll mittels Mausbedienung Scroll und Zoombar sein, Klicks auf einen Mast oder eine Richtfunkstrecke stellen weitere Informationen in einem Popup zur Verfügung.
+
+## Anforderungen
+
+* Die Webseite / der Webserver hat *keinen* Zugriff auf das öffentliche Internet. Online-Kartendienste wie Google, Bing oder OpenStreetMap sind damit nicht erreichbar.
+* Der Server stellt eine API bereit, an welcher die Kartenkacheln als Bitmaps (png/jpeg) bereitgestellt werden.
+* Der darzustellende Bereich wird angegeben durch
+ - Ein Latitude/Longitude Koordinatenpaar (Mittelpunkt) und eine Zoomstufe in % wobei 0% der "Weltraumansicht" und 100% der "Sandkrümel auf der Straße" entspricht.
+ Die benötigten Kacheln werden anhand der Zoomstufe und der Größe des Kartenausschnitts in Bildschirmpixel berechnet.
+ - Zwei Latitude/Longitude Koordinatenpaare, welche die obere rechte Ecke und die untere linke Ecke des darzustellenden Kartenausschnitts darstellen.
+ Die benötigte Zoomstufe wird anhand der Koordinatenpaare und der Größe des Kartenausschnitts in Bildschirmpixel berechnet.
+ + 2 Mögliche SubModi: "Fill" und "Cut"
+* Die Zoomstufen als %-Angaben werden auf die vom Kartenprovider verwendeten ganzzahligen Zoomstufen gemappt.
+ - Nicht jeder Kartenprovider kann für alle Zoomstufen Bitmaps liefern. Gibt es eine Möglichkeit die maximale Provider-Zoomstufe für eine Koordinate abzufragen?
+* Der Client cached die Bildkacheln, um die Serverlast zu reduzieren.
+ - Localstorage?
+
+## Offene Fragen
+
+* Soll die Karte immer eingenordet sein oder ist eine Kartenrotation erforderlich?
+* Welche Karten-UI-Steuerelemente müssen angezeigt werden
+ - +/- Button / Zoom-Slider
+ - 2D-Rotations-Gizmo / Kompass
+ - Geokoordinate Zentrieren
+ - Kartenscale (20m|---------------|)
+ - Copyright-Angaben der verwendeten Kartendaten
+ - Ein/Ausblenden des Vector-Overlays
+* Kann ein eigener Tile Render Server (wie z.B. Maperitive) verwendet werden?
+* Transparente, vorberechnete Kacheln des VectorLayers verfügbar? (Kacheln erlauben keine Hover-Informationen einzelner Richtfunktstrecken)
+
+## Berechnungsformeln
+
+- [OSM: Slippy map tilenames](http://wiki.openstreetmap.org/wiki/Slippy_map_tilenames)
+
+The first part of the URL specifies the tile server, and perhaps other parameters which might influence the style.
+
+Generally several subdomains (server names) are provided to get around browser limitations on the number of simultaneous HTTP connections to each host.
+Browser-based applications can thus request multiple tiles from multiple subdomains faster than from one subdomain.
+For example, OSM, OpenCycleMap and CloudMade servers have three subdomains (a.tile, b.tile, c.tile), MapQuest has four (otile1, otile2, otile3, otile4),
+all pointing to the same CDN. That all comes before the /zoom/x/y.png tail.
+
+Example:
+http://[abc].tile.openstreetmap.org/zoom/x/y.png
+
+```js
+function long2tile(lon,zoom) { return (Math.floor((lon+180)/360*Math.pow(2,zoom))); }
+function lat2tile(lat,zoom) { return (Math.floor((1-Math.log(Math.tan(lat*Math.PI/180) + 1/Math.cos(lat*Math.PI/180))/Math.PI)/2 *Math.pow(2,zoom))); }
+
+var zoom = 9;
+var top_tile = lat2tile(north_edge, zoom); // eg.lat2tile(34.422, 9);
+var left_tile = lon2tile(west_edge, zoom);
+var bottom_tile = lat2tile(south_edge, zoom);
+var right_tile = lon2tile(east_edge, zoom);
+var width = Math.abs(left_tile - right_tile) + 1;
+var height = Math.abs(top_tile - bottom_tile) + 1;
+
+// total tiles
+var total_tiles = width * height; // -> eg. 377
+```
+
+## Links
+
+- [OpenStreetMap DE:Tile usage policy](http://wiki.openstreetmap.org/wiki/DE:Tile_usage_policy)
+- [OpenStreetMap DE:Karte in Webseite einbinden](http://wiki.openstreetmap.org/wiki/DE:Karte_in_Webseite_einbinden)
+- [OpenStreetMap DE:Maperitive](http://wiki.openstreetmap.org/wiki/DE:Maperitive)
+- [Maperitive, EN:Hauptwebseite](http://maperitive.net/)
+- [Google Maps Javascript API + Key anfordern](https://developers.google.com/maps/documentation/javascript/?hl=de)
+- [Google Maps Javascript Erste Schritte](https://developers.google.com/maps/documentation/javascript/tutorial?hl=de)
+- [Google Developer Console](https://console.developers.google.com/)
+- [GoogleMap AngularJS Directive](https://rawgit.com/allenhwkim/angularjs-google-maps/master/build/docs/index.html)
+- [Sample asnyc script load into head element](http://just-run.it/#/ByvA_ClTe/0)
diff --git a/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/images/mwtnTopology.png b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/images/mwtnTopology.png Binary files differnew file mode 100755 index 00000000..7ddbeb2e --- /dev/null +++ b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/images/mwtnTopology.png diff --git a/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/mwtnTopology-custom.css b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/mwtnTopology-custom.css new file mode 100755 index 00000000..d04a7645 --- /dev/null +++ b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/mwtnTopology-custom.css @@ -0,0 +1,102 @@ +/** + * Add your application related css here + */ + +.owl p span { + color: #393939; +} + +.angular-google-map-container { + height: 1200px; +} + +.mwtnTopologyGrid { + height: 412px; + background-color: white; +} + +.mwtnTopologyGrid span { + color: #393939; +} + +#mwtnTopology .nav-tabs { + border-bottom: 1px solid #ddd; +} +#mwtnTopology .nav-tabs > li { + float: left; + margin-bottom: -1px; +} +#mwtnTopology .nav-tabs > li > a { + margin-right: 2px; + line-height: 1.42857143; + border: 1px solid transparent; + border-radius: 4px 4px 0 0; + + color: #555; + cursor: default; + background-color: #fff; + border: 1px solid #ddd; + border-bottom-color: transparent; +} +#mwtnTopology .nav-tabs > li > a:hover { + color: #fff; + cursor: default; + background-color: #428bca; + border: 1px solid #428bca; + border-color: #eee #eee #ddd; + border-bottom-color: transparent; + +} +#mwtnTopology .nav-tabs > li.active > a, +#mwtnTopology .nav-tabs > li.active > a:hover, +#mwtnTopology .nav-tabs > li.active > a:focus { + color: #fff; + cursor: default; + background-color: #428bca; + border: 1px solid #428bca; + border-bottom-color: transparent; +} +#mwtnTopology .nav-tabs.nav-justified { + width: 100%; + border-bottom: 0; +} +#mwtnTopology .nav-tabs.nav-justified > li { + float: none; +} +#mwtnTopology .nav-tabs.nav-justified > li > a { + margin-bottom: 5px; + text-align: center; +} +#mwtnTopology .nav-tabs.nav-justified > .dropdown .dropdown-menu { + top: auto; + left: auto; +} +@media (min-width: 768px) { + #mwtnTopology .nav-tabs.nav-justified > li { + display: table-cell; + width: 1%; + } + #mwtnTopology .nav-tabs.nav-justified > li > a { + margin-bottom: 0; + } +} +#mwtnTopology .nav-tabs.nav-justified > li > a { + margin-right: 0; + border-radius: 4px; +} +#mwtnTopology .nav-tabs.nav-justified > .active > a, +#mwtnTopology .nav-tabs.nav-justified > .active > a:hover, +#mwtnTopology .nav-tabs.nav-justified > .active > a:focus { + border: 1px solid #ddd; +} +@media (min-width: 768px) { + #mwtnTopology .nav-tabs.nav-justified > li > a { + border-bottom: 1px solid #ddd; + border-radius: 4px 4px 0 0; + } + #mwtnTopology .nav-tabs.nav-justified > .active > a, + #mwtnTopology .nav-tabs.nav-justified > .active > a:hover, + #mwtnTopology .nav-tabs.nav-justified > .active > a:focus { + border-bottom-color: #fff; + } +} diff --git a/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/mwtnTopology.controller.js b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/mwtnTopology.controller.js new file mode 100755 index 00000000..f8aa303a --- /dev/null +++ b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/mwtnTopology.controller.js @@ -0,0 +1,4877 @@ +/* + * Copyright (c) 2016 highstreet technologies GmbH and others. All rights reserved. + * + * 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 + */ +if (typeof (Number.prototype.toRad) === "undefined") { + Number.prototype.toRadians = function () { + return this * Math.PI / 180; + } +} + +if (Number.prototype.toDegrees === undefined) { + Number.prototype.toDegrees = function () { + return this * 180 / Math.PI; + }; +} + +// If array is empty, undefined is returned. If not empty, the first element +// that evaluates to false is returned. If no elements evaluate to false, the +// last element in the array is returned. +Array.prototype.and = function (defaultValue) { + for (var i = 0, len = this.length - 1; i < len && this[i]; i++); + return this.length ? this[i] : defaultValue; +}; + +// If array is empty, undefined is returned. If not empty, the first element +// that evaluates to true is returned. If no elements evaluate to true, the +// last element in the array is returned. +Array.prototype.or = function () { + for (var i = 0, len = this.length - 1; i < len && !this[i]; i++); + return this[i]; +}; + +var eventsFabric = function () { + var topics = {}; + var hOP = topics.hasOwnProperty; + + return { + subscribe: function (topic, listener) { + // Create the topic's object if not yet created + if (!hOP.call(topics, topic)) topics[topic] = []; + + // Add the listener to queue + var index = topics[topic].push(listener) - 1; + + // Provide handle back for removal of topic + return { + remove: function () { + delete topics[topic][index]; + } + }; + }, + publish: function (topic, info) { + // If the topic doesn't exist, or there's no listeners in queue, just leave + if (!hOP.call(topics, topic)) return; + + // Cycle through topics queue, fire! + topics[topic].forEach(function (item) { + item(info != undefined ? info : {}); + }); + } + }; +}; + +var lastOpenedInfoWindow = null; + +/*********************************************************************************************/ + +/** @typedef {{ id: string, siteA: string, siteZ: string, siteNameA: string, siteNameZ: string, airInterfaceLinks: {id: string, siteLink: string, radio: string, polarization: string }[]}} SiteLinkDetails */ + +define(['app/mwtnCommons/bower_components/lodash/dist/lodash', + 'app/mwtnCommons/bower_components/cytoscape/dist/cytoscape', + 'app/mwtnTopology/mwtnTopology.module', + 'app/mwtnTopology/mwtnTopology.services', + 'app/mwtnCommons/mwtnCommons.services' +], function (_, cytoscape, mwtnTopologyApp) { + + // module.exports = function () { + // const mwtnTopologyApp = require('app/mwtnTopology/mwtnTopology.module'); + // const mwtnTopologyService = require('app/mwtnTopology/mwtnTopology.services'); + // const cytoscape = require('cytoscape'); + + // remove '_' from global scope but use it here as '_'. + _.noConflict(); + + /********************************************* Sites *************************/ + + mwtnTopologyApp.directive('mwtnTopologyMap', ["$timeout", "$q", "$mwtnTopology", function ($timeout, $q, $mwtnTopology) { + return { + restrict: 'E', + replace: true, + template: '<div style="position:realtive;width:100%;height:700px" ng-transclude=""></div>', + controller: function () { + + }, + transclude: true, + scope: { + manualMapBounds: "=?", + onBoundsChanged: "&?" + }, + link: function (scope, element, attrs, ctrl) { + + var mapApiReadyDefer = $q.defer(); + var disbaleNotifications = true; + //var includeCenter = false; + + var initialMapOptions = { + center: new google.maps.LatLng(0, 0), + mapTypeId: google.maps.MapTypeId.HYBRID, + panControl: false, + rotateControl: false, + streetViewControl: false, + tilt: 0, + zoom: 2, + minZoom: 2 + }; + + // Wait at least one digest cycle before init the google map. + $timeout(function () { + ctrl.map = new google.maps.Map(element[0], initialMapOptions); + + // Wait until google maps is fully intialized to attach nessessary event handler. + waitUntilGoogleMapsIsReady(); + }); + + element.on("$destroy", function () { + if (scope.waitUntilGoogleMapsIsReadyTimeoutId) { + $timeout.cancel(scope.waitUntilGoogleMapsIsReadyTimeoutId); + } + if (scope.onDragEndListener) { + google.maps.event.removeListener(scope.onDragEndListener); + delete (scope.onDragEndListener); + } + if (scope.onZoomChangedListener) { + google.maps.event.removeListener(scope.onZoomChangedListener); + delete (scope.onZoomChangedListener); + } + + // window.removeEventListener('resize', onBoundsChanged); + + }); + + scope.$watch("manualMapBounds", function (newBounds, oldBounds) { + mapApiReadyDefer.promise.then(function () { + + // if this was an uri change from an not user originated action just return; + if (newBounds.internal) return; + + // values must exist and at least one must be different or initial load (new === old) + if (newBounds.bottom != null && newBounds.left != null && newBounds.top != null && newBounds.right != null) { + fitBounds(ctrl.map, new google.maps.LatLngBounds( + new google.maps.LatLng(newBounds.bottom, newBounds.left), + new google.maps.LatLng(newBounds.top, newBounds.right))); + } else if (newBounds.lat != null && newBounds.lng != null && newBounds.zoom != null && (newBounds.lat != oldBounds.lat || newBounds.lng != oldBounds.lng || newBounds.zoom != oldBounds.zoom || newBounds === oldBounds)) { + disbaleNotifications = true; + google.maps.event.addListenerOnce(ctrl.map, 'bounds_changed', function (event) { + disbaleNotifications = false; + onBoundsChanged(false); + + }); + ctrl.map.setCenter({ lat: newBounds.lat, lng: newBounds.lng }); + ctrl.map.setZoom(newBounds.zoom); + + } + console.log("manualMapBounds", newBounds); + }); + }); + + /** + * An asynchronous function that is called continuously every 100 milliseconds until the google maps control has finished its first complete draw. + * Then it sets up all event handlers and reports its bounds. + */ + function waitUntilGoogleMapsIsReady() { + var getBoundsApi = ctrl.map.getBounds(); + if (getBoundsApi) { + delete (scope.waitUntilGoogleMapsIsReadyTimeoutId); + // Change to dragend https://developers.google.com/maps/documentation/javascript/events?hl=de + scope.onDragEndListener = ctrl.map.addListener('dragend', function () { + onBoundsChanged(true); + }); + scope.onZoomChangedListener = ctrl.map.addListener('zoom_changed', function () { + onBoundsChanged(true); + }); + // window.addEventListener('resize', function () { + // onBoundsChanged(false); + // }); + + disbaleNotifications = false; + mapApiReadyDefer.resolve(); + } else { + scope.waitUntilGoogleMapsIsReadyTimeoutId = $timeout(waitUntilGoogleMapsIsReady, 100); + } + } + + /** + * Gets the current bound and zoom level of the map control and reports it to its parent component. + * Hint: do not call directly use fitBounds helper function since there is a google bug in the fit bounds function. + */ + function onBoundsChanged(userOriginated) { + if (!disbaleNotifications && scope.onBoundsChanged && angular.isFunction(scope.onBoundsChanged)) { + + var getBoundsApi = ctrl.map.getBounds(); + var northEastApi = getBoundsApi.getNorthEast(); + var southWestApi = getBoundsApi.getSouthWest(); + var center = ctrl.map.getCenter(); + + var data = { + top: northEastApi.lat(), + right: northEastApi.lng(), + bottom: southWestApi.lat(), + left: southWestApi.lng(), + lat: center.lat(), + lng: center.lng(), + zoom: ctrl.map.getZoom() + }; + + console.log("onBoundsChanged", data); + + scope.onBoundsChanged({ + data: data, + userOriginated: userOriginated === true + }); + } + } + + // bug: the original google code will fit bounds will add some extra space, this function will fix it + function fitBounds(map, bounds) { + var oldBounds = map.getBounds(); + + // ensure there is any change + if (oldBounds.toUrlValue() == bounds.toUrlValue()) { + return; + } + + disbaleNotifications = true; + google.maps.event.addListenerOnce(map, 'bounds_changed', function (event) { + // bugfix: this is a fix for the https://issuetracker.google.com/issues/35820423 + // the map does sometime zoom out if it gets its one bounds + + // var newSpan = map.getBounds().toSpan(); // the span of the map set by Google fitBounds (always larger by what we ask) + // var askedSpan = bounds.toSpan(); // the span of what we asked for + // var latRatio = (newSpan.lat() / askedSpan.lat()) - 1; // the % of increase on the latitude + // var lngRatio = (newSpan.lng() / askedSpan.lng()) - 1; // the % of increase on the longitude + // // if the % of increase is too big (> to a threshold) we zoom in + // if (Math.min(latRatio, lngRatio) > 0.46) { + // // 0.46 is the threshold value for zoming in. It has been established empirically by trying different values. + // this.setZoom(this.getZoom() + 1); + // } + disbaleNotifications = false; + onBoundsChanged(false); + + }); + map.fitBounds(bounds); // does the job asynchronously + } + } + }; + }]); + + mwtnTopologyApp.directive('mwtnTopologyMapSites', ['$compile', '$rootScope', function ($compile, $rootScope) { + + return { + restrict: 'E', + require: '^mwtnTopologyMap', + scope: { + sites: "=", + selectedSite: "=", + api: "=" + }, + link: function (scope, element, attrs, mwtnTopologyMapController) { + // todo: shouild come from a service + var normalIcon = { + path: google.maps.SymbolPath.CIRCLE, + scale: 10, + strokeColor: '#00ccff', + strokeOpacity: 0.8, + strokeWeight: 2, + fillColor: '#00ccff', + fillOpacity: 0.35, + zIndex: 2 + }; + + var highlightIcon = { + path: google.maps.SymbolPath.CIRCLE, + scale: 10, + strokeColor: '#eaae3c', + strokeOpacity: 0.8, + strokeWeight: 3, + fillColor: '#eaae3c', + fillOpacity: 0.65, + zIndex: 2 + }; + + var selectedIcon = { + path: google.maps.SymbolPath.CIRCLE, + scale: 10, + strokeColor: '#00FD30', + strokeOpacity: 0.8, + strokeWeight: 2, + fillColor: '#00FD30', + fillOpacity: 0.35, + zIndex: 2 + }; + + scope.displayedSites = {}; + scope.knownSites = {}; + + scope.$watch("selectedSite", function (newSiteId, oldSiteId) { + + if (oldSiteId && scope.displayedSites[oldSiteId]) { + scope.displayedSites[oldSiteId].setOptions({ + icon: normalIcon + }); + } + + if (newSiteId && scope.displayedSites[newSiteId]) { + scope.displayedSites[newSiteId].setOptions({ + icon: selectedIcon + }); + } + + }); + + if (!scope.api) return; + + /** + * Updates the google map markers + * @param addedSiteIds {string[]} The ids of the sites which are added to the scope.displayedSites dictionary. + * @param removedFromVisibleIds {string[]} The ids of sites which are removed from the visible bounding rectangle. + * @param movedFromVisibleToKnownIds {string[]} The ids of sites which are moved from the visible bounding rectangle to the extended bounding rectangle. + * @param removedFromKnownIds {string[]} The ids of sites which are removed from the extended bounding rectangle. + * @param movedFromKnownToVisibleIds {string[]} The ids of sites which are moved from the extended bounding rectangle to the visible bounding rectangle. + */ + scope.api.updateSites = function (addedSiteIds, removedFromVisibleIds, movedFromVisibleToKnownIds, removedFromKnownIds, movedFromKnownToVisibleIds) { + if (!addedSiteIds) addedSiteIds = []; + if (!removedFromVisibleIds) removedFromVisibleIds = []; + if (!movedFromVisibleToKnownIds) movedFromVisibleToKnownIds = []; + if (!removedFromKnownIds) removedFromKnownIds = []; + if (!movedFromKnownToVisibleIds) movedFromKnownToVisibleIds = []; + + removedFromVisibleIds.forEach(function (siteId) { + var marker = scope.displayedSites[siteId]; + if (marker) { + marker.setMap(null); + //delete marker; + delete scope.displayedSites[siteId]; + } + }); + + removedFromKnownIds.forEach(function (siteId) { + var marker = scope.knownSites[siteId]; + if (marker) { + marker.setMap(null); + //delete marker; + delete scope.knownSites[siteId]; + } + }); + + movedFromVisibleToKnownIds.forEach(function (siteId) { + var marker = scope.displayedSites[siteId]; + if (marker) { + marker.setVisible(false); + scope.knownSites[siteId] = marker; + delete scope.displayedSites[siteId]; + } + }); + + movedFromKnownToVisibleIds.forEach(function (siteId) { + var marker = scope.knownSites[siteId]; + if (marker) { + marker.setVisible(true); + scope.displayedSites[siteId] = marker; + delete scope.knownSites[siteId]; + } + }); + + addedSiteIds.forEach(function (newSiteId) { + var newSite = scope.sites[newSiteId]; + var newSiteNormalIcon = Object.assign({}, normalIcon, { + fillColor: (newSite.type === 'data-center') ? "#ffff00": "#00ccff", + strokeColor: (newSite.type === 'data-center') ? "#ffff00" : "#00ccff" + }); + var newSiteHighlightIcon = Object.assign({}, highlightIcon, { + fillColor: (newSite.type === 'data-center') ? "#ffff00": "#00ccff", + strokeColor: (newSite.type === 'data-center') ? "#ffff00" : "#00ccff" + }); + if (newSite && !scope.displayedSites[newSiteId]) { + + // create the marker + var marker = new google.maps.Marker({ + map: mwtnTopologyMapController.map, + position: newSite.location, + title: newSite.name, + icon: newSiteNormalIcon + }); + + // add event listeners to the marker + marker.addListener('click', function () { + // cloase all already opened windows + if (lastOpenedInfoWindow) { + lastOpenedInfoWindow.close(); + lastOpenedInfoWindow = null; + } + + // compile the content + var infoWindowTemplate = '<mwtn-topology-site-details site-id="siteId" />'; + var infoWindowScope = $rootScope.$new(); + infoWindowScope['siteId'] = newSiteId; + var infoWindowContent = $compile(infoWindowTemplate)(infoWindowScope)[0]; + + // create the info window + var infowindow = new google.maps.InfoWindow({ + content: infoWindowContent, + disableAutoPan: true + }); + + // open the window and keek a refenrece to close it if new window opens + infowindow.open(mwtnTopologyMapController.map, marker); + lastOpenedInfoWindow = infowindow; + + // remove the reference if the windows is closed + infowindow.addListener('closeclick', function () { + lastOpenedInfoWindow = null; + }); + }); + + marker.addListener('mouseover', function () { + marker.setOptions({ icon: newSiteHighlightIcon }); + }); + + marker.addListener('mouseout', function () { + marker.setOptions({ icon: newSiteNormalIcon }); + }); + + // store marker + scope.displayedSites[newSiteId] = marker; + } + }); + }; + + } + } + }]); + + mwtnTopologyApp.directive('mwtnTopologyMapSiteLinks', ['$compile', '$rootScope', function ($compile, $rootScope) { + return { + restrict: 'E', + require: '^mwtnTopologyMap', + scope: { + selectedSiteLink: "=", + siteLinks: "=", + api: "=" + }, + link: function (scope, element, attrs, mwtnTopologyMapController) { + + var normalColor = "#FF0000"; + var selectedColor = "#00FD30"; + + scope.$watch("selectedSiteLink", function (newSiteLinkId, oldSiteLinkId) { + + if (oldSiteLinkId && scope.displayedSiteLinks[oldSiteLinkId]) { + scope.displayedSiteLinks[oldSiteLinkId].setOptions({ + strokeColor: normalColor, + }); + } + + if (newSiteLinkId && scope.displayedSiteLinks[newSiteLinkId]) { + scope.displayedSiteLinks[newSiteLinkId].setOptions({ + strokeColor: selectedColor, + }); + } + + }); + + scope.displayedSiteLinks = {}; + + /** + * Updates the google map Polylines + * @param addedSiteLinkIds {string[]} The ids of sites links which are added to the scope.displayedSiteLinks dictionary and the google map. + * @param removedSiteLinkIds {string[]} The ids of sites links which are removed from the visible bounding rectangle within the google map. + */ + scope.api.updateSiteLinks = function (addedSiteLinkIds, removedSiteLinkIds) { + if (!addedSiteLinkIds) addedSiteLinkIds = []; + if (!removedSiteLinkIds) removedSiteLinkIds = []; + + removedSiteLinkIds.forEach(function (siteLinkId) { + var polyline = scope.displayedSiteLinks[siteLinkId]; + if (polyline) { + polyline.setMap(null); + //delete polyline; + delete scope.displayedSiteLinks[siteLinkId]; + } + }); + + addedSiteLinkIds.forEach(function (siteLinkId) { + var siteLink = scope.siteLinks[siteLinkId]; + console.log(siteLink); + + if (siteLink && !scope.displayedSiteLinks[siteLinkId]) { + + // create the poly line + var polyline = new google.maps.Polyline({ + map: mwtnTopologyMapController.map, + path: [siteLink.siteA.location, siteLink.siteZ.location], + strokeColor: siteLink.type === 'traffic' ? '#00ccff': '#ffff00', + strokeOpacity: 0.8, + strokeWeight: siteLink.type === 'traffic' ? 4 : 2, + zIndex: 1, + geodesic: true + }); + console.log(siteLink.type, polyline.strokeColor); + + // add event listeners to the polyline + polyline.addListener('click', function (event) { + // cloase all already opened windows + if (lastOpenedInfoWindow) { + lastOpenedInfoWindow.close(); + lastOpenedInfoWindow = null; + } + + // compile the content + var infoWindowTemplate = '<mwtn-topology-link-details link-id="linkId"></mwtn-topology-link-details>'; + var infoWindowScope = $rootScope.$new(); + infoWindowScope['linkId'] = siteLinkId; + var infoWindowContent = $compile(infoWindowTemplate)(infoWindowScope)[0]; + + // create the info window + var infowindow = new google.maps.InfoWindow({ + content: infoWindowContent, + disableAutoPan: true + }); + + // open the window and keek a refenrece to close it if new window opens + // adjust and show the info window + infowindow.setPosition(event.latLng); + infowindow.open(mwtnTopologyMapController.map); + lastOpenedInfoWindow = infowindow; + + // remove the reference if the windows is closed + infowindow.addListener('closeclick', function () { + lastOpenedInfoWindow = null; + }); + + }); + + polyline.addListener('mouseover', function () { + polyline.setOptions({ strokeWeight: 6 }); + }); + + polyline.addListener('mouseout', function () { + polyline.setOptions({ strokeWeight: 3 }); + }); + + // store the ployline + scope.displayedSiteLinks[siteLinkId] = polyline; + } + }); + }; + + } + }; + }]); + + mwtnTopologyApp.controller('mwtnTopologySiteDetailsController', ['$scope', '$timeout', '$mwtnTopology', function ($scope, $timeout, $mwtnTopology) { + var vm = this; + vm.site = null; + + $scope.$watch(function () { return vm.siteId }, function (newSiteId, oldSiteId) { + if (!newSiteId) return; + + vm.status = { + message: 'Searching...', + type: 'warning', + isWorking: true + }; + + $mwtnTopology.getSiteDetailsBySiteId(newSiteId).then(function (siteDetails) { + vm.site = siteDetails; + + vm.status = { + message: undefined, + type: 'success', + isWorking: false + }; + }, function (err) { + vm.status = { + message: err, + type: 'error', + isWorking: false + }; + }); + }); + + }]); + + mwtnTopologyApp.directive('mwtnTopologySiteDetails', function () { + return { + scope: { siteId: "=" }, + restrict: 'E', + controller: 'mwtnTopologySiteDetailsController', + controllerAs: 'vm', + bindToController: true, + templateUrl: 'src/app/mwtnTopology/templates/siteDetails.tpl.html' + }; + }); + + mwtnTopologyApp.controller('mwtnTopologyLinkDetailsController', ['$scope', '$timeout', '$mwtnTopology', function ($scope, $timeout, $mwtnTopology) { + /** @type {{ link: SiteLinkDetails } & {[key: string]: any}} */ + var vm = this; + vm.site = null; + vm.link = null; + + $scope.$watch(function () { return vm.linkId }, function (newLinkId, oldLinkId) { + if (!newLinkId) return; + + vm.status = { + message: 'Searching...', + type: 'warning', + isWorking: true + }; + + // getLinkDetailsByLinkId + $mwtnTopology.getLinkDetailsByLinkId(newLinkId).then( + /** @param {SiteLinkDetails} linkDetails*/ + function (linkDetails) { + vm.link = linkDetails; + + vm.status = { + message: undefined, + type: 'success', + isWorking: false + }; + }, function (err) { + vm.status = { + message: err, + type: 'error', + isWorking: false + }; + }); + }); + + }]); + + mwtnTopologyApp.directive('mwtnTopologyLinkDetails', function () { + return { + scope: { linkId: "=" }, + restrict: 'E', + controller: 'mwtnTopologyLinkDetailsController', + controllerAs: 'vm', + bindToController: true, + templateUrl: 'src/app/mwtnTopology/templates/linkDetails.tpl.html' + }; + }); + + mwtnTopologyApp.controller('mwtnTopologyFrameController', ['$scope', '$rootScope', '$timeout', '$state', '$window', '$mwtnTopology', function ($scope, $rootScope, $timeout, $state, $window, $mwtnTopology) { + var vm = this; + + $rootScope.section_logo = 'src/app/mwtnTopology/images/mwtnTopology.png'; // Add your topbar logo location here such as 'assets/images/logo_topology.gif' + + /** @type {{ [tabName: string] : { [parameterName : string] : any } }} */ + var tabParameters = {}; + + var tabs; + (function (tabs) { + tabs[tabs["site"] = 0] = "site"; + tabs[tabs["physical"] = 1] = "physical"; + tabs[tabs["ethernet"] = 2] = "ethernet"; + tabs[tabs["ieee1588"] = 3] = "ieee1588"; + })(tabs || (tabs = {})); + + $scope.$watch(function () { return vm.activeTab; }, function (newVal, oldVal, scope) { + if (newVal == null) return; + + var newName = tabs[newVal]; + + if (oldVal != null && tabs[oldVal]) { + var oldName = tabs[oldVal]; + tabParameters[oldName] = $state.params; + } + + var newParameters = Object.keys($state.params).reduce(function (acc, cur, ind, arr) { acc[cur] = null; return acc; }, {}); + Object.assign(newParameters, tabParameters[newName] || {}, { tab: newName, internal: false }); + + $state.go('main.mwtnTopology', newParameters, { notify: false }); + console.log("activeTab: ", newName); + }); + + $scope.$watch(function () { return $state.params.tab; }, function (newVal, oldVal, scope) { + if (newVal == oldVal) return; + if (newVal && !$state.params.internal) { + vm.activeTab = tabs[newVal || "site"]; + console.log("navigationTab: ", vm.activeTab); + } + }); + + // hide all tabs until the google api is fully loaded. + // initialize with true is the promise is resolved === 1 + vm.googleIsReady = $mwtnTopology.googleMapsApiPromise.$$state.status === 1; + + if (!vm.googleIsReady) $mwtnTopology.googleMapsApiPromise.then(function () { + $timeout(function () { + vm.googleIsReady = true; + }); + }); + + }]); + + mwtnTopologyApp.directive('mwtnTopologyFrame', function () { + return { + restrict: 'E', + controller: 'mwtnTopologyFrameController', + controllerAs: 'vm', + templateUrl: 'src/app/mwtnTopology/templates/frame.tpl.html' + }; + }); + + mwtnTopologyApp.controller('mwtnTopologySiteViewController', ['$scope', '$q', '$timeout', '$state', '$window', '$mwtnTopology', function ($scope, $q, $timeout, $state, $window, $mwtnTopology) { + var vm = this; + // Determines if a database request loop should be canceld. + var cancelRequested = false; + // Represents a defer which is resolved, if a cancel was requested and fulfilled. + var cancelDefer = $q.defer(); + // Represents the new bounding rectangle who was set with the last user action to change the map bounds. + // The value is saved until the cancel operation is fulfilled. + /** @type {{top: number, right: number, bottom: number, left: number, zoom: number}} */ + var waitForCancelMapBoundAndZoom; + // While getting all sites collect all site link ids which are available through visible and known sites. + // This dictionary will be cleared each time a new map bound is changed and a new database request loop is started. + var collectedSiteLinkIds = {}; + + vm.status = { + // Determines the bounds of the map which is manually set by the code. These are the initial values. + manualMapBounds: { + top: !Number.isNaN(+$state.params.top) ? +$state.params.top : undefined, + bottom: !Number.isNaN(+$state.params.bottom) ? +$state.params.bottom : undefined, + left: !Number.isNaN(+$state.params.left) ? +$state.params.left : undefined, + right: !Number.isNaN(+$state.params.right) ? +$state.params.right : undefined, + zoom: !Number.isNaN(+$state.params.zoom) ? +$state.params.zoom : undefined, + lat: !Number.isNaN(+$state.params.lat) ? +$state.params.lat : undefined, + lng: !Number.isNaN(+$state.params.lng) ? +$state.params.lng : undefined + }, + + // Determines if the accordeon group element for SiteMap, SiteGrid or SiteLinkGrid is open. + siteMapIsOpen: true, + siteGridIsOpen: true, + siteLinkGridIsOpen: true, + sitePathGridIsOpen: false, + + // Determines if a processing is running. + processing: false, + totalSitesInBoundingBox: 0, + loadedSitesInBoundingBox: 0, + maximumCountOfVisibleSites: 300, + + // selectet Elements + site: null, + siteLink: null, + sitePath: null + }; + + // Contains the known and visible sites as well as known site links as dictionaries. + vm.knownSites = {}; + vm.visibleSites = {}; + vm.knownSiteLinks = {}; + + // Api-Object that will be filled with update methods from the mwtnTopologyMapSites Component. + vm.mapSitesComponentApi = {}; + // Api-Object that will be filled with update methods from the mwtnTopologyMapSiteLinks Component. + vm.mapSiteLinksComponentApi = {}; + + //addedSiteLinkIds, removedSiteLinkIds + + initializeMapBounds(); + + function initializeMapBounds() { + + vm.status.manualMapBounds = { + top: !Number.isNaN(+$state.params.top) ? +$state.params.top : undefined, + bottom: !Number.isNaN(+$state.params.bottom) ? +$state.params.bottom : undefined, + left: !Number.isNaN(+$state.params.left) ? +$state.params.left : undefined, + right: !Number.isNaN(+$state.params.right) ? +$state.params.right : undefined, + zoom: !Number.isNaN(+$state.params.zoom) ? +$state.params.zoom : undefined, + lat: !Number.isNaN(+$state.params.lat) ? +$state.params.lat : undefined, + lng: !Number.isNaN(+$state.params.lng) ? +$state.params.lng : undefined + }; + + // Calculate the initial map control bound, if we have no initial bounds + if ((vm.status.manualMapBounds.top == null && vm.status.manualMapBounds.bottom == null && vm.status.manualMapBounds.right == null && vm.status.manualMapBounds.left == null && vm.status.manualMapBounds.lat == null && vm.status.manualMapBounds.lng == null && $state.params.site == null && $state.params.siteLink == null && $state.params.sitePath == null)) { + $mwtnTopology.getOuterBoundingRectangleForSites().then(function (bounds) { + // Ensures that the new value is set within a digest cycle. + vm.status.manualMapBounds = bounds; + }); + } + } + + $scope.$watch(function () { return $state.params.site; }, function (newVal, oldVal, scope) { + if (newVal) { + $mwtnTopology.getSiteDetailsBySiteId(newVal).then(function (siteDetails) { + if (siteDetails) { + // just update the location of the browser if the location has changed + $state.go('main.mwtnTopology', { + tab: "site", + lat: siteDetails.location.lat, + lng: siteDetails.location.lng, + zoom: 19, + top: null, + bottom: null, + right: null, + left: null, + site: $state.params.site, + siteLink: null, + sitePath: null, + internal: false + }, { + notify: false + }); + }; + }, function (err) { + + }); + } + }); + + $scope.$watch(function () { return $state.params.siteLink; }, function (newVal, oldVal, scope) { + if (newVal) { + $mwtnTopology.getLinkDetailsByLinkId(newVal).then(function (link) { + if (link) { + + var top = link.siteA.location.lat >= link.siteZ.location.lat ? link.siteA.location.lat : link.siteZ.location.lat; + var bottom = link.siteA.location.lat >= link.siteZ.location.lat ? link.siteZ.location.lat : link.siteA.location.lat; + + // todo: this code is not able to handle links which overlap the -100|180 ° borderline + var left = link.siteA.location.lng <= link.siteZ.location.lng ? link.siteA.location.lng : link.siteZ.location.lng; + var right = link.siteA.location.lng <= link.siteZ.location.lng ? link.siteZ.location.lng : link.siteA.location.lng; + // just update the location of the browser if the location has changed + $state.go('main.mwtnTopology', { + tab: "site", + lat: null, + lng: null, + zoom: $state.params.zoom, + top: top, + bottom: bottom, + right: right, + left: left, + site: null, + siteLink: $state.params.siteLink, + sitePath: null, + internal: false + }, { + notify: false + }); + }; + }, function (err) { + + }); + } + }); + + $scope.$watchCollection(function () { return [vm.status.siteMapIsOpen, vm.status.siteGridIsOpen, vm.status.siteLinkGridIsOpen, vm.status.sitePathGridIsOpen] }, function (newVal, oldVal) { + if (newVal[1] || newVal[2] || newVal[3]) { + $timeout(function () { + $window.dispatchEvent(new Event("resize")); + }); + } + }); + + $scope.$watchCollection(function () { return [+$state.params.top, +$state.params.bottom, +$state.params.left, +$state.params.right, +$state.params.lat, +$state.params.lng, +$state.params.zoom]; }, function (newVal, oldVal, scope) { + + if (oldVal == null || oldVal === newVal) return; // ignore initial value + + if (!vm.status.siteMapIsOpen) { + console.log("open Site Map") + vm.status.siteMapIsOpen = true; + return; + } + + vm.status.manualMapBounds = { + top: !Number.isNaN(newVal[0]) ? newVal[0] : undefined, + bottom: !Number.isNaN(newVal[1]) ? newVal[1] : undefined, + left: !Number.isNaN(newVal[2]) ? newVal[2] : undefined, + right: !Number.isNaN(newVal[3]) ? newVal[3] : undefined, + zoom: !Number.isNaN(newVal[6]) ? newVal[6] : undefined, + internal: !!$state.params.internal + }; + + if (!Number.isNaN(newVal[4]) && !Number.isNaN(newVal[5])) { + vm.status.manualMapBounds.lat = newVal[4]; + vm.status.manualMapBounds.lng = newVal[5]; + } else { + vm.status.manualMapBounds.lat = undefined; + vm.status.manualMapBounds.lng = undefined; + } + + if (!!$state.params.internal) $state.params.internal = false; + + }); + + $scope.$watchCollection(function () { return vm.status.siteMapIsOpen }, function (newVal, oldVal, scope) { + if (oldVal == newVal) return; // ignore initial value + if (newVal) { + // Map (re)-opend + initializeMapBounds(); + } else { + // Map closed + vm.status.loadedSitesInBoundingBox = 0; + vm.status.totalSitesInBoundingBox = 0; + vm.status.manualMapBounds = {}; + vm.knownSites = {}; + vm.visibleSites = {}; + vm.knownSiteLinks = {}; + }; + // tell all sub components the visuability of the map view + $scope.$broadcast('mapViewVisuability', newVal); + }); + + /* callback and helper methods */ + /** + * A callback function which is called by the map control of the user changed the bounds of the map. + * @param mapBoundsAndZoom {{top: number, right: number, bottom: number, left: number, zoom: number}} The new bounds and the new zoom level of the map control. + */ + vm.mapBoundsChanged = function (mapBoundsAndZoom, userOriginated) { + + // just update the location of the browser if the location has changed + $state.go('main.mwtnTopology', { + tab: "site", + lat: mapBoundsAndZoom.lat, + lng: mapBoundsAndZoom.lng, + zoom: mapBoundsAndZoom.zoom, + top: null, + bottom: null, + right: null, + left: null, + site: !userOriginated ? $state.params.site : null, + siteLink: !userOriginated ? $state.params.siteLink : null, + sitePath: !userOriginated ? $state.params.sitePath : null, + internal: true + }, { + notify: false + }); + console.log("handleBoundsChanged", mapBoundsAndZoom); + + if (vm.status.siteMapIsOpen) refreshAllSites(mapBoundsAndZoom); + }; + + /** + * Refreshes all visible elements in the given view port + * @param mapBoundsAndZoom {{top: number, right: number, bottom: number, left: number, zoom: number}} The new bounds and the new zoom level of the map control. + */ + function refreshAllSites(mapBoundsAndZoom) { + + // Datenbankabfragen werden werden in kleine Chunks zerlegt. + // Jeder Chunk enthält maximal ${chunkSize} (100) Sites und die Anzahl aller Sites für die spezifische Abfrage in der Antwort. + // Sind noch nicht alle Chunks von der Datenbank angefordert worden, wird zuerst der nächste Chunk angefordert. + // Der aktuell zurückgegebene Chunk wird aber erst verarbeitet, bevor in einer weiteren Callback-Situation der nächste Datenbank-Chunk abgeholt wird. + // Dadurch werden kontinuierlich alle Sites auch auf der Map ergänzt, sobald sie verarbeitet wurden und es kommt zu keiner Verzögerung im Benutzerinterface. + // Im Maximum werden aber ${vm.status.maximumCountOfVisibleSites} (2500) Sites abgerufen, um die Google Map nicht zu überlasten. + + // Fallunterscheidung: gibt es bereits eine aktive Datenbankabfrage zu den Sites? + // => Nein: Starte eine neue Datenbankabfrage + // => Ja: Breche die aktuelle Verarbeitung ab, aktualisiere den Status und starte dann eine neue Datenbankabfrage. + if (vm.status.processing) { + waitForCancelMapBoundAndZoom = mapBoundsAndZoom; + + if (cancelRequested) { + console.log("Cancel is already requested."); + return; + } + + // Request a database loop cancel. + cancelRequested = true; + console.log("New Cancel requested.") + + // Wait until the current database loos was canceled. + cancelDefer.promise.then(function () { + // The database loop is canceled. Create a new defer for the next possible cancel request. + console.log("Cancel fulfilled."); + cancelDefer = $q.defer(); + // Restart the database loop with the new bounding rectangle. + beginProcessing(waitForCancelMapBoundAndZoom); + }); + + // Do not start a database loop here - so leave the method. + return; + } + + // Start a new database loop here. + beginProcessing(mapBoundsAndZoom); + + /** + * The private function which begins a new database processing loop. + * @param mapBoundsAndZoom {{top: number, right: number, bottom: number, left: number, zoom: number}} The new bounds and the new zoom level of the map control. + */ + function beginProcessing(mapBoundsAndZoom) { + // Set the processing flag to true. + vm.status.processing = true; + + var chunkSize = 100; + var chunkSiteStartIndex = 0; + + // If a site link cannot convert its siteA or siteZ (id) Parameter to a real site object these ids will collected. + // After a subsequent database call to get these sites the queued site links will be converted. + var additionalSiteIds = []; + var queuedSiteLinksToConvert = []; + + // Entferne Sites, welche aufgrund des neuen Bounds leicht außer Sicht sind von den sichtbaren Sites. + // Hinzufügen von Sites aus den leicht außer Sicht Bereich zum sichtbaren Bereich. + var movedOrRemovedSites = refreshOutOfSightSites(mapBoundsAndZoom); + var removedFromVisibleIds = movedOrRemovedSites.removedFromVisibleIds; + var movedFromVisibleToKnownIds = movedOrRemovedSites.movedFromVisibleToKnownIds; + var removedFromKnownIds = movedOrRemovedSites.removedFromKnownIds; + var movedFromKnownToVisibleIds = movedOrRemovedSites.movedFromKnownToVisibleIds; + var removedSiteLinkIds = movedOrRemovedSites.removedSiteLinkIds; + + // While getting all sites collect all site link ids which are available through visible and known sites. + collectedSiteLinkIds = {}; + + doSiteRequestLoop(); + + /* internal function within beginProcessing */ + /** + * Starts a new database request loop to get all sites. + */ + function doSiteRequestLoop() { + requestNextSiteChunk(mapBoundsAndZoom, chunkSize, chunkSiteStartIndex).then( + /** + * @param result {{addedSiteIds: string[], total: number}} An array with the ids of the sites which are added to the vm.visibleSites dictionary. + */ + function (result) { + // update the frontend before continue with the next database request. + vm.mapSitesComponentApi.updateSites && vm.mapSitesComponentApi.updateSites(result.addedSiteIds, removedFromVisibleIds, movedFromVisibleToKnownIds, removedFromKnownIds, movedFromKnownToVisibleIds); + removedSiteLinkIds && removedSiteLinkIds.length && vm.mapSiteLinksComponentApi.updateSiteLinks && vm.mapSiteLinksComponentApi.updateSiteLinks([], removedSiteLinkIds); + // to not re-remove and re-move already removed and moved sites clear the arrays for any subsequent database requests. + removedFromVisibleIds = []; + movedFromVisibleToKnownIds = []; + removedFromKnownIds = []; + movedFromKnownToVisibleIds = []; + removedSiteLinkIds = []; + + if (cancelRequested) { + // reset the cancelRequested flag and resolve the cancel request. + cancelRequested = false; + cancelDefer.resolve(); + return; + } + + // Enforce angular to process a new digest cycle. + $timeout(function () { + vm.status.totalSitesInBoundingBox = result.total; + vm.status.loadedSitesInBoundingBox = Math.min(chunkSiteStartIndex + chunkSize, result.total); + if (chunkSiteStartIndex + chunkSize >= result.total || chunkSiteStartIndex + chunkSize >= vm.status.maximumCountOfVisibleSites) { + // This was the last database request to get sites. + // Remove all known site link ids from the collectedSiteLinkIds dictionary. + var knownSiteLinkIds = Object.keys(vm.knownSiteLinks); + knownSiteLinkIds.forEach(function (knownSiteLinkId) { + if (collectedSiteLinkIds[knownSiteLinkId]) { + delete collectedSiteLinkIds[knownSiteLinkId]; + } + }); + + // Start the request loop for site links now. + doSiteLinkRequestLoop(Object.keys(collectedSiteLinkIds)); + } else { + // There are more data, request the database again. + chunkSiteStartIndex += chunkSize; + + doSiteRequestLoop(); + } + }); + + }, processError); + } + + function endProcessing() { + vm.status.processing = false; + + $timeout(function () { + vm.status.site = $state.params.site; + vm.status.siteLink = $state.params.siteLink; + }); + } + + /** + * Starts a new database request loop to get all site links. + */ + function doSiteLinkRequestLoop(siteLinkIds) { + var requestedSiteLinkIds = siteLinkIds.splice(0, chunkSize); + + $mwtnTopology.getSiteLinksByIds(requestedSiteLinkIds).then( + /** + * Processes the database result. + * The returned site links doesn't contain site objects but site ids. + * In a subsequent step these ids will be converted into real site objects. + * @param result {{id: string, siteA: string, siteZ: string}[]} The database result. + */ + function (result) { + // Subsequent convert. + // All site links which siteA and siteZ site ids are known could be added to vm.knownSiteLinks. + // The rest has to saved until all requests are finished. + // Another database call will get the additional sites to convert these site links. + var addedSiteLinkIds = result.reduce(function (accumulator, currentSiteLink) { + var siteA = vm.visibleSites[currentSiteLink.siteA] || vm.knownSites[currentSiteLink.siteA]; + var siteZ = vm.visibleSites[currentSiteLink.siteZ] || vm.knownSites[currentSiteLink.siteZ]; + if (siteA && siteZ) { + vm.knownSiteLinks[currentSiteLink.id] = { + id: currentSiteLink.id, + siteA: siteA, + siteZ: siteZ, + type: currentSiteLink.type + }; + accumulator.push(currentSiteLink.id); + } else { + // Theoretically, only siteA or siteZ can be unknown. I still check both separately. + var isPushed = false; + if (!siteA) { + additionalSiteIds.push(currentSiteLink.siteA); + queuedSiteLinksToConvert.push(currentSiteLink); + isPushed = true; + } + if (!siteZ) { + additionalSiteIds.push(currentSiteLink.siteZ); + isPushed || queuedSiteLinksToConvert.push(currentSiteLink); + } + } + return accumulator; + }, []); + + // update the frontend before continue with the next database request. + vm.mapSiteLinksComponentApi.updateSiteLinks && vm.mapSiteLinksComponentApi.updateSiteLinks(addedSiteLinkIds); + + if (cancelRequested) { + // reset the cancelRequested flag and resolve the cancel request. + cancelRequested = false; + cancelDefer.resolve(); + return; + } + + // Enforce angular to process a new digest cycle. (And to let angular time to redraw the map.) + $timeout(function () { + if (siteLinkIds.length === 0) { + if (additionalSiteIds.length === 0) { + endProcessing(); + return; + } + + // Only get a maximum of chunkSize additional sites. + // Site links more than that will not be drawed in the map due to performance reasons. + // If the user zooms in the additional site links will be requested again. + $mwtnTopology.getSitesByIds(additionalSiteIds.splice(0, chunkSize)).then( + /** + * Processes the database result to gain new sites within the bounding box of the database request. + * @param result {{total: number, sites: {id: string, name: string, location: {lat: number, lng: number}, amslGround: number, references: {siteLinks: string[]}}[]}} The database result. + */ + function (result) { + var addedSiteLinkIds = queuedSiteLinksToConvert.reduce(function (accumulator, currentSiteLink) { + var siteA = vm.visibleSites[currentSiteLink.siteA] || vm.knownSites[currentSiteLink.siteA] || result.sites.find( + function (site) { + return site.id === currentSiteLink.siteA + }); + var siteZ = vm.visibleSites[currentSiteLink.siteZ] || vm.knownSites[currentSiteLink.siteZ] || result.sites.find( + function (site) { + return site.id === currentSiteLink.siteZ + }); + if (siteA && siteZ) { + vm.knownSiteLinks[currentSiteLink.id] = { + id: currentSiteLink.id, + siteA: siteA, + siteZ: siteZ, + type: currentSiteLink.type + }; + accumulator.push(currentSiteLink.id); + } + return accumulator; + }, []); + // update the frontend the last time until the user changed the map position. + vm.mapSiteLinksComponentApi.updateSiteLinks && vm.mapSiteLinksComponentApi.updateSiteLinks(addedSiteLinkIds); + + // all done - puh. + endProcessing(); + }, processError); + + } else { + // There are more data, request the database again. + doSiteLinkRequestLoop(siteLinkIds); + } + }); + + }, processError); + } + + } + }; + + /** + * Recalculates the targets site container for Sites within knownSites and visibleSites. + * @param mapBoundsAndZoom {{top: number, right: number, bottom: number, left: number, zoom: number}} The new bounds and the new zoom level of the map control. + */ + function refreshOutOfSightSites(mapBoundsAndZoom) { + var additionalWidth = (mapBoundsAndZoom.right - mapBoundsAndZoom.left) / 4; + var additionalHeight = (mapBoundsAndZoom.top - mapBoundsAndZoom.bottom) / 4; + var slightlyTop = mapBoundsAndZoom.top + additionalHeight; + var slightlyRight = mapBoundsAndZoom.right + additionalWidth; + var slightlyBottom = mapBoundsAndZoom.bottom - additionalHeight; + var slightlyLeft = mapBoundsAndZoom.left - additionalWidth; + + var removedFromVisibleIds = []; + var movedFromVisibleToKnownIds = []; + var removedFromKnownIds = []; + var movedFromKnownToVisibleIds = []; + var removedSiteLinkIds = []; + + var visibleSiteKeys = Object.keys(vm.visibleSites); + var knownSiteKeys = Object.keys(vm.knownSites); + var knownSiteLinkKeys = Object.keys(vm.knownSiteLinks); + + visibleSiteKeys.forEach(function (siteId) { + /** @var {{id: string, name: string, location: {lat: number, lng: number}, amslGround: number, references: {siteLinks: string[]}} site */ + var site = vm.visibleSites[siteId]; + + if (site.location.lat > slightlyTop || site.location.lng > slightlyRight || site.location.lat < slightlyBottom || site.location.lng < slightlyLeft) { + // This site is completly out of sight - so remove it and add the id to the removedFromVisibleIds list. + delete vm.visibleSites[siteId]; + removedFromVisibleIds.push(siteId); + return; + } + + if (site.location.lat > mapBoundsAndZoom.top || site.location.lng > mapBoundsAndZoom.right || site.location.lat < mapBoundsAndZoom.bottom || site.location.lng < mapBoundsAndZoom.left) { + // This site is moved from the visible map bounds to the extended map bounds and will only hide but stay in the google object. + vm.knownSites[siteId] = site; + delete vm.visibleSites[siteId]; + movedFromVisibleToKnownIds.push(siteId); + return; + } + }); + + knownSiteKeys.forEach(function (siteId) { + /** @type {{id: string, name: string, location: {lat: number, lng: number}, amslGround: number, references: {siteLinks: string[]}} site */ + var site = vm.knownSites[siteId]; + + if (site.location.lat > slightlyTop || site.location.lng > slightlyRight || site.location.lat < slightlyBottom || site.location.lng < slightlyLeft) { + // This site is completly out of sight - so remove it and add the id to the removedFromKnownIds list. + delete vm.knownSites[siteId]; + removedFromKnownIds.push(siteId); + return; + } + + if (site.location.lat <= mapBoundsAndZoom.top && site.location.lng <= mapBoundsAndZoom.right && site.location.lat >= mapBoundsAndZoom.bottom && site.location.lng >= mapBoundsAndZoom.left) { + // This site is moved from the extended map bounds to the visible map bounds. Therefore the hidden google maps object should set visible again. + vm.visibleSites[siteId] = site; + delete vm.knownSites[siteId]; + movedFromKnownToVisibleIds.push(siteId); + return; + } + }); + + knownSiteLinkKeys.forEach(function (siteLinkId) { + /** @type {{id: string, siteA: {id: string, name: string, location: {lat: number, lng: number}, amslGround: number, references: {siteLinks: string[]}}, siteZ: {id: string, name: string, location: {lat: number, lng: number}, amslGround: number, references: {siteLinks: string[]}}}} siteLink */ + var siteLink = vm.knownSiteLinks[siteLinkId]; + var siteA = siteLink.siteA; + var siteZ = siteLink.siteZ; + + if ((siteA.location.lat > slightlyTop || siteA.location.lng > slightlyRight || siteA.location.lat < slightlyBottom || siteA.location.lng < slightlyLeft) && + (siteZ.location.lat > slightlyTop || siteZ.location.lng > slightlyRight || siteZ.location.lat < slightlyBottom || siteZ.location.lng < slightlyLeft)) { + // This site link is completly out of sight - so remove it and add the id to the removedSiteLinkIds list. + delete vm.knownSiteLinks[siteLinkId]; + removedSiteLinkIds.push(siteLinkId); + } + }); + + return { + removedFromVisibleIds: removedFromVisibleIds, + movedFromVisibleToKnownIds: movedFromVisibleToKnownIds, + removedFromKnownIds: removedFromKnownIds, + movedFromKnownToVisibleIds: movedFromKnownToVisibleIds, + removedSiteLinkIds: removedSiteLinkIds + }; + } + + /** + * Requests a chunk of sites from the database. + * @param mapBoundsAndZoom {{top: number, right: number, bottom: number, left: number, zoom: number}} The bounds and the zoom level of the map control to request the next chunk for. + * @param chunkSize {number} The chunk size of a single database request. To big values will block the user interface, to small values will lead in to many database requests. + * @param chunkSiteStartIndex {number} The index of the first site returned by the database. + */ + function requestNextSiteChunk(mapBoundsAndZoom, chunkSize, chunkSiteStartIndex) { + var requestNextSiteChunkDefer = $q.defer(); + var addedSiteIds = []; + + // Request the next chunk. + $mwtnTopology.getSitesInBoundingBox(mapBoundsAndZoom, chunkSize, chunkSiteStartIndex).then( + /** + * Processes the database result to gain new sites within the bounding box of the database request. + * @param result {{chunkSize: number, chunkSiteStartIndex: number, total: number, sites: {id: string, name: string, location: {lat: number, lng: number}, amslGround: number, references: {siteLinks: string[]}}[]}} The database result. + */ + function (result) { + result.sites.forEach(function (site) { + // The map bounds may have changed since the start of the database request. + // Therefore check if the site is within the bounding rectangle. + + if (!$mwtnTopology.isInBounds(mapBoundsAndZoom, site.location)) { + return; + } + + // add all site link ids to the selectedSiteLinkIds dictionary. + site.references.siteLinks.forEach(function (siteLinkId) { + collectedSiteLinkIds[siteLinkId] = true; + }); + + // check, if the site is within the knownSites dictionary. + if (vm.knownSites[site.id]) { + delete vm.knownSites[site.id]; + } + + // check if the site is within the visibleSites dictionary. + if (vm.visibleSites[site.id]) { + // Override the site (refresh) + vm.visibleSites[site.id] = site; + } else { + // Add the site to the dictionary and remember the siteId. + vm.visibleSites[site.id] = site; + addedSiteIds.push(site.id); + } + }); + + requestNextSiteChunkDefer.resolve({ + addedSiteIds: addedSiteIds, + total: result.total + }); + }, requestNextSiteChunkDefer.reject); + + return requestNextSiteChunkDefer.promise; + } + + /** + * Handles error messages by writing the information to the javascript console. + * Resets the processing flag. + * @param error Information about the error. + */ + function processError(error) { + // Reset the processing flag. + vm.status.processing = false; + // Write the error information to the console. + console.error(error); + } + + }]); + + mwtnTopologyApp.directive('mwtnTopologySiteView', function () { + return { + restrict: 'E', + controller: 'mwtnTopologySiteViewController', + controllerAs: 'vm', + bindToController: true, + templateUrl: 'src/app/mwtnTopology/templates/siteView.tpl.html', + scope: { + initialMapBounds: "=" + } + }; + }); + + mwtnTopologyApp.controller('mwtnTopologySiteGridController', ['$scope', '$timeout', '$state', '$mwtnCommons', '$mwtnTopology', 'uiGridConstants', function ($scope, $timeout, $state, $mwtnCommons, $mwtnTopology, uiGridConstants) { + var vm = this; + + // The page number to show in the grid. + var paginationPage = 1; + // The page size. + var paginationPageSize = 100; + // The grid column object with current sorting informations. + var sortColumn = null; + // The grid column object with current sorting informations. + var gridFilters = []; + // caches all sites at the current grid page + var sitesAtCurrentPageCache = {}; + + vm.showAllSites = false; + + vm.onNavigateToSite = function (row) { + var site = sitesAtCurrentPageCache[row.entity.id]; + $state.go("main.mwtnTopology", { + tab: "site", + lat: site.location.lat, + lng: site.location.lng, + zoom: 19, + site: site.id, + internal: false + }, { notify: false }); + }; + + // see http://ui-grid.info/docs/#/tutorial/317_custom_templates + var buttonCellTemplate = '<div class="ui-grid-cell-contents tooltip-uigrid" title="TOOLTIP"><i ng-click="grid.appScope.vm.onNavigateToSite(row)" ng-class="{\'fa\':true, \'fa-map-marker\': true, \'{{COL_FIELD}}\':true}" aria-hidden="true"></i></div>'; + + vm.gridOptions = Object.assign({}, $mwtnCommons.gridOptions, { + showGridFooter: false, // disable the grid footer because the pagination component sets its own. + paginationPageSizes: [10, 25, 50, 100], + paginationPageSize: paginationPageSize, + useExternalPagination: true, + useExternalFiltering: true, + useExternalSorting: true, + totalItems: 0, + columnDefs: [{ + field: "id", + type: "string", + displayName: "Id" + }, + { + field: "name", + type: "string", + displayName: "Name" + }, + { + field: "location", + type: "string", + displayName: "Location" + }, + { + field: "amslGround", + type: "string", + displayName: "AmslGround" + }, + { + field: "countLinks", + type: "number", + displayName: "Count (Links)" + }, + { + field: "countNetworkElements", + type: "number", + displayName: "Count (Network elements)" + }, + { + field: "buttons", + type: "string", + displayName: "", + width: 40, + enableFiltering: false, + enableSorting: false, + cellTemplate: buttonCellTemplate, + pinnedRight: true + } + ], + data: [], + onRegisterApi: function (gridApi) { + // http://ui-grid.info/docs/#/api/ui.grid.core.api:PublicApi + vm.gridApi = gridApi; + + vm.gridApi.core.on.sortChanged($scope, function (grid, sortColumns) { + // Save the current sort column for later use. + sortColumn = (!sortColumns || sortColumns.length === 0) + ? null + : sortColumns[0]; + loadPage(); + }); + + vm.gridApi.pagination.on.paginationChanged($scope, function (newPage, newPageSize) { + // Save the pagination informations for later use. + paginationPage = newPage; + paginationPageSize = newPageSize; + loadPage(); + }); + + vm.gridApi.core.on.filterChanged($scope, function () { + // Save the all filters for later use. + var filters = []; + this.grid.columns.forEach(function (col, ind) { + if (col.filters[0] && col.filters[0].term) { + filters.push({ field: col.field, term: col.filters[0].term }); + } + }); + gridFilters = filters; + loadPage(); + }); + + loadPage(); + } + }); + + $scope.$on("mapViewVisuability", function (event, data) { + vm.showAllSites = !data; + }); + + $scope.$watch("visibleSites", function (newVisibleSites, oldVisibleSites) { + console.log("watch: visibleSites"); + if (!vm.showAllSites) loadPage(); + }, true); // deep watch, maybe find a better solution; e.g. with an api object like the site in the map. + + $scope.$watch(function () { return vm.showAllSites; }, loadPage); + + function loadPage() { + if (vm.showAllSites) { + loadRemotePage(); + } else { + loadLocalPage(); + } + } + + /** + * Calculates the page content of the grid and sets the values to the gridOprions.data object. + */ + function loadLocalPage() { + var siteIds = Object.keys($scope.visibleSites); + + var tempData = siteIds.filter(function (siteId, ind, arr) { + var site = $scope.visibleSites[siteId]; + return gridFilters.map(function (filter) { + switch (filter.field) { + case "countLinks": + return (site.references.siteLinks ? site.references.siteLinks.length : 0) == +filter.term; + default: + return site[filter.field].contains(filter.term); + } + }).and(true); + }).map(function (siteId) { + var site = $scope.visibleSites[siteId]; + var orderBy; + + if (!sortColumn || !sortColumn.sort.direction) { + return { + id: siteId + } + } + + switch (sortColumn.field) { + case "countLinks": + orderBy = site.references.siteLinks ? site.references.siteLinks.length : 0; + break; + case "countNetworkElements": + orderBy = site.references.networkElements ? site.references.networkElements.length : 0; + break; + case "buttons": + orderBy = siteId; + break; + default: + orderBy = site[sortColumn.field]; + break; + } + + return { + id: siteId, + orderBy: orderBy + }; + }); + + if (sortColumn && sortColumn.sort.direction) { + tempData.sort(function (left, right) { + if (left === right || left.orderBy === right.orderBy) { + return 0; + } + if (left.orderBy > right.orderBy) { + return (sortColumn.sort.direction === uiGridConstants.ASC) ? 1 : -1; + } + return (sortColumn.sort.direction === uiGridConstants.ASC) ? -1 : 1; + }); + } + + var maxPageNumber = Math.max(1, Math.ceil(tempData.length / paginationPageSize)); + var currentPage = Math.min(maxPageNumber, paginationPage); + var orderedSitesAtCurrentPage = tempData.slice((currentPage - 1) * paginationPageSize, currentPage * paginationPageSize); + + sitesAtCurrentPageCache = {}; + var orderedData = []; + + orderedSitesAtCurrentPage.forEach(function (orderedSite) { + var site = $scope.visibleSites[orderedSite.id]; + sitesAtCurrentPageCache[site.id] = site; + orderedData.push({ + id: orderedSite.id, + name: site.name, + location: site.location.lat.toLocaleString("en-US", { + minimumFractionDigits: 4 + }) + ", " + site.location.lng.toLocaleString("en-US", { + minimumFractionDigits: 4 + }), + amslGround: site.amslGround, + countLinks: site.references.siteLinks ? site.references.siteLinks.length : 0, + countNetworkElements: site.references.networkElements ? site.references.networkElements.length : 0 + }); + }); + + $timeout(function () { + vm.gridOptions.data = orderedData; + vm.gridOptions.totalItems = tempData.length; + }); + } + + /** + * Loads the page content for the grid and sets the values to the gridOprions.data object. + */ + function loadRemotePage() { + + $mwtnTopology.getSites((sortColumn && sortColumn.field), sortColumn && ((sortColumn.sort.direction && sortColumn.sort.direction === uiGridConstants.ASC) ? 'asc' : 'desc'), gridFilters, paginationPageSize, (paginationPage - 1) * paginationPageSize).then(function (result) { + sitesAtCurrentPageCache = result.sites.reduce(function (acc, cur, ind, arr) { + acc[cur.id] = cur; + return acc; + }, {}); + vm.gridOptions.data = result.sites.map(function (site) { + return { + id: site.id, + name: site.name, + location: site.location.lat.toLocaleString("en-US", { + minimumFractionDigits: 4 + }) + ", " + site.location.lng.toLocaleString("en-US", { + minimumFractionDigits: 4 + }), + amslGround: site.amslGround, + countLinks: site.references.siteLinks ? site.references.siteLinks.length : 0, + countNetworkElements: site.references.networkElements ? site.references.networkElements.length : 0 + } + }); + vm.gridOptions.totalItems = result.total; + }); + } + }]); + + mwtnTopologyApp.directive('mwtnTopologySiteGrid', function () { + return { + restrict: 'E', + replace: false, + controller: 'mwtnTopologySiteGridController', + controllerAs: 'vm', + scope: { + visibleSites: "=" + }, + templateUrl: 'src/app/mwtnTopology/templates/siteGrid.tpl.html' + }; + }); + + mwtnTopologyApp.controller('mwtnTopologySiteLinkGridController', ['$scope', '$timeout', '$state', '$mwtnCommons', '$mwtnTopology', 'uiGridConstants', function ($scope, $timeout, $state, $mwtnCommons, $mwtnTopology, uiGridConstants) { + var vm = this; + + // The page number to show in the grid. + var paginationPage = 1; + // The page size. + var paginationPageSize = 100; + // The grid column object with current sorting informations. + var sortColumn = null; + // The grid column object with current sorting informations. + var gridFilters = []; + + var linksAtCurrentPageCache = {}; + + vm.showAllLinks = false; + + vm.onNavigateToLink = function (row) { + var link = linksAtCurrentPageCache[row.entity.id]; + + var top = link.siteA.location.lat >= link.siteZ.location.lat ? link.siteA.location.lat : link.siteZ.location.lat; + var bottom = link.siteA.location.lat >= link.siteZ.location.lat ? link.siteZ.location.lat : link.siteA.location.lat; + + // todo: this code is not able to handle links which overlap the -100|180 ° borderline + var left = link.siteA.location.lng <= link.siteZ.location.lng ? link.siteA.location.lng : link.siteZ.location.lng; + var right = link.siteA.location.lng <= link.siteZ.location.lng ? link.siteZ.location.lng : link.siteA.location.lng; + + $state.go("main.mwtnTopology", { + tab: "site", + top: top, + bottom: bottom, + left: left, + right: right, + siteLink: link.id, + internal: false + }, { notify: false }); + console.log(link); + }; + + // see http://ui-grid.info/docs/#/tutorial/317_custom_templates + var buttonCellTemplate = '<div class="ui-grid-cell-contents tooltip-uigrid" title="TOOLTIP"><i ng-click="grid.appScope.vm.onNavigateToLink(row)" ng-class="{\'fa\':true, \'fa-map-marker\': true, \'{{COL_FIELD}}\':true}" aria-hidden="true"></i></div>'; + + vm.gridOptions = Object.assign({}, $mwtnCommons.gridOptions, { + // enableFiltering: false, + showGridFooter: false, // disable the grid footer because the pagination component sets its own. + paginationPageSizes: [10, 25, 50, 100], + paginationPageSize: paginationPageSize, + useExternalPagination: true, + useExternalFiltering: true, + useExternalSorting: true, + totalItems: 0, + columnDefs: [{ + field: "id", + type: "string", + displayName: "Id" + }, + { + field: "name", + type: "string", + displayName: "Name" + }, + { + field: "siteIdA", + type: "string", + displayName: "SiteA" + }, + { + field: "siteIdZ", + type: "string", + displayName: "SiteZ" + }, + { + field: "buttons", + type: "string", + displayName: "", + width: 40, + enableFiltering: false, + enableSorting: false, + cellTemplate: buttonCellTemplate, + pinnedRight: true + } + ], + data: [], + onRegisterApi: function (gridApi) { + // http://ui-grid.info/docs/#/api/ui.grid.core.api:PublicApi + vm.gridApi = gridApi; + + vm.gridApi.core.on.sortChanged($scope, function (grid, sortColumns) { + // save the current sort column for later use. + sortColumn = (!sortColumns || sortColumns.length === 0) ? + null : + sortColumns[0]; + + loadPage(); + }); + + vm.gridApi.pagination.on.paginationChanged($scope, function (newPage, newPageSize) { + paginationPage = newPage; + paginationPageSize = newPageSize; + loadPage(); + }); + + vm.gridApi.core.on.filterChanged($scope, function () { + // Save the all filters for later use. + var filters = []; + this.grid.columns.forEach(function (col, ind) { + if (col.filters[0] && col.filters[0].term) { + filters.push({ field: col.field, term: col.filters[0].term }); + } + }); + gridFilters = filters; + loadPage(); + }); + + loadPage(); + } + }); + + $scope.$on("mapViewVisuability", function (event, data) { + vm.showAllLinks = !data; + }); + + $scope.$watch("knownSiteLinks", function (newKnownSiteLinks, oldKnownSiteLinks) { + console.log("watch: knownSiteLinks"); + loadPage(); + }, true); // deep watch, maybe find a better solution; e.g. with an api object like the site in the map. + + $scope.$watch(function () { return vm.showAllLinks; }, loadPage); + + function loadPage() { + if (vm.showAllLinks) { + loadRemotePage(); + } else { + loadLocalPage(); + } + } + + /** + * Calculates the page content of the grid and sets the values to the gridOprions.data object. + */ + function loadLocalPage() { + var linkIds = Object.keys($scope.knownSiteLinks); + + var tempData = linkIds.filter(function (linkId, ind, arr) { + var link = $scope.knownSiteLinks[linkId]; + return gridFilters.map(function (filter) { + switch (filter.field) { + case 'siteIdA': + return link.siteA.id.contains(filter.term); + case 'siteIdZ': + return link.siteZ.id.contains(filter.term); + default: + return link[filter.field].contains(filter.term); + } + }).and(true); + }).map(function (linkId) { + var link = $scope.knownSiteLinks[linkId]; + var orderBy; + + if (!sortColumn || !sortColumn.sort.direction) { + return { + id: linkId + } + } + + switch (sortColumn.field) { + case 'siteIdA': + orderBy = link.siteA.id; + break; + case 'siteIdZ': + orderBy = link.siteZ.id; + break; + default: + orderBy = link[sortColumn.field]; + break; + } + + return { + id: linkId, + orderBy: orderBy + }; + }); + + if (sortColumn && sortColumn.sort.direction) { + tempData.sort(function (left, right) { + if (left === right || left.orderBy === right.orderBy) { + return 0; + } + if (left.orderBy > right.orderBy) { + return (sortColumn.sort.direction === uiGridConstants.ASC) ? 1 : -1; + } + return (sortColumn.sort.direction === uiGridConstants.ASC) ? -1 : 1; + }); + } + + var maxPageNumber = Math.max(1, Math.ceil(tempData.length / paginationPageSize)); + var currentPage = Math.min(maxPageNumber, paginationPage); + var orderedSitesAtCurrentPage = tempData.slice((currentPage - 1) * paginationPageSize, currentPage * paginationPageSize); + + linksAtCurrentPageCache = {}; + var orderedData = []; + + orderedSitesAtCurrentPage.forEach(function (orderdLink) { + var link = $scope.knownSiteLinks[orderdLink.id]; + linksAtCurrentPageCache[link.id] = link; + orderedData.push({ + id: link.id, + name: link.name, + siteIdA: link.siteA.id, + siteIdZ: link.siteZ.id, + type: link.type + }); + }); + + $timeout(function () { + vm.gridOptions.data = orderedData; + vm.gridOptions.totalItems = tempData.length; + }); + } + + /** + * Loads the page content for the grid and sets the values to the gridOprions.data object. + */ + function loadRemotePage() { + linksAtCurrentPageCache = {}; + + // the links for one page + $mwtnTopology.getLinks((sortColumn && sortColumn.field), sortColumn && ((sortColumn.sort.direction && sortColumn.sort.direction === uiGridConstants.ASC) ? 'asc' : 'desc'), gridFilters, paginationPageSize, (paginationPage - 1) * paginationPageSize).then(function (result) { + // get all site id s + var siteIds = {}; + result.links.forEach(function (link) { + siteIds[link.siteA] = link.siteA; + siteIds[link.siteZ] = link.siteZ; + }); + + // load all sites + $mwtnTopology.getSitesByIds(Object.keys(siteIds)).then(function (sitesResult) { + var sites = sitesResult.sites.reduce(function (acc, cur, ind, arr) { + acc[cur.id] = cur; + return acc; + }, {}); + result.links.forEach(function (link) { + linksAtCurrentPageCache[link.id] = { + id: link.id, + name: link.name, + siteA: sites[link.siteA], + siteZ: sites[link.siteZ], + type: link.type + }; + }); + vm.gridOptions.data = result.links.map(function (link) { + return { + id: link.id, + name: link.name, + siteIdA: link.siteA, + siteIdZ: link.siteZ, + type: link.type + } + }); + vm.gridOptions.totalItems = result.total; + + }); + }); + } + + + }]); + + mwtnTopologyApp.directive('mwtnTopologySiteLinkGrid', function () { + return { + restrict: 'E', + replace: false, + controller: 'mwtnTopologySiteLinkGridController', + controllerAs: 'vm', + templateUrl: 'src/app/mwtnTopology/templates/siteLinkGrid.tpl.html', + scope: { + knownSiteLinks: "=" + }, + }; + }); + + mwtnTopologyApp.controller('mwtnTopologySitePathGridController', ['$scope', function ($scope) { + var vm = this; + + vm.showAllPaths = false; + + $scope.$on("mapViewVisuability", function (event, data) { + vm.showAllPaths = !data; + }); + + }]); + + mwtnTopologyApp.directive('mwtnTopologySitePathGrid', function () { + return { + restrict: 'E', + replace: false, + controller: 'mwtnTopologySitePathGridController', + controllerAs: 'vm', + templateUrl: 'src/app/mwtnTopology/templates/sitePathGrid.tpl.html' + }; + }); + + /********************************************* Physical ***********************************/ + + mwtnTopologyApp.controller('mwtnTopologyPhysicalViewController', ['$scope', '$q', '$timeout', '$state', '$window', '$mwtnTopology', function ($scope, $q, $timeout, $state, $window, $mwtnTopology) { + var vm = this; + vm.status = { + graphIsOpen: false, + networkElementsIsOpen: false, + LinksIsOpen: false + }; + + $scope.$watchCollection(function () { return [vm.status.graphIsOpen, vm.status.networkElementsIsOpen, vm.status.LinksIsOpen] }, function (newVal, oldVal) { + if (newVal[1] || newVal[2]) { + $timeout(function () { + $window.dispatchEvent(new Event("resize")); + }); + } + }); + + }]); + + mwtnTopologyApp.directive('mwtnTopologyPhysicalView', function () { + return { + restrict: 'E', + controller: 'mwtnTopologyPhysicalViewController', + controllerAs: 'vm', + bindToController: true, + templateUrl: 'src/app/mwtnTopology/templates/physicalView.tpl.html', + scope: { + + } + }; + }); + + /** + * Typedefinitions for the mwtnTopologyPhysicalPathData service. + * @typedef { { 'site' | 'device' | 'port' } } NodeLayerType + * @typedef { { x: number, y: number } } PositionType + * @typedef { { id: string, label: string, parent: string, grentparent: string, active: string, latitude: number, longitude: number } } NodeDataVo + * @typedef { { data: NodeDataVo, position: PositionType } } NodeVo + * @typedef { { id: string, label: string, parent: string, type: string, layer: NodeLayerType, active: boolean, latitude?: number, longitude?: number } } NodeData + * @typedef { { data: NodeData, position: PositionType } } Node + * @typedef { { id: string, source: string, target: string, label: string , lentgh: string, azimuthAZ: string , azimuthZA: string , layer: string , active: string } } EdgeData + * @typedef { { data: EdgeData } Edge + */ + mwtnTopologyApp.factory("mwtnTopologyPhysicalPathData", ['$q','$mwtnTopology', + /** @param $q { ng.IQService } */ + function ($q, $mwtnTopology) { + var colors = { + root: '#f54', + port: '#377', + device: '#252', + site: '#525', + edge: '#49a', + white: '#eed', + grey: '#555', + selected: '#ff0' + }; + + var styles = [ + { + selector: 'node', + css: { + 'content': 'data(label)', + 'text-valign': 'center', + 'text-halign': 'center', + 'background-color': '#666666', + 'border-color': '#000000', + 'border-width': '1px', + 'color': '#ffffff' + } + }, + { + selector: 'node[layer = "MWPS"]', + css: { + 'content': 'data(label)', + 'text-valign': 'center', + 'text-halign': 'center', + 'background-color': '#316ac5', + 'border-color': '#000000', + 'border-width': '1px', + 'color': '#ffffff' + } + }, + { + selector: '$node > node', + css: { + 'shape': 'roundrectangle', + 'padding-top': '10px', + 'padding-left': '10px', + 'padding-bottom': '10px', + 'padding-right': '10px', + 'text-valign': 'top', + 'text-halign': 'center', + 'background-color': '#eeeeee', + 'color': '#444444', + 'border-color': '#888888' + } + }, + { + selector: 'node[type = "site"]', + css: { + 'shape': 'roundrectangle', + 'padding-top': '10px', + 'padding-left': '10px', + 'padding-bottom': '10px', + 'padding-right': '10px', + 'text-valign': 'center', + 'text-halign': 'center', + 'background-color': '#fefefe', + 'color': '#444444', + 'border-color': '#888888', + 'font-weight': 'bold' + } + }, + { + selector: 'node[type = "device"][active = "true"]', + css: { + 'background-color': '#316ac5', + 'background-opacity': '0.3', + 'border-color': '#316ac5', + 'border-width': '2px', + 'color': '#444444' + } + }, + { + selector: 'node[type = "port"][active = "true"]', + css: { + 'background-opacity': '1.0', + } + }, + { + selector: 'node[active = "false"]', + css: { + 'background-opacity': '0.3', + 'border-opacity': '0.5' + } + }, + + { + selector: 'edge', + css: { + 'content': 'data(id)', + 'target-arrow-shape': 'triangle', + 'line-color': '#666666', + 'color': '#444444' + } + }, + { + selector: 'edge[active = "false"]', + css: { + 'line-color': '#cccccc', + 'text-opacity': '0.9' + } + }, + { + selector: 'edge[layer = "MWPS"]', + css: { + 'content': 'data(id)', + 'target-arrow-shape': 'triangle', + 'width': '5px', + 'line-color': '#316ac5', + 'color': '#444444' + } + }, + { + selector: 'edge[layer = "MWPS"][active = "false"]', + css: { + 'line-color': '#C0D1EC', + 'text-opacity': '0.9' + } + }, + { + selector: ':selected', + css: { + 'background-color': 'black', + 'line-color': 'black', + 'target-arrow-color': 'black', + 'source-arrow-color': 'black' + } + } + ]; + + var events = eventsFabric(); + + /** Heplerfunction to retrive all elements from the database and convert to the structure needed */ + function getElements() { + var res = $q.defer(); + + $q.all([ + $mwtnTopology.getAllNodes(), + $mwtnTopology.getAllEdges() + ]).then(function (results) { + res.resolve({ nodes: results[0], edges: results[1] }); + }); + + return res.promise; + } + + var result = { + colors: colors, + getElements: getElements, + styles: styles, + events: events + }; + + var someMethodChangingTheElements = function () { + // @Martin: hier kannst Du die Elements ändern, anschließend mußt Du das Ereignis veröffentlichen + // das Ereigniss wird in der Directive aufgefangen und die Grig wird neu gezeichnet + + // Hinweis: Die Reihenfolge muss so bleiben und du kannst NUR result.elements ändern. + + events.publish("elementsChanged", { + elements: result.elements + }); + }; + + return result; + }]); + + mwtnTopologyApp.directive("mwtnTopologyPhysicalPathGraph", ["mwtnTopologyPhysicalPathData", "$mwtnTopology", "$mwtnCommons", function (pathGraphData, $mwtnTopology, $mwtnCommons) { + + return { + restrict: 'E', + replace: true, + template: '<div style="height:750px; width: 100%;"></div>', + controller: function () { + + }, + scope: { + + }, + link: function (scope, element, attrs, ctrl) { + + var cy = cytoscape({ + container: element[0], + + boxSelectionEnabled: false, + autounselectify: true, + + style: pathGraphData.styles, + elements: [], + layout: { + name: 'preset', + padding: 5 + } + }); + + cy.viewport({ + zoom: 0.50, + pan: { x: 100, y: 50 } + }); + + pathGraphData.getElements().then(function (elements) { + cy.json({ + elements: elements + }); + + // disable drag & drop + cy.nodes().ungrabify(); + }); + + var filterActiveMountPoints = function (mountpoints) { + return mountpoints.filter(function (mountpoint) { + if (!mountpoint) return false; + // console.warn(mountpoint['node-id'], mountpoint['netconf-node-topology:connection-status']); + return mountpoint['netconf-node-topology:connection-status'] === 'connected'; + }).map(function (mountpoint) { + return mountpoint['node-id']; + }); + }; + + var setDevicesActive = function (nodeIds) { + // console.warn(nodeIds); + cy.nodes().filter(function (node) { + node.data('active', 'false'); + return node.data('type') === 'device' && nodeIds.contains(node.data('id')); + }).map(function (node) { + node.data('active', 'true'); + }); + }; + + var setAllDevicesInactive = function () { + cy.nodes().map(function (node) { + node.data('active', 'false'); + }); + }; + + var setPortAndEdgedActive = function () { + cy.edges().map(function (edge) { + var active = 'true'; + edge.connectedNodes().map(function (port) { + // console.log(' node', JSON.stringify(edge.data())); + var parent = cy.getElementById(port.data('parent')); + if (parent.data('active') === 'false') { + port.data('active', 'false'); + edge.data('active', 'false'); + } else { + port.data('active', 'true'); + } + }); + }); + }; + + var setCss = function () { + var width = 5 / cy.zoom(); + var stroke = 1 / cy.zoom(); + cy.edges().css('width', width); + cy.nodes().css('border-width', stroke); + }; + + var init = function () { + $mwtnCommons.getMountPoints().then(function (mountpoints) { + var filtered = filterActiveMountPoints(mountpoints); + setDevicesActive(filtered); + setPortAndEdgedActive(); + }, function (error) { + setAllDevicesInactive(); + setPortAndEdgedActive(); + }); + }; + + init(); + setCss(); + + var orderLtps = function () { + var done = []; + var x = 0; + var y = 0; + var row = 0; + var offset = 100; + var selector = "[type = 'device']"; + var devices = cy.nodes(selector).sort(function (a, b) { + if (a.children().length > b.children().length) return -1; + if (a.children().length < b.children().length) return 1; + return 0; + }).map(function (device) { + device.children().filter(function (ltp) { + return done.indexOf(ltp.id()) === -1; + }).map(function (ltp) { + ltp.position({ x: x, y: y }); + y = y + offset; + var remeberX = x; + ltp.connectedEdges().map(function (edge) { + edge.connectedNodes().sort(function (a, b) { + if (a.data("parent") === device.id()) return -1; + return 1; + }).map(function (node) { + // x = remeberX + 0 * offset; + node.position({ x: x, y: y }); + x = x + 3 * offset; + y = y + offset; + done.push(node.id()); + }); + y = y - 2 * offset; + + }); + x = remeberX; + done.push(ltp.id()); + }); + y = row * 6 * offset; + x = x + 6 * offset; + + if (x > 4000) { + row = row + 1; + x = 0; + y = row * 6 * offset; + } + return device; + }); + }; + + var dragedNodes = []; + // add an event handler for 'tabdrag' for all ports + cy.on('drag', 'node[type = "port"]', function (event) { + var id = event.target.data().id; + dragedNodes.indexOf(id) <= -1 && dragedNodes.push(id); + }); + + cy.on('tap', function (event) { + if (event.target !== cy) { + console.info('click', JSON.stringify(event.target.data())); + } else { + orderLtps(); + // cy.zoom(0.1); + cy.fit(); + cy.center(); + } + }); + + cy.on('zoom', function (event) { + setCss(); + }); + + // global keyboard event handler + function handleKey(e) { + if (!e.ctrlKey && !e.commandKey) return; + switch (e.which) { + case 69: + dragedNodes = []; + cy.nodes().grabify(); + e.preventDefault(); + return false; + break; + case 83: + cy.nodes().ungrabify(); + e.preventDefault(); + var modifiedNodes = dragedNodes.map(id => ({ id: id, position: cy.nodes().getElementById(id).position() })); + $mwtnTopology.saveChangedNodes(modifiedNodes); + console.log("dragedNodes", modifiedNodes); + return false; + break; + // default: + // console.log(e.which); + // e.preventDefault(); + // return false; + // break; + } + } + + // register global keyboard event handler + window.addEventListener('keydown', handleKey, false); + + scope.$on('$destroy', function () { + // un-register global keyboard event handler + window.removeEventListener('keydown', handleKey, false); + }); + + } + } + }]); + + mwtnTopologyApp.controller("mwtnTopologyNetworkElementsGridController", ['$scope', '$timeout', '$state', '$mwtnCommons', '$mwtnTopology', 'uiGridConstants', 'mwtnTopologyPhysicalPathData', function ($scope, $timeout, $state, $mwtnCommons, $mwtnTopology, uiGridConstants, mwtnTopologyPhysicalPathData) { + var vm = this; + + // The page number to show in the grid. + var paginationPage = 1; + // The page size. + var paginationPageSize = 100; + // The grid column object with current sorting informations. + var sortColumn = null; + // The grid column object with current sorting informations. + var gridFilters = []; + // caches all sites at the current grid page + + vm.gridOptions = Object.assign({}, $mwtnCommons.gridOptions, { + showGridFooter: false, // disable the grid footer because the pagination component sets its own. + paginationPageSizes: [10, 25, 50, 100], + paginationPageSize: paginationPageSize, + useExternalPagination: true, + useExternalFiltering: true, + useExternalSorting: true, + totalItems: 0, + columnDefs: [{ + field: "id", + type: "string", + displayName: "Id" + }, + { + field: "layer", + type: "string", + displayName: "Layer", + width: 100, + }, + { + field: "active", + type: "string", + displayName: "Active", + width: 100, + }, + { + field: "latitude", + type: "string", + displayName: "Latitude", + visible: false + }, + { + field: "longitude", + type: "string", + displayName: "Longitude", + visible: false + }, + { + field: "installed", // capacity in Mbit/s + type: "number", + displayName: "Installed [Mbit/s]", + className: "number", + width: 150 + }, + { + field: "configured", // capacity in Mbit/s + type: "number", + displayName: "Configured [Mbit/s]", + className: "number", + width: 150 + }, + { + field: "effective", // capacity in Mbit/s + type: "number", + displayName: "Effective [Mbit/s]", + className: "number", + width: 150 + } + ], + data: [], + onRegisterApi: function (gridApi) { + // http://ui-grid.info/docs/#/api/ui.grid.core.api:PublicApi + vm.gridApi = gridApi; + + vm.gridApi.core.on.sortChanged($scope, function (grid, sortColumns) { + // Save the current sort column for later use. + sortColumn = (!sortColumns || sortColumns.length === 0) ? + null : + sortColumns[0]; + loadPage(); + }); + + vm.gridApi.pagination.on.paginationChanged($scope, function (newPage, newPageSize) { + // Save the pagination informations for later use. + paginationPage = newPage; + paginationPageSize = newPageSize; + loadPage(); + }); + + vm.gridApi.core.on.filterChanged($scope, function () { + // Save the all filters for later use. + var filters = []; + this.grid.columns.forEach(function (col, ind) { + if (col.filters[0] && col.filters[0].term) { + filters.push({ + field: col.field, + term: col.filters[0].term + }); + } + }); + gridFilters = filters; + loadPage(); + }); + + loadPage(); + } + }); + + /** + * Calculates the page content of the grid and sets the values to the gridOprions.data object. + */ + function loadPage() { + + // extract all ports + var ports = mwtnTopologyPhysicalPathData.elements.nodes.filter(function (node, ind, arr) { + return node && node.data && node.data.type === 'port'; + }).reduce(function (acc, cur, ind, arr) { + if (cur.data) acc[cur.data.id] = cur.data; + return acc; + }, {}); + + // get all port ids + var portIds = Object.keys(ports); + + // apply the grid filters + var tempData = portIds.filter(function (portId, ind, arr) { + var port = ports[portId]; + return gridFilters.map(function (filter) { + switch (filter.field) { + case "active": + return port[filter.field].toString().contains(filter.term); + default: + return port[filter.field].contains(filter.term); + } + }).and(true); + }).map(function (portId) { + var port = ports[portId]; + var orderBy; + + if (!sortColumn || !sortColumn.sort.direction) { + return { + id: port.id + } + } + + switch (sortColumn.field) { + case "active": + orderBy = port[sortColumn.field] ? 1 : 0; + break; + default: + orderBy = port[sortColumn.field]; + break; + } + + return { + id: port.id, + orderBy: orderBy + }; + }); + + if (sortColumn && sortColumn.sort.direction) { + tempData.sort(function (left, right) { + if (left === right || left.orderBy === right.orderBy) { + return 0; + } + if (left.orderBy > right.orderBy) { + return (sortColumn.sort.direction === uiGridConstants.ASC) ? 1 : -1; + } + return (sortColumn.sort.direction === uiGridConstants.ASC) ? -1 : 1; + }); + } + + var maxPageNumber = Math.max(1, Math.ceil(tempData.length / paginationPageSize)); + var currentPage = Math.min(maxPageNumber, paginationPage); + var orderedPortsAtCurrentPage = tempData.slice((currentPage - 1) * paginationPageSize, currentPage * paginationPageSize); + + portsAtCurrentPageCache = {}; + var orderedData = []; + + orderedPortsAtCurrentPage.forEach(function (orderedPort) { + var port = ports[orderedPort.id]; + portsAtCurrentPageCache[port.id] = port; + orderedData.push({ + id: orderedPort.id, + layer: port.layer, + active: port.active, + latitude: port.latitude.toLocaleString("en-US", { + minimumFractionDigits: 4 + }), + longitude: port.longitude.toLocaleString("en-US", { + minimumFractionDigits: 4 + }), + installed: 0, + configured: 0, + effective: 0 + }); + }); + + $timeout(function () { + vm.gridOptions.data = orderedData; + vm.gridOptions.totalItems = tempData.length; + }); + } + + // subscribe to the elementsChanged event to reload the grid page if the data in the service has chenged + mwtnTopologyPhysicalPathData.events.subscribe("elementsChanged", function (data) { + loadPage(); + }); + + }]); + + mwtnTopologyApp.directive("mwtnTopologyNetworkElementsGrid", [function () { + return { + restrict: 'E', + replace: false, + controller: 'mwtnTopologyNetworkElementsGridController', + controllerAs: 'vm', + scope: { + + }, + templateUrl: 'src/app/mwtnTopology/templates/networkElementsGrid.tpl.html' + }; + }]); + + mwtnTopologyApp.controller("mwtnTopologyLinksGridController", ['$scope', '$timeout', '$state', '$mwtnCommons', '$mwtnTopology', 'uiGridConstants', 'mwtnTopologyPhysicalPathData', function ($scope, $timeout, $state, $mwtnCommons, $mwtnTopology, uiGridConstants, mwtnTopologyPhysicalPathData) { + var vm = this; + + // The page number to show in the grid. + var paginationPage = 1; + // The page size. + var paginationPageSize = 100; + // The grid column object with current sorting informations. + var sortColumn = null; + // The grid column object with current sorting informations. + var gridFilters = []; + // caches all sites at the current grid page + + vm.gridOptions = Object.assign({}, $mwtnCommons.gridOptions, { + showGridFooter: false, // disable the grid footer because the pagination component sets its own. + paginationPageSizes: [10, 25, 50, 100], + paginationPageSize: paginationPageSize, + useExternalPagination: true, + useExternalFiltering: true, + useExternalSorting: true, + totalItems: 0, + columnDefs: [{ + field: "id", + type: "string", + displayName: "Id" + }, + { + field: "source", + type: "string", + displayName: "PortA" + }, + { + field: "target", + type: "string", + displayName: "PortZ" + }, + { + field: "layer", + type: "string", + displayName: "Layer" + }, + { + field: "length", + type: "string", + displayName: "Length" + }, + { + field: "azimuthAZ", + type: "string", + displayName: "azimuthAZ" + }, + { + field: "azimuthZA", + type: "string", + displayName: "azimuthZA" + } + ], + data: [], + onRegisterApi: function (gridApi) { + // http://ui-grid.info/docs/#/api/ui.grid.core.api:PublicApi + vm.gridApi = gridApi; + + vm.gridApi.core.on.sortChanged($scope, function (grid, sortColumns) { + // Save the current sort column for later use. + sortColumn = (!sortColumns || sortColumns.length === 0) ? + null : + sortColumns[0]; + loadPage(); + }); + + vm.gridApi.pagination.on.paginationChanged($scope, function (newPage, newPageSize) { + // Save the pagination informations for later use. + paginationPage = newPage; + paginationPageSize = newPageSize; + loadPage(); + }); + + vm.gridApi.core.on.filterChanged($scope, function () { + // Save the all filters for later use. + var filters = []; + this.grid.columns.forEach(function (col, ind) { + if (col.filters[0] && col.filters[0].term) { + filters.push({ + field: col.field, + term: col.filters[0].term + }); + } + }); + gridFilters = filters; + loadPage(); + }); + + loadPage(); + } + }); + + /** + * Calculates the page content of the grid and sets the values to the gridOprions.data object. + */ + function loadPage() { + // extract all ports + var ports = mwtnTopologyPhysicalPathData.elements.nodes.filter(function (node, ind, arr) { + return node && node.data && node.data.type === 'port'; + }).reduce(function (acc, cur, ind, arr) { + if (cur.data) acc[cur.data.id] = cur.data; + return acc; + }, {}); + + // extract all links + var links = mwtnTopologyPhysicalPathData.elements.edges.filter(function (node, ind, arr) { + return true; // node && node.data && node.data.type === 'port'; + }).reduce(function (acc, cur, ind, arr) { + if (cur.data) { + + if (cur.data.layer === 'MWPS') { + var portA = ports[cur.data.source]; + var portZ = ports[cur.data.target]; + + // calculate length + cur.data.length = (portA && portZ) ? $mwtnTopology.getDistance(portA.latitude, portA.longitude, portZ.latitude, portZ.longitude) : 0; + cur.data.azimuthAZ = (portA && portZ) ? $mwtnTopology.bearing(portA.latitude, portA.longitude, portZ.latitude, portZ.longitude) : 0; + cur.data.azimuthZA = (portA && portZ) ? $mwtnTopology.bearing(portZ.latitude, portZ.longitude, portA.latitude, portA.longitude) : 0; + + } else { + cur.data.length = 0; + cur.data.azimuthAZ = 0; + cur.data.azimuthZA = 0; + } + acc[cur.data.id] = cur.data; + } + return acc; + }, {}); + + // get all link ids + var linkIds = Object.keys(links); + + // apply the grid filters + var tempData = linkIds.filter(function (linkId, ind, arr) { + var link = links[linkId]; + return gridFilters.map(function (filter) { + switch (filter.field) { + case "length": + case "azimuthAZ": + case "azimuthZA": + return true; + default: + return link[filter.field].contains(filter.term); + } + }).and(true); + }).map(function (linkId) { + var link = links[linkId]; + var orderBy; + + if (!sortColumn || !sortColumn.sort.direction) { + return { + id: link.id + } + } + + switch (sortColumn.field) { + default: + orderBy = link[sortColumn.field]; + break; + } + + return { + id: link.id, + orderBy: orderBy + }; + }); + + if (sortColumn && sortColumn.sort.direction) { + tempData.sort(function (left, right) { + if (left === right || left.orderBy === right.orderBy) { + return 0; + } + if (left.orderBy > right.orderBy) { + return (sortColumn.sort.direction === uiGridConstants.ASC) ? 1 : -1; + } + return (sortColumn.sort.direction === uiGridConstants.ASC) ? -1 : 1; + }); + } + + var maxPageNumber = Math.max(1, Math.ceil(tempData.length / paginationPageSize)); + var currentPage = Math.min(maxPageNumber, paginationPage); + var orderedLinksAtCurrentPage = tempData.slice((currentPage - 1) * paginationPageSize, currentPage * paginationPageSize); + + linksAtCurrentPageCache = {}; + var orderedData = []; + + orderedLinksAtCurrentPage.forEach(function (orderedLink) { + var link = links[orderedLink.id]; + linksAtCurrentPageCache[link.id] = link; + orderedData.push({ + id: orderedLink.id, + source: link.source, + target: link.target, + layer: link.layer, + length: link.length, + azimuthAZ: link.azimuthAZ.toLocaleString("en-US", { + minimumFractionDigits: 4 + }), + azimuthZA: link.azimuthZA.toLocaleString("en-US", { + minimumFractionDigits: 4 + }), + }); + }); + + $timeout(function () { + vm.gridOptions.data = orderedData; + vm.gridOptions.totalItems = tempData.length; + }); + } + + // subscribe to the elementsChanged event to reload the grid page if the data in the service has chenged + var subscription = mwtnTopologyPhysicalPathData.events.subscribe("elementsChanged", function (data) { + loadPage(); + // to unsubscribe call subscription.remove(); + }); + + }]); + + mwtnTopologyApp.directive("mwtnTopologyLinksGrid", [function () { + return { + restrict: 'E', + replace: false, + controller: 'mwtnTopologyLinksGridController', + controllerAs: 'vm', + scope: { + + }, + templateUrl: 'src/app/mwtnTopology/templates/linksGrid.tpl.html' + }; + }]); + + /********************************************* Ethernet ***********************************/ + + mwtnTopologyApp.controller('mwtnTopologyEthernetViewController', ['$scope', '$q', '$timeout', '$state', '$window', '$mwtnTopology', function ($scope, $q, $timeout, $state, $window, $mwtnTopology) { + var vm = this; + vm.status = { + topologyIsOpen: false, + portsOpen: false, + ethConnectionsIsOpen: false + } + + $scope.$watchCollection(function () { return [vm.status.topologyIsOpen, vm.status.portsOpen, vm.status.ethConnectionsIsOpen] }, function (newVal, oldVal) { + if (newVal[1] || newVal[2]) { + $timeout(function () { + $window.dispatchEvent(new Event("resize")); + }); + } + }); + + }]); + + mwtnTopologyApp.directive('mwtnTopologyEthernetView', function () { + return { + restrict: 'E', + controller: 'mwtnTopologyEthernetViewController', + controllerAs: 'vm', + bindToController: true, + templateUrl: 'src/app/mwtnTopology/templates/ethernetView.tpl.html', + scope: { + + } + }; + }); + + mwtnTopologyApp.factory("mwtnTopologyEthernetPathData", function () { + var colors = { + root: '#f54', + port: '#377', + device: '#252', + site: '#525', + edge: '#49a', + white: '#eed', + grey: '#555', + selected: '#ff0' + }; + + var styles = [ + { + selector: 'node', + css: { + 'content': 'data(label)', + 'text-valign': 'center', + 'text-halign': 'center', + 'background-color': '#eeeeee', + 'border-color': '#000000', + 'border-width': '1px', + 'color': '#000000' + } + }, + { + selector: 'node[type = "label"]', + css: { + 'content': 'data(label)', + 'border-width': '0px', + 'background-color': '#ffffff', + 'font-size': '50px', + 'text-valign': 'bottom', + 'text-halign': 'right', + + } + }, + + { + selector: 'node[layer = "MWPS"]', + css: { + 'content': 'data(label)', + 'text-valign': 'center', + 'text-halign': 'center', + 'background-color': '#316ac5', + 'border-color': '#000000', + 'border-width': '1px', + 'color': '#ffffff' + } + }, + { + selector: 'node[layer = "ETH-TTP"]', + css: { + 'content': 'data(label)', + 'text-valign': 'center', + 'text-halign': 'center', + 'background-color': '#008800', + 'border-color': '#004400', + 'border-width': '1px', + 'color': '#ffffff' + } + }, + { + selector: '$node > node', + css: { + 'shape': 'roundrectangle', + 'padding-top': '10px', + 'padding-left': '10px', + 'padding-bottom': '10px', + 'padding-right': '10px', + 'text-valign': 'top', + 'text-halign': 'center', + 'background-color': '#eeeeee', + 'color': '#444444', + 'border-color': '#888888' + } + }, + { + selector: 'node[type = "site"]', + css: { + 'shape': 'roundrectangle', + 'padding-top': '10px', + 'padding-left': '10px', + 'padding-bottom': '10px', + 'padding-right': '10px', + 'text-valign': 'center', + 'text-halign': 'center', + 'background-color': '#fefefe', + 'color': '#444444', + 'border-color': '#888888', + 'font-weight': 'bold' + } + }, + { + selector: 'node[type = "device"]', + css: { + 'background-color': '#eeeeee', + 'background-opacity': '0.1', + 'border-color': '#888888', + 'border-width': '2px', + 'color': '#444444' + } + }, + { + selector: 'node[type = "device"][active = "true"]', + css: { + 'background-color': '#316ac5', + 'background-opacity': '0.1', + 'border-color': '#316ac5', + 'border-width': '2px', + 'color': '#444444' + } + }, + { + selector: 'node[type = "port"][active = "true"]', + css: { + 'background-opacity': '1.0', + } + }, + { + selector: 'node[path = "working"]', + css: { + 'background-color': '#FFA500', + 'border-color': '#FFA500', + 'border-width': '2px', + 'color': '#444444' + } + }, + { + selector: 'node[path = "protection"]', + css: { + 'background-color': '#ffffff', + 'border-color': '#FFA500', + 'border-width': '2px', + 'color': '#444444' + } + }, + { + selector: '$node > node[path = "working"]', + css: { + 'background-color': '#FFA500', + 'border-color': '#FFA500', + 'border-width': '2px', + 'color': '#444444' + } + }, + { + selector: '$node > node[path = "protection"]', + css: { + 'border-color': '#FFA500', + 'border-width': '2px', + 'color': '#444444' + } + }, + { + selector: 'node[active = "false"]', + css: { + 'background-opacity': '0.3', + 'border-opacity': '0.5' + } + }, + { + selector: 'edge', + css: { + 'content': 'data(id)', + 'target-arrow-shape': 'triangle', + 'line-color': '#666666', + 'color': '#444444' + } + }, + { + selector: 'edge[active = "false"]', + css: { + 'line-color': '#cccccc', + 'text-opacity': '0.9' + } + }, + { + selector: 'edge[layer = "ETC"]', + css: { + 'content': 'data(id)', + 'target-arrow-shape': 'triangle', + 'width': '3px', + 'line-color': '#316ac5', + 'color': '#444444' + } + }, + { + selector: 'edge[layer = "ETH"]', + css: { + 'content': '', + 'target-arrow-shape': 'triangle', + 'width': '2px', + 'line-color': '#FFA500', + 'color': '#000000' + } + }, { + selector: 'edge[layer = "ETC"][active = "false"]', + css: { + 'line-color': '#C0D1EC', + 'text-opacity': '0.9' + } + }, + + { + selector: 'edge[layer = "ETH"][path = "false"]', + css: { + 'opacity': '0.0' + } + }, + { + selector: 'edge[path = "working"]', + css: { + 'line-color': '#FFA500', + 'width': '5px', + 'opacity': '1.0' + } + }, + { + selector: 'edge[path = "protection"]', + css: { + 'line-color': '#FFA500', + 'line-style': 'dashed', + 'width': '3px', + 'opacity': '1.0' + } + }, + { + selector: ':selected', + css: { + 'background-color': 'black', + 'line-color': 'black', + 'target-arrow-color': 'black', + 'source-arrow-color': 'black' + } + } + ]; + + var elements = { + nodes: [ + { data: { id: 'label', label : '' , type: 'label' }, position: { x: -259, y: -167 } }, + + { data: { id: 'north', label : 'north' , type: 'site', latitude: 50.734916, longitude: 7.137636 } }, + { data: { id: 'north-east', label : 'north-east' , type: 'site', latitude: 50.733028, longitude: 7.151086 } }, + { data: { id: 'north-west', label : 'north-west' , type: 'site', latitude: 50.730230, longitude: 7.126017 } }, + { data: { id: 'east', label : 'east' , type: 'site', latitude: 50.725672, longitude: 7.158488 } }, + { data: { id: 'west', label : 'west' , type: 'site', latitude: 50.721914, longitude: 7.120521 } }, + { data: { id: 'south-east', label : 'south-east' , type: 'site', latitude: 50.717158, longitude: 7.155506 } }, + { data: { id: 'south-west', label : 'south-west' , type: 'site', latitude: 50.714359, longitude: 7.130437 } }, + { data: { id: 'south', label : 'south' , type: 'site', latitude: 50.712472, longitude: 7.143887 } }, + + { data: { id: 'ADVA-Y', label : 'ADVA-Y' , parent : 'north-east', type: 'device', active: 'true' , latitude: 50.733028, longitude: 7.151086 } }, + { data: { id: 'ADVA-Z', label : 'ADVA-Z' , parent : 'south', type: 'device', active: 'true' , latitude: 50.712472, longitude: 7.143887 } }, + { data: { id: 'Aviat-A', label : 'Aviat-A' , parent : 'north-east', type: 'device', active: 'true' , latitude: 50.733028, longitude: 7.151086 } }, + { data: { id: 'Aviat-Z', label : 'Aviat-Z' , parent : 'east', type: 'device', active: 'true' , latitude: 50.725672, longitude: 7.158488 } }, + { data: { id: 'Ceragon-A', label : 'Ceragon-A' , parent : 'north-west', type: 'device', active: 'true' , latitude: 50.730230, longitude: 7.126017 } }, + { data: { id: 'Ceragon-Z', label : 'Ceragon-Z' , parent : 'west', type: 'device', active: 'true' , latitude: 50.721914, longitude: 7.120521 } }, + { data: { id: 'DragonWave-A', label : 'DragonWave-A' , parent : 'south-west', type: 'device', active: 'true' , latitude: 50.714359, longitude: 7.130437 } }, + { data: { id: 'DragonWave-Z', label : 'DragonWave-Z' , parent : 'south', type: 'device', active: 'true' , latitude: 50.712472, longitude: 7.143887 } }, + { data: { id: 'ELVA-1-A', label : 'ELVA-1-A' , parent : 'north', type: 'device', active: 'true' , latitude: 50.734916, longitude: 7.137636 } }, + { data: { id: 'ELVA-1-Z', label : 'ELVA-1-Z' , parent : 'south-west', type: 'device', active: 'true' , latitude: 50.714359, longitude: 7.130437 } }, + { data: { id: 'Ericsson-A', label : 'Ericsson-A' , parent : 'north-east', type: 'device', active: 'true' , latitude: 50.733028, longitude: 7.151086 } }, + { data: { id: 'Ericsson-Z', label : 'Ericsson-Z' , parent : 'east', type: 'device', active: 'true' , latitude: 50.725672, longitude: 7.158488 } }, + { data: { id: 'Fujitsu-A', label : 'Fujitsu-A' , parent : 'east', type: 'device', active: 'true' , latitude: 50.725672, longitude: 7.158488 } }, + { data: { id: 'Fujitsu-Z', label : 'Fujitsu-Z' , parent : 'south-east', type: 'device', active: 'true' , latitude: 50.717158, longitude: 7.155506 } }, + { data: { id: 'Huawei-A', label : 'Huawei-A' , parent : 'south-west', type: 'device', active: 'true' , latitude: 50.714359, longitude: 7.130437 } }, + { data: { id: 'Huawei-Z', label : 'Huawei-Z' , parent : 'south', type: 'device', active: 'true' , latitude: 50.712472, longitude: 7.143887 } }, + { data: { id: 'Intracom-A', label : 'Intracom-A' , parent : 'south', type: 'device', active: 'true' , latitude: 50.712472, longitude: 7.143887 } }, + { data: { id: 'Intracom-Z', label : 'Intracom-Z' , parent : 'south-east', type: 'device', active: 'true' , latitude: 50.717158, longitude: 7.155506 } }, + { data: { id: 'NEC-A', label : 'NEC-A' , parent : 'north', type: 'device', active: 'true' , latitude: 50.734916, longitude: 7.137636 } }, + { data: { id: 'NEC-Z', label : 'NEC-Z' , parent : 'north-east', type: 'device', active: 'true' , latitude: 50.733028, longitude: 7.151086 } }, + { data: { id: 'Nokia-A', label : 'Nokia-A' , parent : 'west', type: 'device', active: 'fasel' , latitude: 50.721914, longitude: 7.120521 } }, + { data: { id: 'Nokia-Z', label : 'Nokia-Z' , parent : 'south-west', type: 'device', active: 'true' , latitude: 50.714359, longitude: 7.130437 } }, + { data: { id: 'SIAE-A', label : 'SIAE-A' , parent : 'south', type: 'device', active: 'true' , latitude: 50.712472, longitude: 7.143887 } }, + { data: { id: 'SIAE-Z', label : 'SIAE-Z' , parent : 'south-east', type: 'device', active: 'true' , latitude: 50.717158, longitude: 7.155506 } }, + { data: { id: 'ZTE-A', label : 'ZTE-A' , parent : 'north-west', type: 'device', active: 'true' , latitude: 50.730230, longitude: 7.126017 } }, + { data: { id: 'ZTE-Z', label : 'ZTE-Z' , parent : 'north', type: 'device', active: 'true' , latitude: 50.734916, longitude: 7.137636 } }, + + { data: { id: 'Aviat-Z#5', label : '#5' , parent : 'Aviat-Z' , type: 'port', layer: 'ETY', active: 'true', latitude: 50.725672, longitude: 7.158488 }, position: { x: 1984, y: 390 } }, + { data: { id: 'Aviat-Z#6', label : '#6' , parent : 'Aviat-Z' , type: 'port', layer: 'ETC', active: 'true', latitude: 50.725672, longitude: 7.158488 }, position: { x: 1984, y: 321 } }, + { data: { id: 'Ericsson-Z#5', label : '#5' , parent : 'Ericsson-Z' , type: 'port', layer: 'ETY', active: 'true', latitude: 50.725672, longitude: 7.158488 }, position: { x: 1777, y: 393 } }, + { data: { id: 'Ericsson-Z#6', label : '#6' , parent : 'Ericsson-Z' , type: 'port', layer: 'ETC', active: 'true', latitude: 50.725672, longitude: 7.158488 }, position: { x: 1765, y: 325 } }, + { data: { id: 'Fujitsu-A#5', label : '#5' , parent : 'Fujitsu-A' , type: 'port', layer: 'ETY', active: 'true', latitude: 50.725672, longitude: 7.158488 }, position: { x: 1859, y: 567 } }, + { data: { id: 'Fujitsu-A#6', label : '#6' , parent : 'Fujitsu-A' , type: 'port', layer: 'ETC', active: 'true', latitude: 50.725672, longitude: 7.158488 }, position: { x: 1859, y: 647 } }, + { data: { id: 'ELVA-1-A#2', label : '#2' , parent : 'ELVA-1-A' , type: 'port', layer: 'ETY', active: 'true', latitude: 50.734916, longitude: 7.137636 }, position: { x: 895, y: 150 } }, + { data: { id: 'ELVA-1-A#6', label : '#6' , parent : 'ELVA-1-A' , type: 'port', layer: 'ETC', active: 'true', latitude: 50.734916, longitude: 7.137636 }, position: { x: 815, y: 150 } }, + { data: { id: 'NEC-A#3', label : '#3' , parent : 'NEC-A' , type: 'port', layer: 'ETY', active: 'true', latitude: 50.734916, longitude: 7.137636 }, position: { x: 955, y: -52 } }, + { data: { id: 'NEC-A#6', label : '#6' , parent : 'NEC-A' , type: 'port', layer: 'ETC', active: 'true', latitude: 50.734916, longitude: 7.137636 }, position: { x: 1035, y: -52 } }, + { data: { id: 'ZTE-Z#4', label : '#4' , parent : 'ZTE-Z' , type: 'port', layer: 'ETY', active: 'true', latitude: 50.734916, longitude: 7.137636 }, position: { x: 707, y: -67 } }, + { data: { id: 'ZTE-Z#5', label : '#5' , parent : 'ZTE-Z' , type: 'port', layer: 'ETY', active: 'true', latitude: 50.734916, longitude: 7.137636 }, position: { x: 747, y: -27 } }, + { data: { id: 'ZTE-Z#6', label : '#6' , parent : 'ZTE-Z' , type: 'port', layer: 'ETC', active: 'true', latitude: 50.734916, longitude: 7.137636 }, position: { x: 667, y: -27 } }, + // { data: { id: 'ADVA-Y#1', label : '#1' , parent : 'ADVA-Y' , type:'port', layer:'ETY', active:'true', latitude:50.733028, longitude:7.151086}, position: { x: 1392, y: 229 } }, + { data: { id: 'ADVA-Y#2', label : '#2' , parent : 'ADVA-Y' , type: 'port', layer: 'ETY', active: 'true', latitude: 50.733028, longitude: 7.151086 }, position: { x: 1449, y: 172 } }, + { data: { id: 'ADVA-Y#3', label : '#3' , parent : 'ADVA-Y' , type: 'port', layer: 'ETY', active: 'true', latitude: 50.733028, longitude: 7.151086 }, position: { x: 1392, y: 172 } }, + { data: { id: 'ADVA-Y#4', label : '#4' , parent : 'ADVA-Y' , type: 'port', layer: 'ETY', active: 'true', latitude: 50.733028, longitude: 7.151086 }, position: { x: 1449, y: 229 } }, + { data: { id: 'Aviat-A#5', label : '#5' , parent : 'Aviat-A' , type: 'port', layer: 'ETY', active: 'true', latitude: 50.733028, longitude: 7.151086 }, position: { x: 1654, y: -47 } }, + { data: { id: 'Aviat-A#6', label : '#6' , parent : 'Aviat-A' , type: 'port', layer: 'ETC', active: 'true', latitude: 50.733028, longitude: 7.151086 }, position: { x: 1654, y: 22 } }, + { data: { id: 'Ericsson-A#4', label : '#4' , parent : 'Ericsson-A' , type: 'port', layer: 'ETY', active: 'true', latitude: 50.733028, longitude: 7.151086 }, position: { x: 1605, y: 229 } }, + { data: { id: 'Ericsson-A#5', label : '#5' , parent : 'Ericsson-A' , type: 'port', layer: 'ETY', active: 'true', latitude: 50.733028, longitude: 7.151086 }, position: { x: 1605, y: 172 } }, + { data: { id: 'Ericsson-A#6', label : '#6' , parent : 'Ericsson-A' , type: 'port', layer: 'ETC', active: 'true', latitude: 50.733028, longitude: 7.151086 }, position: { x: 1664, y: 226 } }, + // { data: { id: 'NEC-Z#3', label : '#3' , parent : 'NEC-Z' , type:'port', layer:'ETY', active:'true', latitude:50.733028, longitude:7.151086}, position: { x: 1392, y: 16 } }, + { data: { id: 'NEC-Z#4', label : '#4' , parent : 'NEC-Z' , type: 'port', layer: 'ETY', active: 'true', latitude: 50.733028, longitude: 7.151086 }, position: { x: 1449, y: 16 } }, + { data: { id: 'NEC-Z#2', label : '#2' , parent : 'NEC-Z' , type: 'port', layer: 'ETY', active: 'true', latitude: 50.733028, longitude: 7.151086 }, position: { x: 1449, y: -41 } }, + { data: { id: 'NEC-Z#6', label : '#6' , parent : 'NEC-Z' , type: 'port', layer: 'ETC', active: 'true', latitude: 50.733028, longitude: 7.151086 }, position: { x: 1382, y: -23 } }, + { data: { id: 'Ceragon-A#5', label : '#5' , parent : 'Ceragon-A' , type: 'port', layer: 'ETY', active: 'true', latitude: 50.730230, longitude: 7.126017 }, position: { x: 195, y: 312 } }, + { data: { id: 'Ceragon-A#6', label : '#6' , parent : 'Ceragon-A' , type: 'port', layer: 'ETC', active: 'true', latitude: 50.730230, longitude: 7.126017 }, position: { x: 136, y: 366 } }, + { data: { id: 'ZTE-A#5', label : '#5' , parent : 'ZTE-A' , type: 'port', layer: 'ETY', active: 'true', latitude: 50.730230, longitude: 7.126017 }, position: { x: 345, y: 108 } }, + { data: { id: 'ZTE-A#6', label : '#6' , parent : 'ZTE-A' , type: 'port', layer: 'ETC', active: 'true', latitude: 50.730230, longitude: 7.126017 }, position: { x: 408, y: 99 } }, + { data: { id: 'ADVA-Z#1', label : '#1' , parent : 'ADVA-Z' , type: 'port', layer: 'ETY', active: 'true', latitude: 50.712472, longitude: 7.143887 }, position: { x: 1139, y: 1001 } }, + // { data: { id: 'ADVA-Z#2', label : '#2' , parent : 'ADVA-Z' , type:'port', layer:'ETY', active:'true', latitude:50.712472, longitude:7.143887}, position: { x: 1196, y: 944 } }, + // { data: { id: 'ADVA-Z#3', label : '#3' , parent : 'ADVA-Z' , type:'port', layer:'ETY', active:'true', latitude:50.712472, longitude:7.143887}, position: { x: 1139, y: 944 } }, + { data: { id: 'ADVA-Z#4', label : '#4' , parent : 'ADVA-Z' , type: 'port', layer: 'ETY', active: 'true', latitude: 50.712472, longitude: 7.143887 }, position: { x: 1196, y: 1001 } }, + { data: { id: 'DragonWave-Z#2', label : '#2' , parent : 'DragonWave-Z' , type: 'port', layer: 'ETY', active: 'true', latitude: 50.712472, longitude: 7.143887 }, position: { x: 1133, y: 1252 } }, + { data: { id: 'DragonWave-Z#6', label : '#6' , parent : 'DragonWave-Z' , type: 'port', layer: 'ETC', active: 'true', latitude: 50.712472, longitude: 7.143887 }, position: { x: 1053, y: 1252 } }, + { data: { id: 'Huawei-Z#3', label : '#3' , parent : 'Huawei-Z' , type: 'port', layer: 'ETY', active: 'true', latitude: 50.712472, longitude: 7.143887 }, position: { x: 1046, y: 1094 } }, + // { data: { id: 'Huawei-Z#4', label : '#4' , parent : 'Huawei-Z' , type:'port', layer:'ETY', active:'true', latitude:50.712472, longitude:7.143887}, position: { x: 989, y: 1094 } }, + { data: { id: 'Huawei-Z#5', label : '#5' , parent : 'Huawei-Z' , type: 'port', layer: 'ETY', active: 'true', latitude: 50.712472, longitude: 7.143887 }, position: { x: 1058, y: 1123 } }, + { data: { id: 'Huawei-Z#6', label : '#6' , parent : 'Huawei-Z' , type: 'port', layer: 'ETC', active: 'true', latitude: 50.712472, longitude: 7.143887 }, position: { x: 978, y: 1123 } }, + { data: { id: 'Intracom-A#2', label : '#2' , parent : 'Intracom-A' , type: 'port', layer: 'ETY', active: 'true', latitude: 50.712472, longitude: 7.143887 }, position: { x: 1203, y: 1252 } }, + { data: { id: 'Intracom-A#6', label : '#6' , parent : 'Intracom-A' , type: 'port', layer: 'ETC', active: 'true', latitude: 50.712472, longitude: 7.143887 }, position: { x: 1283, y: 1252 } }, + { data: { id: 'SIAE-A#4', label : '#4' , parent : 'SIAE-A' , type: 'port', layer: 'ETY', active: 'true', latitude: 50.712472, longitude: 7.143887 }, position: { x: 1289, y: 1094 } }, + { data: { id: 'SIAE-A#5', label : '#5' , parent : 'SIAE-A' , type: 'port', layer: 'ETY', active: 'true', latitude: 50.712472, longitude: 7.143887 }, position: { x: 1278, y: 1123 } }, + { data: { id: 'SIAE-A#6', label : '#6' , parent : 'SIAE-A' , type: 'port', layer: 'ETC', active: 'true', latitude: 50.712472, longitude: 7.143887 }, position: { x: 1346, y: 1094 } }, + { data: { id: 'Fujitsu-Z#5', label : '#5' , parent : 'Fujitsu-Z' , type: 'port', layer: 'ETY', active: 'true', latitude: 50.717158, longitude: 7.155506 }, position: { x: 1855, y: 821 } }, + { data: { id: 'Fujitsu-Z#6', label : '#6' , parent : 'Fujitsu-Z' , type: 'port', layer: 'ETC', active: 'true', latitude: 50.717158, longitude: 7.155506 }, position: { x: 1855, y: 741 } }, + { data: { id: 'Intracom-Z#5', label : '#5' , parent : 'Intracom-Z' , type: 'port', layer: 'ETY', active: 'true', latitude: 50.717158, longitude: 7.155506 }, position: { x: 1755, y: 998 } }, + { data: { id: 'Intracom-Z#6', label : '#6' , parent : 'Intracom-Z' , type: 'port', layer: 'ETC', active: 'true', latitude: 50.717158, longitude: 7.155506 }, position: { x: 1714, y: 1018 } }, + { data: { id: 'SIAE-Z#4', label : '#4' , parent : 'SIAE-Z' , type: 'port', layer: 'ETY', active: 'true', latitude: 50.717158, longitude: 7.155506 }, position: { x: 1590, y: 784 } }, + { data: { id: 'SIAE-Z#5', label : '#5' , parent : 'SIAE-Z' , type: 'port', layer: 'ETY', active: 'true', latitude: 50.717158, longitude: 7.155506 }, position: { x: 1647, y: 784 } }, + { data: { id: 'SIAE-Z#6', label : '#6' , parent : 'SIAE-Z' , type: 'port', layer: 'ETC', active: 'true', latitude: 50.717158, longitude: 7.155506 }, position: { x: 1588, y: 838 } }, + { data: { id: 'DragonWave-A#2', label : '#2' , parent : 'DragonWave-A' , type: 'port', layer: 'ETY', active: 'true', latitude: 50.714359, longitude: 7.130437 }, position: { x: 455, y: 1178 } }, + { data: { id: 'DragonWave-A#6', label : '#6' , parent : 'DragonWave-A' , type: 'port', layer: 'ETC', active: 'true', latitude: 50.714359, longitude: 7.130437 }, position: { x: 535, y: 1178 } }, + { data: { id: 'ELVA-1-Z#2', label : '#2' , parent : 'ELVA-1-Z' , type: 'port', layer: 'ETY', active: 'true', latitude: 50.714359, longitude: 7.130437 }, position: { x: 455, y: 878 } }, + { data: { id: 'ELVA-1-Z#6', label : '#6' , parent : 'ELVA-1-Z' , type: 'port', layer: 'ETC', active: 'true', latitude: 50.714359, longitude: 7.130437 }, position: { x: 535, y: 878 } }, + { data: { id: 'Huawei-A#5', label : '#5' , parent : 'Huawei-A' , type: 'port', layer: 'ETY', active: 'true', latitude: 50.714359, longitude: 7.130437 }, position: { x: 605, y: 1028 } }, + { data: { id: 'Huawei-A#6', label : '#6' , parent : 'Huawei-A' , type: 'port', layer: 'ETC', active: 'true', latitude: 50.714359, longitude: 7.130437 }, position: { x: 685, y: 1028 } }, + { data: { id: 'Nokia-Z33', label : '33' , parent : 'Nokia-Z' , type: 'port', layer: 'ETY', active: 'true', latitude: 50.714359, longitude: 7.130437 }, position: { x: 385, y: 1028 } }, + { data: { id: 'Nokia-Z#6', label : '#6' , parent : 'Nokia-Z' , type: 'port', layer: 'ETC', active: 'true', latitude: 50.714359, longitude: 7.130437 }, position: { x: 305, y: 1028 } }, + { data: { id: 'Ceragon-Z#4', label : '#4' , parent : 'Ceragon-Z' , type: 'port', layer: 'ETY', active: 'true', latitude: 50.721914, longitude: 7.120521 }, position: { x: -159, y: 547 } }, + { data: { id: 'Ceragon-Z#5', label : '#5' , parent : 'Ceragon-Z' , type: 'port', layer: 'ETY', active: 'true', latitude: 50.721914, longitude: 7.120521 }, position: { x: -159, y: 604 } }, + { data: { id: 'Ceragon-Z#6', label : '#6' , parent : 'Ceragon-Z' , type: 'port', layer: 'ETC', active: 'true', latitude: 50.721914, longitude: 7.120521 }, position: { x: -130, y: 536 } }, + // { data: { id: 'Nokia-A13', label : '13' , parent : 'Nokia-A' , type:'port', layer:'ETY', active:'true', latitude:50.721914, longitude:7.120521}, position: { x: 40, y: 801 } }, + // { data: { id: 'Nokia-A34', label : '34' , parent : 'Nokia-A' , type:'port', layer:'ETY', active:'true', latitude:50.721914, longitude:7.120521}, position: { x: 28, y: 772 } }, + { data: { id: 'Nokia-A11', label : '11' , parent : 'Nokia-A' , type: 'port', layer: 'ETY', active: 'true', latitude: 50.721914, longitude: 7.120521 }, position: { x: -29, y: 772 } }, + { data: { id: 'Nokia-A#6', label : '#6' , parent : 'Nokia-A' , type: 'port', layer: 'ETC', active: 'true', latitude: 50.721914, longitude: 7.120521 }, position: { x: 28, y: 829 } }, + + { data: { id: 'Spirent#1', label : '#1' , parent : 'Spirent' , type: 'host', layer: 'ETH-TTP', active: 'true', service: 'service13' }, position: { x: 707, y: -167 } }, + { data: { id: 'Spirent#2', label : '#2' , parent : 'Spirent' , type: 'host', layer: 'ETH-TTP', active: 'true', service: 'service24' }, position: { x: -259, y: 547 } }, + { data: { id: 'Spirent#3', label : '#3' , parent : 'Spirent' , type: 'host', layer: 'ETH-TTP', active: 'true', service: 'service13' }, position: { x: 1292, y: 172 } }, + { data: { id: 'Spirent#4', label : '#4' , parent : 'Spirent' , type: 'host', layer: 'ETH-TTP', active: 'true', service: 'service24' }, position: { x: 1490, y: 784 } }, + { data: { id: 'Spirent#5', label : '#5' , parent : 'Spirent' , type: 'host', layer: 'ETH-TTP', active: 'true', service: 'service56' }, position: { x: 1754, y: -47 } }, + { data: { id: 'Spirent#6', label : '#6' , parent : 'Spirent' , type: 'host', layer: 'ETH-TTP', active: 'true', service: 'service56' }, position: { x: 455, y: 1278 } }, + { data: { id: 'Spirent#7', label : '#7' , parent : 'Spirent' , type: 'host', layer: 'ETH-TTP', active: 'true', service: 'service78' }, position: { x: 895, y: 250 } }, + { data: { id: 'Spirent#8', label : '#8' , parent : 'Spirent' , type: 'host', layer: 'ETH-TTP', active: 'true', service: 'service78' }, position: { x: 455, y: 778 } }, + + ], + edges: [ + + { data: { id: '21', source: 'Aviat-A#6', target: 'Aviat-Z#6', label: '21', layer: 'ETC' , active: 'true' } }, + { data: { id: '31', source: 'Ceragon-A#6', target: 'Ceragon-Z#6', label: '31', layer: 'ETC' , active: 'true' } }, + { data: { id: '41', source: 'DragonWave-A#6', target: 'DragonWave-Z#6', label: '41', layer: 'ETC' , active: 'true' } }, + { data: { id: '121', source: 'ELVA-1-A#6', target: 'ELVA-1-Z#6', label: '121' , layer: 'ETC' , active: 'true' } }, + { data: { id: 'ERI1', source: 'Ericsson-A#6', target: 'Ericsson-Z#6', label: 'ERI1', layer: 'ETC' , active: 'true' } }, + { data: { id: '61', source: 'Fujitsu-A#6', target: 'Fujitsu-Z#6', label: '61', layer: 'ETC' , active: 'true' } }, + { data: { id: '71', source: 'Huawei-A#6', target: 'Huawei-Z#6', label: '71', layer: 'ETC' , active: 'true' } }, + { data: { id: '131', source: 'Intracom-A#6', target: 'Intracom-Z#6', label: '131', layer: 'ETC' , active: 'true' } }, + { data: { id: '81', source: 'NEC-A#6', target: 'NEC-Z#6', label: '81', layer: 'ETC' , active: 'true' } }, + { data: { id: '91', source: 'Nokia-A#6', target: 'Nokia-Z#6', label: '91', layer: 'ETC' , active: 'true' } }, + { data: { id: '101', source: 'SIAE-A#6', target: 'SIAE-Z#6', label: '101', layer: 'ETC' , active: 'true' } }, + { data: { id: '111', source: 'ZTE-A#6', target: 'ZTE-Z#6', label: '111', layer: 'ETC' , active: 'true' } }, + + // { data: { id: 'ETY01', source: 'ADVA-A#1', target: 'Nokia-A34', label: 'ADVA-A#1-Nokia-A34' , layer: 'ETY' , active: 'true' } }, + // { data: { id: 'ETY02', source: 'ADVA-A#2', target: 'ZTE-A#4', label: 'ADVA-A#2-ZTE-A#4' , layer: 'ETY' , active: 'false' } }, + // { data: { id: 'ETY03', source: 'ADVA-B#1', target: 'Nokia-A13', label: 'ADVA-B#1-Nokia-A13' , layer: 'ETY' , active: 'true' } }, + // { data: { id: 'ETY04', source: 'ADVA-B#2', target: 'ZTE-A#3', label: 'ADVA-B#2-ZTE-A#3' , layer: 'ETY' , active: 'true' } }, + // { data: { id: 'ETY05', source: 'ADVA-Y#1', target: 'Huawei-Z#4', label: 'ADVA-Y#1-Huawei-Z#4' , layer: 'ETY' , active: 'true' } }, + { data: { id: 'ETY06', source: 'ADVA-Y#2', target: 'NEC-Z#4', label: 'ADVA-Y#2-NEC-Z#4' , layer: 'ETY' , active: 'true' } }, + { data: { id: 'ETY07', source: 'ADVA-Y#3', target: 'Spirent#3', label: 'ADVA-Y#3-Spirent#3' , layer: 'ETY' , active: 'true' } }, + { data: { id: 'ETY08', source: 'ADVA-Y#4', target: 'Ericsson-A#4', label: 'ADVA-Y#4-Ericsson-A#4' , layer: 'ETY' , active: 'true' } }, + { data: { id: 'ETY09', source: 'ADVA-Z#1', target: 'Huawei-Z#3', label: 'ADVA-Z#1-Huawei-Z#3' , layer: 'ETY' , active: 'true' } }, + // { data: { id: 'ETY10', source: 'ADVA-Z#2', target: 'NEC-Z#3', label: 'ADVA-Z#2-NEC-Z#3' , layer: 'ETY' , active: 'true' } }, + { data: { id: 'ETY11', source: 'ADVA-Z#4', target: 'SIAE-A#4', label: 'ADVA-Z#4-SIAE-A#4' , layer: 'ETY' , active: 'true' } }, + { data: { id: 'ETY12', source: 'Aviat-A#5', target: 'Spirent#5', label: 'Aviat-A#5-Spirent#5' , layer: 'ETY' , active: 'true' } }, + { data: { id: 'ETY13', source: 'Aviat-Z#5', target: 'Fujitsu-A#5', label: 'Aviat-Z#5-Fujitsu-A#5' , layer: 'ETY' , active: 'true' } }, + { data: { id: 'ETY14', source: 'Ceragon-A#5', target: 'ZTE-A#5', label: 'Ceragon-A#5-ZTE-A#5' , layer: 'ETY' , active: 'true' } }, + { data: { id: 'ETY15', source: 'Ceragon-Z#4', target: 'Spirent#2', label: 'Ceragon-Z#4-Spirent#2' , layer: 'ETY' , active: 'true' } }, + { data: { id: 'ETY16', source: 'Ceragon-Z#5', target: 'Nokia-A11', label: 'Ceragon-Z#5-Nokia-A11' , layer: 'ETY' , active: 'true' } }, + { data: { id: 'ETY17', source: 'DragonWave-A#2', target: 'Spirent#6', label: 'DragonWave-A#2-Spirent#6' , layer: 'ETY' , active: 'true' } }, + { data: { id: 'ETY18', source: 'DragonWave-Z#2', target: 'Intracom-A#2', label: 'DragonWave-Z#2-Intracom-A#2' , layer: 'ETY' , active: 'true' } }, + { data: { id: 'ETY19', source: 'ELVA-1-A#2', target: 'Spirent#7', label: 'ELVA-1-A#2-Spirent#7' , layer: 'ETY' , active: 'true' } }, + { data: { id: 'ETY20', source: 'ELVA-1-Z#2', target: 'Spirent#8', label: 'ELVA-1-Z#2-Spirent#8' , layer: 'ETY' , active: 'true' } }, + { data: { id: 'ETY21', source: 'Ericsson-A#5', target: 'NEC-Z#2', label: 'Ericsson-A#5-NEC-Z#2' , layer: 'ETY' , active: 'true' } }, + { data: { id: 'ETY22', source: 'Ericsson-Z#5', target: 'SIAE-Z#5', label: 'Ericsson-Z#5-SIAE-Z#5' , layer: 'ETY' , active: 'true' } }, + { data: { id: 'ETY23', source: 'Fujitsu-Z#5', target: 'Intracom-Z#5', label: 'Fujitsu-Z#5-Intracom-Z#5' , layer: 'ETY' , active: 'true' } }, + { data: { id: 'ETY24', source: 'Huawei-A#5', target: 'Nokia-Z33', label: 'Huawei-A#5-Nokia-Z33' , layer: 'ETY' , active: 'true' } }, + { data: { id: 'ETY25', source: 'Huawei-Z#5', target: 'SIAE-A#5', label: 'Huawei-Z#5-SIAE-A#5' , layer: 'ETY' , active: 'true' } }, + { data: { id: 'ETY26', source: 'NEC-A#3', target: 'ZTE-Z#5', label: 'NEC-A#3-ZTE-Z#5' , layer: 'ETY' , active: 'true' } }, + { data: { id: 'ETY27', source: 'SIAE-Z#4', target: 'Spirent#4', label: 'SIAE-Z#4-Spirent#4' , layer: 'ETY' , active: 'true' } }, + { data: { id: 'ETY28', source: 'ZTE-Z#4', target: 'Spirent#1', label: 'Spirent#1-ZTE-Z#4' , layer: 'ETY' , active: 'true' } }, + + { data: { id: 'ADVA-Y#2-ETH-13<->ADVA-Y#3-ETH-13', source: 'ADVA-Y#2', target: 'ADVA-Y#3', label: 'service13' , layer: 'ETH' , active: 'true' , path: 'false' , service: 'service13' , rule: 'protection' } }, + { data: { id: 'ADVA-Y#2-ETH-24<->ADVA-Y#4-ETH-24', source: 'ADVA-Y#2', target: 'ADVA-Y#4', label: 'service24' , layer: 'ETH' , active: 'true' , path: 'false' , service: 'service24' , rule: 'protection' } }, + { data: { id: 'ADVA-Y#3-ETH-13<->ADVA-Y#4-ETH-13', source: 'ADVA-Y#3', target: 'ADVA-Y#4', label: 'service13' , layer: 'ETH' , active: 'true' , path: 'false' , service: 'service13' , rule: 'working' } }, + { data: { id: 'Aviat-A#5-ETH-56<->Aviat-A#6-ETH-56', source: 'Aviat-A#5', target: 'Aviat-A#6', label: 'service56' , layer: 'ETH' , active: 'true' , path: 'false' , service: 'service56' , rule: 'working' } }, + { data: { id: 'Aviat-Z#5-ETH-56<->Aviat-Z#6-ETH-56', source: 'Aviat-Z#5', target: 'Aviat-Z#6', label: 'service56' , layer: 'ETH' , active: 'true' , path: 'false' , service: 'service56' , rule: 'working' } }, + { data: { id: 'Ceragon-A#5-ETH-13<->Ceragon-A#6-ETH-13', source: 'Ceragon-A#5', target: 'Ceragon-A#6', label: 'service13' , layer: 'ETH' , active: 'true' , path: 'false' , service: 'service13' , rule: 'working' } }, + { data: { id: 'Ceragon-A#5-ETH-24<->Ceragon-A#6-ETH-24', source: 'Ceragon-A#5', target: 'Ceragon-A#6', label: 'service24' , layer: 'ETH' , active: 'true' , path: 'false' , service: 'service24' , rule: 'protection' } }, + { data: { id: 'Ceragon-Z#4-ETH-24<->Ceragon-Z#5-ETH-24', source: 'Ceragon-Z#4', target: 'Ceragon-Z#5', label: 'service24' , layer: 'ETH' , active: 'true' , path: 'false' , service: 'service24' , rule: 'working' } }, + { data: { id: 'Ceragon-Z#4-ETH-24<->Ceragon-Z#6-ETH-24', source: 'Ceragon-Z#4', target: 'Ceragon-Z#6', label: 'service24' , layer: 'ETH' , active: 'true' , path: 'false' , service: 'service24' , rule: 'protection' } }, + { data: { id: 'Ceragon-Z#5-ETH-13<->Ceragon-Z#6-ETH-13', source: 'Ceragon-Z#5', target: 'Ceragon-Z#6', label: 'service13' , layer: 'ETH' , active: 'true' , path: 'false' , service: 'service13' , rule: 'working' } }, + { data: { id: 'DragonWave-A#2-ETH-56<->DragonWave-A#6-ETH-56', source: 'DragonWave-A#2', target: 'DragonWave-A#6', label: 'service56' , layer: 'ETH' , active: 'true' , path: 'false' , service: 'service56' , rule: 'working' } }, + { data: { id: 'DragonWave-Z#2-ETH-56<->DragonWave-Z#6-ETH-56', source: 'DragonWave-Z#2', target: 'DragonWave-Z#6', label: 'service56' , layer: 'ETH' , active: 'true' , path: 'false' , service: 'service56' , rule: 'working' } }, + { data: { id: 'ELVA-1-A#2-ETH-78<->ELVA-1-A#6-ETH-78', source: 'ELVA-1-A#2', target: 'ELVA-1-A#6', label: 'service78' , layer: 'ETH' , active: 'true' , path: 'false' , service: 'service78' , rule: 'working' } }, + { data: { id: 'ELVA-1-Z#2-ETH-78<->ELVA-1-Z#6-ETH-78', source: 'ELVA-1-Z#2', target: 'ELVA-1-Z#6', label: 'service78' , layer: 'ETH' , active: 'true' , path: 'false' , service: 'service78' , rule: 'working' } }, + { data: { id: 'Ericsson-A#4-ETH-13<->Ericsson-A#6-ETH-13', source: 'Ericsson-A#4', target: 'Ericsson-A#6', label: 'service13' , layer: 'ETH' , active: 'true' , path: 'false' , service: 'service13' , rule: 'working' } }, + { data: { id: 'Ericsson-A#4-ETH-24<->Ericsson-A#6-ETH-24', source: 'Ericsson-A#4', target: 'Ericsson-A#6', label: 'service24' , layer: 'ETH' , active: 'true' , path: 'false' , service: 'service24' , rule: 'protection' } }, + { data: { id: 'Ericsson-Z#5-ETH-13<->Ericsson-Z#6-ETH-13', source: 'Ericsson-Z#5', target: 'Ericsson-Z#6', label: 'service13' , layer: 'ETH' , active: 'true' , path: 'false' , service: 'service13' , rule: 'working' } }, + { data: { id: 'Ericsson-Z#5-ETH-24<->Ericsson-Z#6-ETH-24', source: 'Ericsson-Z#5', target: 'Ericsson-Z#6', label: 'service24' , layer: 'ETH' , active: 'true' , path: 'false' , service: 'service24' , rule: 'protection' } }, + { data: { id: 'Fujitsu-A#5-ETH-56<->Fujitsu-A#6-ETH-56', source: 'Fujitsu-A#5', target: 'Fujitsu-A#6', label: 'service56' , layer: 'ETH' , active: 'true' , path: 'false' , service: 'service56' , rule: 'working' } }, + { data: { id: 'Fujitsu-Z#5-ETH-56<->Fujitsu-Z#6-ETH-56', source: 'Fujitsu-Z#5', target: 'Fujitsu-Z#6', label: 'service56' , layer: 'ETH' , active: 'true' , path: 'false' , service: 'service56' , rule: 'working' } }, + { data: { id: 'Huawei-A#5-ETH-13<->Huawei-A#6-ETH-13', source: 'Huawei-A#5', target: 'Huawei-A#6', label: 'service13' , layer: 'ETH' , active: 'true' , path: 'false' , service: 'service13' , rule: 'working' } }, + { data: { id: 'Huawei-A#5-ETH-24<->Huawei-A#6-ETH-24', source: 'Huawei-A#5', target: 'Huawei-A#6', label: 'service24' , layer: 'ETH' , active: 'true' , path: 'false' , service: 'service24' , rule: 'working' } }, + { data: { id: 'Huawei-Z#5-ETH-13<->Huawei-Z#6-ETH-13', source: 'Huawei-Z#5', target: 'Huawei-Z#6', label: 'service13' , layer: 'ETH' , active: 'true' , path: 'false' , service: 'service13' , rule: 'working' } }, + { data: { id: 'Huawei-Z#5-ETH-24<->Huawei-Z#6-ETH-24', source: 'Huawei-Z#5', target: 'Huawei-Z#6', label: 'service24' , layer: 'ETH' , active: 'true' , path: 'false' , service: 'service24' , rule: 'working' } }, + { data: { id: 'Intracom-A#2-ETH-56<->Intracom-A#6-ETH-56', source: 'Intracom-A#2', target: 'Intracom-A#6', label: 'service56' , layer: 'ETH' , active: 'true' , path: 'false' , service: 'service56' , rule: 'working' } }, + { data: { id: 'Intracom-Z#5-ETH-56<->Intracom-Z#6-ETH-56', source: 'Intracom-Z#5', target: 'Intracom-Z#6', label: 'service56' , layer: 'ETH' , active: 'true' , path: 'false' , service: 'service56' , rule: 'working' } }, + { data: { id: 'NEC-A#3-ETH-13<->NEC-A#6-ETH-13', source: 'NEC-A#3', target: 'NEC-A#6', label: 'service13' , layer: 'ETH' , active: 'true' , path: 'false' , service: 'service13' , rule: 'protection' } }, + { data: { id: 'NEC-A#3-ETH-24<->NEC-A#6-ETH-24', source: 'NEC-A#3', target: 'NEC-A#6', label: 'service24' , layer: 'ETH' , active: 'true' , path: 'false' , service: 'service24' , rule: 'protection' } }, + { data: { id: 'NEC-Z#4-ETH-13<->NEC-Z#6-ETH-13', source: 'NEC-Z#4', target: 'NEC-Z#6', label: 'service13' , layer: 'ETH' , active: 'true' , path: 'false' , service: 'service13' , rule: 'protection' } }, + { data: { id: 'NEC-Z#4-ETH-24<->NEC-Z#6-ETH-24', source: 'NEC-Z#4', target: 'NEC-Z#6', label: 'service24' , layer: 'ETH' , active: 'true' , path: 'false' , service: 'service24' , rule: 'protection' } }, + { data: { id: 'Nokia-A11-ETH-13<->Nokia-A#6-ETH-13', source: 'Nokia-A11', target: 'Nokia-A#6', label: 'service13' , layer: 'ETH' , active: 'true' , path: 'false' , service: 'service13' , rule: 'working' } }, + { data: { id: 'Nokia-A11-ETH-24<->Nokia-A#6-ETH-24', source: 'Nokia-A11', target: 'Nokia-A#6', label: 'service24' , layer: 'ETH' , active: 'true' , path: 'false' , service: 'service24' , rule: 'working' } }, + { data: { id: 'Nokia-Z33-ETH-13<->Nokia-Z#6-ETH-13', source: 'Nokia-Z33', target: 'Nokia-Z#6', label: 'service13' , layer: 'ETH' , active: 'true' , path: 'false' , service: 'service13' , rule: 'working' } }, + { data: { id: 'Nokia-Z33-ETH-24<->Nokia-Z#6-ETH-24', source: 'Nokia-Z33', target: 'Nokia-Z#6', label: 'service24' , layer: 'ETH' , active: 'true' , path: 'false' , service: 'service24' , rule: 'working' } }, + { data: { id: 'SIAE-A#5-ETH-13<->SIAE-A#6-ETH-13', source: 'SIAE-A#5', target: 'SIAE-A#6', label: 'service13' , layer: 'ETH' , active: 'true' , path: 'false' , service: 'service13' , rule: 'working' } }, + { data: { id: 'SIAE-A#5-ETH-24<->SIAE-A#6-ETH-24', source: 'SIAE-A#5', target: 'SIAE-A#6', label: 'service24' , layer: 'ETH' , active: 'true' , path: 'false' , service: 'service24' , rule: 'working' } }, + { data: { id: 'SIAE-Z#4-ETH-24<->SIAE-Z#6-ETH-24', source: 'SIAE-Z#4', target: 'SIAE-Z#6', label: 'service24' , layer: 'ETH' , active: 'true' , path: 'false' , service: 'service24' , rule: 'working' } }, + { data: { id: 'SIAE-Z#4-ETH-24<->SIAE-Z#5-ETH-24', source: 'SIAE-Z#4', target: 'SIAE-Z#5', label: 'service24' , layer: 'ETH' , active: 'true' , path: 'false' , service: 'service24' , rule: 'protection' } }, + { data: { id: 'SIAE-Z#5-ETH-13<->SIAE-Z#6-ETH-13', source: 'SIAE-Z#5', target: 'SIAE-Z#6', label: 'service13' , layer: 'ETH' , active: 'true' , path: 'false' , service: 'service13' , rule: 'working' } }, + { data: { id: 'ZTE-A#5-ETH-13<->ZTE-A#6-ETH-13', source: 'ZTE-A#5', target: 'ZTE-A#6', label: 'service13' , layer: 'ETH' , active: 'true' , path: 'false' , service: 'service13' , rule: 'working' } }, + { data: { id: 'ZTE-A#5-ETH-24<->ZTE-A#6-ETH-24', source: 'ZTE-A#5', target: 'ZTE-A#6', label: 'service24' , layer: 'ETH' , active: 'true' , path: 'false' , service: 'service24' , rule: 'protection' } }, + { data: { id: 'ZTE-A#5-ETH-24<->ZTE-A#6-ETH-24', source: 'ZTE-A#5', target: 'ZTE-A#6', label: 'service24' , layer: 'ETH' , active: 'true' , path: 'false' , service: 'service24' , rule: 'protection' } }, + { data: { id: 'ZTE-Z#4-ETH-13<->ZTE-Z#6-ETH-13', source: 'ZTE-Z#4', target: 'ZTE-Z#6', label: 'service13' , layer: 'ETH' , active: 'true' , path: 'false' , service: 'service13' , rule: 'working' } }, + { data: { id: 'ZTE-Z#4-ETH-13<->ZTE-Z#5-ETH-13', source: 'ZTE-Z#4', target: 'ZTE-Z#5', label: 'service13' , layer: 'ETH' , active: 'true' , path: 'false' , service: 'service13' , rule: 'protection' } }, + { data: { id: 'ZTE-Z#5-ETH-24<->ZTE-Z#6-ETH-24', source: 'ZTE-Z#5', target: 'ZTE-Z#6', label: 'service24' , layer: 'ETH' , active: 'true' , path: 'false' , service: 'service24' , rule: 'protection' } }, + ] + }; + + var events = eventsFabric(); + + var result = { + colors: colors, + elements: elements, + styles: styles, + events: events + }; + + var someMethodChangingTheElements = function () { + // @Martin: hier kannst Du die Elements ändern, anschließend mußt Du das Ereignis veröffentlichen + // das Ereigniss wird in der Directive aufgefangen und die Grig wird neu gezeichnet + + // Hinweis: Die Reihenfolge muss so bleiben und du kannst NUR result.elements ändern. + + events.publish("elementsChanged", { + elements: result.elements + }); + }; + + return result; + }); + + mwtnTopologyApp.directive("mwtnTopologyEthernetPathGraph", ["mwtnTopologyEthernetPathData", '$mwtnCommons', function (mwtnTopologyEthernetPathData, $mwtnCommons) { + + return { + restrict: 'E', + replace: true, + template: '<div id="cy" style="height: 750px; width: 100%;"></div>', + controller: function () { + + }, + scope: { + + }, + link: function (scope, element, attrs, ctrl) { + + var cy = cytoscape({ + container: element[0], + + boxSelectionEnabled: false, + autounselectify: true, + + style: mwtnTopologyEthernetPathData.styles, + elements: mwtnTopologyEthernetPathData.elements, + layout: { + name: 'preset', + padding: 5 + } + }); + + // @ Martin: Hier wird das Ereignis aus dem Service aboniert. + // Es ist möglich mehrere Ereignisse zu definieren. + mwtnTopologyEthernetPathData.events.subscribe("elementsChanged", function (data) { + + // @Martin: cy aktualisiert sich mit Hilfe der Referenz auf die Elemente aus dem Service + cy.json({ + elements: mwtnTopologyEthernetPathData.elements // oder data.elements + }); + + }); + + // pathGraphData.events.subscribe("styleChanged", function () { + // cy.json({ + // style: mwtnTopologyEthernetPathData.styles + // }); + // }); + + cy.viewport({ + zoom: 0.5, + pan: { x: 150, y: 100 } + }); + + var clearService = function () { + var lable = cy.getElementById('label'); + lable.data('label', ''); + + var pathState = ['working', 'protection', 'hidden']; + pathState.map(function (state) { + var selector = "[path = '" + state + "']"; + cy.elements(selector).map(function (element) { + element.data('path', 'false'); + }); + }); + }; + + var highlightService = function (service) { + var lable = cy.getElementById('label'); + lable.data('label', service); + + var selector = "[service = '" + service + "']"; + // start and end service node (host, traffic analyser) + cy.nodes(selector).map(function (node) { + // console.log(node.id()); + node.data('path', 'working'); + }); + + ['protection', 'working'].map(function (state) { + selector = "[service = '" + service + "'][rule = '" + state + "']"; + cy.edges(selector).map(function (edge) { + edge.connectedNodes().map(function (node) { + node.data('path', edge.data('rule')); + }); + }); + return state; + }).reverse().map(function (state) { + selector = "[path = '" + state + "']"; + cy.nodes(selector).connectedEdges().filter(function (edge) { + return edge.data('service') === service || edge.data('layer') !== "ETH"; + }).map(function (edge) { + edge.data('path', state); + }); + }); + }; + var filterActiveMountPoints = function (mountpoints) { + return mountpoints.filter(function (mountpoint) { + if (!mountpoint) return false; + // console.warn(mountpoint['node-id'], mountpoint['netconf-node-topology:connection-status']); + return mountpoint['netconf-node-topology:connection-status'] === 'connected'; + }).map(function (mountpoint) { + return mountpoint['node-id']; + }); + }; + + var setDevicesActive = function (nodeIds) { + // console.warn(nodeIds); + cy.nodes().filter(function (node) { + node.data('active', 'false'); + return node.data('type') === 'device' && nodeIds.contains(node.data('id')); + }).map(function (node) { + node.data('active', 'true'); + }); + }; + + var setAllDevicesInactive = function () { + cy.nodes().map(function (node) { + node.data('active', 'false'); + }); + }; + + var setPortAndEdgedActive = function () { + cy.edges().map(function (edge) { + var active = 'true'; + edge.connectedNodes().map(function (port) { + // console.log(' node', JSON.stringify(edge.data())); + var parent = cy.getElementById(port.data('parent')); + if (parent.data('active') === 'false') { + port.data('active', 'false'); + edge.data('active', 'false'); + } else { + port.data('active', 'true'); + } + }); + }); + }; + + var init = function () { + var timerName = 'init ethernet'; + console.time(timerName); + $mwtnCommons.getMountPoints().then(function (mountpoints) { + var filtered = filterActiveMountPoints(mountpoints); + setDevicesActive(filtered); + setPortAndEdgedActive(); + console.timeEnd(timerName); + }, function (error) { + setAllDevicesInactive(); + setPortAndEdgedActive(); + console.timeEnd(timerName); + }); + + }; + init(); + + cy.on('tap', function (event) { + clearService(); + if (event.target !== cy) { + if (event.target.data('service')) { + highlightService(event.target.data('service')); + } + } else { + init(); + } + }); + } + } + }]); + + mwtnTopologyApp.controller("mwtnTopologyPortsGridController", ['$scope', '$timeout', '$state', '$mwtnCommons', '$mwtnTopology', 'uiGridConstants', 'mwtnTopologyEthernetPathData', function ($scope, $timeout, $state, $mwtnCommons, $mwtnTopology, uiGridConstants, mwtnTopologyEthernetPathData) { + var vm = this; + + // The page number to show in the grid. + var paginationPage = 1; + // The page size. + var paginationPageSize = 100; + // The grid column object with current sorting informations. + var sortColumn = null; + // The grid column object with current sorting informations. + var gridFilters = []; + // caches all sites at the current grid page + + vm.gridOptions = Object.assign({}, $mwtnCommons.gridOptions, { + showGridFooter: false, // disable the grid footer because the pagination component sets its own. + paginationPageSizes: [10, 25, 50, 100], + paginationPageSize: paginationPageSize, + useExternalPagination: true, + useExternalFiltering: true, + useExternalSorting: true, + totalItems: 0, + columnDefs: [{ + field: "id", + type: "string", + displayName: "Id" + }, + { + field: "layer", + type: "string", + displayName: "Layer" + }, + { + field: "active", + type: "string", + displayName: "Active" + } + ], + data: [], + onRegisterApi: function (gridApi) { + // http://ui-grid.info/docs/#/api/ui.grid.core.api:PublicApi + vm.gridApi = gridApi; + + vm.gridApi.core.on.sortChanged($scope, function (grid, sortColumns) { + // Save the current sort column for later use. + sortColumn = (!sortColumns || sortColumns.length === 0) ? + null : + sortColumns[0]; + loadPage(); + }); + + vm.gridApi.pagination.on.paginationChanged($scope, function (newPage, newPageSize) { + // Save the pagination informations for later use. + paginationPage = newPage; + paginationPageSize = newPageSize; + loadPage(); + }); + + vm.gridApi.core.on.filterChanged($scope, function () { + // Save the all filters for later use. + var filters = []; + this.grid.columns.forEach(function (col, ind) { + if (col.filters[0] && col.filters[0].term) { + filters.push({ + field: col.field, + term: col.filters[0].term + }); + } + }); + gridFilters = filters; + loadPage(); + }); + + loadPage(); + } + }); + + /** + * Calculates the page content of the grid and sets the values to the gridOprions.data object. + */ + function loadPage() { + + // extract all ports + var ports = mwtnTopologyEthernetPathData.elements.nodes.filter(function (node, ind, arr) { + return node && node.data && node.data.type === 'port'; + }).reduce(function (acc, cur, ind, arr) { + if (cur.data) acc[cur.data.id] = cur.data; + return acc; + }, {}); + + // get all port ids + var portIds = Object.keys(ports); + + // apply the grid filters + var tempData = portIds.filter(function (portId, ind, arr) { + var port = ports[portId]; + return gridFilters.map(function (filter) { + switch (filter.field) { + case "active": + return port[filter.field].toString().contains(filter.term); + default: + return port[filter.field].contains(filter.term); + } + }).and(true); + }).map(function (portId) { + var port = ports[portId]; + var orderBy; + + if (!sortColumn || !sortColumn.sort.direction) { + return { + id: port.id + } + } + + switch (sortColumn.field) { + case "active": + orderBy = port[sortColumn.field] ? 1 : 0; + break; + default: + orderBy = port[sortColumn.field]; + break; + } + + return { + id: port.id, + orderBy: orderBy + }; + }); + + if (sortColumn && sortColumn.sort.direction) { + tempData.sort(function (left, right) { + if (left === right || left.orderBy === right.orderBy) { + return 0; + } + if (left.orderBy > right.orderBy) { + return (sortColumn.sort.direction === uiGridConstants.ASC) ? 1 : -1; + } + return (sortColumn.sort.direction === uiGridConstants.ASC) ? -1 : 1; + }); + } + + var maxPageNumber = Math.max(1, Math.ceil(tempData.length / paginationPageSize)); + var currentPage = Math.min(maxPageNumber, paginationPage); + var orderedPortsAtCurrentPage = tempData.slice((currentPage - 1) * paginationPageSize, currentPage * paginationPageSize); + + portsAtCurrentPageCache = {}; + var orderedData = []; + + orderedPortsAtCurrentPage.forEach(function (orderedPort) { + var port = ports[orderedPort.id]; + portsAtCurrentPageCache[port.id] = port; + orderedData.push({ + id: orderedPort.id, + layer: port.layer, + active: port.active + }); + }); + + $timeout(function () { + vm.gridOptions.data = orderedData; + vm.gridOptions.totalItems = tempData.length; + }); + } + + // subscribe to the elementsChanged event to reload the grid page if the data in the service has chenged + mwtnTopologyEthernetPathData.events.subscribe("elementsChanged", function (data) { + loadPage(); + }); + + }]); + + mwtnTopologyApp.directive("mwtnTopologyPortsGrid", [function () { + return { + restrict: 'E', + replace: false, + controller: 'mwtnTopologyPortsGridController', + controllerAs: 'vm', + scope: { + + }, + templateUrl: 'src/app/mwtnTopology/templates/portsGrid.tpl.html' + }; + }]); + + mwtnTopologyApp.controller("mwtnTopologyEthConnectionsGridController", ['$scope', '$timeout', '$state', '$mwtnCommons', '$mwtnTopology', 'uiGridConstants', 'mwtnTopologyEthernetPathData', function ($scope, $timeout, $state, $mwtnCommons, $mwtnTopology, uiGridConstants, mwtnTopologyEthernetPathData) { + var vm = this; + + // The page number to show in the grid. + var paginationPage = 1; + // The page size. + var paginationPageSize = 100; + // The grid column object with current sorting informations. + var sortColumn = null; + // The grid column object with current sorting informations. + var gridFilters = []; + // caches all sites at the current grid page + + vm.gridOptions = Object.assign({}, $mwtnCommons.gridOptions, { + showGridFooter: false, // disable the grid footer because the pagination component sets its own. + paginationPageSizes: [10, 25, 50, 100], + paginationPageSize: paginationPageSize, + useExternalPagination: true, + useExternalFiltering: true, + useExternalSorting: true, + totalItems: 0, + columnDefs: [{ + field: "id", + type: "string", + displayName: "Id", + width: 400 + }, + { + field: "source", + type: "string", + displayName: "PortA", + width: 200 + }, + { + field: "target", + type: "string", + displayName: "PortZ", + width: 200 + }, + { + field: "layer", + type: "string", + displayName: "Layer", + width: 80 + }, + { + field: "service", + type: "string", + displayName: "Service", + width: 150 + }, + { + field: "rule", + type: "string", + displayName: "Rule", + width: 150 + } + ], + data: [], + onRegisterApi: function (gridApi) { + // http://ui-grid.info/docs/#/api/ui.grid.core.api:PublicApi + vm.gridApi = gridApi; + + vm.gridApi.core.on.sortChanged($scope, function (grid, sortColumns) { + // Save the current sort column for later use. + sortColumn = (!sortColumns || sortColumns.length === 0) ? + null : + sortColumns[0]; + loadPage(); + }); + + vm.gridApi.pagination.on.paginationChanged($scope, function (newPage, newPageSize) { + // Save the pagination informations for later use. + paginationPage = newPage; + paginationPageSize = newPageSize; + loadPage(); + }); + + vm.gridApi.core.on.filterChanged($scope, function () { + // Save the all filters for later use. + var filters = []; + this.grid.columns.forEach(function (col, ind) { + if (col.filters[0] && col.filters[0].term) { + filters.push({ + field: col.field, + term: col.filters[0].term + }); + } + }); + gridFilters = filters; + loadPage(); + }); + + loadPage(); + } + }); + + /** + * Calculates the page content of the grid and sets the values to the gridOprions.data object. + */ + function loadPage() { + + // extract all links + var links = mwtnTopologyEthernetPathData.elements.edges.filter(function (link, ind, arr) { + // return true; // node && node.data && node.data.type === 'port'; + return link.data.layer === 'ETH'; + }).reduce(function (acc, cur, ind, arr) { + if (cur.data) { + acc[cur.data.id] = cur.data; + } + return acc; + }, {}); + + // get all relevant link ids + var linkIds = Object.keys(links); + + // apply the grid filters + var tempData = linkIds.filter(function (linkId, ind, arr) { + var link = links[linkId]; + return gridFilters.map(function (filter) { + switch (filter.field) { + default: + return link[filter.field].contains(filter.term); + } + }).and(true); + }).map(function (linkId) { + var link = links[linkId]; + var orderBy; + + if (!sortColumn || !sortColumn.sort.direction) { + return { + id: link.id + } + } + + switch (sortColumn.field) { + default: + orderBy = link[sortColumn.field]; + break; + } + + return { + id: link.id, + orderBy: orderBy + }; + }); + + if (sortColumn && sortColumn.sort.direction) { + tempData.sort(function (left, right) { + if (left === right || left.orderBy === right.orderBy) { + return 0; + } + if (left.orderBy > right.orderBy) { + return (sortColumn.sort.direction === uiGridConstants.ASC) ? 1 : -1; + } + return (sortColumn.sort.direction === uiGridConstants.ASC) ? -1 : 1; + }); + } + + var maxPageNumber = Math.max(1, Math.ceil(tempData.length / paginationPageSize)); + var currentPage = Math.min(maxPageNumber, paginationPage); + var orderedLinksAtCurrentPage = tempData.slice((currentPage - 1) * paginationPageSize, currentPage * paginationPageSize); + + linksAtCurrentPageCache = {}; + var orderedData = []; + + orderedLinksAtCurrentPage.forEach(function (orderedLink) { + var link = links[orderedLink.id]; + linksAtCurrentPageCache[link.id] = link; + orderedData.push({ + id: orderedLink.id, + source: link.source, + target: link.target, + layer: link.layer, + service: link.service, + rule: link.rule + }); + }); + + $timeout(function () { + vm.gridOptions.data = orderedData; + vm.gridOptions.totalItems = tempData.length; + }); + } + + // subscribe to the elementsChanged event to reload the grid page if the data in the service has chenged + var subscription = mwtnTopologyEthernetPathData.events.subscribe("elementsChanged", function (data) { + loadPage(); + // to unsubscribe call subscription.remove(); + }); + + }]); + + mwtnTopologyApp.directive("mwtnTopologyEthConnectionsGrid", [function () { + return { + restrict: 'E', + replace: false, + controller: 'mwtnTopologyEthConnectionsGridController', + controllerAs: 'vm', + scope: { + + }, + templateUrl: 'src/app/mwtnTopology/templates/ethConnectionsGrid.tpl.html' + }; + }]); + + /********************************************* IEEE 1588v2 (PTP) **************************/ + + mwtnTopologyApp.controller('mwtnTopologyIeee1588ViewController', ['$scope', '$q', '$timeout', '$state', '$window', '$mwtnTopology', function ($scope, $q, $timeout, $state, $window, $mwtnTopology) { + var vm = this; + vm.status = { + topologyIsOpen: false, + portsOpen: false, + ethConnectionsIsOpen: false + } + + $scope.$watchCollection(function () { return [vm.status.topologyIsOpen, vm.status.portsOpen, vm.status.ethConnectionsIsOpen] }, function (newVal, oldVal) { + if (newVal[1] || newVal[2]) { + $timeout(function () { + $window.dispatchEvent(new Event("resize")); + }); + } + }); + }]); + + mwtnTopologyApp.directive('mwtnTopologyIeee1588View', function () { + return { + restrict: 'E', + controller: 'mwtnTopologyIeee1588ViewController', + controllerAs: 'vm', + bindToController: true, + templateUrl: 'src/app/mwtnTopology/templates/ieee1588View.tpl.html', + scope: { + + } + }; + }); + + mwtnTopologyApp.factory("mwtnTopologyIeee1588PathData", function () { + var colors = { + root: '#f54', + port: '#377', + device: '#252', + site: '#525', + edge: '#49a', + white: '#eed', + grey: '#555', + selected: '#ff0' + }; + + var styles = [ + { + selector: 'node', + css: { + 'content': 'data(label)', + 'text-valign': 'center', + 'text-halign': 'center', + 'background-color': '#aaaaaa', + 'border-color': '#000000', + 'border-width': '1px', + 'color': '#ffffff' + } + }, + { + selector: '$node > node', + css: { + 'shape': 'roundrectangle', + 'padding-top': '10px', + 'padding-left': '10px', + 'padding-bottom': '10px', + 'padding-right': '10px', + 'text-valign': 'top', + 'text-halign': 'center', + 'background-color': '#eeeeee', + 'color': '#444444', + 'border-color': '#888888' + } + }, + { + selector: 'node[type = "site"]', + css: { + 'shape': 'roundrectangle', + 'padding-top': '10px', + 'padding-left': '10px', + 'padding-bottom': '10px', + 'padding-right': '10px', + 'text-valign': 'center', + 'text-halign': 'center', + 'background-color': '#fefefe', + 'color': '#444444', + 'border-color': '#888888', + 'font-weight': 'bold' + } + }, + { + selector: 'node[type = "ptp-clock"][active = "true"]', + css: { + 'background-color': '#316ac5', + 'background-opacity': '0.2', + 'border-color': '#316ac5', + 'border-opacity': '0.8', + 'border-width': '2px', + 'color': '#444444' + } + }, + { + selector: 'node[type = "port"][active = "true"]', + css: { + 'background-opacity': '1.0', + } + }, + { + selector: 'node[active = "false"]', + css: { + 'background-opacity': '0.3', + 'border-opacity': '0.5' + } + }, + { + selector: 'node[path = "true"]', + css: { + 'background-color': '#ff00ff', + 'background-opacity': '0.9', + 'border-color': '#880088', + } + }, + { + selector: '$node > node[path = "true"]', + css: { + 'background-color': '#ff00ff', + 'background-opacity': '0.3', + 'border-color': '#ff00ff', + 'border-opacity': '1.0', + 'border-width': '2px', + } + }, + { + selector: 'edge', + css: { + 'content': 'data(id)', + 'target-arrow-shape': 'triangle', + 'line-color': '#666666', + 'color': '#444444' + } + }, + { + selector: 'edge[active = "false"]', + css: { + 'line-color': '#cccccc', + 'text-opacity': '0.9' + } + }, + { + selector: 'edge[path = "true"]', + css: { + 'line-color': '#ff00ff', + 'width': '5px' + } + }, + { + selector: ':selected', + css: { + 'background-color': 'black', + 'line-color': 'black', + 'target-arrow-color': 'black', + 'source-arrow-color': 'black' + } + }]; + + var elements = { + nodes: [ + { data: { id: 'north', label: 'north', type: 'site', latitude: 50.734916, longitude: 7.137636 } }, + { data: { id: 'north-east', label: 'north-east', type: 'site', latitude: 50.733028, longitude: 7.151086 } }, + { data: { id: 'north-west', label: 'north-west', type: 'site', latitude: 50.730230, longitude: 7.126017 } }, + { data: { id: 'east', label: 'east', type: 'site', latitude: 50.725672, longitude: 7.158488 } }, + { data: { id: 'west', label: 'west', type: 'site', latitude: 50.721914, longitude: 7.120521 } }, + { data: { id: 'south-east', label: 'south-east', type: 'site', latitude: 50.717158, longitude: 7.155506 } }, + { data: { id: 'south-west', label: 'south-west', type: 'site', latitude: 50.714359, longitude: 7.130437 } }, + { data: { id: 'south', label: 'south', type: 'site', latitude: 50.712472, longitude: 7.143887 } }, + + { data: { id: 'ADVA-A', label : 'ADVA-A' , parent : 'west', type: 'ptp-clock', base64: 'AIDq//6MFzA=', hex: '0x47 0x4D 0x30 0x30 0x30 0x30 0x30 0x31', active: 'true' , latitude: 50.721914, longitude: 7.120521, parentDs: '', path: 'false' } }, + { data: { id: 'ADVA-B', label : 'ADVA-B' , parent : 'north-west', type: 'ptp-clock', base64: 'AIDq//6MGDA=', hex: '0x47 0x4D 0x30 0x30 0x30 0x30 0x30 0x32', active: 'true' , latitude: 50.730230, longitude: 7.126017, parentDs: '', path: 'false' } }, + { data: { id: 'ADVA-Y', label : 'ADVA-Y' , parent : 'north-east', type: 'ptp-clock', base64: 'AIDqb0hQAAE=', hex: '0x53 0x4C 0x41 0x56 0x45 0x30 0x30 0x31', active: 'true' , latitude: 50.733028, longitude: 7.151086, parentDs: 'NEC-Z#4', path: 'false' } }, + { data: { id: 'ADVA-Z', label : 'ADVA-Z' , parent : 'south', type: 'ptp-clock', base64: 'AIDqb0mAAAA=', hex: '0x53 0x4C 0x41 0x56 0x45 0x30 0x30 0x32', active: 'true' , latitude: 50.712472, longitude: 7.143887, parentDs: 'Huawei-Z#3', path: 'false' } }, + { data: { id: 'Ericsson-A', label : 'Ericsson-A' , parent : 'north-east', type: 'ptp-clock', base64: 'BE4G//4jsio=', hex: '0x42 0x43 0x30 0x30 0x30 0x30 0x30 0x31', active: 'true' , latitude: 50.733028, longitude: 7.151086, parentDs: 'NEC-Z#2', path: 'false' } }, + { data: { id: 'Ericsson-Z', label : 'Ericsson-Z' , parent : 'east', type: 'ptp-clock', base64: 'BE4G//4jtBA=', hex: '0x42 0x43 0x30 0x30 0x30 0x30 0x30 0x32', active: 'true' , latitude: 50.725672, longitude: 7.158488, parentDs: 'Ericsson-A#6', path: 'false' } }, + { data: { id: 'Huawei-A', label : 'Huawei-A' , parent : 'south-west', type: 'ptp-clock', base64: 'ACWeIQAJq6A=', hex: '0x42 0x43 0x30 0x30 0x30 0x30 0x30 0x33', active: 'true' , latitude: 50.714359, longitude: 7.130437, parentDs: 'Nokia-Z33', path: 'false' } }, + { data: { id: 'Huawei-Z', label : 'Huawei-Z' , parent : 'south', type: 'ptp-clock', base64: 'ACWeIQAJAm8=', hex: '0x42 0x43 0x30 0x30 0x30 0x30 0x30 0x34', active: 'true' , latitude: 50.712472, longitude: 7.143887, parentDs: 'Huawei-A#6', path: 'false' } }, + { data: { id: 'NEC-A', label : 'NEC-A' , parent : 'north', type: 'ptp-clock', base64: 'jN+d//5XDuA=', hex: '0x42 0x43 0x30 0x30 0x30 0x30 0x30 0x35', active: 'true' , latitude: 50.734916, longitude: 7.137636, parentDs: 'ZTE-Z#5', path: 'false' } }, + { data: { id: 'NEC-Z', label : 'NEC-Z' , parent : 'north-east', type: 'ptp-clock', base64: 'jN+d//5XDwA=', hex: '0x42 0x43 0x30 0x30 0x30 0x30 0x30 0x36', active: 'true' , latitude: 50.733028, longitude: 7.151086, parentDs: 'NEC-A#6', path: 'false' } }, + { data: { id: 'Nokia-A', label : 'Nokia-A' , parent : 'west', type: 'ptp-clock', base64: 'ACGu//4Crac=', hex: '0x42 0x43 0x30 0x30 0x30 0x30 0x30 0x37', active: 'true' , latitude: 50.721914, longitude: 7.120521, parentDs: 'ADVA-A#1', path: 'false' } }, + { data: { id: 'Nokia-Z', label : 'Nokia-Z' , parent : 'south-west', type: 'ptp-clock', base64: 'ACGu//4CrZY=', hex: '0x42 0x43 0x30 0x30 0x30 0x30 0x30 0x38', active: 'true' , latitude: 50.714359, longitude: 7.130437, parentDs: 'Nokia-A#6', path: 'false' } }, + { data: { id: 'SIAE-A', label : 'SIAE-A' , parent : 'south', type: 'ptp-clock', base64: 'ALCs//4R6K8=', hex: '0x42 0x43 0x30 0x30 0x30 0x30 0x30 0x39', active: 'true' , latitude: 50.712472, longitude: 7.143887, parentDs: 'Huawei-Z#5', path: 'false' } }, + { data: { id: 'SIAE-Z', label : 'SIAE-Z' , parent : 'south-east', type: 'ptp-clock', base64: 'ALCs//4RucQ=', hex: '0x42 0x43 0x30 0x30 0x30 0x30 0x31 0x30', active: 'true' , latitude: 50.717158, longitude: 7.155506, parentDs: 'SIAE-A#6', path: 'false' } }, + { data: { id: 'ZTE-A', label : 'ZTE-A' , parent : 'north-west', type: 'ptp-clock', base64: 'DBJi//7Zdpo=', hex: '0x42 0x43 0x30 0x30 0x30 0x30 0x31 0x31', active: 'true' , latitude: 50.730230, longitude: 7.126017, parentDs: 'ADVA-B#2', path: 'false' } }, + { data: { id: 'ZTE-Z', label : 'ZTE-Z' , parent : 'north', type: 'ptp-clock', base64: 'DBJi//7ZdqQ=', hex: '0x42 0x43 0x30 0x30 0x30 0x30 0x31 0x32', active: 'true' , latitude: 50.734916, longitude: 7.137636, parentDs: 'ZTE-A#6', path: 'false' } }, + + { data: { id: 'ADVA-A#1', label: '#1', parent: 'ADVA-A', type: 'port', layer: 'PTP', active: 'true', path: 'false', latitude: 50.721914, longitude: 7.120521 }, position: { x: 124, y: 564 } }, + { data: { id: 'ADVA-A#2', label: '#2', parent: 'ADVA-A', type: 'port', layer: 'PTP', active: 'true', path: 'false', latitude: 50.721914, longitude: 7.120521 }, position: { x: 124, y: 507 } }, + { data: { id: 'ADVA-B#1', label: '#1', parent: 'ADVA-B', type: 'port', layer: 'PTP', active: 'true', path: 'false', latitude: 50.730230, longitude: 7.126017 }, position: { x: 380, y: 381 } }, + { data: { id: 'ADVA-B#2', label: '#2', parent: 'ADVA-B', type: 'port', layer: 'PTP', active: 'true', path: 'false', latitude: 50.730230, longitude: 7.126017 }, position: { x: 380, y: 301 } }, + { data: { id: 'ADVA-Y#1', label: '#1', parent: 'ADVA-Y', type: 'port', layer: 'PTP', active: 'true', path: 'false', latitude: 50.733028, longitude: 7.151086 }, position: { x: 1392, y: 229 } }, + { data: { id: 'ADVA-Y#2', label: '#2', parent: 'ADVA-Y', type: 'port', layer: 'PTP', active: 'true', path: 'false', latitude: 50.733028, longitude: 7.151086 }, position: { x: 1449, y: 172 } }, + { data: { id: 'ADVA-Z#1', label: '#1', parent: 'ADVA-Z', type: 'port', layer: 'PTP', active: 'true', path: 'false', latitude: 50.712472, longitude: 7.143887 }, position: { x: 1139, y: 1001 } }, + { data: { id: 'ADVA-Z#2', label: '#2', parent: 'ADVA-Z', type: 'port', layer: 'PTP', active: 'true', path: 'false', latitude: 50.712472, longitude: 7.143887 }, position: { x: 1196, y: 944 } }, + { data: { id: 'Ericsson-A#5', label: '#5', parent: 'Ericsson-A', type: 'port', layer: 'PTP', active: 'true', path: 'false', latitude: 50.733028, longitude: 7.151086 }, position: { x: 1605, y: 172 } }, + { data: { id: 'Ericsson-A#6', label: '#6', parent: 'Ericsson-A', type: 'port', layer: 'PTP', active: 'true', path: 'false', latitude: 50.733028, longitude: 7.151086 }, position: { x: 1664, y: 226 } }, + { data: { id: 'Ericsson-Z#6', label: '#6', parent: 'Ericsson-Z', type: 'port', layer: 'PTP', active: 'true', path: 'false', latitude: 50.725672, longitude: 7.158488 }, position: { x: 1765, y: 325 } }, + { data: { id: 'Huawei-A#5', label: '#5', parent: 'Huawei-A', type: 'port', layer: 'PTP', active: 'true', path: 'false', latitude: 50.714359, longitude: 7.130437 }, position: { x: 605, y: 1028 } }, + { data: { id: 'Huawei-A#6', label: '#6', parent: 'Huawei-A', type: 'port', layer: 'PTP', active: 'true', path: 'false', latitude: 50.714359, longitude: 7.130437 }, position: { x: 685, y: 1028 } }, + { data: { id: 'Huawei-Z#3', label: '#3', parent: 'Huawei-Z', type: 'port', layer: 'PTP', active: 'true', path: 'false', latitude: 50.712472, longitude: 7.143887 }, position: { x: 1046, y: 1094 } }, + { data: { id: 'Huawei-Z#4', label: '#4', parent: 'Huawei-Z', type: 'port', layer: 'PTP', active: 'true', path: 'false', latitude: 50.712472, longitude: 7.143887 }, position: { x: 989, y: 1094 } }, + { data: { id: 'Huawei-Z#5', label: '#5', parent: 'Huawei-Z', type: 'port', layer: 'PTP', active: 'true', path: 'false', latitude: 50.712472, longitude: 7.143887 }, position: { x: 1058, y: 1123 } }, + { data: { id: 'Huawei-Z#6', label: '#6', parent: 'Huawei-Z', type: 'port', layer: 'PTP', active: 'true', path: 'false', latitude: 50.712472, longitude: 7.143887 }, position: { x: 978, y: 1123 } }, + { data: { id: 'NEC-A#3', label: '#3', parent: 'NEC-A', type: 'port', layer: 'PTP', active: 'true', path: 'false', latitude: 50.734916, longitude: 7.137636 }, position: { x: 955, y: -52 } }, + { data: { id: 'NEC-A#6', label: '#6', parent: 'NEC-A', type: 'port', layer: 'PTP', active: 'true', path: 'false', latitude: 50.734916, longitude: 7.137636 }, position: { x: 1035, y: -52 } }, + { data: { id: 'NEC-Z#2', label: '#2', parent: 'NEC-Z', type: 'port', layer: 'PTP', active: 'true', path: 'false', latitude: 50.733028, longitude: 7.151086 }, position: { x: 1449, y: -41 } }, + { data: { id: 'NEC-Z#3', label: '#3', parent: 'NEC-Z', type: 'port', layer: 'PTP', active: 'true', path: 'false', latitude: 50.733028, longitude: 7.151086 }, position: { x: 1392, y: 16 } }, + { data: { id: 'NEC-Z#4', label: '#4', parent: 'NEC-Z', type: 'port', layer: 'PTP', active: 'true', path: 'false', latitude: 50.733028, longitude: 7.151086 }, position: { x: 1449, y: 16 } }, + { data: { id: 'NEC-Z#6', label: '#6', parent: 'NEC-Z', type: 'port', layer: 'PTP', active: 'true', path: 'false', latitude: 50.733028, longitude: 7.151086 }, position: { x: 1382, y: -23 } }, + { data: { id: 'Nokia-A13', label: '13', parent: 'Nokia-A', type: 'port', layer: 'PTP', active: 'true', path: 'false', latitude: 50.721914, longitude: 7.120521 }, position: { x: 40, y: 801 } }, + { data: { id: 'Nokia-A34', label: '34', parent: 'Nokia-A', type: 'port', layer: 'PTP', active: 'true', path: 'false', latitude: 50.721914, longitude: 7.120521 }, position: { x: 28, y: 772 } }, + { data: { id: 'Nokia-A#6', label: '#6', parent: 'Nokia-A', type: 'port', layer: 'PTP', active: 'true', path: 'false', latitude: 50.721914, longitude: 7.120521 }, position: { x: 28, y: 829 } }, + { data: { id: 'Nokia-Z33', label: '33', parent: 'Nokia-Z', type: 'port', layer: 'PTP', active: 'true', path: 'false', latitude: 50.714359, longitude: 7.130437 }, position: { x: 385, y: 1028 } }, + { data: { id: 'Nokia-Z#6', label: '#6', parent: 'Nokia-Z', type: 'port', layer: 'PTP', active: 'true', path: 'false', latitude: 50.714359, longitude: 7.130437 }, position: { x: 305, y: 1028 } }, + { data: { id: 'SIAE-A#5', label: '#5', parent: 'SIAE-A', type: 'port', layer: 'PTP', active: 'true', path: 'false', latitude: 50.712472, longitude: 7.143887 }, position: { x: 1278, y: 1123 } }, + { data: { id: 'SIAE-A#6', label: '#6', parent: 'SIAE-A', type: 'port', layer: 'PTP', active: 'true', path: 'false', latitude: 50.712472, longitude: 7.143887 }, position: { x: 1346, y: 1094 } }, + { data: { id: 'SIAE-Z#6', label: '#6', parent: 'SIAE-Z', type: 'port', layer: 'PTP', active: 'true', path: 'false', latitude: 50.717158, longitude: 7.155506 }, position: { x: 1588, y: 838 } }, + { data: { id: 'ZTE-A#3', label: '#3', parent: 'ZTE-A', type: 'port', layer: 'PTP', active: 'true', path: 'false', latitude: 50.730230, longitude: 7.126017 }, position: { x: 380, y: 168 } }, + { data: { id: 'ZTE-A#4', label: '#4', parent: 'ZTE-A', type: 'port', layer: 'PTP', active: 'true', path: 'false', latitude: 50.730230, longitude: 7.126017 }, position: { x: 345, y: 148 } }, + { data: { id: 'ZTE-A#6', label: '#6', parent: 'ZTE-A', type: 'port', layer: 'PTP', active: 'true', path: 'false', latitude: 50.730230, longitude: 7.126017 }, position: { x: 408, y: 99 } }, + { data: { id: 'ZTE-Z#5', label: '#5', parent: 'ZTE-Z', type: 'port', layer: 'PTP', active: 'true', path: 'false', latitude: 50.734916, longitude: 7.137636 }, position: { x: 747, y: -27 } }, + { data: { id: 'ZTE-Z#6', label: '#6', parent: 'ZTE-Z', type: 'port', layer: 'PTP', active: 'true', path: 'false', latitude: 50.734916, longitude: 7.137636 }, position: { x: 667, y: -27 } }, + + ], + edges: [ + { data: { id: 'ERI1', source: 'Ericsson-A#6', target: 'Ericsson-Z#6', label: 'ERI1', layer: 'PTP', active: 'true' } }, + { data: { id: '71', source: 'Huawei-A#6', target: 'Huawei-Z#6', label: '71', layer: 'PTP', active: 'true' } }, + { data: { id: '81', source: 'NEC-A#6', target: 'NEC-Z#6', label: '81', layer: 'PTP', active: 'true' } }, + { data: { id: '91', source: 'Nokia-A#6', target: 'Nokia-Z#6', label: '91', layer: 'PTP', active: 'true' } }, + { data: { id: '101', source: 'SIAE-A#6', target: 'SIAE-Z#6', label: '101', layer: 'PTP', active: 'true' } }, + { data: { id: '111', source: 'ZTE-A#6', target: 'ZTE-Z#6', label: '111', layer: 'PTP', active: 'true' } }, + + { data: { id: 'ETY01', source: 'ADVA-A#1', target: 'Nokia-A34', label: 'ADVA-A#1-Nokia-A34', layer: 'PTP', active: 'true' } }, + { data: { id: 'ETY02', source: 'ADVA-A#2', target: 'ZTE-A#4', label: 'ADVA-A#2-ZTE-A#4', layer: 'PTP', active: 'false' } }, + { data: { id: 'ETY03', source: 'ADVA-B#1', target: 'Nokia-A13', label: 'ADVA-B#1-Nokia-A13', layer: 'PTP', active: 'true' } }, + { data: { id: 'ETY04', source: 'ADVA-B#2', target: 'ZTE-A#3', label: 'ADVA-B#2-ZTE-A#3', layer: 'PTP', active: 'true' } }, + { data: { id: 'ETY05', source: 'ADVA-Y#1', target: 'Huawei-Z#4', label: 'ADVA-Y#1-Huawei-Z#4', layer: 'PTP', active: 'true' } }, + { data: { id: 'ETY06', source: 'ADVA-Y#2', target: 'NEC-Z#4', label: 'ADVA-Y#2-NEC-Z#4', layer: 'PTP', active: 'true' } }, + { data: { id: 'ETY09', source: 'ADVA-Z#1', target: 'Huawei-Z#3', label: 'ADVA-Z#1-Huawei-Z#3', layer: 'PTP', active: 'true' } }, + { data: { id: 'ETY10', source: 'ADVA-Z#2', target: 'NEC-Z#3', label: 'ADVA-Z#2-NEC-Z#3', layer: 'PTP', active: 'true' } }, + { data: { id: 'ETY21', source: 'Ericsson-A#5', target: 'NEC-Z#2', label: 'Ericsson-A#5-NEC-Z#2', layer: 'PTP', active: 'true' } }, + { data: { id: 'ETY24', source: 'Huawei-A#5', target: 'Nokia-Z33', label: 'Huawei-A#5-Nokia-Z33', layer: 'PTP', active: 'true' } }, + { data: { id: 'ETY25', source: 'Huawei-Z#5', target: 'SIAE-A#5', label: 'Huawei-Z#5-SIAE-A#5', layer: 'PTP', active: 'true' } }, + { data: { id: 'ETY26', source: 'NEC-A#3', target: 'ZTE-Z#5', label: 'NEC-A#3-ZTE-Z#5', layer: 'PTP', active: 'true' } }, + + ] + }; + + var events = eventsFabric(); + + var result = { + colors: colors, + elements: elements, + styles: styles, + events: events + }; + + var someMethodChangingTheElements = function () { + // @Martin: hier kannst Du die Elements ändern, anschließend mußt Du das Ereignis veröffentlichen + // das Ereigniss wird in der Directive aufgefangen und die Grig wird neu gezeichnet + + // Hinweis: Die Reihenfolge muss so bleiben und du kannst NUR result.elements ändern. + + events.publish("elementsChanged", { + elements: result.elements + }); + }; + + return result; + }); + + mwtnTopologyApp.directive("mwtnTopologyIeee1588PathGraph", ["mwtnTopologyIeee1588PathData", "$mwtnPtp", function (mwtnTopologyIeee1588PathData, $mwtnPtp) { + + return { + restrict: 'E', + replace: true, + template: '<div style="height: 750px; width: 100%;"></div>', + controller: function () { + + }, + scope: { + + }, + link: function (scope, element, attrs, ctrl) { + + var cy = cytoscape({ + container: element[0], + + boxSelectionEnabled: false, + autounselectify: true, + + style: mwtnTopologyIeee1588PathData.styles, + elements: mwtnTopologyIeee1588PathData.elements, + layout: { + name: 'preset', + padding: 5 + } + }); + + // @ Martin: Hier wird das Ereignis aus dem Service aboniert. + // Es ist möglich mehrere Ereignisse zu definieren. + mwtnTopologyIeee1588PathData.events.subscribe("elementsChanged", function (data) { + + // @Martin: cy aktualisiert sich mit Hilfe der Referenz auf die Elemente aus dem Service + cy.json({ + elements: mwtnTopologyIeee1588PathData.elements // oder data.elements + }); + }); + + // pathGraphData.events.subscribe("styleChanged", function () { + // cy.json({ + // style: mwtnTopologyIeee1588PathData.styles + // }); + // }); + + cy.viewport({ + zoom: 0.5, + pan: { x: 150, y: 100 } + }); + + var clearPtpPath = function () { + var selector = "[path = 'true']"; + cy.elements(selector).map(function (element) { + element.data('path', 'false'); + }); + }; + + var highlightPtpMaster = function (id) { + var selector = "[id = '" + id + "']"; + cy.nodes(selector).map(function (node) { + if (node.data('parentDs') && node.data('parentDs') != '') { + // console.warn('parentDs', node.data('parentDs')); + var parentNode = node.data('parentDs').slice(0, -2); + if (parentNode !== id) { + highlightPtpMaster(parentNode); + + // highlight edge + selector = "[id = '" + node.data('parentDs') + "']"; + cy.nodes(selector).connectedEdges().map(function (edge) { + edge.data('path', 'true'); + edge.connectedNodes().map(function (node) { + node.data('path', 'true'); + }); + }); + } + } + }); + }; + + var setAllDevicesInactive = function () { + cy.nodes().map(function (node) { + node.data('active', 'false'); + }); + }; + + var setPortAndEdgedActive = function () { + cy.edges().map(function (edge) { + var active = 'true'; + edge.connectedNodes().map(function (port) { + // console.log(' node', JSON.stringify(edge.data())); + var parent = cy.getElementById(port.data('parent')); + if (parent.data('active') === 'false') { + port.data('active', 'false'); + edge.data('active', 'false'); + } else { + port.data('active', 'true'); + } + }); + }); + }; + + var init = function () { + setAllDevicesInactive(); + $mwtnPtp.getPtpClocks().then(function (clocks) { + // setDevicesActive(Object.keys(clocks)); + var hex = true; + // update clock ids first + Object.keys(clocks).map(function (key) { + var clock = clocks[key]; + var graphClock = cy.getElementById(key); + graphClock.data('active', 'true') + graphClock.data('base64', clock.getIdentity()); + graphClock.data('hex', clock.getIdentity(hex)); + }); + // update rest + Object.keys(clocks).map(function (key) { + var clock = clocks[key]; + var graphClock = cy.getElementById(key); + var graphParentDs = nodeId(clock.getParent().slice(0, -2)); + graphClock.data('parentDs', graphParentDs + clock.getParent().slice(-2)); + graphClock.data('grandMaster', nodeId(clock.getGrandMaster())); + + // clock.getPtpPorts().map(function(port){ + // // console.warn(port.getId(), port.getNumber(), port.getState(), port.isSlave(), port.isMaster(), port.getLogicalTerminationPointReference()); + // var portKey = [key, port.getNumber() < 10 ? '#' : '', port.getNumber()].join(''); + // var graphPort = cy.getElementById(portKey); + // // console.warn(JSON.stringify(graphPort.data())); + // if (graphPort === undefined) { + // console.error('PtpPort not found in graph:' , portKey); + // } else { + // console.info('PtpPort found in graph:' , portKey); + // } + + // }); + }); + setPortAndEdgedActive(); + }, function (error) { + setPortAndEdgedActive(); + console.error(JSON.stringify(error)); + }); + }; + // init(); + + var getNodeId = function (base64) { + if (base64 === undefined || base64 === '') return ''; + + var selector = "[type = 'ptp-clock']"; + var result = cy.nodes(selector).filter(function (graphClock) { + // console.error(base64, graphClock.data('base64'), graphClock.data('base64') === base64); + return graphClock.data('base64') === base64; + }); + if (result.length === 0) { + console.warn('Clock', base64, 'not found!'); + return ''; + } else { + return result[0].id(); + } + }; + + var getParentClock = function (nodeId) { + $mwtnPtp.getParent(nodeId).then(function (parentPortIdentity) { + var parentNode = getNodeId(parentPortIdentity['clock-identity']); + console.log(JSON.stringify(parentPortIdentity), parentNode); + if (parentNode) { + getParentClock(parentNode); + } + }); + }; + + cy.on('tap', function (event) { + console.log('tap'); + clearPtpPath(); + if (event.target !== cy) { + if (event.target.data('type') === 'ptp-clock') { + getParentClock(event.target.id()); + // highlightPtpMaster(event.target.id()); + } else if (event.target.data('type') === 'port') { + var parent = cy.getElementById(event.target.data('parent')); + // highlightPtpMaster(parent.id()); + getParentClock(event.target.id()); + } + } else { + // init(); + } + }); + + } + } + }]); + + mwtnTopologyApp.controller("mwtnTopologyClocksGridController", ['$scope', '$timeout', '$state', '$mwtnCommons', '$mwtnTopology', 'uiGridConstants', 'mwtnTopologyIeee1588PathData', function ($scope, $timeout, $state, $mwtnCommons, $mwtnTopology, uiGridConstants, mwtnTopologyIeee1588PathData) { + var vm = this; + + // The page number to show in the grid. + var paginationPage = 1; + // The page size. + var paginationPageSize = 100; + // The grid column object with current sorting informations. + var sortColumn = null; + // The grid column object with current sorting informations. + var gridFilters = []; + // caches all sites at the current grid page + + vm.gridOptions = Object.assign({}, $mwtnCommons.gridOptions, { + showGridFooter: false, // disable the grid footer because the pagination component sets its own. + paginationPageSizes: [10, 25, 50, 100], + paginationPageSize: paginationPageSize, + useExternalPagination: true, + useExternalFiltering: true, + useExternalSorting: true, + totalItems: 0, + columnDefs: [{ + field: "id", + type: "string", + displayName: "Node id", + width: 120 + }, + { + field: "hex", + type: "string", + displayName: "Clock identity in hex", + width: 300 + }, { + field: "base64", + type: "string", + displayName: "... in base64", + width: 150 + }, + { + field: "parentDs", + type: "string", + displayName: "parentDs", + width: 150 + }, + { + field: "grandMaster", + type: "string", + displayName: "grandmaster", + width: 300 + }, + { + field: "active", + type: "string", + displayName: "Active", + width: 80 + } + ], + data: [], + onRegisterApi: function (gridApi) { + // http://ui-grid.info/docs/#/api/ui.grid.core.api:PublicApi + vm.gridApi = gridApi; + + vm.gridApi.core.on.sortChanged($scope, function (grid, sortColumns) { + // Save the current sort column for later use. + sortColumn = (!sortColumns || sortColumns.length === 0) ? + null : + sortColumns[0]; + loadPage(); + }); + + vm.gridApi.pagination.on.paginationChanged($scope, function (newPage, newPageSize) { + // Save the pagination informations for later use. + paginationPage = newPage; + paginationPageSize = newPageSize; + loadPage(); + }); + + vm.gridApi.core.on.filterChanged($scope, function () { + // Save the all filters for later use. + var filters = []; + this.grid.columns.forEach(function (col, ind) { + if (col.filters[0] && col.filters[0].term) { + filters.push({ + field: col.field, + term: col.filters[0].term + }); + } + }); + gridFilters = filters; + loadPage(); + }); + + loadPage(); + } + }); + + /** + * Calculates the page content of the grid and sets the values to the gridOprions.data object. + */ + function loadPage() { + + // extract all ports + var ports = mwtnTopologyIeee1588PathData.elements.nodes.filter(function (node, ind, arr) { + return node && node.data && node.data.type === 'ptp-clock'; + }).reduce(function (acc, cur, ind, arr) { + if (cur.data) acc[cur.data.id] = cur.data; + return acc; + }, {}); + + // get all port ids + var portIds = Object.keys(ports); + + // apply the grid filters + var tempData = portIds.filter(function (portId, ind, arr) { + var port = ports[portId]; + return gridFilters.map(function (filter) { + switch (filter.field) { + case "active": + return port[filter.field].toString().contains(filter.term); + default: + return port[filter.field].contains(filter.term); + } + }).and(true); + }).map(function (portId) { + var port = ports[portId]; + var orderBy; + + if (!sortColumn || !sortColumn.sort.direction) { + return { + id: port.id + } + } + + switch (sortColumn.field) { + case "active": + orderBy = port[sortColumn.field] ? 1 : 0; + break; + default: + orderBy = port[sortColumn.field]; + break; + } + + return { + id: port.id, + orderBy: orderBy + }; + }); + + if (sortColumn && sortColumn.sort.direction) { + tempData.sort(function (left, right) { + if (left === right || left.orderBy === right.orderBy) { + return 0; + } + if (left.orderBy > right.orderBy) { + return (sortColumn.sort.direction === uiGridConstants.ASC) ? 1 : -1; + } + return (sortColumn.sort.direction === uiGridConstants.ASC) ? -1 : 1; + }); + } + + var maxPageNumber = Math.max(1, Math.ceil(tempData.length / paginationPageSize)); + var currentPage = Math.min(maxPageNumber, paginationPage); + var orderedPortsAtCurrentPage = tempData.slice((currentPage - 1) * paginationPageSize, currentPage * paginationPageSize); + + portsAtCurrentPageCache = {}; + var orderedData = []; + + orderedPortsAtCurrentPage.forEach(function (orderedPort) { + var port = ports[orderedPort.id]; // TODO [sko] varible port should be renamed to clock + portsAtCurrentPageCache[port.id] = port; + orderedData.push({ + id: orderedPort.id, + layer: port.layer, + active: port.active, + hex: port.hex, + base64: port.base64, + parentDs: port.parentDs, + grandMaster: port.grandMaster + }); + }); + + $timeout(function () { + vm.gridOptions.data = orderedData; + vm.gridOptions.totalItems = tempData.length; + }); + } + + // subscribe to the elementsChanged event to reload the grid page if the data in the service has chenged + mwtnTopologyIeee1588PathData.events.subscribe("elementsChanged", function (data) { + loadPage(); + }); + + }]); + + mwtnTopologyApp.directive("mwtnTopologyClocksGrid", [function () { + return { + restrict: 'E', + replace: false, + controller: 'mwtnTopologyClocksGridController', + controllerAs: 'vm', + scope: { + + }, + templateUrl: 'src/app/mwtnTopology/templates/clocksGrid.tpl.html' + }; + }]); + + mwtnTopologyApp.controller("mwtnTopologyPtpLinksGridController", ['$scope', '$timeout', '$state', '$mwtnCommons', '$mwtnTopology', 'uiGridConstants', 'mwtnTopologyIeee1588PathData', function ($scope, $timeout, $state, $mwtnCommons, $mwtnTopology, uiGridConstants, mwtnTopologyIeee1588PathData) { + var vm = this; + + // The page number to show in the grid. + var paginationPage = 1; + // The page size. + var paginationPageSize = 100; + // The grid column object with current sorting informations. + var sortColumn = null; + // The grid column object with current sorting informations. + var gridFilters = []; + // caches all sites at the current grid page + + vm.gridOptions = Object.assign({}, $mwtnCommons.gridOptions, { + showGridFooter: false, // disable the grid footer because the pagination component sets its own. + paginationPageSizes: [10, 25, 50, 100], + paginationPageSize: paginationPageSize, + useExternalPagination: true, + useExternalFiltering: true, + useExternalSorting: true, + totalItems: 0, + columnDefs: [{ + field: "id", + type: "string", + displayName: "Id" + }, + { + field: "source", + type: "string", + displayName: "PortA" + }, + { + field: "target", + type: "string", + displayName: "PortZ" + }, + { + field: "active", + type: "string", + displayName: "active" + } + ], + data: [], + onRegisterApi: function (gridApi) { + // http://ui-grid.info/docs/#/api/ui.grid.core.api:PublicApi + vm.gridApi = gridApi; + + vm.gridApi.core.on.sortChanged($scope, function (grid, sortColumns) { + // Save the current sort column for later use. + sortColumn = (!sortColumns || sortColumns.length === 0) ? + null : + sortColumns[0]; + loadPage(); + }); + + vm.gridApi.pagination.on.paginationChanged($scope, function (newPage, newPageSize) { + // Save the pagination informations for later use. + paginationPage = newPage; + paginationPageSize = newPageSize; + loadPage(); + }); + + vm.gridApi.core.on.filterChanged($scope, function () { + // Save the all filters for later use. + var filters = []; + this.grid.columns.forEach(function (col, ind) { + if (col.filters[0] && col.filters[0].term) { + filters.push({ + field: col.field, + term: col.filters[0].term + }); + } + }); + gridFilters = filters; + loadPage(); + }); + + loadPage(); + } + }); + + /** + * Calculates the page content of the grid and sets the values to the gridOprions.data object. + */ + function loadPage() { + + // extract all links + var links = mwtnTopologyIeee1588PathData.elements.edges.filter(function (node, ind, arr) { + return true; // node && node.data && node.data.type === 'port'; + }).reduce(function (acc, cur, ind, arr) { + if (cur.data) { + acc[cur.data.id] = cur.data; + } + return acc; + }, {}); + + // get all link ids + var linkIds = Object.keys(links); + + // apply the grid filters + var tempData = linkIds.filter(function (linkId, ind, arr) { + var link = links[linkId]; + return gridFilters.map(function (filter) { + switch (filter.field) { + default: + return link[filter.field].contains(filter.term); + } + }).and(true); + }).map(function (linkId) { + var link = links[linkId]; + var orderBy; + + if (!sortColumn || !sortColumn.sort.direction) { + return { + id: link.id + } + } + + switch (sortColumn.field) { + case "active": + orderBy = link[sortColumn.field] ? 1 : 0; + default: + orderBy = link[sortColumn.field]; + break; + } + + return { + id: link.id, + orderBy: orderBy + }; + }); + + if (sortColumn && sortColumn.sort.direction) { + tempData.sort(function (left, right) { + if (left === right || left.orderBy === right.orderBy) { + return 0; + } + if (left.orderBy > right.orderBy) { + return (sortColumn.sort.direction === uiGridConstants.ASC) ? 1 : -1; + } + return (sortColumn.sort.direction === uiGridConstants.ASC) ? -1 : 1; + }); + } + + var maxPageNumber = Math.max(1, Math.ceil(tempData.length / paginationPageSize)); + var currentPage = Math.min(maxPageNumber, paginationPage); + var orderedLinksAtCurrentPage = tempData.slice((currentPage - 1) * paginationPageSize, currentPage * paginationPageSize); + + linksAtCurrentPageCache = {}; + var orderedData = []; + + orderedLinksAtCurrentPage.forEach(function (orderedLink) { + var link = links[orderedLink.id]; + linksAtCurrentPageCache[link.id] = link; + orderedData.push({ + id: orderedLink.id, + source: link.source, + target: link.target, + active: link.active + }); + }); + + $timeout(function () { + vm.gridOptions.data = orderedData; + vm.gridOptions.totalItems = tempData.length; + }); + } + + // subscribe to the elementsChanged event to reload the grid page if the data in the service has chenged + var subscription = mwtnTopologyIeee1588PathData.events.subscribe("elementsChanged", function (data) { + loadPage(); + // to unsubscribe call subscription.remove(); + }); + + }]); + + mwtnTopologyApp.directive("mwtnTopologyPtpLinksGrid", [function () { + return { + restrict: 'E', + replace: false, + controller: 'mwtnTopologyPtpLinksGridController', + controllerAs: 'vm', + scope: { + + }, + templateUrl: 'src/app/mwtnTopology/templates/ptpLinksGrid.tpl.html' + }; + }]); + + mwtnTopologyApp.filter('coordinateFilter', coordinateFilter); + + function coordinateFilter($sce) { + + return function (coordinate, conversion, type, places) { + + // The filter will be running as we type values into the input boxes, which returns undefined + // and brings up an error in the console. Here wait until the coordinate is defined + if (coordinate != undefined) { + + // Check for user input that is a positive or negative number with the option + // that it is a float. Match only the numbers and not the white space or other characters + var pattern = /[-+]?[0-9]*\.?[0-9]+/g + var match = String(coordinate).match(pattern); + + if (conversion === "toDD" && match && coordinateIsValid(match, type)) { + // If the match array only has one item, the user has provided decimal degrees + // and we can just return what the user typed in + if (match.length === 1) { + return parseFloat(match); + } + + // If the match array has a length of three then we know degrees, minutes, and seconds + // were provided so we can convert it to decimal degrees + if (match.length === 3) { + return toDecimalDegrees(match); + } + } + + else if (conversion === 'toDMS' && match && coordinateIsValid(match, type)) { + // When converting from decimal degrees to degrees, minutes and seconds, if + // the match array has one item we know the user has input decimal degrees + // so we can convert it to degrees, minutes and seconds + if (match.length === 1) { + return toDegreesMinutesSeconds(match, type); + } + + // To properly format the converted coordinates we will need to add in HTML entities + // which means we'll need to bind the returned string as HTML and thus we need + // to use $sce (Strict Contextual Escaping) to say that we trust what is being bound as HTML + if (match.length === 3) { + return $sce.trustAsHtml(match[0] + '° ' + match[1] + '′ ' + match[2] + '″ '); + } + } + + // Output a notice that the coordinates are invalid if they are + else if (!coordinateIsValid(match, type)) { + return "Invalid Coordinate!"; + } + + function toDecimalDegrees(coord) { + // Setup for all parts of the DMS coordinate and the necessary math to convert + // from DMS to DD + var degrees = parseInt(coord[0]); + var minutes = parseInt(coord[1]) / 60; + var seconds = parseInt(coord[2]) / 3600; + + // When the degrees value is negative, the math is a bit different + // than when the value is positive. This checks whether the value is below zero + // and does subtraction instead of addition if it is. + if (degrees < 0) { + var calculated = degrees - minutes - seconds; + return calculated.toFixed(places || 4); + } + else { + var calculated = degrees + minutes + seconds + return calculated.toFixed(places || 4); + } + } + + // This function converts from DD to DMS. Math.abs is used a lot because + // for the minutes and seconds, negative values aren't valid + function toDegreesMinutesSeconds(decimal_degrees, type) { + + var dd = decimal_degrees[0]; + var direction = 'E'; + + if (type === 'lat') { + if (dd < 0) { + direction = 'S'; + } else { + direction = 'N' + } + } else { + if (dd < 0) { + direction = 'W'; + } else { + direction = 'E' + } + } + + dd = Math.abs(dd); + var degrees = Math.floor(dd); + var frac = dd - degrees; // get fractional part + var min = Math.floor(frac * 60); + var sec = frac * 3600 - min * 60; + + var formated = [degrees, '° ', ("0" + min).slice(-2), '\' ', ("0" + sec.toFixed(4)).slice(-7), '\" ', direction]; + return formated.join(''); + + // var degrees = coordinate[0].split('.')[0]; + // var minutes = Math.abs(Math.floor(60 * (Math.abs(coordinate[0]) - Math.abs(degrees)))); + // var seconds = 3600 * (Math.abs(coordinate[0]) - Math.abs(degrees) - Math.abs(minutes) / 60).toFixed(2); + + // return $sce.trustAsHtml(degrees + '° ' + minutes + '\' ' + seconds + '\" '); + + } + + // This function checks whether the coordinate value the user enters is valid or not. + // If the coordinate doesn't pass one of these rules, the function will return false + // which will then alert the user that the coordinate is invalid. + function coordinateIsValid(coordinate, type) { + if (coordinate) { + + // The degree values of latitude coordinates have a range between -90 and 90 + if (coordinate[0] && type === 'lat') { + if (!(-90 <= +(coordinate[0]) <= 90)) return false; + } + // The degree values longitude coordinates have a range between -180 and 180 + else if (coordinate[0] && type === 'lon') { + if (!(-180 <= +(coordinate[0]) <= 180)) return false; + } + // Minutes and seconds can only be between 0 and 60 + if (coordinate[1]) { + if (!(0 <= +(coordinate[1]) <= 60)) return false; + } + if (coordinate[2]) { + if (!(0 <= +(coordinate[2]) <= 60)) return false; + } + } + + // If the coordinate made it through all the rules above, the function + // returns true because the coordinate is good + return true; + } + } + } + } +});
\ No newline at end of file diff --git a/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/mwtnTopology.module.js b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/mwtnTopology.module.js new file mode 100755 index 00000000..db795d22 --- /dev/null +++ b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/mwtnTopology.module.js @@ -0,0 +1,57 @@ +/* + * Copyright (c) 2016 highstreet technologies GmbH and others. All rights reserved. + * + * 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(['angularAMD', + 'app/routingConfig', + 'app/core/core.services', + 'common/config/env.module', + 'app/mwtnCommons/mwtnCommons.module'], function(ng) { + + var mwtnTopologyApp = angular.module('app.mwtnTopology', ['app.core', 'ui.router.state', 'ui.grid', 'ui.grid.pagination', 'ui.grid.selection', 'ui.bootstrap', 'config', 'app.mwtnCommons']); + + mwtnTopologyApp.config(function ($stateProvider, $compileProvider, $controllerProvider, $provide, NavHelperProvider, $translateProvider) { + // // AF/MF: Warum? (Remove as soon as possible) + // mwtnTopologyApp.register = { + // controller: $controllerProvider.register, + // directive: $compileProvider.directive, + // factory: $provide.factory, + // service: $provide.service + // }; + + NavHelperProvider.addControllerUrl('app/mwtnTopology/mwtnTopology.controller'); + NavHelperProvider.addToMenu('mwtnTopology', { + "link": "#/pnfTopology/site", + "active": "main.mwtnTopology", + "title": "pnf Topology", + "icon": "fa fa-connectdevelop", // Add navigation icon css class here + "page": { + "title": "pnf Topology", + "description": "mwtnTopology" + } + }); + + var access = routingConfig.accessLevels; + + $stateProvider.state('main.mwtnTopology', { + url: 'pnfTopology/:tab?&top&bottom&right&left&lat&lng&zoom&site&siteLink&sitePath', + reloadOnSearch: false, + access: access.admin, + params: { + internal: false + }, + views: { + content: { + template: '<mwtn-topology-frame />' + } + } + }); + + }); + + return mwtnTopologyApp; +});
\ No newline at end of file diff --git a/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/mwtnTopology.rest b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/mwtnTopology.rest new file mode 100755 index 00000000..323b13ad --- /dev/null +++ b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/mwtnTopology.rest @@ -0,0 +1,209 @@ +###
+# get outer bounding box for all sites.
+POST http://03-wtp-poc:9200/mwtn/site/_search HTTP/1.1
+content-type: application/json
+
+{
+ "aggregations": {
+ "top": {
+ "max": {
+ "field": "location.lat"
+ }
+ },
+ "right": {
+ "max": {
+ "field": "location.lon"
+ }
+ },
+ "bottom": {
+ "min": {
+ "field": "location.lat"
+ }
+ },
+ "left": {
+ "min": {
+ "field": "location.lon"
+ }
+ }
+ },
+ "size": 0
+}
+
+###
+# get sites in bounding box
+POST http://03-wtp-poc:9200/mwtn/site/_search HTTP/1.1
+content-type: application/json
+
+{
+ "query": {
+ "geo_bounding_box": {
+ "location": {
+ "top": -10.681254175812176,
+ "right": -48.3738302863769,
+ "bottom": -10.736012963621369,
+ "left": -48.433356043212834
+ }
+ }
+ },
+ "size": 100
+}
+
+###
+# get single site by id
+POST http://03-wtp-poc:9200/mwtn/site/_search HTTP/1.1
+content-type: application/json
+
+{
+ "query": {
+ "bool": {
+ "must": [
+ {
+ "term": {
+ "id": "vivsp"
+ }
+ }
+ ]
+ }
+ }
+}
+
+###
+# get sites with site links
+POST http://03-wtp-poc:9200/mwtn/site/_search HTTP/1.1
+content-type: application/json
+
+{
+ "query": {
+ "bool": {
+ "must": {
+ "exists": {
+ "field": "references.site-links"
+ }
+ }
+ }
+ },
+ "size": 100
+}
+
+###
+# get the first 3 site links
+POST http://03-wtp-poc:9200/mwtn/site-link/_search HTTP/1.1
+content-type: application/json
+
+{
+ "query": {
+ "match_all": {}
+ },
+ "size": 3
+}
+
+###
+# get site links where siteA or siteZ refers to a list ob site ids.
+POST http://03-wtp-poc:9200/mwtn/site-link/_search HTTP/1.1
+content-type: application/json
+
+{
+ "query": {
+ "bool": {
+ "filter": {
+ "term": {
+ "siteA": "atdrj"
+ }
+ }
+ }
+ }
+}
+
+###
+# get site links where siteLinkId is one of the ids in given List.
+POST http://03-wtp-poc:9200/mwtn/site-link/_search
+content-type: application/json
+
+{
+ "query": {
+ "bool": {
+ "should": [
+ {"term": {"id" : "aaapb:aacal"}},
+ {"term": {"id" : "site-6:site-7"}},
+ {"term": {"id" : "site-7:site-8"}}
+ ]
+ }
+ }
+}
+
+###
+# get the first 3 site links
+POST http://03-wtp-poc:9200/mwtn/site/_search HTTP/1.1
+content-type: application/json
+
+{
+ "query": {
+ "match_all": {}
+ },
+ "sort" : {
+ "name": {
+ "order": "asc"
+ }
+ },
+ "size": 30
+}
+
+###
+# get the first 3 site links
+POST http://03-wtp-poc:9200/mwtn/site/_search HTTP/1.1
+content-type: application/json
+
+{
+ "query": {
+ "match_all": {}
+ },
+ "sort" : {
+ "_script" : {
+ "script" : {
+ "lang": "expression",
+ "inline" : "doc['references'].value['site-links'].length"
+ } ,
+ "type" : "number",
+ "order" : "desc"
+ }
+ },
+ "size": 30
+}
+
+
+###
+# get the first 3 site links
+POST http://03-wtp-poc:9200/mwtn/site/_search HTTP/1.1
+content-type: application/json
+
+{
+ "from":0,
+ "size":10,
+ "sort": {
+ "id":{
+ "order":"asc"
+ }
+ },
+ "query":{
+ "regexp":{
+ "name":".*00.*"
+ }
+ }
+}
+
+
+###
+# get the first 3 site links
+GET http://03-wtp-poc:9200/mwtn/site/_search HTTP/1.1
+content-type: application/json
+
+{
+ "query": {
+ "function_score": {
+ "script_score": {
+ "script": "Math.pow(2, 2)",
+ "lang": "groovy"
+ }
+ }
+ }
+}
\ No newline at end of file diff --git a/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/mwtnTopology.services.js b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/mwtnTopology.services.js new file mode 100755 index 00000000..195c08f0 --- /dev/null +++ b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/mwtnTopology.services.js @@ -0,0 +1,1020 @@ +/* + * Copyright (c) 2016 highstreet technologies GmbH and others. All rights reserved. + * + * 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 + */ + +/** Type Definitions + * @typedef {{id: string, siteLink: string, radio: string, polarization: string }} AirInterfaceLink + * @typedef {{id: string, siteA: string, siteZ: string, siteNameA: string, siteNameZ: string, airInterfaceLinks: AirInterfaceLink[] }} DbLink + * @typedef {{data: {hits: {hits: {_id: string, _index: string, _score: number, _source: DbLink, _type: string}[], max_score: number, total: number}}, status: number}} DbLinkResult */ + +define(['app/mwtnTopology/mwtnTopology.module'], function (mwtnTopologyApp) { +// module.exports = function () { +// const mwtnTopologyApp = require('app/mwtnTopology/mwtnTopology.module'); +// const mwtnTopologyCommons = require('app/mwtnCommons/mwtnCommons.service'); + + mwtnTopologyApp.factory('$mwtnTopology', function ($q, $mwtnCommons, $mwtnDatabase, $mwtnLog) { + var service = {}; + + // AF/MF: Obsolete - will removed soon. All data access function + service.getRequiredNetworkElements = $mwtnCommons.getRequiredNetworkElements; + service.gridOptions = $mwtnCommons.gridOptions; + service.highlightFilteredHeader = $mwtnCommons.highlightFilteredHeader; + service.getAllData = $mwtnDatabase.getAllData; + + + /** + * Since not all browsers implement this we have our own utility that will + * convert from degrees into radians + * + * @param deg - The degrees to be converted into radians + * @return radians + */ + var _toRad = function (deg) { + return deg * Math.PI / 180; + }; + + /** + * Since not all browsers implement this we have our own utility that will + * convert from radians into degrees + * + * @param rad - The radians to be converted into degrees + * @return degrees + */ + var _toDeg = function (rad) { + return rad * 180 / Math.PI; + }; + + // public functions + /** + * Calculate the bearing between two positions as a value from 0-360 + * + * @param lat1 - The latitude of the first position + * @param lng1 - The longitude of the first position + * @param lat2 - The latitude of the second position + * @param lng2 - The longitude of the second position + * + * @return int - The bearing between 0 and 360 + */ + service.bearing = function (lat1, lng1, lat2, lng2) { + var dLon = (lng2 - lng1); + var y = Math.sin(dLon) * Math.cos(lat2); + var x = Math.cos(lat1) * Math.sin(lat2) - Math.sin(lat1) * Math.cos(lat2) * Math.cos(dLon); + var brng = _toDeg(Math.atan2(y, x)); + return 360 - ((brng + 360) % 360); + }, + + + /** + * Gets the geospatial distance between two points + * @param lat1 {number} The latitude of the first point. + * @param lon1 {number} The longitude of the first point. + * @param lat2 {number} The latitude of the second point. + * @param lon2 {number} The longitude of the second point. + * @returns {number} The distance between the two given points. + */ + service.getDistance = function (lat1, lon1, lat2, lon2) { + var R = 6371; // km + var φ1 = _toRad(lat1); + var φ2 = _toRad(lat2); + var Δφ = _toRad(lat2 - lat1); + var Δλ = _toRad(lon2 - lon1); + + var a = Math.sin(Δφ / 2) * Math.sin(Δφ / 2) + + Math.cos(φ1) * Math.cos(φ2) * + Math.sin(Δλ / 2) * Math.sin(Δλ / 2); + var c = 2 * Math.atan2(Math.sqrt(a), Math.sqrt(1 - a)); + + return (R * c).toFixed(3); + }; + + /** + * Gets a promise which is resolved if the database has been calculated the bounds containing all sites. + * @returns {promise} The promise which is resolved if the database has completed its calculation. + */ + service.getOuterBoundingRectangleForSites = function () { + var getOuterBoundingRectangleForSitesDefer = $q.defer(); + var aggregation = { + "aggregations": { + "top": { + "max": { + "field": "location.lat" + } + }, + "right": { + "max": { + "field": "location.lon" + } + }, + "bottom": { + "min": { + "field": "location.lat" + } + }, + "left": { + "min": { + "field": "location.lon" + } + } + }, + "size": 0 + }; + + $mwtnDatabase.getAggregatedData('mwtn', 'site', aggregation).then(function (result) { + getOuterBoundingRectangleForSitesDefer.resolve({ + top: result.data.aggregations.top.value, + right: result.data.aggregations.right.value, + bottom: result.data.aggregations.bottom.value, + left: result.data.aggregations.left.value + }); + }, function (error) { + getOuterBoundingRectangleForSitesDefer.reject(error); + }); + + return getOuterBoundingRectangleForSitesDefer.promise; + }; + + /** + * Gets a promise which resolved with an array of sites within the given bounding box. + * @param boundingBox {{top: number, right: number, bottom: number, left: number}} The bounding box to get all sites for. + * @param chunkSize {number} The maximum count of sites who should return. + * @param chunkSiteStartIndex {number} The index of the first site element to get. + */ + service.getSitesInBoundingBox = function (boundingBox, chunkSize, chunkSiteStartIndex) { + var resultDefer = $q.defer(); + + var filter = { + "geo_bounding_box": { + "location": { + "top": boundingBox.top, + "right": boundingBox.right, + "bottom": boundingBox.bottom, + "left": boundingBox.left + } + } + }; + + $mwtnDatabase.getFilteredData("mwtn", "site", chunkSiteStartIndex, chunkSize, filter) + .then(processResult, resultDefer.reject); + + return resultDefer.promise; + + /** + * Callback for the database request. + * @param result {{data: {hits: {hits: {_id: string, _index: string, _score: number, _source: {id: string, name: string, location: {lat: number, lon: number}, "amsl-ground": number, references: {"network-elements": string[], "site-links": string[]}}, _type: string}[], max_score: number, total: number}}, status: number}} The database result. + */ + function processResult(result) { + var hits = result && result.data && result.data.hits; + if (!hits) { + resultDefer.reject("Invalid result."); + return; + } + + var total = hits.total; + var sites = []; + + for (var hitIndex = 0; hitIndex < hits.hits.length; ++hitIndex) { + var site = hits.hits[hitIndex]; + sites.push({ + id: site._source.id, + name: site._source.name, + type: site._source.type, + location: { + lat: site._source.location.lat, + lng: site._source.location.lon + }, + amslGround: site._source["amsl-ground"], + references: { + siteLinks: site._source.references["site-links"] + } + }); + } + + resultDefer.resolve({ + chunkSize: chunkSize, + chunkSiteStartIndex: chunkSiteStartIndex, + total: total, + sites: sites + }) + } + }; + + /** + * Gets a promise which is resolved with an array of sites filtered by given site ids. + * This function does not use chunks! + * @param siteIds {string[]} The ids of the sites to return. + */ + service.getSitesByIds = function (siteIds) { + var resultDefer = $q.defer(); + + if (!siteIds || siteIds.length === 0) { + resultDefer.resolve([]); + return resultDefer.promise; + } + + var query = { + bool: { + should: siteIds.map(function (siteId) { + return { term: { id: siteId } }; + }) + } + }; + + $mwtnDatabase.getFilteredData("mwtn", "site", 0, siteIds.length, query) + .then(processResult, resultDefer.reject); + + return resultDefer.promise; + + /** + * Callback for the database request. + * @param result {{data: {hits: {hits: {_id: string, _index: string, _score: number, _source: {id: string, name: string, location: {lat: number, lon: number}, "amsl-ground": number, references: {"network-elements": string[], "site-links": string[]}}, _type: string}[], max_score: number, total: number}}, status: number}} The database result. + */ + function processResult(result) { + var hits = result && result.data && result.data.hits; + if (!hits) { + resultDefer.reject("Invalid result."); + return; + } + + var total = hits.total; + var sites = []; + + for (var hitIndex = 0; hitIndex < hits.hits.length; ++hitIndex) { + var site = hits.hits[hitIndex]; + sites.push({ + id: site._source.id, + name: site._source.name, + type: site._source.type, + location: { + lat: site._source.location.lat, + lng: site._source.location.lon + }, + amslGround: site._source["amsl-ground"], + references: { + siteLinks: site._source.references["site-links"] + } + }); + } + + resultDefer.resolve({ + total: total, + sites: sites + }) + } + }; + + /** + * Gets a promise which is resolved with an array of sites using the given filter expression. + */ + service.getSites = function (sortColumn, sortDirection, filters, chunkSize, chunkSiteStartIndex) { + var resultDefer = $q.defer(); + + // determine the sort parameter + var sort = null; + if (sortColumn != null && sortDirection != null) { + sort = {}; + switch (sortColumn) { + case 'countNetworkElements': + case 'countLinks': + sort = null; + break; + case 'amslGround': + sort['amsl-ground'] = { + order: sortDirection === 'desc' ? 'desc' : 'asc' + } + break; + default: + sort[sortColumn] = { + order: sortDirection === 'desc' ? 'desc' : 'asc' + } + break; + } + } + + // determine the query parameter + var query = {}; + if (filters == null || filters.length == 0) { + query["match_all"] = {}; + } else { + var regexp = {}; + filters.forEach(function (filter) { + if (filter && filter.field) { + regexp[filter.field] = '.*'+ filter.term + '.*'; + } + }); + query["regexp"] = regexp; + } + + + if (sort) { + $mwtnDatabase.getFilteredSortedData("mwtn", "site", chunkSiteStartIndex, chunkSize, sort, query).then(processResult, resultDefer.reject); + } else { + $mwtnDatabase.getFilteredData("mwtn", "site", chunkSiteStartIndex, chunkSize, query).then(processResult, resultDefer.reject); + } + + return resultDefer.promise; + + /** + * Callback for the database request. + * @param result {{data: {hits: {hits: {_id: string, _index: string, _score: number, _source: {id: string, name: string, location: {lat: number, lon: number}, "amsl-ground": number, references: {"network-elements": string[], "site-links": string[]}}, _type: string}[], max_score: number, total: number}}, status: number}} The database result. + */ + function processResult(result) { + var hits = result && result.data && result.data.hits; + if (!hits) { + resultDefer.reject("Invalid result."); + return; + } + + var total = hits.total; + var sites = []; + + for (var hitIndex = 0; hitIndex < hits.hits.length; ++hitIndex) { + var site = hits.hits[hitIndex]; + sites.push({ + id: site._source.id, + name: site._source.name, + type: site._source.type, + location: { + lat: site._source.location.lat, + lng: site._source.location.lon + }, + amslGround: site._source["amsl-ground"], + references: { + siteLinks: site._source.references["site-links"] + } + }); + } + + resultDefer.resolve({ + total: total, + sites: sites + }) + } + }; + + /** + * Gets a promise which resolved with an array of site links referenced by given sites. + * @param sites {({id: string, name: string, location: {lat: number, lng: number}, amslGround: number, references: {siteLinks: string[]})[]} + * @param chunkSize {number} The maximum count of site links who should return. + * @param chunkSiteLinkStartIndex {number} The index of the first site link element to get. + */ + service.getSiteLinksForSites = function (sites, chunkSize, chunkSiteLinkStartIndex) { + var resultDefer = $q.defer(); + + if (!sites || sites.length === 0) { + resultDefer.resolve([]); + return resultDefer.promise; + } + + var siteLinkIds = Object.keys(sites.reduce(function (accumulator, currentSite) { + // Add all site link ids referenced by the current site to the accumulator object. + currentSite.references.siteLinks.forEach(function (siteLinkId) { + // The value "true"" isnt important, i only use the key (siteLinkId) later. + // But this way i dont have to check, if the key is already known. + accumulator[siteLinkId] = true; + }); + return accumulator; + }, {})).map(function (siteLinkId) { + return { term: { id: siteLinkId } }; + }); + + var query = { + bool: { should: siteLinkIds } + }; + + $mwtnDatabase.getFilteredData("mwtn", "site-link", chunkSiteLinkStartIndex, chunkSize, query).then( + /** + * Callback for the database request. + * @param result {{data: {hits: {hits: {_id: string, _index: string, _score: number, _source: {id: string, siteA: string, siteZ: string, siteNameA: string, siteNameZ: string, airInterfaceLinks: {id: string, siteLink: string, radio: string, polarization: string }[] }, _type: string}[], max_score: number, total: number}}, status: number}} The database result. + */ + function (result) { + var hits = result && result.data && result.data.hits; + if (!hits) { + resultDefer.reject("Invalid result."); + return; + } + + if (hits.total === 0) { + resultDefer.resolve([]); + return; + } + + // get additional sites that wont be given in the sites array but are referenced by the site links. + // get all sites, referenced by the site links. + var allReferencedSiteIds = hits.hits.reduce(function (accumulator, currentSiteLink) { + accumulator[currentSiteLink._source.siteA] = true; + accumulator[currentSiteLink._source.siteZ] = true; + return accumulator; + }, {}); + // remove all known sites + sites.forEach(function (site) { + if (allReferencedSiteIds.hasOwnProperty(site.id)) { + delete allReferencedSiteIds[site.id]; + } + }); + + var additionalReferencedSiteIds = Object.keys(allReferencedSiteIds).map(function (referencedSiteId) { + return { term: { id: referencedSiteId } }; + }); + + if (additionalReferencedSiteIds.length > 0) { + query = { + bool: { should: additionalReferencedSiteIds } + }; + + $mwtnDatabase.getFilteredData("mwtn", "site", 0, 400, query).then( + /** + * Callback for the database request. + * @param result {{data: {hits: {hits: {_id: string, _index: string, _score: number, _source: {id: string, name: string, location: {lat: number, lon: number}, "amsl-ground": number, references: {"network-elements": string[], "site-links": string[]}}, _type: string}[], max_score: number, total: number}}, status: number}} The database result. + */ + function (result) { + var siteHits = result && result.data && result.data.hits; + if (!siteHits) { + resultDefer.reject("Invalid result."); + return; + } + + var additionalSites = siteHits.hits.map(function (site) { + return { + id: site._source.id, + name: site._source.name, + type: site._source.type, + location: { + lat: site._source.location.lat, + lng: site._source.location.lon + }, + amslGround: site._source["amsl-ground"], + type: site._source.type, + references: { + siteLinks: site._source.references["site-links"] + } + }; + }); + + var siteLinks = hits.hits.map(function (siteLink) { + return { + id: siteLink._source.id, + siteA: sites.find(function (site) { return site.id === siteLink._source.siteA; }) || additionalSites.find(function (site) { return site.id === siteLink._source.siteA; }), + siteZ: sites.find(function (site) { return site.id === siteLink._source.siteZ; }) || additionalSites.find(function (site) { return site.id === siteLink._source.siteZ; }), + type: siteLink._source.type, + length: 5000 // AF/MF: the length will be served from the database in the next version. + }; + }); + + resultDefer.resolve(siteLinks); + }, + resultDefer.reject); + + return; + } + + var siteLinks = hits.hits.map(function (siteLink) { + return { + id: siteLink._source.id, + siteA: sites.find(function (site) { return site.id === siteLink._source.siteA; }), + siteZ: sites.find(function (site) { return site.id === siteLink._source.siteZ; }), + type: siteLink._source.type, + length: 5000 // AF/MF: the length will be served from the database in the next version. + }; + }); + + resultDefer.resolve(siteLinks); + }, + resultDefer.reject); + + return resultDefer.promise; + }; + + /** + * Gets a promise which is resolved with an array of planned filtered by given network element ids. + * This function does not use chunks! + * @param neIds {string[]} The ids of the site links to return. + */ + service.getPlannedNetworkElementsByIds = function (neIds) { + var resultDefer = $q.defer(); + + if (!neIds || neIds.length === 0) { + resultDefer.resolve([]); + return resultDefer.promise; + } + + var query = { + bool: { + should: neIds.map(function (neId) { + return { term: { id: neId } }; + }) + } + }; + + $mwtnDatabase.getFilteredData("mwtn", "planned-network-elements", 0, neIds.length, query).then( + /** + * Callback for the database request. + * @param result {{data: {hits: {hits: {_id: string, _index: string, _score: number, _source: {id: string, name: string, type: string}, _type: string}[], max_score: number, total: number}}, status: number}} The database result. + */ + function (result) { + var hits = result && result.data && result.data.hits; + if (!hits) { + resultDefer.reject("Invalid result."); + return; + } + + if (hits.total === 0) { + resultDefer.resolve([]); + return; + } + + var plannedNetworkElements = hits.hits.map(function (plannedNetworkElement) { + return { + id: plannedNetworkElement._source.id, + name: plannedNetworkElement._source.name, + type: plannedNetworkElement._source.radioType + }; + }); + + resultDefer.resolve(plannedNetworkElements); + }, resultDefer.reject); + + return resultDefer.promise; + }; + + + /** + * Gets a promise which is resolved with an array of site links filtered by given site link ids. + * This function does not use chunks! + * @param siteLinkIds {string[]} The ids of the site links to return. + */ + service.getSiteLinksByIds = function (siteLinkIds) { + var resultDefer = $q.defer(); + + if (!siteLinkIds || siteLinkIds.length === 0) { + resultDefer.resolve([]); + return resultDefer.promise; + } + + var query = { + bool: { + should: siteLinkIds.map(function (siteLinkId) { + return { term: { id: siteLinkId } }; + }) + } + }; + + $mwtnDatabase.getFilteredData("mwtn", "site-link", 0, siteLinkIds.length, query).then( + /** + * Callback for the database request. + * @param result {{data: {hits: {hits: {_id: string, _index: string, _score: number, _source: {id: string, siteA: string, siteZ: string}, _type: string}[], max_score: number, total: number}}, status: number}} The database result. + */ + function (result) { + var hits = result && result.data && result.data.hits; + if (!hits) { + resultDefer.reject("Invalid result."); + return; + } + + if (hits.total === 0) { + resultDefer.resolve([]); + return; + } + + var siteLinks = hits.hits.map(function (siteLink) { + return { + id: siteLink._source.id, + siteA: siteLink._source.siteA, + siteZ: siteLink._source.siteZ, + azimuthAz: siteLink._source.azimuthAZ, + azimuthZa: siteLink._source.azimuthZA, + length: siteLink._source.length, + type: siteLink._source.type + }; + }); + + resultDefer.resolve(siteLinks); + }, resultDefer.reject); + + return resultDefer.promise; + }; + + /** + * Gets a promise with all details for a given site by its id. + * @param siteId {string} The id of the site to request the details for. + */ + service.getSiteDetailsBySiteId = function (siteId) { + var resultDefer = $q.defer(); + + var siteQuery = { + "bool": { + "must": [ + { + "term": { + "id": siteId + } + } + ] + } + }; + + // get all site details + $mwtnDatabase.getFilteredData("mwtn", "site", 0, 1, siteQuery).then( + /** + * Callback for the database request. + * @param result {{data: {hits: {hits: {_id: string, _index: string, _score: number, _source: {id: string, name: string, location: {lat: number, lon: number}, "amsl-ground": number, references: {"network-elements": string[], "site-links": string[]}}, _type: string}[], max_score: number, total: number}}, status: number}} The database result. + */ + function (result) { + if (result.data.hits.total != 1) { + // todo: handle this error + resultDefer.reject("Error loading details for " + siteId + ((result.data.hits.total) ? ' Too many recoeds found.' : ' No record found.')); + } + var site = result.data.hits.hits[0]; + var siteDetails = { + id: site._source.id, + name: site._source.name, + type: site._source.type, + location: { + lat: site._source.location.lat, + lng: site._source.location.lon + }, + amslGround: site._source["amsl-ground"], + references: { + siteLinks: site._source.references["site-links"], + networkElements: site._source.references["network-elements"] + } + }; + + service.getSiteLinksByIds(siteDetails.references.siteLinks).then( + /** Callback for the database request. + * @param result {{id: string, siteA: string, siteZ: string }[]} + */ + function (result) { + siteDetails.siteLinks = result; + resultDefer.resolve(siteDetails); + }); + + service.getPlannedNetworkElementsByIds(siteDetails.references.networkElements).then( + /** Callback for the database request. + * @param result {{id: string, name: string, type: string }[]} + */ + function (result) { + siteDetails.plannedNetworkElements = result; + resultDefer.resolve(siteDetails); + }); + } + ); + return resultDefer.promise; + }; + + /** + * Gets a promise with all details for a given link by its id. + * @param siteId {string} The id of the link to request the details for. + */ + service.getLinkDetailsByLinkId = function (linkId) { + var resultDefer = $q.defer(); + + var linkQuery = { + "bool": { + "must": [ + { + "term": { + "id": linkId + } + } + ] + } + }; + + // get all site details + $mwtnDatabase.getFilteredData("mwtn", "site-link", 0, 1, linkQuery).then( + /** + * Callback for the database request. + * @param result { DbLinkResult } The database result. + */ + function (result) { + if (result.data.hits.total != 1) { + // todo: handle this error + resultDefer.reject("Error loading details for " + siteId + ((result.data.hits.total) ? ' Too many recoeds found.' : ' No record found.')); + } + var link = result.data.hits.hits[0]; + var linkDetails = { + id: link._source.id, + siteA: link._source.siteA, + siteZ: link._source.siteZ, + siteNameA: link._source.siteNameA, + siteNameZ: link._source.siteNameZ, + length: link._source.length, + azimuthA: link._source.azimuthAZ, + azimuthB: link._source.azimuthZA, + airInterfaceLinks: link._source.airInterfaceLinks, + type: link._source.type, + airInterfaceLinks: link._source.airInterfaceLinks + }; + + service.getSitesByIds([link._source.siteA, link._source.siteZ]).then( + /** Callback for the database request. + * @param result {{ total: number, sites: { id: string, name: string } []}} + */ + function (result) { + var siteA = result.sites.find(function (site) { return site.id == linkDetails.siteA }); + var siteZ = result.sites.find(function (site) { return site.id == linkDetails.siteZ }); + if (result.total != 2 || !siteA || !siteZ) { + resultDefer.reject("Could not load Sites for link "+linkDetails.id); + } + linkDetails.siteA = siteA; + linkDetails.siteZ = siteZ; + + resultDefer.resolve(linkDetails); + }) + } + ); + return resultDefer.promise; + } + + /** + * Gets a promise which is resolved with an array of links using the given filter expression. + */ + service.getLinks = function (sortColumn, sortDirection, filters, chunkSize, chunkSiteStartIndex) { + var resultDefer = $q.defer(); + + // determine the sort parameter + var sort = null; + if (sortColumn != null && sortDirection != null) { + sort = {}; + switch (sortColumn) { + case 'siteIdA': + sort['siteA'] = { + order: sortDirection === 'desc' ? 'desc' : 'asc' + } + break; + case 'siteIdZ': + sort['siteZ'] = { + order: sortDirection === 'desc' ? 'desc' : 'asc' + } + break; + default: + sort[sortColumn] = { + order: sortDirection === 'desc' ? 'desc' : 'asc' + } + break; + } + } + + // determine the query parameter + var query = {}; + if (filters == null || filters.length == 0) { + query["match_all"] = {}; + } else { + var regexp = {}; + filters.forEach(function (filter) { + if (filter && filter.field) { + switch (filter.field) { + case 'siteIdA': + regexp['siteIdA'] = '.*' + filter.term + '.*'; + break; + case 'siteIdZ': + regexp['siteZ'] = '.*' + filter.term + '.*'; + break; + default: + regexp[filter.field] = '.*' + filter.term + '.*'; + break; + } + } + }); + query["regexp"] = regexp; + } + + + if (sort) { + $mwtnDatabase.getFilteredSortedData("mwtn", "site-link", chunkSiteStartIndex, chunkSize, sort, query).then(processResult, resultDefer.reject); + } else { + $mwtnDatabase.getFilteredData("mwtn", "site-link", chunkSiteStartIndex, chunkSize, query).then(processResult, resultDefer.reject); + } + + /** + * Callback for the database request. + * @param result {{data: {hits: {hits: {_id: string, _index: string, _score: number, _source: {id: string, siteA: string, siteZ: string}, _type: string}[], max_score: number, total: number}}, status: number}} The database result. + */ + function processResult (result) { + var hits = result && result.data && result.data.hits; + if (!hits) { + resultDefer.reject("Invalid result."); + return; + } + + var total = hits.total; + var links = []; + + var siteLinks = hits.hits.map(function (siteLink) { + return { + id: siteLink._source.id, + siteA: siteLink._source.siteA, + siteZ: siteLink._source.siteZ, + type: siteLink._source.type, + }; + }); + + resultDefer.resolve({ + total: total, + links: siteLinks + }); + } + + return resultDefer.promise; + + + }; + + /** + * Determines if a coordinate is in a bounding box + * @param bounds {{ top: number, left: number, right: number, bottom: number}} The bounding box. + * @param coordinate {{ lat: number, lng: number }} The coordinate. + * @return if the bounding box contains the coordinate + */ + service.isInBounds = function(bounds, coordinate) { + var isLongInRange = (bounds.right < bounds.left) + ? coordinate.lng >= bounds.left || coordinate.lng <= bounds.right + : coordinate.lng >= bounds.left && coordinate.lng <= bounds.right ; + + return coordinate.lat >= bounds.bottom && coordinate.lat <= bounds.top && isLongInRange; + } + + service.getAllEdges = function () { + var edges = []; + return getGenericChunk("edge", edges).then(function () { + return edges; + }); + }; + + /** + * Retrieves all nodes. + * @return a Promis containing an array of nodes + */ + service.getAllNodes = function () { + var resultDefer = $q.defer(); + var nodes = []; + getGenericChunk("node", nodes).then(function () { + + // recreate the tree structure from the flat list + var finalNodes = nodes.reduce( + /** @param acc { Node[] } */ + function (acc, cur, ind, arr) { + // the site will be added with the first device, so it can not be missing after the first device is in + if (!acc.some(node => node.data.type == "site" && node.data.id == cur.data.grandparent)) { + acc.push({ + data: { + type: "site", + id: cur.data.grandparent, + label: cur.data.grandparent, + active: cur.data.active + } + }); + } + if (!acc.some(node => node.data.type == "device" && node.data.id == cur.data.parent)) { + acc.push({ + data: { + _parent: cur.data.grandparent, + type: "device", + id: cur.data.parent, + get parent() { return cur.data.grandparent }, + set parent(val) { debugger; }, + label: cur.data.parent, + active: cur.data.active + } + }); + } + acc.push({ + data: Object.keys(cur.data).reduce(function (obj, key) { + if (key == 'grandparent') { + obj['type'] = 'port' + } else { + cur.data.hasOwnProperty(key) && (obj[key] = cur.data[key]); + } + return obj; + }, {}), + position: cur.position + }); + return acc; + }, []); + + resultDefer.resolve(finalNodes); + }, function (err) { + console.error(err); + resultDefer.reject(err); + }); + return resultDefer.promise; + } + + /** @param nodes {{id: string,position:{ x:number, y:number}}}[]} */ + service.saveChangedNodes = function (nodes) { + return $mwtnDatabase.getBase('topology').then(function (base) { + var resultDefer = $q.when(); + + nodes.forEach(function (node) { + resultDefer = resultDefer.then(function () { + return $mwtnDatabase.genericRequest({ + method: 'POST', + base: base.base, + index: base.index, + docType: 'node', + command: encodeURI(node.id) +'/_update', + data: { + "doc": { + "position": node.position + } + } + }); + }) + }); + return resultDefer; + }); + } + + // Start to initialize google maps api and save the returned promise. + service.googleMapsApiPromise = initializeGoogleMapsApi(); + + return service; + + // private helper functions of $mwtnTopology + + function getGenericChunk(docType, target) { + var size = 30; + return $mwtnDatabase.getAllData('topology', docType, target.length || 0, size, undefined) + .then(function (result) { + if (result.status === 200 && result.data) { + var total = (result.data.hits && result.data.hits.total) || 0; + var hits = (total && result.data.hits.hits) || []; + hits.forEach(function (hit) { + target.push(hit._source || {}); + }); + if (total > target.length) { + return getGenericChunk(docType, target); + } + return $q.resolve(true); + } else { + return $q.reject("Could not load " + docType + "."); + } + }, function (err) { + resultDefer.reject(err); + }); + + return resultDefer.promise; + } + + + /** + * Gets a promise which is resolved if the google maps api initialization is completed. + * @returns {promise} The promise which is resolved if the initialization is completed. + */ + function initializeGoogleMapsApi() { + var googleMapsApiDefer = $q.defer(); + window.googleMapsApiLoadedEvent = new Event("googleMapsApiLoaded"); + + window.addEventListener("googleMapsApiLoaded", function (event) { + + /** + * Calculates the bounds this map would display at a given zoom level. + * + * @member google.maps.Map + * @method boundsAt + * @param {Number} zoom Zoom level to use for calculation. + * @param {google.maps.LatLng} [center] May be set to specify a different center than the current map center. + * @param {google.maps.Projection} [projection] May be set to use a different projection than that returned by this.getProjection(). + * @param {Element} [div] May be set to specify a different map viewport than this.getDiv() (only used to get dimensions). + * @return {google.maps.LatLngBounds} the calculated bounds. + * + * @example + * var bounds = map.boundsAt(5); // same as map.boundsAt(5, map.getCenter(), map.getProjection(), map.getDiv()); + */ + google.maps.Map.prototype.boundsAt = function (zoom, center, projection, div) { + var p = projection || this.getProjection(); + if (!p) return undefined; + var d = $(div || this.getDiv()); + var zf = Math.pow(2, zoom) * 2; + var dw = d.getStyle('width').toInt() / zf; + var dh = d.getStyle('height').toInt() / zf; + var cpx = p.fromLatLngToPoint(center || this.getCenter()); + return new google.maps.LatLngBounds( + p.fromPointToLatLng(new google.maps.Point(cpx.x - dw, cpx.y + dh)), + p.fromPointToLatLng(new google.maps.Point(cpx.x + dw, cpx.y - dh))); + } + + googleMapsApiDefer.resolve(); + }); + + var head = document.getElementsByTagName('head')[0]; + + var callbackScript = document.createElement("script"); + callbackScript.appendChild(document.createTextNode("function googleMapsApiLoadedCallback() { window.dispatchEvent(window.googleMapsApiLoadedEvent); };")); + + var googleScript = document.createElement('script'); + googleScript.src = "https://maps.googleapis.com/maps/api/js?key=AIzaSyBWyNNhRUhXxQpvR7i-Roh23PaWqi-kNdQ&callback=googleMapsApiLoadedCallback"; + + head.appendChild(callbackScript); + head.appendChild(googleScript); + + return googleMapsApiDefer.promise; + } + + }); + +});
\ No newline at end of file diff --git a/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/accordeonHeader.tpl.html b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/accordeonHeader.tpl.html new file mode 100755 index 00000000..21b2a28c --- /dev/null +++ b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/accordeonHeader.tpl.html @@ -0,0 +1,13 @@ +<div role="tab" id="{{::headingId}}" aria-selected="{{isOpen}}" class="panel-heading" ng-keypress="toggleOpen($event)">
+ <h4 class="panel-title">
+ <a role="button" data-toggle="collapse" href aria-expanded="{{isOpen}}" aria-controls="{{::panelId}}" tabindex="0" class="accordion-toggle"
+ ng-click="toggleOpen()" uib-accordion-transclude="heading" ng-disabled="isDisabled" uib-tabindex-toggle>
+ <i class="pull-left fa" ng-class="{'fa-chevron-down': isOpen, 'fa-chevron-right': !isOpen}"></i>
+ <span uib-accordion-header ng-class="{'text-muted': isDisabled}">{{heading}}</span>
+ </a>
+ </h4>
+</div>
+<div id="{{::panelId}}" aria-labelledby="{{::headingId}}" aria-hidden="{{!isOpen}}" role="tabpanel" class="panel-collapse collapse"
+ uib-collapse="!isOpen">
+ <div class="panel-body" ng-transclude></div>
+</div>
diff --git a/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/clocksGrid.tpl.html b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/clocksGrid.tpl.html new file mode 100755 index 00000000..b5d3cbc7 --- /dev/null +++ b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/clocksGrid.tpl.html @@ -0,0 +1 @@ +<div class="mwtnTopologyGrid" ui-grid="vm.gridOptions" ui-grid-pagination ui-grid-pinning ui-grid-selection ui-grid-resize-columns ui-grid-move-columns></div>
\ No newline at end of file diff --git a/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/ethConnectionsGrid.tpl.html b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/ethConnectionsGrid.tpl.html new file mode 100755 index 00000000..b5d3cbc7 --- /dev/null +++ b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/ethConnectionsGrid.tpl.html @@ -0,0 +1 @@ +<div class="mwtnTopologyGrid" ui-grid="vm.gridOptions" ui-grid-pagination ui-grid-pinning ui-grid-selection ui-grid-resize-columns ui-grid-move-columns></div>
\ No newline at end of file diff --git a/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/ethernetView.tpl.html b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/ethernetView.tpl.html new file mode 100755 index 00000000..7f234477 --- /dev/null +++ b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/ethernetView.tpl.html @@ -0,0 +1,18 @@ +<uib-accordion close-others="false">
+
+ <div uib-accordion-group="" class="panel-primary" is-open="vm.status.topologyIsOpen" template-url="src/app/mwtnTopology/templates/accordeonHeader.tpl.html"
+ heading="{{'Topology' | translate }}">
+ <mwtn-topology-ethernet-path-graph ng-if="vm.status.topologyIsOpen" />
+ </div>
+
+ <div uib-accordion-group="" class="panel-primary" is-open="vm.status.portsOpen" template-url="src/app/mwtnTopology/templates/accordeonHeader.tpl.html"
+ heading="{{'Ports' | translate}}">
+ <mwtn-topology-ports-grid />
+ </div>
+
+ <div uib-accordion-group="" class="panel-primary" is-open="vm.status.ethConnectionsIsOpen" template-url="src/app/mwtnTopology/templates/accordeonHeader.tpl.html"
+ heading="{{'ETH connections' | translate}}">
+ <mwtn-topology-eth-connections-grid />
+ </div>
+
+</uib-accordion>
diff --git a/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/frame.tpl.html b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/frame.tpl.html new file mode 100755 index 00000000..7e15cfb9 --- /dev/null +++ b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/frame.tpl.html @@ -0,0 +1,34 @@ +<ht-header help-link='sdnr/mwtnTopology/0.4.0/README.md'></ht-header> +<div class="owl"> + <!-- Display a loading indicator as long as google isn't initialized. --> + <div class="bbg" ng-if="!vm.googleIsReady"> + <i class="fa fa-spinner fa-pulse" aria-hidden="true"></i> + <span>{{'MWTN_LOADING' | translate}}</span> + </div> + + <uib-tabset id="mwtnTopology" active="vm.activeTab" ng-if="vm.googleIsReady"> + + <uib-tab index="0" heading="{{'MWTN_SITE' | translate}}"> + <mwtn-topology-site-view /> + </uib-tab> + + <uib-tab index="1" heading="{{'MWTN_AIR_INTERFACE' | translate}}"> + <mwtn-topology-physical-view /> + </uib-tab> + + <!-- [sko] no data for TST + <uib-tab index="2" heading="{{'MWTN_ETHERNET' | translate}}"> + <mwtn-topology-ethernet-view /> + </uib-tab> + + <uib-tab index="3" heading="{{'MWTN_PTP' | translate}}"> + <mwtn-topology-ieee1588-view /> + </uib-tab> --> + + </uib-tabset> + + <hr /> + <div class="owl"> + <span>ONAP SDN-R | ONF Wireless for @distversion@ - Build: @buildtime@</span> + </div> +</div> diff --git a/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/ieee1588View.tpl.html b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/ieee1588View.tpl.html new file mode 100755 index 00000000..4551aa6e --- /dev/null +++ b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/ieee1588View.tpl.html @@ -0,0 +1,18 @@ +<uib-accordion close-others="false">
+
+ <div uib-accordion-group="" class="panel-primary" is-open="vm.status.topologyIsOpen" template-url="src/app/mwtnTopology/templates/accordeonHeader.tpl.html"
+ heading="{{'Graph' | translate }}">
+ <mwtn-topology-ieee1588-path-graph ng-if="vm.status.topologyIsOpen" />
+ </div>
+
+ <div uib-accordion-group="" class="panel-primary" is-open="vm.status.portsOpen" template-url="src/app/mwtnTopology/templates/accordeonHeader.tpl.html"
+ heading="{{'Clocks' | translate}}">
+ <mwtn-topology-clocks-grid />
+ </div>
+
+ <div uib-accordion-group="" class="panel-primary" is-open="vm.status.ethConnectionsIsOpen" template-url="src/app/mwtnTopology/templates/accordeonHeader.tpl.html"
+ heading="{{'PTP links' | translate}}">
+ <mwtn-topology-ptp-links-grid />
+ </div>
+
+</uib-accordion>
diff --git a/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/linkDetails.tpl.html b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/linkDetails.tpl.html new file mode 100755 index 00000000..e26979a1 --- /dev/null +++ b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/linkDetails.tpl.html @@ -0,0 +1,110 @@ +<div>
+ <uib-alert type="{{status.type}}" ng-show="status.message"> <i ng-show="status.isWorking" class="fa fa-spinner fa-pulse"></i>
+ <b><span>{{status.message}}</span></b>
+ </uib-alert>
+ <div ng-show="!status.message">
+ <p>
+ <span>Sitelink name: </span>
+ <b>{{vm.link.name || vm.link.id }}</b>
+ <br/>
+ <span>Length: </span>
+ <b> {{vm.link.length || 0 | number:3 }} </b>
+ <span> km</span>
+ <br/>
+ <span>Type: </span>
+ <b> {{vm.link.type || 'traffic' }} </b>
+ <span> </span>
+ </p>
+ <table>
+ <caption class="text-left">
+ <b>{{'SITE' | translate}} A</b>
+ </caption>
+ <tbody>
+ <tr>
+ <td class="text-right" style="padding-right: 5px;">{{'MWTN_SITE_ID' | translate}}:</td>
+ <td class="text-left">
+ <b>{{vm.link.siteA.id}}</b>
+ </td>
+ </tr>
+ <tr>
+ <td class="text-right" style="padding-right: 5px;">{{'MWTN_NAME' | translate}}:</td>
+ <td class="text-left">
+ <b>{{vm.link.siteA.name}}</b>
+ </td>
+ </tr>
+ <tr>
+ <td class="text-right" style="padding-right: 5px;">Lat/Lon:</td>
+ <td class="text-left">
+ <b>{{vm.link.siteA.location.lat | coordinateFilter:'toDMS':'lat'}} | {{vm.link.siteA.location.lng | coordinateFilter:'toDMS':'lon'}}</b>
+ </td>
+ </tr>
+ <tr>
+ <td class="text-right" style="padding-right: 5px;">Azimuth:</td>
+ <td class="text-left">
+ <b> {{vm.link.azimuthA || 0 | number:1 }} </b>
+ <span> °</span>
+ </td>
+ </tr>
+ </tbody>
+ </table>
+ <table>
+ <caption class="text-left">
+ <b>{{'MWTN_SITE' | translate}} Z</b>
+ </caption>
+ <tbody>
+ <tr>
+ <td class="text-right" style="padding-right: 5px;">{{'MWTN_SITE_ID' | translate}}:</td>
+ <td class="text-left">
+ <b>{{vm.link.siteZ.id}}</b>
+ </td>
+ </tr>
+ <tr>
+ <td class="text-right" style="padding-right: 5px;">Site-Name:</td>
+ <td class="text-left">
+ <b>{{vm.link.siteZ.name}}</b>
+ </td>
+ </tr>
+ <tr>
+ <td class="text-right" style="padding-right: 5px;">Lat/Lon:</td>
+ <td class="text-left">
+ <b>{{vm.link.siteZ.location.lat | coordinateFilter:'toDMS':'lat'}} | {{vm.link.siteZ.location.lng | coordinateFilter:'toDMS':'lon'}}</b>
+ </td>
+ </tr>
+ <tr>
+ <td class="text-right" style="padding-right: 5px;">Azimuth:</td>
+ <td class="text-left">
+ <b> {{vm.link.azimuthB || 0 | number:1 }} </b>
+ <span> °</span>
+ </td>
+ </tr>
+ </tbody>
+ </table>
+ <br/>
+ <br/>
+ <table class='table table-striped' ng-show="vm.link.airInterfaceLinks && vm.link.airInterfaceLinks.length">
+ <caption class="text-left">
+ <b>{{'MWTN_AIR_INTERFACE_LINKS' | translate}}</b>
+ </caption>
+ <thead>
+ <tr>
+ <th>{{'MWTN_ID' | translate}}</th>
+ <th>{{'MWTN_RADIO' | translate}}</th>
+ <th>{{'MWTN_BAND' | translate}}</th>
+ <th>{{'MWTN_POLARIZATION' | translate}}</th>
+ <th>{{'MWTN_STATUS' | translate}}</th>
+ </tr>
+ </thead>
+ <tbody>
+ <tr ng-repeat="airIf in vm.link.airInterfaceLinks">
+ <td> {{ airIf.id}} </td>
+ <td> {{ airIf.radio}} </td>
+ <td> {{ airIf.bandDesignator }} </td>
+ <td> {{ airIf.polarization }} </td>
+ <td> {{ airIf.mainStatus }} </td>
+
+
+ </tr>
+ </tbody>
+ </table>
+ </div>
+</div>
\ No newline at end of file diff --git a/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/links.tpl.html b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/links.tpl.html new file mode 100755 index 00000000..8299a834 --- /dev/null +++ b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/links.tpl.html @@ -0,0 +1,2 @@ +<div id="mwtnNodesGrid" ui-grid="gridOptionsLinks" ui-grid-exporter ui-grid-selection ui-grid-pinning ui-grid-resize-columns ui-grid-move-columns + class="mwtnTopologyGrid"></div> diff --git a/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/linksGrid.tpl.html b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/linksGrid.tpl.html new file mode 100755 index 00000000..b5d3cbc7 --- /dev/null +++ b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/linksGrid.tpl.html @@ -0,0 +1 @@ +<div class="mwtnTopologyGrid" ui-grid="vm.gridOptions" ui-grid-pagination ui-grid-pinning ui-grid-selection ui-grid-resize-columns ui-grid-move-columns></div>
\ No newline at end of file diff --git a/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/maps.tpl.html b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/maps.tpl.html new file mode 100755 index 00000000..71e6c0ee --- /dev/null +++ b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/maps.tpl.html @@ -0,0 +1,59 @@ +<!-- +<ui-gmap-google-map bounds="mapObjects.map.bounds" + center="mapObjects.map.center" + control="mapObjects.map.control" + dragging="mapObjects.map.dragging" + events="mapObjects.map.events" + options="mapObjects.map.options" + zoom="mapObjects.map.zoom"> + + <ui-gmap-markers + models="mapObjects.sites.models" + idkey="marker.id" + fit="true" + coords="'self'" + options="'options'" + icon="mapObjects.sites.icon" + doCluster="doGoogleCluster" + events="mapObjects.sites.events" + > + </ui-gmap-markers> + + <ui-gmap-window + coords="mapObjects.sites.tooltip" + options="mapObjects.sites.tooltipOptions" + show="mapObjects.sites.tooltip.show"> + </ui-gmap-window>--> + + <!-- siteLinks --> +<!-- + <ui-gmap-polylines + models="mapObjects.siteLinks.models" + events="mapObjects.siteLinks.events" + path="'path'" + stroke="'stroke'" + geodesic="'geodesic'" + editable="'editable'" + draggable="'draggable'" + static="true" + visible="mapObjects.siteLinks.visible" + zindex="'zIndex'" + > + </ui-gmap-polylines> + +</ui-gmap-google-map>--> + +<map center="{{mapObjects.map.center}}" + map-type-id=“MapTypeId.HYBRID” + street-view-control="false"> + + <marker data-ng-repeat="mapObjects.sites.models" + position="{{}}" + /> +</map> + +<!-- + <sigma-topology drag-nodes="true" topology-data="topologyData" trigger-resize-sigma="triggerResizeSigma" panel="panel" + topology-custfunc="topologyCustfunc"> + </sigma-toppology> + --> diff --git a/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/networkElementsGrid.tpl.html b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/networkElementsGrid.tpl.html new file mode 100755 index 00000000..b5d3cbc7 --- /dev/null +++ b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/networkElementsGrid.tpl.html @@ -0,0 +1 @@ +<div class="mwtnTopologyGrid" ui-grid="vm.gridOptions" ui-grid-pagination ui-grid-pinning ui-grid-selection ui-grid-resize-columns ui-grid-move-columns></div>
\ No newline at end of file diff --git a/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/nodes.tpl.html b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/nodes.tpl.html new file mode 100755 index 00000000..826e7dd9 --- /dev/null +++ b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/nodes.tpl.html @@ -0,0 +1,2 @@ +<div id="mwtnNodesGrid" ui-grid="gridOptionsNodes" ui-grid-exporter ui-grid-selection ui-grid-pinning ui-grid-resize-columns ui-grid-move-columns + class="mwtnTopologyGrid"></div> diff --git a/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/physicalView.tpl.html b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/physicalView.tpl.html new file mode 100755 index 00000000..dfeabe4e --- /dev/null +++ b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/physicalView.tpl.html @@ -0,0 +1,18 @@ +<uib-accordion close-others="false">
+
+ <div uib-accordion-group="" class="panel-primary" is-open="vm.status.graphIsOpen" template-url="src/app/mwtnTopology/templates/accordeonHeader.tpl.html"
+ heading="{{'MWTN_GRAPH' | translate }}">
+ <mwtn-topology-physical-path-graph ng-if="vm.status.graphIsOpen" />
+ </div>
+
+ <div uib-accordion-group="" class="panel-primary" is-open="vm.status.networkElementsIsOpen" template-url="src/app/mwtnTopology/templates/accordeonHeader.tpl.html"
+ heading="{{'MWTN_AIR_INTERFACES' | translate}}">
+ <mwtn-topology-network-elements-grid />
+ </div>
+
+ <div uib-accordion-group="" class="panel-primary" is-open="vm.status.LinksIsOpen" template-url="src/app/mwtnTopology/templates/accordeonHeader.tpl.html"
+ heading="{{'MWTN_LINKS' | translate}}">
+ <mwtn-topology-links-grid />
+ </div>
+
+</uib-accordion>
\ No newline at end of file diff --git a/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/portsGrid.tpl.html b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/portsGrid.tpl.html new file mode 100755 index 00000000..b5d3cbc7 --- /dev/null +++ b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/portsGrid.tpl.html @@ -0,0 +1 @@ +<div class="mwtnTopologyGrid" ui-grid="vm.gridOptions" ui-grid-pagination ui-grid-pinning ui-grid-selection ui-grid-resize-columns ui-grid-move-columns></div>
\ No newline at end of file diff --git a/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/ptpLinksGrid.tpl.html b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/ptpLinksGrid.tpl.html new file mode 100755 index 00000000..b5d3cbc7 --- /dev/null +++ b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/ptpLinksGrid.tpl.html @@ -0,0 +1 @@ +<div class="mwtnTopologyGrid" ui-grid="vm.gridOptions" ui-grid-pagination ui-grid-pinning ui-grid-selection ui-grid-resize-columns ui-grid-move-columns></div>
\ No newline at end of file diff --git a/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/siteDetails.tpl.html b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/siteDetails.tpl.html new file mode 100755 index 00000000..3a06fa8d --- /dev/null +++ b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/siteDetails.tpl.html @@ -0,0 +1,77 @@ +<div class="owl">
+ <uib-alert type="{{status.type}}" ng-show="status.message">
+ <i ng-show="status.isWorking" class="fa fa-spinner fa-pulse" aria-hidden="true"></i>
+ <b><span>{{status.message}}</span></b>
+ </uib-alert>
+ <div ng-show="!status.message">
+ <p>
+ <span>{{'MWTN_SITE_ID' | translate}}: </span>
+ <b>{{vm.site.id}}</b>
+ </p>
+ <hr />
+ <p>
+ <span>{{'MWTN_SITE_NAME' | translate}}: </span>
+ <b>{{vm.site.name}}</b>
+ <br />
+ <span>{{'MWTN_LAT_LON' | translate}}</span>
+ <b>{{ vm.site.location.lat | coordinateFilter:'toDMS':'lat'}} | {{ vm.site.location.lng | coordinateFilter:'toDMS':'lon'}}</b>
+ <br />
+ <span>{{'MWTN_AMSL_GRD' | translate}}: </span>
+ <b> {{vm.site.amslGround | number:2 }} </b>
+ <span> [m]</span>
+ <br />
+ <span>{{'MWTN_TYPE' | translate}}: </span>
+ <b> {{vm.site.type || 'pyhsical-network-function' }} </b>
+ <span> </span>
+ </p>
+ <p>
+ <b>Site-Links ({{vm.site.siteLinks.length}}): </b>
+ <span style="color: #337ab7;" class="pointer glyphicon glyphicon-plus-sign" aria-hidden="true" ng-class="{'selected-site' : createNewLinkMode}"
+ ng-show="showNewLinkButton" ng-click="toggleCreateNewLinkMode()"></span>
+ <p />
+ <table class='table table-striped' ng-show="vm.site.siteLinks.length">
+ <thead>
+ <tr>
+ <th class='text-left'>Site-Link-Name</th>
+ <th class='text-right'>Azimuth A [°]</th>
+ <th class='text-right'>Azimuth Z [°]</th>
+ <th class='text-right'>Length [km]</th>
+ </tr>
+ </thead>
+ <tbody>
+ <tr ng-repeat='siteLink in vm.site.siteLinks'>
+ <td class='text-left'>
+ <a href='/ux/#/siteLinks/{{siteIndex}}/{{siteLink._source.id.high}}/{{siteLink._source.id.low}}' target='htSolutions'>{{siteLink.id}}</a>
+ </td>
+ <td class='text-right'>{{ siteLink.azimuthAz | number : 1 }}</td>
+ <td class='text-right'>{{ siteLink.azimuthZa | number : 1 }}</td>
+ <td class='text-right'>{{ siteLink.length | number : 3 }}</td>
+ </tr>
+ </tbody>
+ </table>
+ <p>
+ <b>Network elements ({{vm.site.plannedNetworkElements.length}}): </b>
+ <!--
+ <span style="color: #337ab7;" class="pointer glyphicon glyphicon-plus-sign" aria-hidden="true" ng-class="{'selected-site' : createNewLinkMode}"
+ ng-show="showNewLinkButton" ng-click="toggleCreateNewLinkMode()"></span> -->
+ <p />
+ <table class='table table-striped' ng-show="vm.site.plannedNetworkElements.length">
+ <thead>
+ <tr>
+ <th class='text-left'>{{'MWTN_ID' | translate}}</th>
+ <th class='text-left'>{{'MWTN_NAME' | translate}}</th>
+ <th class='text-left'>{{'MWTN_TYPE' | translate}}</th>
+ </tr>
+ </thead>
+ <tbody>
+ <tr ng-repeat='ne in vm.site.plannedNetworkElements'>
+ <td class='text-left'>
+ <a href='#/pnfInventory/{{ne.id}}' target='htSolutions'>{{ne.id}}</a>
+ </td>
+ <td class='text-left'>{{ ne.name }}</td>
+ <td class='text-left'>{{ ne.type }}</td>
+ </tr>
+ </tbody>
+ </table>
+ </div>
+</div>
\ No newline at end of file diff --git a/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/siteGrid.tpl.html b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/siteGrid.tpl.html new file mode 100755 index 00000000..612fb92e --- /dev/null +++ b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/siteGrid.tpl.html @@ -0,0 +1,9 @@ +<!--<h1 style="color:#000">Here is the sites grid</h1>-->
+<div class="checkbox">
+ <label>
+ <input type="checkbox" ng-model="vm.showAllSites">
+ Show all sites
+ </label>
+</div>
+
+<div class="mwtnTopologyGrid" ui-grid="vm.gridOptions" ui-grid-pagination ui-grid-pinning ui-grid-selection ui-grid-resize-columns ui-grid-move-columns></div>
diff --git a/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/siteLinkGrid.tpl.html b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/siteLinkGrid.tpl.html new file mode 100755 index 00000000..ba4f270c --- /dev/null +++ b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/siteLinkGrid.tpl.html @@ -0,0 +1,8 @@ +<div class="checkbox">
+ <label>
+ <input type="checkbox" ng-model="vm.showAllLinks">
+ Show all links
+ </label>
+</div>
+
+<div class="mwtnTopologyGrid" ui-grid="vm.gridOptions" ui-grid-pagination ui-grid-pinning ui-grid-selection ui-grid-resize-columns ui-grid-move-columns></div>
\ No newline at end of file diff --git a/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/sitePathGrid.tpl.html b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/sitePathGrid.tpl.html new file mode 100755 index 00000000..bc1372e6 --- /dev/null +++ b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/sitePathGrid.tpl.html @@ -0,0 +1 @@ +<h1 style="color:#000">Here is the site paths grid</h1>
diff --git a/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/siteView.tpl.html b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/siteView.tpl.html new file mode 100755 index 00000000..e56a2273 --- /dev/null +++ b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/siteView.tpl.html @@ -0,0 +1,31 @@ +<uib-accordion close-others="false">
+
+ <div uib-accordion-group="" class="panel-primary" is-open="vm.status.siteMapIsOpen" template-url="src/app/mwtnTopology/templates/accordeonHeader.tpl.html"
+ heading="{{'Map (' + vm.status.loadedSitesInBoundingBox + ' of ' + vm.status.totalSitesInBoundingBox + ' sites loaded)'}}">
+
+ <mwtn-topology-map ng-if="vm.status.siteMapIsOpen" manual-map-bounds="vm.status.manualMapBounds" on-bounds-changed="vm.mapBoundsChanged(data, userOriginated)">
+ <mwtn-topology-map-sites sites="vm.visibleSites" selected-site="vm.status.site" api="vm.mapSitesComponentApi" />
+ <mwtn-topology-map-site-links site-links="vm.knownSiteLinks" selected-site-link="vm.status.siteLink"
+ api="vm.mapSiteLinksComponentApi" />
+ </mwtn-topology-map>
+ </div>
+
+ <div uib-accordion-group="" class="panel-primary" is-open="vm.status.siteGridIsOpen" template-url="src/app/mwtnTopology/templates/accordeonHeader.tpl.html"
+ heading="{{'Sites' | translate}}">
+
+ <mwtn-topology-site-grid visible-sites="vm.visibleSites" />
+ </div>
+
+ <div uib-accordion-group="" class="panel-primary" is-open="vm.status.siteLinkGridIsOpen" template-url="src/app/mwtnTopology/templates/accordeonHeader.tpl.html"
+ heading="{{'Site links' | translate}}">
+
+ <mwtn-topology-site-link-grid known-site-links="vm.knownSiteLinks" />
+ </div>
+
+ <!-- [sko, 2017-06-23] TODO deferred
+ <div uib-accordion-group="" class="panel-primary" is-open="vm.status.sitePathGridIsOpen" template-url="src/app/mwtnTopology/templates/accordeonHeader.tpl.html"
+ heading="{{'Site paths' | translate}}">
+
+ <mwtn-topology-site-path-grid />
+ </div> -->
+</uib-accordion>
diff --git a/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/topology.tpl.html b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/topology.tpl.html new file mode 100755 index 00000000..6a71bbf8 --- /dev/null +++ b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/mwtnTopology-module/src/main/resources/mwtnTopology/templates/topology.tpl.html @@ -0,0 +1,2 @@ + <sigma-topology drag-nodes="true" topology-data="topologyData" trigger-resize-sigma="triggerResizeSigma" panel="panel" topology-custfunc="topologyCustfunc"> + </sigma-toppology> diff --git a/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/pom.xml b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/pom.xml new file mode 100644 index 00000000..0131f51c --- /dev/null +++ b/sdnr/wireless-transport/code-Carbon-SR1/ux/mwtnTopology/pom.xml @@ -0,0 +1,27 @@ +<?xml version="1.0" encoding="UTF-8"?> +<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" + xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd"> + <modelVersion>4.0.0</modelVersion> + + <parent> + <groupId>com.highstreet.technologies.odl.dlux</groupId> + <artifactId>mwtn</artifactId> + <version>0.5.1-SNAPSHOT</version> + <relativePath>..</relativePath> + </parent> + + <packaging>pom</packaging> + <groupId>com.highstreet.technologies.odl.dlux</groupId> + <artifactId>mwtnTopology</artifactId> + <version>0.5.1-SNAPSHOT</version> + <name>${prefix} ${project.artifactId}</name> + + <prerequisites> + <maven>3.0</maven> + </prerequisites> + + <modules> + <module>mwtnTopology-module</module> + <module>mwtnTopology-bundle</module> + </modules> +</project>
\ No newline at end of file |
