updated test to include node_pair_services

test/test_worker.py

@@ -242,6 +242,18 @@ def test_transform_ims_data():
         assert len(v[0]["fibre-routes"]) == 1
         assert v[0]["fibre-routes"][0]["id"] == "carrier_id_3"
 
+    nps = res["node_pair_services"]
+    assert list(nps.keys()) == ["eq_a/eq_b", "eq_b/eq_a"]
+    v1 = nps["eq_a/eq_b"]["circ_id_1"]
+    v2 = nps["eq_a/eq_b"]["circ_id_1"]
+    assert v1 == v2
+    assert json.dumps(v1, sort_keys=True) == json.dumps(v2, sort_keys=True)
+    assert len(v) == 1
+    assert len(v[0]["related-services"]) == 1
+    assert v[0]["related-services"][0]["id"] == "sub_circuit_2"
+    assert len(v[0]["fibre-routes"]) == 1
+    assert v[0]["fibre-routes"][0]["id"] == "carrier_id_3"
+
 
 def test_persist_ims_data(mocker, data_config, mocked_redis):
 
@@ -285,6 +297,10 @@ def test_persist_ims_data(mocker, data_config, mocked_redis):
                 }
             ]
         },
+        "node_pair_services": {
+            "np1": {"id_1": "data for np1"},
+            "np2": {"id_2": "data for np2"},
+        },
         "services_by_type": {},
     }
     for k in r.keys("ims:*"):
@@ -303,6 +319,9 @@ def test_persist_ims_data(mocker, data_config, mocked_redis):
     assert [k.decode("utf-8") for k in r.keys("ims:interface_services:*")] == \
            ["ims:interface_services:if1", "ims:interface_services:if2"]
 
+    assert [k.decode("utf-8") for k in r.keys("ims:node_pair_services:*")] == \
+           ["ims:node_pair_services:np1", "ims:node_pair_services:np2"]
+
     assert [k.decode("utf-8") for k in r.keys("poller_cache:*")] == \
            ["poller_cache:eq1", "poller_cache:eq2"]