Calipso initial release for OPNFV

Change-Id: I7210c244b0c10fa80bfa8c77cb86c9d6ddf8bc88
Signed-off-by: Yaron Yogev <yaronyogev@gmail.com>

1 files changed, 81 insertions, 0 deletions

diff --git a/app/discover/fetchers/db/db_fetch_oteps.py b/app/discover/fetchers/db/db_fetch_oteps.py
new file mode 100644
index 0000000..9055c11
--- /dev/null
+++ b/app/discover/fetchers/db/db_fetch_oteps.py
@@ -0,0 +1,81 @@
+###############################################################################
+# Copyright (c) 2017 Koren Lev (Cisco Systems), Yaron Yogev (Cisco Systems)   #
+# and others                                                                  #
+#                                                                             #
+# All rights reserved. This program and the accompanying materials            #
+# are made available under the terms of the Apache License, Version 2.0       #
+# which accompanies this distribution, and is available at                    #
+# http://www.apache.org/licenses/LICENSE-2.0                                  #
+###############################################################################
+import re
+
+from discover.fetchers.cli.cli_access import CliAccess
+from discover.fetchers.db.db_access import DbAccess
+from utils.inventory_mgr import InventoryMgr
+from utils.singleton import Singleton
+
+
+class DbFetchOteps(DbAccess, CliAccess, metaclass=Singleton):
+    def __init__(self):
+        super().__init__()
+        self.inv = InventoryMgr()
+        self.port_re = re.compile("^\s*port (\d+): ([^(]+)( \(internal\))?$")
+
+    def get(self, id):
+        vedge = self.inv.get_by_id(self.get_env(), id)
+        tunnel_type = None
+        if "configurations" not in vedge:
+            return []
+        if "tunnel_types" not in vedge["configurations"]:
+            return []
+        if not vedge["configurations"]["tunnel_types"]:
+            return []
+        tunnel_type = vedge["configurations"]["tunnel_types"][0]
+        host_id = vedge["host"]
+        table_name = "neutron.ml2_" + tunnel_type + "_endpoints"
+        env_config = self.config.get_env_config()
+        distribution = env_config["distribution"]
+        if distribution == "Canonical-icehouse":
+            # for Icehouse, we only get IP address from the DB, so take the
+            # host IP address and from the host data in Mongo
+            host = self.inv.get_by_id(self.get_env(), host_id)
+            results = [{"host": host_id, "ip_address": host["ip_address"]}]
+        else:
+            results = self.get_objects_list_for_id(
+                """
+                SELECT *
+                FROM {}
+                WHERE host = %s
+                """.format(table_name),
+                "vedge", host_id)
+        for doc in results:
+            doc["id"] = host_id + "-otep"
+            doc["name"] = doc["id"]
+            doc["host"] = host_id
+            doc["overlay_type"] = tunnel_type
+            doc["ports"] = vedge["tunnel_ports"] if "tunnel_ports" in vedge else []
+            if "udp_port" not in doc:
+                doc["udp_port"] = "67"
+            self.get_vconnector(doc, host_id, vedge)
+
+        return results
+
+    # find matching vConnector by tunneling_ip of vEdge
+    # look for that IP address in ifconfig for the host
+    def get_vconnector(self, doc, host_id, vedge):
+        tunneling_ip = vedge["configurations"]["tunneling_ip"]
+        ifconfig_lines = self.run_fetch_lines("ifconfig", host_id)
+        interface = None
+        ip_string = " " * 10 + "inet addr:" + tunneling_ip + " "
+        vconnector = None
+        for l in ifconfig_lines:
+            if l.startswith(" "):
+                if interface and l.startswith(ip_string):
+                    vconnector = interface
+                    break
+            else:
+                if " " in l:
+                    interface = l[:l.index(" ")]
+
+        if vconnector:
+            doc["vconnector"] = vconnector