diff --git a/lso/routes/ip_trunk.py b/lso/routes/ip_trunk.py
index 24287bd4dc3a692cee9b2a7cadb3bf06b5f93b08..ceecca6b2d9498775980e3ff3834d67977c1fdde 100644
--- a/lso/routes/ip_trunk.py
+++ b/lso/routes/ip_trunk.py
@@ -173,7 +173,9 @@ def check_ip_trunk(params: IPTrunkCheckParams) -> PlaybookLaunchResponse:
"""
extra_vars = {
'wfo_ip_trunk_json': params.subscription,
- } # FIXME: needs to be updated when checks become available
+ }
+ # FIXME: needs to be updated when checks become available, this includes
+ # writing tests.
return run_playbook(
playbook_path=path.join(config_params.ansible_playbooks_root_dir,
diff --git a/test/__init__.py b/test/__init__.py
new file mode 100644
index 0000000000000000000000000000000000000000..e69de29bb2d1d6434b8b29ae775ad8c2e48c5391
diff --git a/test/routes/__init__.py b/test/routes/__init__.py
new file mode 100644
index 0000000000000000000000000000000000000000..e69de29bb2d1d6434b8b29ae775ad8c2e48c5391
diff --git a/test/test_device_routes.py b/test/routes/test_device.py
similarity index 97%
rename from test/test_device_routes.py
rename to test/routes/test_device.py
index 2b7369e2e9a9e50ef5c1bd25da20ce4ecc3ca413..55c294eb449902e81ea1bac3afe01f41a8e28fd0 100644
--- a/test/test_device_routes.py
+++ b/test/routes/test_device.py
@@ -8,7 +8,7 @@ from lso.playbook import PlaybookLaunchResponse
@responses.activate
-def test_nominal_node_provisioning(client):
+def test_router_provisioning(client):
callback_url = 'http://fqdn.xyz.abc:12345/'
responses.add(
method=responses.POST,
diff --git a/test/routes/test_ip_trunk.py b/test/routes/test_ip_trunk.py
new file mode 100644
index 0000000000000000000000000000000000000000..20ac3c95e5ff00945f6a16b609878e9ac6b2bf22
--- /dev/null
+++ b/test/routes/test_ip_trunk.py
@@ -0,0 +1,182 @@
+import time
+from unittest.mock import patch
+
+import jsonschema
+import responses
+
+from lso.playbook import PlaybookLaunchResponse
+
+_SUBSCRIPTION_OBJECT = {
+ 'subscription_id': '0',
+ 'description': 'IP trunk, geant_s_sid:GS-00000',
+ 'iptrunk': {
+ 'geant_s_sid': 'GS-00000',
+ 'iptrunk_description': 'A description for this trunk',
+ 'iptrunk_isis_metric': 9000,
+ 'iptrunk_minimum_links': 1,
+ 'iptrunk_sideA_ae_geant_a_sid': 'GA-00000',
+ 'iptrunk_sideA_ae_iface': 'ae0',
+ 'iptrunk_sideA_ae_members': [
+ 'ge-0/0/0'
+ ],
+ 'iptrunk_sideA_ae_members_description': [
+ 'this is the first interface on side A'
+ ],
+ 'iptrunk_sideA_node': {
+ 'device_fqdn': 'rtx.city.country.geant.net',
+ 'device_ias_lt_ipv4_network': '1.0.0.0/31',
+ 'device_ias_lt_ipv6_network': 'dead:beef::3/126',
+ 'device_lo_ipv4_address': '1.0.0.0',
+ 'device_lo_ipv6_address': 'dead:beef::',
+ 'device_lo_iso_address': '00.0000.0000.0000.0000.0000.00',
+ 'device_role': 'p',
+ 'device_si_ipv4_network': '0.0.1.0/31',
+ 'device_site': {
+ 'name': 'SiteBlock',
+ 'label': None,
+ 'site_city': 'City',
+ 'site_name': 'city',
+ 'site_tier': '1',
+ 'site_country': 'Country',
+ 'site_latitude': 0.0,
+ 'site_longitude': 0.0,
+ 'site_internal_id': 0,
+ 'site_country_code': 'XX',
+ 'owner_subscription_id': '0',
+ 'site_bgp_community_id': 0,
+ 'subscription_instance_id': '0'
+ },
+ 'device_ts_address': '127.0.0.1',
+ 'device_ts_port': 22,
+ 'device_vendor': 'vendor',
+ 'owner_subscription_id': '0',
+ 'subscription_instance_id': '0'
+ },
+ 'iptrunk_sideB_ae_geant_a_sid': 'GA-00002',
+ 'iptrunk_sideB_ae_iface': 'ae0',
+ 'iptrunk_sideB_ae_members': [
+ 'ge-0/0/0'
+ ],
+ 'iptrunk_sideB_ae_members_description': [
+ 'this is the first interface side B'
+ ],
+ 'iptrunk_sideB_node': {
+ 'device_fqdn': 'rtx.town.country.geant.net',
+ 'device_ias_lt_ipv4_network': '0.0.0.0/31',
+ 'device_ias_lt_ipv6_network': 'deaf:beef::1/126',
+ 'device_lo_ipv4_address': '0.0.0.0',
+ 'device_lo_ipv6_address': 'dead:beef::2',
+ 'device_lo_iso_address': '00.0000.0000.0000.0000.0000.00',
+ 'device_role': 'p',
+ 'device_si_ipv4_network': '0.1.0.0/31',
+ 'device_site': {
+ 'name': 'SiteBlock',
+ 'label': None,
+ 'site_city': 'Town',
+ 'site_name': 'town',
+ 'site_tier': '1',
+ 'site_country': 'Country',
+ 'site_latitude': 0.0,
+ 'site_longitude': 0.0,
+ 'site_internal_id': 1,
+ 'site_country_code': 'xx',
+ 'owner_subscription_id': '0',
+ 'site_bgp_community_id': 2,
+ 'subscription_instance_id': '0'
+ },
+ 'device_ts_address': '127.0.0.2',
+ 'device_ts_port': 22,
+ 'device_vendor': 'vendor',
+ 'owner_subscription_id': '0',
+ 'subscription_instance_id': '0'
+ },
+ 'iptrunk_speed': '1',
+ 'iptrunk_type': 'Dark_fiber'
+ },
+ 'status': 'provisioning'
+ }
+
+
+@responses.activate
+def test_ip_trunk_provisioning(client):
+ callback_url = 'http://fqdn.xyz.abc:12345/'
+ responses.add(
+ method=responses.POST,
+ url=callback_url)
+
+ params = {
+ 'callback': callback_url,
+ 'dry_run': True,
+ 'object': 'trunk_interface',
+ 'subscription': _SUBSCRIPTION_OBJECT
+ }
+
+ with patch('lso.playbook.ansible_runner.run') as _run:
+ rv = client.post('/api/ip_trunk/', json=params)
+ assert rv.status_code == 200
+ response = rv.json()
+ # wait a second for the run thread to finish
+ time.sleep(1)
+ _run.assert_called()
+
+ jsonschema.validate(response, PlaybookLaunchResponse.schema())
+ # responses.assert_call_count(callback_url, 1)
+
+ assert response['status'] == 'ok'
+
+
+@responses.activate
+def test_ip_trunk_modification(client):
+ callback_url = 'http://fqdn.xyz.abc:12345/'
+ responses.add(
+ method=responses.PUT,
+ url=callback_url)
+
+ params = {
+ 'callback': callback_url,
+ 'dry_run': True,
+ 'subscription': _SUBSCRIPTION_OBJECT,
+ 'old_subscription': _SUBSCRIPTION_OBJECT
+ }
+
+ with patch('lso.playbook.ansible_runner.run') as _run:
+ rv = client.put('/api/ip_trunk/', json=params)
+ assert rv.status_code == 200
+ response = rv.json()
+ # wait a second for the run thread to finish
+ time.sleep(1)
+ _run.assert_called()
+
+ jsonschema.validate(response, PlaybookLaunchResponse.schema())
+ # responses.assert_call_count(callback_url, 1)
+
+ assert response['status'] == 'ok'
+
+
+@responses.activate
+def test_ip_trunk_modification(client):
+ callback_url = 'http://fqdn.xyz.abc:12345/'
+ responses.add(
+ method=responses.DELETE,
+ url=callback_url)
+
+ params = {
+ 'callback': callback_url,
+ 'dry_run': True,
+ 'subscription': _SUBSCRIPTION_OBJECT
+ }
+
+ with patch('lso.playbook.ansible_runner.run') as _run:
+ rv = client.request(url='/api/ip_trunk/',
+ method=responses.DELETE,
+ json=params)
+ assert rv.status_code == 200
+ response = rv.json()
+ # wait a second for the run thread to finish
+ time.sleep(1)
+ _run.assert_called()
+
+ jsonschema.validate(response, PlaybookLaunchResponse.schema())
+ # responses.assert_call_count(callback_url, 1)
+
+ assert response['status'] == 'ok'