fix(backrest): use Connect-RPC endpoints with Basic Auth

This commit is contained in:
2026-04-06 13:18:07 +00:00
parent a940b585e8
commit 9e35e51bbf
@@ -14,38 +14,43 @@ class BackrestClient(BaseHTTPClient):
def __init__(self, settings: Settings) -> None:
super().__init__(settings, "backrest", settings.backrest_base_url)
def _auth(self) -> tuple[str, str] | None:
if self.settings.backrest_username and self.settings.backrest_password:
return (self.settings.backrest_username, self.settings.backrest_password)
return None
async def fetch_status(self) -> BackrestSnapshot:
snapshot = BackrestSnapshot()
if not self.base_url:
logger.info("backrest skipped: base URL missing")
return snapshot
# Backrest uses Connect-RPC: POST /v1.Backrest/{Method}
try:
data = await self._request_json("POST", "/v1.Backrest/GetConfig", json={})
except Exception as exc:
logger.warning("backrest fetch_status GetConfig failed: %s", exc)
return snapshot
auth = self._auth()
# Get config (repo list) via Connect-RPC
data = await self._request_json(
"POST", "/v1.Backrest/GetConfig",
json={},
auth=auth,
)
if not isinstance(data, dict):
return snapshot
repos = data.get("repos") or []
repo_count = len(repos) if isinstance(repos, list) else 0
# Fetch recent operations for backup status
# Get recent operations via Connect-RPC
last_backup_age_hours: float | None = None
error_count = 0
last_backup_status = "unknown"
try:
ops_data = await self._request_json(
"POST",
"/v1.Backrest/GetOperations",
json={"lastN": 20},
)
ops = ops_data.get("operations") or [] if isinstance(ops_data, dict) else []
# backupOp is a oneof field serialised directly at the operation level in proto3 JSON
ops_data = await self._request_json(
"POST", "/v1.Backrest/GetOperations",
json={"lastN": 20},
auth=auth,
)
if isinstance(ops_data, dict):
ops = ops_data.get("operations") or []
backup_ops = [
op for op in ops
if isinstance(op, dict) and op.get("backupOp") is not None
@@ -61,13 +66,12 @@ class BackrestClient(BaseHTTPClient):
now = datetime.now(timezone.utc)
last_backup_age_hours = round((now - ended).total_seconds() / 3600, 1)
status_str = latest.get("status", "")
last_backup_status = (
"ok" if status_str == "STATUS_SUCCESS"
else "error" if status_str == "STATUS_ERROR"
else "unknown"
)
except Exception as exc:
logger.warning("backrest fetch_status GetOperations failed: %s", exc)
if status_str == "STATUS_SUCCESS":
last_backup_status = "ok"
elif status_str == "STATUS_ERROR":
last_backup_status = "error"
else:
last_backup_status = "unknown"
return BackrestSnapshot(
source_status="online",