feat(runtime): compose and install passive modules

Author: Philip Z

src/teaql/runtime/context.py

@@ -159,6 +159,10 @@ def with_module(self, module: Any) -> 'UserContext':
             module.apply_to(self)
         return self
 
+    def install(self, module: Any) -> 'UserContext':
+        """Install a passive runtime manifest without changing database schemas."""
+        return self.with_module(module)
+
     def set_initial_graphs(self, graphs: List[Any]):
         self._initial_graphs = graphs
 
@@ -630,6 +634,10 @@ def get_service(self, name: str) -> Optional[Any]:
     def require_service(self, name: str) -> Any:
         return self._ctx.require_resource(name)
 
+    def install(self, module: Any) -> 'TeaqlRuntime':
+        self._ctx.install(module)
+        return self
+
 from enum import Enum, auto
 from dataclasses import dataclass, field
 from datetime import datetime, timedelta

src/teaql/runtime/module.py

@@ -36,6 +36,18 @@ def audit_event_sink(self, sink: Any) -> 'RuntimeModule':
         self._audit_sinks.append(sink)
         return self
 
+    def and_module(self, other: 'RuntimeModule') -> 'RuntimeModule':
+        combined = RuntimeModule.new()
+        combined._entities = [*self._entities, *other._entities]
+        combined._behaviors = {**self._behaviors, **other._behaviors}
+        combined._dependencies = {**self._dependencies, **other._dependencies}
+        combined._audit_sinks = [*self._audit_sinks, *other._audit_sinks]
+        combined._initial_graphs = [
+            *getattr(self, '_initial_graphs', []),
+            *getattr(other, '_initial_graphs', []),
+        ]
+        return combined
+
     def apply_to(self, ctx: UserContext):
         for name, dep in self._dependencies.items():
             ctx.insert_resource(name, dep)

tests/runtime/test_runtime.py

@@ -30,6 +30,13 @@ def test_runtime_module_initialization():
     assert "Dummy" in behaviors
     assert isinstance(behaviors["Dummy"], DummyBehavior)
 
+def test_runtime_module_composes_and_installs_without_schema_changes():
+    first = RuntimeModule.new().entity(DummyEntity)
+    second = RuntimeModule.new().provide_custom_dependency("dummy", DummyDependency())
+    ctx = UserContext.new().install(first.and_module(second))
+    assert DummyEntity in ctx.require_resource("entities")
+    assert isinstance(ctx.require_resource("dummy"), DummyDependency)
+
 @pytest.mark.asyncio
 async def test_runtime_module_configure():
     module = RuntimeModule.new()