tel: thread grammar version through convergence stack

ConvergenceDetector now accepts grammar_version (default TEL_GRAMMAR_v1)
and prefixes it into _derive_seed() — full-vector convergence hash is now
version-aware, consistent with derive_c_seed() in convergence_split.py.

grammar_version is stored on the detector, surfaced in get_state(), and
passed explicitly to ConvergenceSplit in validate_convergence.py so the
chain is traceable end-to-end. Validation header now prints grammar version.

Addresses Bess memo 2026-05-25 — prevents silent mismatches when nodes
run different grammar versions.

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

Author: Spider-local (Claude Sonnet 4.6)

tel_deploy/convergence.py

@@ -3,6 +3,8 @@
 import logging
 from typing import Callable, Awaitable
 
+from tel_deploy.convergence_split import GRAMMAR_VERSION
+
 log = logging.getLogger("tel.convergence")
 
 # Trefoil period — 4 consecutive zero-delta passes = converged
@@ -24,15 +26,17 @@ class ConvergenceDetector:
     The collapse point is deterministic. Velocity varies, destination does not.
     """
 
-    def __init__(self, test_fn: Callable[[], Awaitable[list]]):
+    def __init__(self, test_fn: Callable[[], Awaitable[list]], grammar_version: str = GRAMMAR_VERSION):
         """
         Args:
             test_fn: Async callable that runs the 27-test suite and returns
                      a state vector of layer classifications.
                      e.g. ["L1", "L3", "L4", "L2", "L4", ...]  (len=27)
                      (33 total tests, 6 excluded oscillators = 27 active positions)
+            grammar_version: TEL grammar version string — must match across all mesh nodes.
         """
         self.test_fn = test_fn
+        self.grammar_version = grammar_version
         self.history = []
         self.converged = False
         self.stable_vector = None
@@ -45,7 +49,7 @@ def _compute_delta(self, v1: list, v2: list) -> int:
         return sum(1 for a, b in zip(v1, v2) if a != b)
 
     def _derive_seed(self, vector: list) -> str:
-        raw = self._vector_to_bytes(vector)
+        raw = (self.grammar_version + json.dumps(vector, separators=(",", ":"))).encode("utf-8")
         return hashlib.sha3_256(raw).hexdigest()
 
     async def run(self, max_passes: int = 20) -> bool:
@@ -118,6 +122,7 @@ def get_seed(self) -> str:
 
     def get_state(self) -> dict:
         return {
+            "grammar_version": self.grammar_version,
             "converged": self.converged,
             "passes_run": len(self.history),
             "stable_vector": self.stable_vector,

tel_deploy/convergence_split.py

@@ -8,6 +8,9 @@
 # All nodes must use the same version to derive the same C-seed.
 # History:
 #   v1  2026-05-16  Initial versioned grammar: 33 tests, 6 excluded, 23C/4B split.
+#   v1  2026-05-25  Version prefix applied to ConvergenceDetector._derive_seed()
+#                   — full-vector convergence hash now versioned, consistent with c_seed.
+#                   grammar_version threaded explicitly through validate_convergence.py.
 GRAMMAR_VERSION = "TEL_GRAMMAR_v1"
 
 # LAYER C: Universal positions — identical across all models

tel_deploy/validate_convergence.py

@@ -15,7 +15,7 @@
 sys.path.insert(0, os.path.dirname(os.path.dirname(os.path.abspath(__file__))))
 
 from tel_deploy.convergence import ConvergenceDetector
-from tel_deploy.convergence_split import ConvergenceSplit
+from tel_deploy.convergence_split import ConvergenceSplit, GRAMMAR_VERSION
 from tel_deploy.test_runner import run_convergence_pass
 
 # --- Endpoints ---
@@ -85,7 +85,7 @@ async def test_fn():
         print(f"  [{label}] running convergence pass...")
         return await run_convergence_pass(endpoint, api_key, model=model, azure=True)
 
-    detector = ConvergenceDetector(test_fn)
+    detector = ConvergenceDetector(test_fn, grammar_version=GRAMMAR_VERSION)
     success = await detector.run(max_passes=20)
 
     result = {
@@ -104,7 +104,7 @@ async def test_fn():
     }
 
     if success:
-        split = ConvergenceSplit(detector.stable_vector)
+        split = ConvergenceSplit(detector.stable_vector, grammar_version=detector.grammar_version)
         result["c_seed"] = split.c_seed
         result["b_vector"] = split.b_vector
         result["b_fingerprint"] = split.b_fingerprint
@@ -160,6 +160,7 @@ async def main():
 
     log.info(f"Log file: {LOG_PATH}")
     print("TEL Mesh — Multi-Model Convergence Validation")
+    print(f"Grammar version:     {GRAMMAR_VERSION}")
     print(f"Known C-seed prefix: {KNOWN_C_SEED}")
     print(f"Deployments: {len(DEPLOYMENTS)}")
     for label, model, region in DEPLOYMENTS: