From 0ff68ce4bf8384246a7b9e375bd7064bb1540d37 Mon Sep 17 00:00:00 2001
From: Chris Zerafa <chris@zerafa.com>
Date: Mon, 27 Jul 2026 23:08:30 -0400
Subject: [PATCH] Add initial Restic backup telemetry collector

---
 collectors/__init__.py                        |   0
 .../__pycache__/__init__.cpython-313.pyc      | Bin 0 -> 136 bytes
 collectors/__pycache__/backup.cpython-313.pyc | Bin 0 -> 1029 bytes
 collectors/backup.py                          |  32 ++++++++++++++++++
 telemetry/collector.py                        |  22 ++++++++++++
 5 files changed, 54 insertions(+)
 create mode 100644 collectors/__init__.py
 create mode 100644 collectors/__pycache__/__init__.cpython-313.pyc
 create mode 100644 collectors/__pycache__/backup.cpython-313.pyc
 create mode 100644 collectors/backup.py
 create mode 100755 telemetry/collector.py

diff --git a/collectors/__init__.py b/collectors/__init__.py
new file mode 100644
index 0000000..e69de29
diff --git a/collectors/__pycache__/__init__.cpython-313.pyc b/collectors/__pycache__/__init__.cpython-313.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..cfdbacd8160651797de236c8253e50588c0031e2
GIT binary patch
literal 136
zcmey&%ge<81gTOPSs?l`h=2h`DC08=kTI1Zok5e)ZzV$!6Oi{ABy~$&Kfj<vKRvTV
zzbwBpF+H_NKRG`qCpEbwzo=M0K0Y%qvm`!Vub}c4hfQvNN@-52T@fo#AIRKd5aS~=
LBO_xGGmr%UIu#xV

literal 0
HcmV?d00001

diff --git a/collectors/__pycache__/backup.cpython-313.pyc b/collectors/__pycache__/backup.cpython-313.pyc
new file mode 100644
index 0000000000000000000000000000000000000000..b3540928cd12ae9c9a27c2533afab6ef7598bcd7
GIT binary patch
literal 1029
zcmZuvOHbQC5MDoGCngE+gpxol1V~mz+zQc`N~H=>l~&>qLoY}m<19(2V_Umx+C)9%
zSoKo+5~(<}*Z!Lz4n$iHNbRM!p!5fHZ3sxTWBHqzo$>59<LM+43J7GZwB6tV_!&Cq
z!2D1;<4k=91~9m10G(+LaR!fgLl^}}C~}(kJ4juwrF2Lv9YIXWmJSO=c=J{cIy+Wa
z=o}=b1@?BbTv(S|yND)%!Osc~SnJ*m^5RAC!k7StV2G<g7mNsdq<ezHt#bLG?iDfQ
z`!4}7Sp!DYh_RgLl?3MId;UF}J3lg%oG=O2;@ymVvTI%H3Bc<1UHV;Xj&&D^!y7$D
zd~NW|17MZ!Mp(CrS^j?!BbgH?f!4cR6LRWAEjyu3PpfBBRk34wxa1P7&dh9M*P-I3
ziAyzp##+&MnzT%h_y}&eKJk1)MFL+D6pWL~?$(xFc3>@@5C4w}5pt0x&<G|bfmFtR
zrDCEgl?srUWt&Q_6Xa9*2{dg|s@9at%QX=NvqZ4~f*qpCF0l>E^&O%qRLL(ID@zL-
zi_6ccg8fYoxfaBj3dnb;f*|ARSZ)DQ36laN6A(dVkBVVi5!*EjIE=Ags9-~faTTme
zfl6!?zD;PXdnLxfLaC}sr*zjNda+FO9k*&0A<`|^wxLB_g!N6+df|IHuS(_fQ<P=j
z1wG(>26fPi_kL2|yl!UhG?lycg<pyEyY;v0tyu5w&@OI9Gp%%{mFPc}#iUe!+>V22
z@<<*zkVhJi4&||v;qg{_s+G#_Ro+*QQrbaEJ51eR$$d&2h%x0)9P|(GDIb)^?XUA+
z<`4U{`chj01Ea0M?D6nO<J!md=FsG~r_BNVcyz2$-p`%JB5|n=A`z*>=m9qLUZ&7c
z0KqDT^uGf%7T6gEH2R?87JM5%MAw-ctRPM^XbT+2btJ$I`~W>CiK)8Mk<y$Le)tz~
CK<yg<

literal 0
HcmV?d00001

diff --git a/collectors/backup.py b/collectors/backup.py
new file mode 100644
index 0000000..67d777d
--- /dev/null
+++ b/collectors/backup.py
@@ -0,0 +1,32 @@
+#!/usr/bin/env python3
+
+import subprocess
+import json
+
+RESTIC_ENV = "/etc/restic/edge01.env"
+
+
+def collect():
+    cmd = f'. "{RESTIC_ENV}" && restic snapshots --json'
+
+    result = subprocess.run(
+        ["bash", "-c", cmd],
+        capture_output=True,
+        text=True,
+    )
+
+    if result.returncode != 0:
+        return {
+            "state": "offline",
+            "summary": "Restic error",
+            "detail": result.stderr.strip()
+        }
+
+    snapshots = json.loads(result.stdout)
+
+    return {
+        "state": "online",
+        "summary": "Healthy",
+        "detail": f"{len(snapshots)} snapshots",
+        "snapshot_count": len(snapshots)
+    }
diff --git a/telemetry/collector.py b/telemetry/collector.py
new file mode 100755
index 0000000..7e113bc
--- /dev/null
+++ b/telemetry/collector.py
@@ -0,0 +1,22 @@
+#!/usr/bin/env python3
+
+from pathlib import Path
+
+from .common import write_json
+from collectors.backup import collect
+
+OUTPUT = Path("/opt/docker/caddy/site/voyager/data/status.json")
+
+
+def main():
+    payload = {
+        "systems": {
+            "backup": collect()
+        }
+    }
+
+    write_json(OUTPUT, payload)
+
+
+if __name__ == "__main__":
+    main()