This commit is contained in:
oliver committed 2026-10-13 09:47:24 -03:00
1 parent 250280a2c7
commit 796047a39f
3 files changed
+103 -20

No files matched your search

+19 -1
View File
@@ -551,13 +551,31 @@ def backup_move(request: MoveRequest):
class BackupCheckRequest(BaseModel): class BackupCheckRequest(BaseModel):
uuid: str uuid: Optional[str] = None
@app.post("/backup/check", dependencies=[Depends(verify_api_key)]) @app.post("/backup/check", dependencies=[Depends(verify_api_key)])
def backup_check(request: BackupCheckRequest): def backup_check(request: BackupCheckRequest):
if request.uuid:
return {"message": run_command([f"{BIN_PATH}/checkBackup", request.uuid])} return {"message": run_command([f"{BIN_PATH}/checkBackup", request.uuid])}
# No uuid: check all active containers. checkBackup -a exits 1 when any
# backup is NOK, but its table is still the valid result, so don't raise.
result = subprocess.run(
[f"{BIN_PATH}/checkBackup", "-a"], capture_output=True, text=True
)
if result.returncode != 0 and not result.stdout.strip():
raise HTTPException(
status_code=500,
detail=f"checkBackup -a failed: {result.stderr.strip() or 'no output'}",
)
return {"message": result.stdout}
@app.get("/containers/active", dependencies=[Depends(verify_api_key)])
def containers_active():
return {"message": run_command([f"{BIN_PATH}/activeContainers"])}
@app.get("/backup/all", dependencies=[Depends(verify_api_key)]) @app.get("/backup/all", dependencies=[Depends(verify_api_key)])
def backup_all(): def backup_all():
+80 -16
View File
@@ -1,44 +1,108 @@
#!/usr/bin/env python3 #!/usr/bin/env python3
"""Check the latest backup date.
Usage:
checkBackup <uuid> print latest backup date for one container
checkBackup -a check all containers returned by activeContainers;
status is OK if the latest backup is at most 2 days
old, NOK if older or missing
"""
import subprocess
import sys import sys
from datetime import date, datetime
from pathlib import Path from pathlib import Path
BACKUP_ROOT = Path("/BACKUP") BACKUP_ROOT = Path("/BACKUP")
MAX_AGE_DAYS = 2
ACTIVE_CONTAINERS = Path(__file__).resolve().parent / "activeContainers"
if len(sys.argv) < 2:
print("Usage: checkBackup <uuid>")
sys.exit(1)
uuid = sys.argv[1] def check_backup(uuid):
"""Return (ok, message) for the given UUID."""
directory = BACKUP_ROOT / uuid directory = BACKUP_ROOT / uuid
if not directory.is_dir(): if not directory.is_dir():
print(f"ERROR: directory not found for UUID {uuid}") return False, f"ERROR: directory not found for UUID {uuid}"
sys.exit(1)
latest_date = None latest_date = None
latest_file = None latest_file = None
for zip_file in directory.rglob("*.zip"): for zip_file in directory.rglob("*.zip"):
name = zip_file.name date_part = zip_file.name.split("_")[0]
try:
date_part = name.split("_")[0]
if len(date_part) != 8 or not date_part.isdigit(): if len(date_part) != 8 or not date_part.isdigit():
continue continue
except Exception:
continue
if latest_date is None or date_part > latest_date: if latest_date is None or date_part > latest_date:
latest_date = date_part latest_date = date_part
latest_file = zip_file latest_file = zip_file
if latest_date is None: if latest_date is None:
print("NO BACKUPS") return False, "NO BACKUPS"
sys.exit(1)
if latest_file.stat().st_size < 1000: if latest_file.stat().st_size < 1000:
print("01-01-2000") return True, "01-01-2000"
sys.exit(0)
# Format as yyyy-mm-dd # Format as yyyy-mm-dd
print(f"{latest_date[:4]}-{latest_date[4:6]}-{latest_date[6:8]}") return True, f"{latest_date[:4]}-{latest_date[4:6]}-{latest_date[6:8]}"
def is_recent(ok, message):
"""True if the backup date in message is at most MAX_AGE_DAYS old."""
if not ok:
return False
try:
backup_date = datetime.strptime(message, "%Y-%m-%d").date()
except ValueError:
# e.g. the "01-01-2000" placeholder for too-small backup files
return False
return (date.today() - backup_date).days <= MAX_AGE_DAYS
def active_uuids():
"""UUIDs printed by activeContainers (skips header and separator lines)."""
result = subprocess.run(
[str(ACTIVE_CONTAINERS)], capture_output=True, text=True
)
if result.returncode != 0:
print(
f"ERROR: activeContainers failed: {result.stderr.strip()}",
file=sys.stderr,
)
sys.exit(1)
lines = result.stdout.splitlines()
uuids = []
for line in lines[2:]: # line 0 = header, line 1 = "----" separator
fields = line.split()
if fields:
uuids.append(fields[0])
return uuids
def main():
if len(sys.argv) < 2:
print("Usage: checkBackup <uuid> | -a")
sys.exit(1)
if sys.argv[1] == "-a":
rows = [("uuid", "latest", "status")]
failed = False
for uuid in active_uuids():
ok, message = check_backup(uuid)
recent = is_recent(ok, message)
rows.append((uuid, message, "OK" if recent else "NOK"))
failed = failed or not recent
widths = [max(len(row[i]) for row in rows) for i in range(2)]
for uuid, message, status in rows:
print(f"{uuid:<{widths[0]}} {message:<{widths[1]}} {status}")
sys.exit(1 if failed else 0)
ok, message = check_backup(sys.argv[1])
print(message)
sys.exit(0 if ok else 1)
if __name__ == "__main__":
main()
+4 -3
View File
@@ -15,6 +15,7 @@ rex doas chmod 600 /home/4server/.ssh/borg*
# link all save scripts to /usr/sbin # link all save scripts to /usr/sbin
rex doas ln -s /4server/sbin/activeContainers /usr/bin/ rex doas ln -sf /4server/sbin/activeContainers /usr/bin/
rex doas ln -s /4server/sbin/startContainer /usr/bin/ rex doas ln -sf /4server/sbin/startContainer /usr/bin/
rex doas ln -s /4server/sbin/restartContainers /usr/bin/ rex doas ln -sf /4server/sbin/restartContainers /usr/bin/
rex doas ln -sf /4server/sbin/checkBackup /usr/bin/