X-Git-Url: https://osm.etsi.org/gitweb/?p=osm%2FNBI.git;a=blobdiff_plain;f=osm_nbi%2Ftests%2Ftest_instance_topics.py;h=9dc5cc16fd3b25caa588f028d6a61ccd28707ba6;hp=14abde734a5c3110003961a2d2686c50d8226bae;hb=f0441eadb3653b045aa8919907ba089e8fce849a;hpb=c3ee9cb2997aa717529e3e8936370084defcfde0;ds=sidebyside diff --git a/osm_nbi/tests/test_instance_topics.py b/osm_nbi/tests/test_instance_topics.py index 14abde7..9dc5cc1 100644 --- a/osm_nbi/tests/test_instance_topics.py +++ b/osm_nbi/tests/test_instance_topics.py @@ -250,11 +250,13 @@ class TestNsrTopic(unittest.TestCase): self.db.set_one = Mock() self.nsr_topic.delete(session, self.nsr_id) - db_args = self.db.del_one.call_args[0] + db_args_ro_nsrs = self.db.del_one.call_args_list[1][0] + db_args = self.db.del_one.call_args_list[0][0] msg_args = self.msg.write.call_args[0] self.assertEqual(msg_args[0], self.nsr_topic.topic_msg, "Wrong message topic") self.assertEqual(msg_args[1], "deleted", "Wrong message action") self.assertEqual(msg_args[2], {"_id": self.nsr_id}, "Wrong message content") + self.assertEqual(db_args_ro_nsrs[0], "ro_nsrs", "Wrong DB topic") self.assertEqual(db_args[0], self.nsr_topic.topic, "Wrong DB topic") self.assertEqual(db_args[1]["_id"], self.nsr_id, "Wrong DB ID") self.assertEqual(db_args[1]["_admin.projects_read.cont"], [p_id], "Wrong DB filter") @@ -287,11 +289,13 @@ class TestNsrTopic(unittest.TestCase): self.fs.file_delete.reset_mock() self.nsr_topic.delete(session_force, self.nsr_id) - db_args = self.db.del_one.call_args[0] + db_args_ro_nsrs = self.db.del_one.call_args_list[1][0] + db_args = self.db.del_one.call_args_list[0][0] msg_args = self.msg.write.call_args[0] self.assertEqual(msg_args[0], self.nsr_topic.topic_msg, "Wrong message topic") self.assertEqual(msg_args[1], "deleted", "Wrong message action") self.assertEqual(msg_args[2], {"_id": self.nsr_id}, "Wrong message content") + self.assertEqual(db_args_ro_nsrs[0], "ro_nsrs", "Wrong DB topic") self.assertEqual(db_args[0], self.nsr_topic.topic, "Wrong DB topic") self.assertEqual(db_args[1]["_id"], self.nsr_id, "Wrong DB ID") self.db.set_one.assert_not_called()