Define connector runtime preview contract

2026-08-02 14:54:44 +02:00
parent c6ef644842
commit af5c6af0e7
3 changed files with 312 additions and 0 deletions
@@ -0,0 +1,70 @@
+from __future__ import annotations
+
+import unittest
+from datetime import UTC, datetime
+
+from govoplan_core.core.connector_runtime import (
+    CONNECTOR_RUNTIME_CONTRACT_VERSION,
+    ConnectorContractError,
+    ConnectorDryRunResult,
+    ConnectorEffectPreview,
+    ConnectorEndpoint,
+    summarize_connector_effects,
+)
+
+
+class ConnectorRuntimeContractTests(unittest.TestCase):
+    def test_endpoint_rejects_embedded_credentials(self) -> None:
+        with self.assertRaisesRegex(ConnectorContractError, "must not contain credentials"):
+            ConnectorEndpoint(url="ldaps://user:secret@directory.example.test")
+
+    def test_dry_run_is_bounded_consistent_and_apply_gated(self) -> None:
+        effects = (
+            ConnectorEffectPreview(
+                effect="create",
+                source_object_ref="ldap:uid=one",
+                sample={"display_name": "Example Person"},
+            ),
+            ConnectorEffectPreview(
+                effect="unchanged",
+                source_object_ref="ldap:uid=two",
+                target_object_ref="contact-2",
+            ),
+        )
+        result = ConnectorDryRunResult(
+            contract_version=CONNECTOR_RUNTIME_CONTRACT_VERSION,
+            source_ref="source-1",
+            source_revision="revision-1",
+            source_fingerprint="a" * 64,
+            input_hash="b" * 64,
+            generated_at=datetime(2026, 8, 2, tzinfo=UTC),
+            summary=summarize_connector_effects(effects),
+            effects=effects,
+            apply_token="plan-1",
+        )
+
+        self.assertEqual(1, result.summary.creates)
+        self.assertEqual(1, result.summary.unchanged)
+        self.assertTrue(result.can_apply)
+
+    def test_summary_must_describe_exact_returned_effects(self) -> None:
+        with self.assertRaisesRegex(ConnectorContractError, "summary counts"):
+            ConnectorDryRunResult(
+                contract_version=CONNECTOR_RUNTIME_CONTRACT_VERSION,
+                source_ref="source-1",
+                source_revision="revision-1",
+                source_fingerprint="a" * 64,
+                input_hash="b" * 64,
+                generated_at=datetime(2026, 8, 2, tzinfo=UTC),
+                summary=summarize_connector_effects(()),
+                effects=(
+                    ConnectorEffectPreview(
+                        effect="create",
+                        source_object_ref="source:one",
+                    ),
+                ),
+            )
+
+
+if __name__ == "__main__":
+    unittest.main()