Workflow : Nto1CheckConnectivity

Author: dvandra

js/api.ts

@@ -671,8 +671,8 @@ export function REGEX(param: any): Predicate {
     return new Predicate("REGEX", param)
 }
 
-export function WITHIN(...params: any[]): Predicate {
-    return new Predicate("WITHIN", ...params)
+export function Within(...params: any[]): Predicate {
+    return new Predicate("Within", ...params)
 }
 
 export function WITHOUT(...params: any[]): Predicate {

js/browser.ts

@@ -26,7 +26,7 @@ window.GTE = apiLib.GTE
 window.LTE = apiLib.LTE
 window.IPV4RANGE = apiLib.IPV4RANGE
 window.REGEX = apiLib.REGEX
-window.WITHIN = apiLib.WITHIN
+window.Within = apiLib.Within
 window.WITHOUT = apiLib.WITHOUT
 window.INSIDE = apiLib.INSIDE
 window.OUTSIDE = apiLib.OUTSIDE

statics/workflows/Nto1-check-connectivity.yaml

@@ -0,0 +1,91 @@
+---
+UUID: "18349e06-37d4-43c0-5882-d1aa4bf66133"
+Name: "Nto1CheckConnectivity"
+Title: "Test connectivity between N source to 1 Destination"
+Abstract: "This workflow aims to test the connectivity between N source to 1 Destination. It returns the status of the connection, true (with Flows) or false."
+Description: >
+  # How to use:
+    1. Enter the Gremlin Query for Source Nodes and Select the Destination Nodes to check the Connectivity between them
+    2. Hit the 'Execute' button to run the workflow
+    3. Result will be shown as status true or false along with flows between those interfaces.
+  # How It Works:
+    1. It will start capture on all Nodes from Source to Destination and injects 5 ICMP-Pkts from Source to Destination
+    2. After 1 sec it will check for flows having the same capture-id created by this workflow
+    3. If flows are there and the BA-Packtes in flow-metric > 0, then return 'Connectivity = ture' else 'Connectivity = false', along with this it also returns the flows
+    4. For more information about Skydive workflows please follow - 'skydive.network/blog/introduction-to-workflows.html'
+Parameters:
+  - Name: srcQuery
+    Description: Gremlin Expression for Source-Nodes
+    Type: string
+  - Name: dstNode
+    Description: Select Destination node
+    Type: node
+Source: |
+  function Nto1CheckConnectivity(srcQuery, to) {
+    var result = {}
+    try {
+      sources = client.gremlin.query(srcQuery);
+      dstNode = client.gremlin.G().V().Has('TID', to).result();
+      dstNodeIP = (dstNode[0].Metadata.IPV4[0]).split("/");
+      datNodeIP = dstNodeIP[0]
+      var id = Math.floor(25000 + (Math.random() * 10000));
+      var maxID = id + sources.length;
+
+      var getIP = function(sources) {
+        var srcIP = [];
+        for (var i = 0; i != sources.length; i++) {
+          if (sources[i].Metadata.IPV4) {
+            ip = (sources[i].Metadata.IPV4[0]).split("/");
+            srcIP[i] = ip[0]
+          }
+        }
+        return srcIP
+      }
+
+      var srcIP = getIP(sources)
+
+      var capture = new Capture();
+      capture.GremlinQuery = "G.V().Has('TID', '" + to + "')";
+      var bpf = "icmp and (src " + datNodeIP + " or dst " + datNodeIP + ") and (icmp[4:2]>=" + id + " and icmp[4:2]<" + maxID + ")";
+      capture.BPFFilter = "(" + bpf + ") " + "or (vlan and " + bpf + ")";
+
+      var packetInjection = new PacketInjection();
+      packetInjection.Src = srcQuery
+      packetInjection.Dst = "G.V().Has('TID', '" + to + "')";
+      packetInjection.Type = "icmp4"
+      packetInjection.ICMPID = id;
+      packetInjection.Count = 5
+      packetInjection.Mode = 0
+
+      capture = client.captures.create(capture)
+      sleep(1000)
+      client.packetInjections.create(packetInjection)
+      sleep(1000)
+
+      var dstFlowCaptured = client.gremlin.G().Flows().Has('NodeTID', to, 'CaptureID', capture.UUID).result();
+
+      var flows = {};
+      var noFlows = [];
+      for (var i = 0; i != srcIP.length; i++) {
+        var found = false;
+        for (var j = 0; j != dstFlowCaptured.length; j++) {
+          if (srcIP[i] == dstFlowCaptured[j].Network.A && dstFlowCaptured[j].Metric.ABPackets > 0 && dstFlowCaptured[j].Metric.BAPackets > 0) {
+            found = true;
+            flows[sources[i].Metadata.TID] = {"Connectivity" : true, "Flow" : dstFlowCaptured[j]}
+            break;
+          }
+        }
+        if (!found) {
+          noFlows.push(i);
+          flows[sources[i].Metadata.TID] = {"Connectivity" : false}
+        }
+      }
+
+      result["Connectivity"] = flows
+    } catch (e) {
+      console.log(e)
+      result["Error"] = JSON.stringify(e)
+    }
+    if (capture && capture.UUID) client.captures.delete(capture.UUID)
+    return result
+  }