feat: add fallback backup manifests and recovery telemetry events

src/clawops/recovery/backends.py

@@ -12,7 +12,7 @@
 type RunCommandFunc = Callable[..., ExecResult]
 type TarWriter = Callable[
     [pathlib.Path],
-    None,
+    dict[str, object],
 ]
 
 
@@ -21,7 +21,9 @@ class BackupBackend(Protocol):
 
     name: str
 
-    def create(self, archive_tmp_path: pathlib.Path) -> tuple[bool, str | None]:
+    def create(
+        self, archive_tmp_path: pathlib.Path
+    ) -> tuple[bool, str | None, dict[str, object] | None]:
         """Create one archive and return status + optional failure reason."""
         ...
 
@@ -39,16 +41,18 @@ def is_available(self) -> bool:
         """Return whether the OpenClaw executable is available."""
         return self._which("openclaw") is not None
 
-    def create(self, archive_tmp_path: pathlib.Path) -> tuple[bool, str | None]:
+    def create(
+        self, archive_tmp_path: pathlib.Path
+    ) -> tuple[bool, str | None, dict[str, object] | None]:
         """Create one archive through OpenClaw."""
         result = self._run_command(
             ["openclaw", "backup", "create", str(archive_tmp_path)],
             timeout_seconds=600,
         )
         if result.ok:
-            return True, None
+            return True, None, None
         detail = result.stderr.strip() or result.stdout.strip() or "openclaw backup create failed"
-        return False, detail
+        return False, detail, None
 
 
 class TarBackupBackend:
@@ -59,7 +63,9 @@ class TarBackupBackend:
     def __init__(self, *, writer: TarWriter) -> None:
         self._writer = writer
 
-    def create(self, archive_tmp_path: pathlib.Path) -> tuple[bool, str | None]:
+    def create(
+        self, archive_tmp_path: pathlib.Path
+    ) -> tuple[bool, str | None, dict[str, object] | None]:
         """Create one archive through the fallback tar writer."""
-        self._writer(archive_tmp_path)
-        return True, None
+        manifest = self._writer(archive_tmp_path)
+        return True, None, manifest

src/clawops/recovery/models.py

@@ -49,3 +49,4 @@ class BackupCreateExecution:
     mode: str | None = None
     fallback_used: bool = False
     fallback_reason: str | None = None
+    manifest: dict[str, object] | None = None

src/clawops/recovery/orchestrator.py

@@ -13,7 +13,7 @@
 from clawops.strongclaw_runtime import CommandError, ExecResult
 
 type RunCommandFunc = Callable[..., ExecResult]
-type TarWriter = Callable[[pathlib.Path], None]
+type TarWriter = Callable[[pathlib.Path], dict[str, object]]
 type SafeUnlink = Callable[[pathlib.Path], None]
 
 
@@ -49,7 +49,7 @@ def create_backup_execution(
     fallback_reason: str | None = None
     if openclaw_backend.is_available():
         safe_unlink(archive_tmp_path)
-        backend_ok, backend_error = openclaw_backend.create(archive_tmp_path)
+        backend_ok, backend_error, _ = openclaw_backend.create(archive_tmp_path)
         if backend_ok:
             archive_tmp_path.replace(archive_path)
             return BackupCreateExecution(
@@ -65,8 +65,9 @@ def create_backup_execution(
 
     safe_unlink(archive_tmp_path)
     fallback_backend = TarBackupBackend(writer=tar_writer)
+    fallback_manifest: dict[str, object] | None = None
     try:
-        fallback_backend.create(archive_tmp_path)
+        _, _, fallback_manifest = fallback_backend.create(archive_tmp_path)
         archive_tmp_path.replace(archive_path)
     except (OSError, tarfile.TarError) as exc:
         safe_unlink(archive_tmp_path)
@@ -79,4 +80,5 @@ def create_backup_execution(
         mode="tar-fallback",
         fallback_used=fallback_reason is not None,
         fallback_reason=fallback_reason,
+        manifest=fallback_manifest,
     )

src/clawops/recovery/telemetry.py

@@ -4,7 +4,9 @@
 
 from collections.abc import Mapping
 
+from clawops.observability import TelemetryValue
 
-def event_payload(event: str, fields: Mapping[str, object]) -> dict[str, object]:
+
+def event_payload(event: str, fields: Mapping[str, TelemetryValue]) -> dict[str, TelemetryValue]:
     """Build one structured recovery telemetry payload."""
     return {"event": event, **dict(fields)}