workflow: add ping-mesh workflow

Author: dvandra

statics/workflows/ping-mesh.yaml

@@ -0,0 +1,97 @@
+---
+UUID: "784c3329-0f47-449b-5c58-2d207bcfb501"
+name: "Ping Mesh (ICMP/TCP/UDP)"
+description: "Check Connectivity from Multiple Source to Single Destination"
+parameters:
+  - name: protocol
+    description: Protocol
+    type:  choice
+    default: icmp
+    values:
+      - description: "Protocol : ICMPv4/Echo request"
+        value: icmp4
+      - description: "Protocol : TCP/IPv4"
+        value: tcp4
+      - description: "Protocol : UDP/IPv4"
+        value: udp4
+  - name: destination
+    description: Destination Node
+    type: node
+  - name: sources
+    description: Source Nodes
+    type: node
+source: |
+  function PingMesh(protocol, to, source) {
+    var sources = [source];
+    var result = {};
+    var From = {};
+    var capture = new Capture();
+    capture.GremlinQuery = "G.V().Has('TID', '" + to + "')";
+    var packetInjection = new PacketInjection();
+    return client.captures.create(capture).then(function (c) {
+      capture = c
+    }).then(function () {
+      return sleep(1000)
+    }).then(function () {
+      sources.forEach(function(source) {
+        packetInjection.Src = "G.V().Has('TID', '" + source + "')"
+        packetInjection.Dst = "G.V().Has('TID', '" + to + "')"
+        packetInjection.Count = 5
+        return client.G.V().Has("TID", to).then(
+          function (nodes) {
+          if (nodes[0].Metadata.Neutron && nodes[0].Metadata.Neutron.IPV4) {
+            packetInjection.DstIP = nodes[0].Metadata.Neutron.IPV4[0]
+          }
+          if (nodes[0].Metadata.ExtID && nodes[0].Metadata.ExtID["attached-mac"]) {
+            packetInjection.DstMAC = nodes[0].Metadata.ExtID["attached-mac"]
+          }
+          if (protocol == "icmp4") {
+            packetInjection.Type = protocol;
+            packetInjection.ICMPID = Math.floor(Math.random() * 65535);
+          }
+          if (protocol == "tcp4" || protocol == "udp4") {
+            packetInjection.Type = protocol;
+            packetInjection.SrcPort = 1024 + Math.floor(Math.random() * (65535-1024));
+            packetInjection.DstPort = 1024 + Math.floor(Math.random() * (65535-1024));
+          }
+        }).then(function () {
+          return client.G.V().Has("TID", source)
+        }).then(function (nodes) {
+          if (nodes[0].Metadata.Neutron && nodes[0].Metadata.Neutron.IPV4) {
+            packetInjection.SrcIP = nodes[0].Metadata.Neutron.IPV4[0]
+          }
+          if (nodes[0].Metadata.ExtID && nodes[0].Metadata.ExtID["attached-mac"]) {
+            packetInjection.SrcMAC = nodes[0].Metadata.ExtID["attached-mac"]
+          } else {
+            packetInjection.SrcIP = nodes[0].Metadata.IPV4[0]
+          }
+          From[source] = packetInjection;
+          From[source].SrcIP = From[source].SrcIP.split("/")[0]
+          return client.packetInjections.create(packetInjection)
+        })
+      });
+    }).then(function () {
+      return sleep(1000)
+    }).then(function () {
+      if (protocol == "icmp4") {
+        return client.G.Flows().Has("ICMP.ID", From[source].ICMPID, "Network.A", From[source].SrcIP).then(function(flows) {
+          result[source] = {"Connected" : flows.length > 0 && flows[0].Metric.ABPackets > 0, "Replied" : flows.length > 0 && flows[0].Metric.BAPackets > 0};
+        }).then(function () {
+            return result
+        });
+      } else {
+        transport_protocol = protocol.toUpperCase();
+        return client.G.Flows().Has("Transport.A", From[source].SrcPort, "Transport.B", From[source].DstPort, "Transport.Protocol", transport_protocol, "Network.A", From[source].SrcIP).then(function(flows) {
+          result[source] = {"Connected" : flows.length > 0 && flows[0].Metric.ABPackets > 0, "Replied" : flows.length > 0 && flows[0].Metric.BAPackets > 0};
+        }).then(function () {
+            return result
+        });
+      }
+    }).then(function () {
+      return result
+    }).finally(function () {
+      return client.captures.delete(capture.UUID)
+    }).catch(function () {
+      return client.captures.delete(capture.UUID)
+    });
+  }