Implement quagga peering

- Create an openstack instance
- Assign it a floating IP
- Execute a quagga bootstrap script using cloud init
- Tell ODL to peer with the instance
- Start an instance in a VPN
- make sure the route was exchanged between the peered quagga and ODL

Change-Id: I73bcaec5425df2b953c2bceaca7d4f09ff28f3d0
Signed-off-by: Romanos Skiadas <rski@intracom-telecom.com>

1 files changed, 154 insertions, 12 deletions

diff --git a/sdnvpn/test/functest/testcase_3.py b/sdnvpn/test/functest/testcase_3.py
index 42b672a..26593f8 100644
--- a/sdnvpn/test/functest/testcase_3.py
+++ b/sdnvpn/test/functest/testcase_3.py
@@ -1,4 +1,3 @@
-#!/usr/bin/python
 #
 # Copyright (c) 2017 All rights reserved
 # This program and the accompanying materials
@@ -7,13 +6,37 @@
 #
 # http://www.apache.org/licenses/LICENSE-2.0
 #
-
+# Tests performed:
+# - Peering OpenDaylight with Quagga:
+#   - Set up a Quagga instance in the functest container
+#   - Start a BGP router with OpenDaylight
+#   - Add the functest Quagga as a neighbor
+#   - Verify that the OpenDaylight and functest Quaggas peer
+# - Exchange routing information with Quagga:
+#   - Create a network, instance and BGPVPN in OpenStack
+#   - Verify the route to the instance is present in the OpenDaylight FIB
+#   - Verify that the functest Quagga also learns these routes
+import os
 import argparse
+
+from sdnvpn.lib import quagga
+import sdnvpn.lib.utils as test_utils
+import sdnvpn.lib.config as sdnvpn_config
+
+import functest.utils.openstack_utils as os_utils
+import functest.utils.functest_utils as ft_utils
 import functest.utils.functest_logger as ft_logger
-from sdnvpn.lib import config as sdnvpn_config
+
 from sdnvpn.lib.results import Results
+
 from opnfv.deployment.factory import Factory as DeploymentFactory
 
+
+COMMON_CONFIG = sdnvpn_config.CommonConfig()
+TESTCASE_CONFIG = sdnvpn_config.TestcaseConfig("testcase_3")
+
+logger = ft_logger.Logger("sdnvpn-testcase-3").getLogger()
+
 parser = argparse.ArgumentParser()
 
 parser.add_argument("-r", "--report",
@@ -45,15 +68,15 @@ def main():
 
     controllers = [node for node in openstack_nodes
                    if node.is_odl()]
-
     msg = ("Verify that OpenDaylight can start/communicate with zrpcd/Quagga")
     results.record_action(msg)
     results.add_to_summary(0, "-")
 
     if not controllers:
-        msg = ("Controller (ODL) list is empty")
+        msg = ("Controller (ODL) list is empty. Skipping rest of tests.")
         logger.info(msg)
         results.add_failure(msg)
+        return results.compile_summary()
     else:
         msg = ("Controller (ODL) list is ready")
         logger.info(msg)
@@ -79,11 +102,10 @@ def main():
         results.add_to_summary(0, "-")
 
         # TODO here we need the external ip of the controller
-        cmd_start_quagga = '/opt/opendaylight/bin/client "odl:configure-bgp ' \
-                           '-op start-bgp-server --as-num 100 ' \
-                           '--router-id {0}"'.format(controller.ip)
+        start_quagga = "odl:configure-bgp -op start-bgp-server " \
+                       "--as-num 100 --router-id {0}".format(controller.ip)
 
-        controller.run_cmd(cmd_start_quagga)
+        test_utils.run_odl_cmd(controller, start_quagga)
 
         logger.info("Checking if bgpd is running"
                     " on the controller node")
@@ -103,10 +125,9 @@ def main():
 
         results.add_to_summary(0, "-")
 
-        cmd_stop_quagga = '/opt/opendaylight/bin/client -v "odl:configure' \
-                          '-bgp -op stop-bgp-server"'
+        stop_quagga = 'odl:configure-bgp -op stop-bgp-server'
 
-        controller.run_cmd(cmd_stop_quagga)
+        test_utils.run_odl_cmd(controller, stop_quagga)
 
         # disabled because of buggy upstream
         # https://github.com/6WIND/zrpcd/issues/15
@@ -125,6 +146,127 @@ def main():
         #     logger.info("bgpd is still running on the controller node")
         #     results.add_failure(msg)
 
+    # Taken from the sfc tests
+    if not os.path.isfile(COMMON_CONFIG.ubuntu_image_path):
+        logger.info("Downloading image")
+        ft_utils.download_url(
+            "https://cloud-images.ubuntu.com/releases/16.04/"
+            "release/ubuntu-16.04-server-cloudimg-amd64-disk1.img",
+            "/home/opnfv/functest/data/")
+    else:
+        logger.info("Using old image")
+
+    glance_client = os_utils.get_glance_client()
+    nova_client = os_utils.get_nova_client()
+    neutron_client = os_utils.get_neutron_client()
+
+    sg_id = os_utils.create_security_group_full(neutron_client,
+                                                TESTCASE_CONFIG.secgroup_name,
+                                                TESTCASE_CONFIG.secgroup_descr)
+    test_utils.open_icmp_ssh(neutron_client, sg_id)
+    test_utils.open_bgp_port(neutron_client, sg_id)
+    net_id, _, _ = test_utils.create_network(neutron_client,
+                                             TESTCASE_CONFIG.net_1_name,
+                                             TESTCASE_CONFIG.subnet_1_name,
+                                             TESTCASE_CONFIG.subnet_1_cidr,
+                                             TESTCASE_CONFIG.router_1_name)
+
+    quagga_net_id, _, _ = test_utils.create_network(
+        neutron_client,
+        TESTCASE_CONFIG.quagga_net_name,
+        TESTCASE_CONFIG.quagga_subnet_name,
+        TESTCASE_CONFIG.quagga_subnet_cidr,
+        TESTCASE_CONFIG.quagga_router_name)
+
+    ubuntu_image_id = os_utils.create_glance_image(
+        glance_client,
+        COMMON_CONFIG.ubuntu_image_name,
+        COMMON_CONFIG.ubuntu_image_path,
+        disk="qcow2",
+        container="bare",
+        public="public")
+
+    # NOTE(rski) The order of this seems a bit weird but
+    # there is a reason for this, namely
+    # https://jira.opnfv.org/projects/SDNVPN/issues/SDNVPN-99
+    # so we create the quagga instance using cloud-init
+    # and immediately give it a floating IP.
+    # The cloud-init script should contain a small sleep for
+    # this to work.
+    # We also create the FIP first because it is used in the
+    # cloud-init script.
+    fip = os_utils.create_floating_ip(neutron_client)
+
+    quagga_bootstrap_script = quagga.gen_quagga_setup_script(
+        controllers[0].ip, fip['fip_addr'])
+    quagga_vm = test_utils.create_instance(
+        nova_client,
+        TESTCASE_CONFIG.quagga_instance_name,
+        ubuntu_image_id,
+        quagga_net_id,
+        sg_id,
+        fixed_ip=TESTCASE_CONFIG.quagga_instance_ip,
+        flavor=TESTCASE_CONFIG.quagga_instance_flavor,
+        userdata=quagga_bootstrap_script)
+    fip_added = os_utils.add_floating_ip(nova_client,
+                                         quagga_vm.id,
+                                         fip['fip_addr'])
+
+    msg = "Assign a Floating IP to %s " % TESTCASE_CONFIG.quagga_instance_name
+    if fip_added:
+        results.add_success(msg)
+    else:
+        results.add_failure(msg)
+
+    testcase = "Bootstrap quagga inside an OpenStack instance"
+    success = False
+    if success:
+        results.add_success(testcase)
+    else:
+        results.add_failure(testcase)
+    results.add_to_summary(0, "=")
+
+    results.add_to_summary(0, '-')
+    results.add_to_summary(1, "Peer Quagga with OpenDaylight")
+    results.add_to_summary(0, '-')
+
+    neighbor = quagga.odl_add_neighbor(fip['fip_addr'], controller)
+    peer = quagga.check_for_peering(controller)
+
+    image_id = os_utils.create_glance_image(glance_client,
+                                            TESTCASE_CONFIG.image_name,
+                                            COMMON_CONFIG.image_path,
+                                            disk=COMMON_CONFIG.image_format,
+                                            container="bare",
+                                            public=True)
+
+    instance = test_utils.create_instance(
+        nova_client,
+        TESTCASE_CONFIG.instance_1_name,
+        image_id,
+        net_id,
+        sg_id,
+        fixed_ip=TESTCASE_CONFIG.instance_1_ip,
+        secgroup_name=TESTCASE_CONFIG.secgroup_name)
+
+    kwargs = {"import_targets": TESTCASE_CONFIG.import_targets,
+              "export_targets": TESTCASE_CONFIG.export_targets,
+              "route_targets": TESTCASE_CONFIG.export_targets,
+              "name": "bgpvpn-3-1"}
+
+    bgpvpn = os_utils.create_bgpvpn(neutron_client, **kwargs)
+    bgpvpn_id = bgpvpn['bgpvpn']['id']
+    os_utils.create_network_association(
+        neutron_client, bgpvpn_id, net_id)
+
+    test_utils.wait_for_instance(instance)
+
+    exchange = quagga.check_for_route_exchange(fip['fip_addr'])
+    if neighbor and peer and exchange:
+        results.add_success("Peering with quagga")
+    else:
+        results.add_failure("Peering with quagga")
+
     return results.compile_summary()