Changeset 918474d in flexoentity

Timestamp:

11/29/25 18:38:36 (7 weeks ago)

Author:

Enrico Schwass <ennoausberlin@…>

Branches:

master

Children:

4f91fed

Parents:

df459f7

Message:

add EntityRegistry

Files:

• flexoentity/__init__.py (modified) (2 diffs)
• flexoentity/domain_manager.py (modified) (4 diffs)
• flexoentity/entity_registry.py (added)
• flexoentity/flexo_collection.py (modified) (1 diff)
• tests/conftest.py (modified) (2 diffs)

flexoentity/__init__.py

@@ -17 +17 @@
 from .domain_manager import DomainManager, DuplicateDomainError
 from .flexo_signature import FlexoSignature, CertificateReference
+from .entity_registry import EntityRegistry
 from .signing_backends import get_signing_backend
 
@@ -30 +31 @@
     "FlexoCollection",
     "FlexoSignature",
+    "EntityRegistry",
     "CertificateReference",
     "get_signing_backend",

flexoentity/domain_manager.py

@@ -32 +32 @@
     """
 
-    def __init__(self, domains: Iterable[Domain] | None = None):
+    def __init__(self, registry):
         # store is a general-purpose collection
         self._store = FlexoCollection()
-
-        if domains:
-            for dom in domains:
-                self.add(dom)
+        self._registry = registry
 
     # ---------------------------------------------------------------
@@ -65 +62 @@
         return result
 
-    def has(self, domain_id: str) -> bool:
-        """Check if a domain exists."""
-        return self._store.has(domain_id)
+    def can_delete(self, domain_id):
+        return not any(self._registry.entities_by_domain(domain_id))
+
+    def delete(self, domain_id):
+        if not self.can_delete(domain_id):
+            raise ValueError(f"Domain {domain_id} is still referenced.")
+        self.remove(domain_id)
 
     def remove(self, domain_id: str) -> None:
         """Remove a domain (rarely used, mostly for tests)."""
-        if not self._store.has(domain_id):
+        if domain_id not in self._store:
             raise DomainNotFoundError(domain_id)
         self._store.remove(domain_id)
@@ -77 +78 @@
     def all(self) -> list[Domain]:
         """List of all domains."""
-        return list(self._store.values())
+        return self._store.entities()
+
+    def all_domain_ids(self):
+        return self._store.ids() 
 
     def clear(self):
@@ -108 +112 @@
 
     def __contains__(self, domain_id: str) -> bool:
-        return self.has(domain_id)
+        return domain_id in self._store
 
     def __repr__(self) -> str:

flexoentity/flexo_collection.py

@@ -82 +82 @@
     # Additional public helpers (unchanged)
     # ------------------------------------------------------------------
-
     def entities(self):
         """Return all entities as a list."""

tests/conftest.py

@@ -3 +3 @@
 from pathlib import Path
 from datetime import datetime
-from flexoentity import Domain, FlexoSignature, DomainManager
+from flexoentity import Domain, FlexoSignature, DomainManager, EntityRegistry
 from flexoentity import get_signing_backend, CertificateReference
 
@@ -30 +30 @@
 @pytest.fixture
 def sample_domain_manager():
-    return DomainManager()
+    return DomainManager(EntityRegistry())
 
 # ─────────────────────────────────────────────────────────────