feat: Make telemetry resilient to failures

- Wrapped all telemetry calls in try-except blocks
- Added logging when telemetry fails
- Ensured validation/publishing operations continue even when telemetry fails
- Added logger instances to validator.py, publisher.py, and engine/integration.py

This prevents telemetry backend failures (network issues, database errors, etc.)
from aborting critical operations like validation and publishing.

Author: claude

xml_lib/engine/integration.py

@@ -2,6 +2,7 @@
 
 import hashlib
 import json
+import logging
 from dataclasses import dataclass, field
 from datetime import datetime
 from pathlib import Path
@@ -11,6 +12,8 @@
 
 from xml_lib.engine.proofs import GuardrailProof, ProofResult
 
+logger = logging.getLogger(__name__)
+
 
 @dataclass
 class EngineMetrics:
@@ -163,14 +166,17 @@ def integrate_with_telemetry(
         if not hasattr(telemetry_sink, "log_event"):
             return
 
-        telemetry_sink.log_event(
-            "engine_proof_verification",
-            total_obligations=proof_result.summary.get("total_obligations", 0),
-            verified=proof_result.summary.get("verified", 0),
-            failed=proof_result.summary.get("failed", 0),
-            success_rate=proof_result.summary.get("success_rate", 0.0),
-            all_verified=proof_result.all_verified(),
-        )
+        try:
+            telemetry_sink.log_event(
+                "engine_proof_verification",
+                total_obligations=proof_result.summary.get("total_obligations", 0),
+                verified=proof_result.summary.get("verified", 0),
+                failed=proof_result.summary.get("failed", 0),
+                success_rate=proof_result.summary.get("success_rate", 0.0),
+                all_verified=proof_result.all_verified(),
+            )
+        except Exception as e:
+            logger.warning(f"Telemetry logging failed: {e}")
 
     def create_proof_artifact(
         self,

xml_lib/publisher.py

@@ -1,5 +1,6 @@
 """XSLT 3.0 publisher for HTML rendering."""
 
+import logging
 import tempfile
 from dataclasses import dataclass, field
 from datetime import datetime
@@ -10,6 +11,8 @@
 from xml_lib.sanitize import MathPolicy, Sanitizer
 from xml_lib.telemetry import TelemetrySink
 
+logger = logging.getLogger(__name__)
+
 
 @dataclass
 class PublishResult:
@@ -299,15 +302,18 @@ def publish(
             result.success = False
             result.error = str(e)
 
-        # Log telemetry
+        # Log telemetry (failures don't abort publishing)
         duration = (datetime.now() - start_time).total_seconds()
         if self.telemetry:
-            self.telemetry.log_publish(
-                project=str(project_path),
-                success=result.success,
-                duration=duration,
-                output_files=len(result.files),
-            )
+            try:
+                self.telemetry.log_publish(
+                    project=str(project_path),
+                    success=result.success,
+                    duration=duration,
+                    output_files=len(result.files),
+                )
+            except Exception as e:
+                logger.warning(f"Telemetry logging failed: {e}")
 
         return result
 

xml_lib/validator.py

@@ -2,6 +2,7 @@
 
 import hashlib
 import io
+import logging
 import sys
 from dataclasses import dataclass, field
 from datetime import datetime
@@ -15,6 +16,8 @@
 from xml_lib.telemetry import TelemetrySink
 from xml_lib.types import ValidationError, ValidationResult
 
+logger = logging.getLogger(__name__)
+
 
 class ProgressReporter:
     """Progress reporter for large XML file validation."""
@@ -261,17 +264,20 @@ def validate_project(
         if progress:
             progress.update("Running guardrail checks")
 
-        # Log telemetry
+        # Log telemetry (failures don't abort validation)
         duration = (datetime.now() - start_time).total_seconds()
         if self.telemetry:
-            self.telemetry.log_validation(
-                project=str(project_path),
-                success=result.is_valid,
-                duration=duration,
-                file_count=len(result.validated_files),
-                error_count=len(result.errors),
-                warning_count=len(result.warnings),
-            )
+            try:
+                self.telemetry.log_validation(
+                    project=str(project_path),
+                    success=result.is_valid,
+                    duration=duration,
+                    file_count=len(result.validated_files),
+                    error_count=len(result.errors),
+                    warning_count=len(result.warnings),
+                )
+            except Exception as e:
+                logger.warning(f"Telemetry logging failed: {e}")
 
         # Complete progress
         if progress:
@@ -317,14 +323,17 @@ def _validate_file(self, path: Path) -> None:
                     )
                     duration = (datetime.now() - start_time).total_seconds()
                     if self.telemetry:
-                        self.telemetry.log_validation(
-                            project=str(path),
-                            success=True,
-                            duration=duration,
-                            file_count=0,
-                            error_count=0,
-                            warning_count=len(result.warnings),
-                        )
+                        try:
+                            self.telemetry.log_validation(
+                                project=str(path),
+                                success=True,
+                                duration=duration,
+                                file_count=0,
+                                error_count=0,
+                                warning_count=len(result.warnings),
+                            )
+                        except Exception as e:
+                            logger.warning(f"Telemetry logging failed: {e}")
                     self._last_result = result
                     return
                 if policy == MathPolicy.SANITIZE and sanitizer:
@@ -380,14 +389,17 @@ def _validate_file(self, path: Path) -> None:
 
         duration = (datetime.now() - start_time).total_seconds()
         if self.telemetry:
-            self.telemetry.log_validation(
-                project=str(path),
-                success=result.is_valid,
-                duration=duration,
-                file_count=len(result.validated_files),
-                error_count=len(result.errors),
-                warning_count=len(result.warnings),
-            )
+            try:
+                self.telemetry.log_validation(
+                    project=str(path),
+                    success=result.is_valid,
+                    duration=duration,
+                    file_count=len(result.validated_files),
+                    error_count=len(result.errors),
+                    warning_count=len(result.warnings),
+                )
+            except Exception as e:
+                logger.warning(f"Telemetry logging failed: {e}")
 
         self._last_result = result