tests: add update parameter to subscription

Modify 2 subscriptions to test the update parameter. The
module_change_cb is called on sysrepo update events.

Signed-off-by: Jeremie Leska <[email protected]>

Author: jeremie6wind

tests/test_subs_module_change.py

@@ -45,13 +45,13 @@ def test_module_change_sub(self):
         expected_changes = []
 
         def module_change_cb(event, req_id, changes, private_data):
-            self.assertIn(event, ("change", "done", "abort"))
+            self.assertIn(event, ("change", "done", "abort", "update"))
             self.assertIs(private_data, priv)
             for c in changes:
                 if c.xpath == "/sysrepo-example:conf/system/hostname":
                     if event == "change" and c.value == "INVALID":
                         raise sysrepo.SysrepoValidationFailedError("invalid hostname")
-            if event in ("change", "done"):
+            if event in ("change", "done", "update"):
                 self.assertEqual(changes, expected_changes)
             if event == "done":
                 sysrepo.update_config_cache(current_config, changes)
@@ -61,6 +61,7 @@ def module_change_cb(event, req_id, changes, private_data):
             "/sysrepo-example:conf",
             module_change_cb,
             private_data=priv,
+            update=True,
         )
 
         with self.conn.start_session("running") as ch_sess:
@@ -316,15 +317,15 @@ def test_module_change_sub_unsafe(self):
 
         def module_change_cb(session, event, req_id, private_data):
             self.assertIsInstance(session, SysrepoSession)
-            self.assertIn(event, ("change", "done", "abort"))
+            self.assertIn(event, ("change", "done", "abort", "update"))
             self.assertIsInstance(req_id, int)
             self.assertIs(private_data, priv)
             changes = list(session.get_changes("/sysrepo-example:conf//."))
             for c in changes:
                 if c.xpath == "/sysrepo-example:conf/system/hostname":
                     if event == "change" and c.value == "INVALID":
                         raise sysrepo.SysrepoValidationFailedError("invalid hostname")
-            if event in ("change", "done"):
+            if event in ("change", "done", "update"):
                 self.assertEqual(changes, expected_changes)
             if event == "done":
                 sysrepo.update_config_cache(current_config, changes)
@@ -334,6 +335,7 @@ def module_change_cb(session, event, req_id, private_data):
             "/sysrepo-example:conf",
             module_change_cb,
             private_data=priv,
+            update=True,
         )
 
         with self.conn.start_session("running") as ch_sess: