1 files changed, 118 insertions, 0 deletions
diff --git a/tests/integration_tests/datasources/test_oci_networking.py b/tests/integration_tests/datasources/test_oci_networking.py
new file mode 100644
index 00000000..f569650e
--- /dev/null
+++ b/tests/integration_tests/datasources/test_oci_networking.py
@@ -0,0 +1,118 @@
+import re
+from typing import Iterator, Set
+
+import pytest
+import yaml
+
+from tests.integration_tests.clouds import IntegrationCloud
+from tests.integration_tests.instances import IntegrationInstance
+from tests.integration_tests.util import verify_clean_log
+
+DS_CFG = """\
+datasource:
+  Oracle:
+    configure_secondary_nics: {configure_secondary_nics}
+"""
+
+
+def customize_environment(
+    client: IntegrationInstance,
+    tmpdir,
+    configure_secondary_nics: bool = False,
+):
+    cfg = tmpdir.join("01_oracle_datasource.cfg")
+    with open(cfg, "w") as f:
+        f.write(
+            DS_CFG.format(configure_secondary_nics=configure_secondary_nics)
+        )
+    client.push_file(cfg, "/etc/cloud/cloud.cfg.d/01_oracle_datasource.cfg")
+
+    client.execute("cloud-init clean --logs")
+    client.restart()
+
+
+def extract_interface_names(network_config: dict) -> Set[str]:
+    if network_config["version"] == 1:
+        interfaces = map(lambda conf: conf["name"], network_config["config"])
+    elif network_config["version"] == 2:
+        interfaces = network_config["ethernets"].keys()
+    else:
+        raise NotImplementedError(
+            f'Implement me for version={network_config["version"]}'
+        )
+    return set(interfaces)
+
+
+@pytest.mark.oci
+def test_oci_networking_iscsi_instance(client: IntegrationInstance, tmpdir):
+    customize_environment(client, tmpdir, configure_secondary_nics=False)
+    result_net_files = client.execute("ls /run/net-*.conf")
+    assert result_net_files.ok, "No net files found under /run"
+
+    log = client.read_from_file("/var/log/cloud-init.log")
+    verify_clean_log(log)
+
+    assert (
+        "opc/v2/vnics/" not in log
+    ), "vnic data was fetched and it should not have been"
+
+    netplan_yaml = client.read_from_file("/etc/netplan/50-cloud-init.yaml")
+    netplan_cfg = yaml.safe_load(netplan_yaml)
+    configured_interfaces = extract_interface_names(netplan_cfg["network"])
+    assert 1 <= len(
+        configured_interfaces
+    ), "Expected at least 1 primary network configuration."
+
+    expected_interfaces = set(
+        re.findall(r"/run/net-(.+)\.conf", result_net_files.stdout)
+    )
+    for expected_interface in expected_interfaces:
+        assert (
+            f"Reading from /run/net-{expected_interface}.conf" in log
+        ), "Expected {expected_interface} not found in: {log}"
+
+    not_found_interfaces = expected_interfaces.difference(
+        configured_interfaces
+    )
+    assert not not_found_interfaces, (
+        f"Interfaces, {not_found_interfaces}, expected to be configured in"
+        f" {netplan_cfg['network']}"
+    )
+    assert client.execute("ping -c 2 canonical.com").ok
+
+
+@pytest.fixture(scope="function")
+def client_with_secondary_vnic(
+    session_cloud: IntegrationCloud,
+) -> Iterator[IntegrationInstance]:
+    """Create an instance client and attach a temporary vnic"""
+    with session_cloud.launch() as client:
+        ip_address = client.instance.add_network_interface()
+        yield client
+        client.instance.remove_network_interface(ip_address)
+
+
+@pytest.mark.oci
+def test_oci_networking_iscsi_instance_secondary_vnics(
+    client_with_secondary_vnic: IntegrationInstance, tmpdir
+):
+    client = client_with_secondary_vnic
+    customize_environment(client, tmpdir, configure_secondary_nics=True)
+
+    log = client.read_from_file("/var/log/cloud-init.log")
+    verify_clean_log(log)
+
+    assert "opc/v2/vnics/" in log, f"vnics data not fetched in {log}"
+    netplan_yaml = client.read_from_file("/etc/netplan/50-cloud-init.yaml")
+    netplan_cfg = yaml.safe_load(netplan_yaml)
+    configured_interfaces = extract_interface_names(netplan_cfg["network"])
+    assert 2 <= len(
+        configured_interfaces
+    ), "Expected at least 1 primary and 1 secondary network configurations"
+
+    result_net_files = client.execute("ls /run/net-*.conf")
+    expected_interfaces = set(
+        re.findall(r"/run/net-(.+)\.conf", result_net_files.stdout)
+    )
+    assert len(expected_interfaces) + 1 == len(configured_interfaces)
+    assert client.execute("ping -c 2 canonical.com").ok