diff options
Diffstat (limited to 'actn-topo-generator/ongen.js')
| -rw-r--r-- | actn-topo-generator/ongen.js | 636 |
1 files changed, 636 insertions, 0 deletions
diff --git a/actn-topo-generator/ongen.js b/actn-topo-generator/ongen.js new file mode 100644 index 0000000..bcbd6d6 --- /dev/null +++ b/actn-topo-generator/ongen.js @@ -0,0 +1,636 @@ +/*- + * ============LICENSE_START======================================================= + * ACTN tool - Topo Generator + * ================================================================================ + * Copyright (C) 2021 Huawei Technologies Co., Ltd. All rights reserved. + * ================================================================================ + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * ============LICENSE_END========================================================= + */ +"use strict"; +Draw.loadPlugin(function (ui) { + const { app, dialog, BrowserWindow } = require("electron").remote; + const win = BrowserWindow.getFocusedWindow(); + const fs = require("fs"); + const path = require("path"); + const ongenDir = path.dirname(app.getPath("exe")) + "/ongen/"; + var graph = ui.editor.graph; + var model = ui.editor.graph.model; + const tsNumbers = new Map([ + ["ODU1", 2], + ["ODU2", 8], + ["ODU3", 32], + ["ODU4", 80] + ]); + const getBitmap = (ts) => + Buffer.alloc(Math.ceil(ts / 8), 255).toString("base64"); + const btoa = (b) => Buffer.from(b, "utf8").toString("base64"); + const http = require("http"); + + // Adds resource and menu for action + mxResources.parse("actnJSON=Export to ACTN JSON files"); + mxResources.parse("initPNC=Initialize PNC Simulators"); + mxResources.parse("collapseAll=Collapse Containers"); + mxResources.parse("expandAll=Expand Containers"); + mxResources.parse("assignNodeId=Auto-assign Node IDs"); + mxResources.parse("loadSetting=Load Default Settings"); + mxResources.parse("saveSetting=Save Current Settings"); + var menu = ui.menus.get("extras"); + var oldFunct = menu.funct; + menu.funct = function (menu, parent) { + oldFunct(menu, parent); + ui.menus.addMenuItems( + menu, + [ + "-", + "actnJSON", + "initPNC", + "collapseAll", + "expandAll", + "assignNodeId", + "loadSetting" + ], + parent + ); + }; + + // Adds action of collpaseAll + ui.actions.addAction( + "collapseAll", + function () { + var cells = model.filterDescendants( + (cell) => !!cell.getAttribute("te_node_id") + ); + var nodeAllCollapsed = true; + cells.forEach((cell) => (nodeAllCollapsed &= cell.collapsed)); + if (!nodeAllCollapsed) { + graph.cellsFolded(cells, true, false, true); + } else { + graph.selectVertices(null, true); + graph.cellsFolded(graph.getSelectionCells(), true, false, true); + graph.clearSelection(); + } + }, + null, + null, + "Ctrl+J" + ); + ui.keyHandler.bindAction(74, !0, "collapseAll", !1); + + // Adds action of expandAll + ui.actions.addAction( + "expandAll", + function () { + graph.selectVertices(null, true); + graph.cellsFolded(graph.getSelectionCells(), false, false, true); + graph.clearSelection(); + }, + null, + null, + "Ctrl+K" + ); + ui.keyHandler.bindAction(75, !0, "expandAll", !1); + + // Adds action of loadSetting + ui.actions.addAction("loadSetting", function () { + var plugins = mxSettings.getPlugins(); + mxSettings.parse(DEFAULT_SETTING); + mxSettings.setPlugins(plugins); + mxSettings.save(); + + ui.setDatabaseItem( + null, + [ + { + title: ".scratchpad", + size: SCRATCHPAD.length, + lastModified: Date.now(), + type: "L" + }, + { title: ".scratchpad", data: SCRATCHPAD } + ], + null, + null, + ["filesInfo", "files"] + ); + notify("Restart the App to take effect."); + }); + + // Adds hidden action with CTRL+H + ui.actions.addAction("saveSetting", function () { + win.webContents.toggleDevTools(); + fs.writeFileSync( + ongenDir + "default-settings.json", + JSON.stringify(mxSettings.settings) + ); + }); + ui.keyHandler.bindAction(72, !0, "saveSetting", !1); + + // Adds action for actn JSON + ui.actions.addAction("actnJSON", function () { + var domains = generateJson(); + if (!domains) { + return; + } + //Get file base name + var fileDir = dialog.showOpenDialogSync(win, { + title: "Choose A Directory to Save ACTN JSON Data Files", + buttonLabel: "Yes", + properties: ["openDirectory"] + }); + if (!fileDir) { + return; + } + + domains.forEach(function (domain) { + var fileName = fileDir + "/" + (domain._port_ || domain.te_name); + fs.writeFileSync(fileName + "{otn-topo}.json", domain._data_); + }); + + dialog.showOpenDialogSync(win, { + title: "Generated ACTN JSON Data Files", + defaultPath: fileDir + "/*", + buttonLabel: "Ok", + filters: [{ name: "DATA", extensions: ["json", "xlsx"] }], + properties: ["multiSelections", "dontAddToRecent"] + }); + }); + + // Adds action for initializing PNC simulators + ui.actions.addAction("initPNC", function () { + var domains = generateJson(); + if (!domains) { + return; + } + //Send PUT messages to each PNC simulator + var reqNum = 0; + domains.forEach(function (domain) { + reqNum++; + const options = { + host: domain._ip_, + port: parseInt(domain._port_), + path: "/pncsimu/v1/reload-data", + method: "POST", + headers: { "Content-Type": "application/json" } + }; + const req = http.request(options, function (res) { + if (res.statusCode != 201 && res.statusCode != 200) { + notify( + `${res.statusCode} Error from ${options.host}:${options.port}` + ); + return res.resume(); + } + if (!--reqNum) { + notify(`${domains.length} PNC simulators initialized`); + } + }); + req.write(domain._data_); + req.end(); + }); + }); + + // Adds action: Auto assign node id of all nodes + ui.actions.addAction("assignNodeId", function () { + var domains = model.filterDescendants( + (cell) => !!cell.getAttribute("network_types") + ); + var i = 1; + graph.clearSelection(); + model.beginUpdate(); + domains.forEach(function (domain) { + var nodes = model.getChildVertices(domain); + var j = 1; + var k = 1; + nodes.forEach(function (node) { + if (!node.hasAttribute("te_node_id")) { + return; + } + var newXmlValue = node.value.cloneNode(false); + newXmlValue.setAttribute("te_node_id", "10." + i + "." + j + "." + k); + model.setValue(node, newXmlValue); + graph.addSelectionCell(node); + if (k < 254) { + k++; + } else { + k = 1; + j++; + } + }); + i++; + }); + model.endUpdate(); + }); + + function generateJson() { + //prepare js object arrays for domains, nodes, TP&links + var domainNetworks = []; + var domains = model.filterDescendants( + (cell) => !!cell.getAttribute("network_types") + ); + var domainMap = new Map(); + graph.clearSelection(); + try { + domains.forEach(function (domain) { + checkObjId("Domain", "te_name", domainMap, domain); + var otnTopo = xml2js(domain.value); + var ethTopo = { ...otnTopo }; + ethTopo["network_types"] = "eth-tran-topology"; + + var nodes = model.getChildVertices(domain); + var nodeMap = new Map(); + (otnTopo.nodes = []), (ethTopo.nodes = []); + (otnTopo.links = []), (ethTopo.links = []); + nodes.forEach(function (node) { + checkObjId("Node", "te_node_id", nodeMap, node); + let otnNode = xml2js(node.value); + let ethNode = { ...otnNode }; + (otnNode.tps = []), (ethNode.tps = []); + otnTopo.nodes.push(otnNode); + ethTopo.nodes.push(ethNode); + + let tps = model.getChildVertices(node); + let tpMap = new Map(); + tps.forEach(function (tp) { + checkObjId("TP", "te_tp_id", tpMap, tp); + let newTpLink = xml2js(tp.value); + newTpLink["te_node_id"] = otnNode["te_node_id"]; + if (newTpLink["otn_odu_type"]) + newTpLink.ts_number = + tsNumbers.get(newTpLink["otn_odu_type"]) || 0; + let links = model.getConnections(tp); + let inniLinkNumber = 0, + enniLinkNumber = 0; + for (let link of links) { + if (link.hasAttribute("te_inter_domain_plug_id")) { + if (!link.getAttribute("te_inter_domain_plug_id")) { + link.setAttribute( + "te_inter_domain_plug_id", + link.getId().substr(-8) + ); + } + enniLinkNumber++; + } else if (link.hasAttribute("te_delay_metric")) { + inniLinkNumber++; + } else { + notify("unknown link!"); + graph.addSelectionCell(link); + return; + } + } + if (inniLinkNumber + enniLinkNumber > 1) { + notify("NNI TP has more than one link!"); + graph.addSelectionCell(tp); + return; + } + if (newTpLink["otn_odu_type"] && links.length == 1) { + xml2js(links[0].value, newTpLink); + newTpLink.bitmap = getBitmap(newTpLink.ts_number); + let dest_tp = model.getOpposites(links, tp, true, true); + if (dest_tp.length != 0) { + if ( + newTpLink["otn_odu_type"] != + dest_tp[0].getAttribute("otn_odu_type") + ) { + notify( + "The two TPs of the link don't have the same odu_type!" + ); + graph.addSelectionCell(tp); + graph.addSelectionCell(links[0]); + graph.addSelectionCell(dest_tp[0]); + return; + } + let dest_node = dest_tp[0].parent; + if ( + dest_node != null && + dest_node != undefined && + node.parent == dest_node.parent + ) { + newTpLink["dest_node"] = dest_node.getAttribute("te_node_id"); + newTpLink["dest_tp"] = dest_tp[0].getAttribute("te_tp_id"); + } + } + } + + if (newTpLink["otn_odu_type"]) { + otnNode.tps.push(newTpLink); + otnTopo.links.push(newTpLink); + } else if (newTpLink["eth_bandwidth"]) { + ethNode.tps.push(newTpLink); + ethTopo.links.push(newTpLink); + } + }); + }); + + //generate JSON data for each domain + let jsonData = jjsRender(ONGEN_TMPL, { + networks: [otnTopo, ethTopo], + btoa: btoa + }); + otnTopo._data_ = JSON.stringify(JSON.parse(jsonData), null, 3); + domainNetworks.push(otnTopo); + }); + } catch (e) { + return notify(e.message); + } + if (domainNetworks.length == 0) return notify("No domain network exists"); + return domainNetworks; + } + + function notify(message) { + dialog.showMessageBoxSync(win, { title: "ongen", message: message }); + } + + //convert data from xml node to js object + function xml2js(xmlNode, jsObj = {}) { + for (let attr of xmlNode.attributes) { + if (attr.name != "label" && attr.name != "placeholders") { + attr.value = attr.value.replace(/(^\s*)|(\s*$)/gm, ""); + jsObj[attr.name] = attr.value; + } + } + return jsObj; + } + + //check the id of a new object: null, undefined or conflicts with other's + function checkObjId(objName, objIdName, objMap, newObj) { + let newObjValue = newObj.getAttribute(objIdName); + if (!newObjValue) { + graph.addSelectionCell(newObj); + throw new Error(objName + " " + objIdName + " is missing!"); + } + if (objMap.has(newObjValue)) { + graph.addSelectionCell(newObj); + graph.addSelectionCell(objMap.get(newObjValue)); + throw new Error("Same " + objName + " " + objIdName + "!"); + } + objMap.set(newObjValue, newObj); + return true; + } + + function jjsRender(tmpl, data, debug = false) { + // generate variable part + var i = 2, + res = [""]; + Object.keys(data).forEach((k) => (res[0] += `var ${k} = __data['${k}'];`)); + res[1] = "var __i = 0, __res = []\n__res[__i++] = `"; + + // generate body part + var sRegex = /<</g, + eRegex = />>/g; + while (sRegex.test(tmpl)) { + res[i++] = tmpl.slice(eRegex.lastIndex, sRegex.lastIndex - 2); + eRegex.lastIndex = sRegex.lastIndex; + if (!eRegex.test(tmpl)) throw new Error(`>> not found.`); + res[++i] = tmpl.slice(sRegex.lastIndex, eRegex.lastIndex - 2); + res[i - 1] = /[\{\}]/.test(res[i++]) ? "`\n" : "`\n__res[__i++] = "; + res[i++] = "\n__res[__i++] = `"; + sRegex.lastIndex = eRegex.lastIndex; + } + res[i++] = tmpl.slice(eRegex.lastIndex); + + // generate return part + res[i] = "`\nreturn __res.join('')"; + if (debug) return res.join(""); + return Function("__data", res.join(""))(data); + } +}); + +const DEFAULT_SETTING = `{"language":"","configVersion":null,"customFonts":[],"libraries":"","customLibraries":["L.scratchpad"],"recentColors":["999999","B3B3B3"],"formatWidth":240,"createTarget":false,"pageFormat":{"x":0,"y":0,"width":1169,"height":827},"search":true,"showStartScreen":true,"gridColor":"#d0d0d0","darkGridColor":"#6e6e6e","autosave":false,"resizeImages":null,"openCounter":272,"version":18,"unit":1,"isRulerOn":false,"ui":"dark"}`; +const SCRATCHPAD = `<mxlibrary>[{"xml":"dVTBbtswDP0aHzvIctI0xyXtusM2FN1hR0O2OVurLAoyUyf7+lGynDjBmiAAxfdIPlJUsmLfH5+9ct13bMBkxVNW7D0iTVZ/3IMxmRS6yYrHTErBv0x++QDNIyqc8mDpPwFY/YGamGFUFYo9RnBNUFrVA1uZvDccuKs8W22w2Nlgr7QtuUgghAJzQEzw9aBG0Hc/gEb0b0mBUTV0aBrww5U0O7FKOjlICJK9I3RosD1NpNKhp3KWFzwXCVMykYjaJVouN58Ef1OZmRjDr2c10Mkk5UOnXDB5XsoYYAFe9dyzA697IPC32MsF2I2dJvjpuE9mjXyD7OuoD1PN2fytjdlzTyGHRcuk3aD/Bi7LvF+vN8VmI1bb/EEU8oHBd/Cka2U+G91aZlVIhEFMvKoXHDRpDEDNVxsFzBHfbgg8S0ZVynOm12iJZxibyqez5WVQVZyGYA93pp4aTYngoT74Qb/DK8zKQxPk8Q1+6Ya6xJs8c6+ZLLbxE3cn3EXQCccPFzRfXNEzIIvwvAZiTBUYXRVp7TrQbZfC5CrtgEpr1J5jz+leQ3+25QalSAK2Keo0L1I6L8qdfVflbqopw1O1imCHB9sMy0fGxqKTiyvu33xML3E+Xl78FL38Q/gH","w":435,"h":240,"aspect":"fixed","title":"Network"},{"xml":"dVPRbsIwDPyavKKQCtBeKYyXTZrYB6C08dqgNKlSA2VfP6dJoUwgtZJ9d87VdsqyvOl3Xrb1p1NgWLZlWe6dwxg1fQ7GMMG1YtmGCcHpZeL9BTsfWN5KDxafFLjiCCWSwsgimG0GcoFwsLIBiphYGipcF56iKkSJpo87kEtQDA5GllA7o8B3D9YTbYT5LD13PlgNZFBGeJSLkD721uHVJD0Buu0oWV9qjfDd0kcQc6HxEVZjE1qaU/ijjcmdcZ5y62yoKJ1FqS34JPFQnnynz7CHTv+GY3hUWZqQLMyINIByqzSmMus+0ugCOYzxSyqlbZUg6FtpVUpic2fwCP3LDc0nPe/AkaG/kuSiFdZR8RaXyGvQVY2PmEzzr26Vt8P2oRNbUSuCj/arVHZN817MVmmlE7/lEz/xz08aBG8lwtqdrOqmt4yCSSd3aFjomKarOKb3Kx+rp3/EHw==","w":90,"h":90,"aspect":"fixed","title":"Node"},{"xml":"dVJNb4MwDP01OXYK4aPsuEHX07TDtDNKwZRsAaPgjvLvF0jaUmklQkree36OHbMwa897I/vmHSvQLNyxMDOI5HbtOQOtmeCqYmHOhOD2Z+LtARssLO+lgY7+CcDDN5RkFVoe5mT5QsYEBfWFNRGxN9CyhAZ1BWa4c74qHSjWaCdb8PjGL0cjdQVWp4Km3gs+8q/oxpVa2esWtSxVd3SCWuoBnOKSbMl1X/ZAk/aOBk9dBbM0YOHr2CiCz94WYYHRdtdiDbXa07XSOkONZokNEy6fg63FBzL4AytG5NuE8zkCO1rh9fJZvAWSu0qRN0abUtFkT/EcJbXG8cUYHOcuzogr6RcMwfnhkwWrSveANoeZrGRybPyUpFEYBWma8NQuAZvAN3NUFTVOFfqnaUAdG+8r+FPkldI/6/FqfxsSu/Edvhz92FyOt/FcpHfT+wc=","w":32,"h":20.44,"aspect":"fixed","title":"OTN NNI"},{"xml":"dVJNb4MwDP01uVZ8qEM9rtD2NGm3bacqEAuyBVIFt4V/PyeEQrQVCcnPz89fMUvzdjgZfmnetADF0gNLc6M1TlY75KAUSyIpWFqwJInoZ8nxCRs7NrpwAx3+I9DlN1RIEYqXtljhSCdRvIJGKwGmD3IhnKkvPp5bQCOrgJvLuhxhRz2OCiYWOvFqjL4T6nRHzn2DrS0ek0nkUSqLIkLV1dxAeKpHo3/gQwpsyEMF9tQCPwiJPhrI5KUr41INEj9X9pcN22w9KoZZZcHowTQHiBqeLjBeDXcCbdcwUsjd90Xsdtpx1ICsGwx9hnaH8ham537F9SPdo8K7lp19oNG/3ibLdsuXJVmYoddXU4EXrQ9jzjNMcS+7UIfc1IB/dGSshlxc7lFn6I9ohsuxTur1Lf8C","w":69,"h":1,"aspect":"fixed","title":"INNI Link"},{"xml":"dVNNb4MwDP01XCcKarXrSj9Ok3Zbd0KBGMgWSGXcFv79TEjaoK0HJD8/28+xTZRm7XBEcW7ejQQdpfsozdAYmq12yEDrKImVjNJdlCQxf1FyeMKuLBufBUJH/ySY4htK4ggtiklsZ0mbokUJjdESsF/UIshVR4C5NK1QXX7Wlzr3enOIRxYuG+tp1DCz0Mk3RHNj1JmOnduG2qmHFZtMHpSeUMyovOAVpKN6QvMDn0pSwx4W2LZAYi8VuWhgUxRWxpYaFJ0C+2sKe1k7tBt81gRGByrWzow2aFtNq6pKyvKuHTByU2zWG9sw4XjytSYQ6EzwIWSRV5onBrKGpxtbBWM8guHX4sghNzcBZtfzUuMGVN3Q0oegBanrsrxwO63v5e4KH4bXG4T05oIlOG94aj5wcJWT12VtElgD/UlkI3jGw2UPxEN3lx4+7n/ODn+PXw==","w":128,"h":1,"aspect":"fixed","title":"ENNI Link"},{"xml":"dVJNb8IwDP01OW5KEzF2XmGcph2mnavQuDQsjatgBv33c5sARRqNKsXvPdvxh9Bld95E07cfaMELvRa6jIiUbt25BO+Fks4KvRJKSf6Fen/AFhMrexMh0D8OuN1DTazwZjsmW03kgqCivuIgapEDeFNDi95CPNxFvionUBVqDgfTQVY/5ZNopFChPVY09FnwufpWN672jt9bNaZ2YZcEFI+QBNdko3lf9oEGnwNGPAYLo7QQ+u3UOoKvnotg4MTdZaylzme6cd6X6DFOvvrFSNk0jB8o4g/MGL2UsixHDww0w5vpY7wDMmvrKAdGTuloYGsh2awxBO632U6vHJFU0i9EgvPDkRWzSjeAnCMOLDk5S21S6DRV2YLbtdlLyefXZYJNHtru6nxbAb7k/l3MvBQX87Z8k/RuN/8A","w":30,"h":20.87,"aspect":"fixed","title":"OTN UNI"},{"xml":"dVLbbsIwDP2aPIJyaVFfRwc87WkfgFJiSLc0qYI36N/PTQMUaSSKFB8fH8eOmaq76y7q3n4EA46pDVN1DAGnW3etwTkmeWuYemdScjpMbl94RfLyXkfw+E9AaL7ggMRwuhmTvSdnibDHfk8isswCTh/ABmcgnp+U78wElkLOYa87yOxF3pMb0O4b7c2lNWgzg09rItwEk9xzaWccXFaN4ccbGKmCqfXFtgifPT2UgAt1kDCLncvuY+tcHVyIKVaJRgsg7fUZY/iGmYfz1eZtO0YEjzP8mBbhHaDemBazcKCULQ5klZzMQ/Ceeqqb9MoRmUr6hYhwffktYlbpDgLliANRhtzY5aoqVCGqasUr2hIWophEZj1UuXsW2pPNupIvi8zU+etOd/nHINAld/hm5tG4mY8RTNSnCf0D","w":30,"h":20.44,"aspect":"fixed","title":"ETH UNI"}]</mxlibrary>`; + +const ONGEN_TMPL = ` +{ + "ietf-network:networks": { + "network": [ + << networks.forEach((network, i)=> { >> + << i ? ',' : '' >> + { + "network-id": "providerId-<< network.domain_id >>-clientId-0-topologyId-<< i+1 >>", + "ietf-te-topology:te": { + "name": "<< network.te_name >>" + }, + "ietf-te-topology:provider-id": << network.domain_id >>, + "ietf-te-topology:client-id": 0, + "ietf-te-topology:te-topology-id": "<< i+1 >>", + "network-types": { + "ietf-te-topology:te-topology": { + << if (network.network_types == "otn-topology") { >> + "ietf-otn-topology:<< network.network_types >>": {} + << } else if (network.network_types == "eth-tran-topology") { >> + "ietf-eth-te-topology:<< network.network_types >>": {} + << } >> + } + }, + "node": [ + << network.nodes.forEach((node, i)=> { >> + << i ? ',' : '' >> + { + "node-id": "<< node.te_node_id >>", + "ietf-te-topology:te-node-id": "<< node.te_node_id >>", + "ietf-network-topology:termination-point": [ + << node.tps.forEach((tp, i)=> { >> + << i ? ',' : '' >> + { + "tp-id": "<< tp.te_tp_id >>", + "ietf-te-topology:te-tp-id": << tp.te_tp_id >>, + << if (tp.eth_bandwidth) { >> + "ietf-eth-te-topology:svc": { + "client-facing": true, + "supported-classification": { + "port-classification": true, + "vlan-classification": { + "outer-tag": { + "supported-tag-types": [ + "ietf-eth-tran-types:classify-c-vlan", + "ietf-eth-tran-types:classify-s-vlan" + ], + "vlan-bundling": false, + "vlan-range": "1-4094" + } + } + } + }, + << } >> + "ietf-te-topology:te": { + "name": "<< tp.te_tp_name >>", + "admin-status": "up", + "oper-status": "up", + << if (tp.te_inter_domain_plug_id) { >> + "inter-domain-plug-id": "<< btoa(tp.te_inter_domain_plug_id) >>", + << } >> + << if (tp.otn_odu_type) { >> + "ietf-otn-topology:client-facing": << tp.otn_client_facing >>, + "interface-switching-capability": [ + { + "encoding": "ietf-te-types:lsp-encoding-oduk", + "switching-capability": "ietf-te-types:switching-otn", + "max-lsp-bandwidth": [ + { + "priority": 7, + "te-bandwidth": { + "ietf-otn-topology:odu-type": "ietf-otn-types:prot-<< tp.otn_odu_type>>" + } + } + ] + } + ] + << } >> + << if (tp.eth_bandwidth) { >> + "interface-switching-capability": [ + { + "encoding": "ietf-te-types:lsp-encoding-ethernet", + "switching-capability": "ietf-te-types:switching-l2sc", + "max-lsp-bandwidth": [ + { + "priority": 7, + "te-bandwidth": { + "ietf-eth-te-topology:eth-bandwidth": << tp.eth_bandwidth >> + } + } + ] + } + ] + << } >> + } + } + << }) >> + ], + "ietf-te-topology:te": { + "oper-status": "up", + "te-node-attributes": { + "admin-status": "up", + "name": "<< node.te_name >>" + } + << if (network.network_types == "otn-topology") { >>, + "tunnel-termination-point": [ + << let $i = 0; node.tps.forEach((tp, i)=> { >> + << if (tp.otn_client_facing == "false") { >> + << $i ? ',' : ''; $i = 1 >> + { + "tunnel-tp-id": "<< btoa(tp.te_tp_id) >>", + "admin-status": "up", + "oper-status": "up", + "encoding": "ietf-te-types:lsp-encoding-oduk", + "name": "<< tp.te_tp_name >>", + "protection-type": "ietf-te-types:lsp-protection-unprotected", + "switching-capability": "ietf-te-types:switching-otn", + "local-link-connectivities": { + "local-link-connectivity": [ + { + "is-allowed": true, + "link-tp-ref": "<< tp.te_tp_id >>" + } + ] + } + } + << } }) >> + ] + << } >> + } + } + << }) >> + ], + "ietf-network-topology:link": [ + << network.links.forEach((link, i)=> { >> + << i ? ',' : '' >> + { + "link-id": "<< link.te_node_id >>-<< link.te_tp_id >>", + "source": { + "source-node": "<< link.te_node_id >>", + "source-tp": "<< link.te_tp_id >>" + }, + << if (link.dest_node) { >> + "destination": { + "dest-node": "<< link.dest_node >>", + "dest-tp": "<< link.dest_tp >>" + }, + << } >> + "ietf-te-topology:te": { + "oper-status": "up", + "te-link-attributes": { + "access-type": "point-to-point", + "admin-status": "up", + "name": "<< link.te_node_id >>-<< link.te_tp_id >>", + << if (link.te_delay_metric) { >> + "te-delay-metric": << link.te_delay_metric >>, + << } >> + << if (link.ts_number) { >> + << if (link.te_inter_domain_plug_id) { >> + "label-restriction": [ + { + "inclusive-exclusive": "inclusive", + "index": 1, + "label-end": { + "te-label": { + "ietf-otn-topology:tpn": << link.ts_number >> + } + }, + "label-start": { + "te-label": { + "ietf-otn-topology:tpn": 1 + } + }, + "label-step": 1, + "range-bitmap": "<< link.bitmap >>" + } + ], + << } >> + "max-link-bandwidth": { + "te-bandwidth": { + "ietf-otn-topology:odulist": [ + { + "odu-type": "ietf-otn-types:prot-ODU0", + "number": << link.ts_number >> + } + ] + } + }, + "unreserved-bandwidth": [ + { + "priority": 7, + "te-bandwidth": { + "ietf-otn-topology:odulist": [ + { + "number": << link.ts_number >>, + "odu-type": "ietf-otn-types:prot-ODU0" + } + ] + } + } + ] + << } >> + << if (link.eth_bandwidth) { >> + "max-link-bandwidth": { + "te-bandwidth": { + "ietf-eth-te-topology:eth-bandwidth": << link.eth_bandwidth >> + } + }, + "unreserved-bandwidth": [ + { + "priority": 7, + "te-bandwidth": { + "ietf-eth-te-topology:eth-bandwidth": << link.eth_bandwidth >> + } + } + ] + << } >> + } + } + } + << }) >> + ] + } + << }) >> + ] + } +}`; |