Добавлены флаги для возможности указания допусимости изменения / удаления item'ов

examples/extension_service/servicer.py

@@ -87,6 +87,9 @@ class Servicer(ExtensionService):
         ),
         SyncPolicyItem(
             collection_id="test_collection",
+            # Запрет на изменение или удаление записи политики синхронизации
+            with_update=False,
+            with_delete=False,
         ),
         Item(
             collection_id="secrets",

perxis/extensions/extension_setup.py

@@ -584,19 +584,12 @@ class ExtensionSetup:
         )
 
         for item in self.items:
-            try:
-                if item.rules:
-                    all_rules_satisfied = all(
-                        [
-                            await rule(item, space_id, env_id)
-                            for rule
-                            in item.rules
-                        ]
-                    )
+            all_rules_satisfied = await item.all_rules_is_satisfied(space_id, env_id)
 
             if not all_rules_satisfied:
                 continue
 
+            try:
                 message = await wrapper.find(
                     collection_id=item.collection_id,
                     env_id=env_id,
@@ -624,14 +617,7 @@ class ExtensionSetup:
         )
 
         for item in self.items:
-            if item.rules:
-                all_rules_satisfied = all(
-                    [
-                        await rule(item, space_id, env_id)
-                        for rule
-                        in item.rules
-                    ]
-                )
+            all_rules_satisfied = await item.all_rules_is_satisfied(space_id, env_id)
 
             if not all_rules_satisfied:
                 continue
@@ -714,14 +700,7 @@ class ExtensionSetup:
         )
 
         for item in self.items:
-            if item.rules:
-                all_rules_satisfied = all(
-                    [
-                        await rule(item, space_id, env_id)
-                        for rule
-                        in item.rules
-                    ]
-                )
+            all_rules_satisfied = await item.all_rules_is_satisfied(space_id, env_id)
 
             if not all_rules_satisfied:
                 continue