Refactor func. tests RFC8040 utils 44/99444/2
authorguillaume.lambert <guillaume.lambert@orange.com>
Tue, 25 Jan 2022 18:29:01 +0000 (19:29 +0100)
committerguillaume.lambert <guillaume.lambert@orange.com>
Wed, 26 Jan 2022 10:05:52 +0000 (11:05 +0100)
JIRA: TRNSPRTPCE-567
Signed-off-by: guillaume.lambert <guillaume.lambert@orange.com>
Change-Id: I909a7110bed2aa135c8ff59edde0fef8fe8c37ac

tests/transportpce_tests/common/test_utils_rfc8040.py

index a6ab0517a9e90c0a903bb18a2b295168f8184a76..f56755f3a04f933aa288bf73da612c3655913589 100644 (file)
@@ -507,50 +507,10 @@ def del_ietf_network_node_request(network: str, node: str, content: str):
     return response
 
 #
-# TransportPCE network utils operations
+# TransportPCE network-utils and service-path operations
 #
 
 
-def connect_xpdr_to_rdm_request(payload: dict):
-    url = "{}/operations/transportpce-networkutils:init-xpdr-rdm-links"
-    payload_prefix = {'rfc8040': '', 'draft-bierman02': 'networkutils:'}
-    data = {
-        payload_prefix[RESTCONF_VERSION] + "input": {
-            payload_prefix[RESTCONF_VERSION] + "links-input": {
-                payload_prefix[RESTCONF_VERSION] + "xpdr-node": payload['xpdr-node'],
-                payload_prefix[RESTCONF_VERSION] + "xpdr-num": payload['xpdr-num'],
-                payload_prefix[RESTCONF_VERSION] + "network-num": payload['network-num'],
-                payload_prefix[RESTCONF_VERSION] + "rdm-node": payload['rdm-node'],
-                payload_prefix[RESTCONF_VERSION] + "srg-num": payload['srg-num'],
-                payload_prefix[RESTCONF_VERSION] + "termination-point-num": payload['termination-point-num']
-            }
-        }
-    }
-    return post_request(url, data)
-
-
-def connect_rdm_to_xpdr_request(payload: dict):
-    url = "{}/operations/transportpce-networkutils:init-rdm-xpdr-links"
-    payload_prefix = {'rfc8040': '', 'draft-bierman02': 'networkutils:'}
-    data = {
-        payload_prefix[RESTCONF_VERSION] + "input": {
-            payload_prefix[RESTCONF_VERSION] + "links-input": {
-                payload_prefix[RESTCONF_VERSION] + "xpdr-node": payload['xpdr-node'],
-                payload_prefix[RESTCONF_VERSION] + "xpdr-num": payload['xpdr-num'],
-                payload_prefix[RESTCONF_VERSION] + "network-num": payload['network-num'],
-                payload_prefix[RESTCONF_VERSION] + "rdm-node": payload['rdm-node'],
-                payload_prefix[RESTCONF_VERSION] + "srg-num": payload['srg-num'],
-                payload_prefix[RESTCONF_VERSION] + "termination-point-num": payload['termination-point-num']
-            }
-        }
-    }
-    return post_request(url, data)
-
-
-#
-# TransportPCE device renderer service path operations
-#
-
 def prepend_dict_keys(input_dict: dict, prefix: str):
     return_dict = {}
     for key, value in input_dict.items():
@@ -565,11 +525,28 @@ def prepend_dict_keys(input_dict: dict, prefix: str):
     return return_dict
 
 
+def connect_xpdr_to_rdm_request(payload: dict):
+    url = "{}/operations/transportpce-networkutils:init-xpdr-rdm-links"
+    if RESTCONF_VERSION == 'draft-bierman02':
+        data = prepend_dict_keys({'input': {'links-input': payload}}, 'networkutils:')
+    else:
+        data = {'input': {'links-input': payload}}
+    return post_request(url, data)
+
+
+def connect_rdm_to_xpdr_request(payload: dict):
+    url = "{}/operations/transportpce-networkutils:init-rdm-xpdr-links"
+    if RESTCONF_VERSION == 'draft-bierman02':
+        data = prepend_dict_keys({'input': {'links-input': payload}}, 'networkutils:')
+    else:
+        data = {'input': {'links-input': payload}}
+    return post_request(url, data)
+
+
 def device_renderer_service_path_request(payload: dict):
     url = "{}/operations/transportpce-device-renderer:service-path"
-    payload_prefix = {'rfc8040': '', 'draft-bierman02': 'transportpce-device-renderer:'}
     if RESTCONF_VERSION == 'draft-bierman02':
-        data = prepend_dict_keys(payload, payload_prefix[RESTCONF_VERSION])
+        data = prepend_dict_keys(payload, 'transportpce-device-renderer:')
     else:
         data = payload
     return post_request(url, data)