feat: refactor backup with configurable intervals and retention

- Fix env var: HF_BACKUP_REPO -> HF_DATASET
- Add WebDAV env vars: WEBDAV_URL, WEBDAV_USERNAME, WEBDAV_PASSWORD
- Add interval config: BACKUP_WEBDAV_INTERVAL (default 1440min/24h),
BACKUP_HF_INTERVAL (default 10min)
- WebDAV: timestamped files, keep max 10, delete oldest
- HF Dataset: fixed filename, auto-overwrite
- Scheduler uses configurable intervals

backup-manager.py

@@ -91,6 +91,15 @@ class WebDAVClient:
         except:
             return False
 
+    def delete(self, path: str) -> bool:
+        """Delete a file"""
+        try:
+            resp = self.session.delete(self._url(path))
+            return resp.status_code in [200, 204, 404]
+        except Exception as e:
+            print(f"[WebDAV] DELETE error: {e}")
+            return False
+
 
 # G2.2/G2.3: 备份管理器
 class BackupManager:
@@ -106,10 +115,12 @@ class BackupManager:
         self.webdav_user = os.environ.get("WEBDAV_USERNAME", "")
         self.webdav_pass = os.environ.get("WEBDAV_PASSWORD", "")
         self.webdav_path = os.environ.get("WEBDAV_BACKUP_PATH", "/openclaw-backups")
-        
+        self.webdav_interval = int(os.environ.get("BACKUP_WEBDAV_INTERVAL", "1440"))  # minutes, default 24h
+
         # HF Dataset 配置
         self.hf_token = os.environ.get("HF_TOKEN", "")
-        self.hf_repo = os.environ.get("HF_BACKUP_REPO", "")
+        self.hf_repo = os.environ.get("HF_DATASET", "")
+        self.hf_interval = int(os.environ.get("BACKUP_HF_INTERVAL", "10"))  # minutes, default 10min
         
         self.webdav: Optional[WebDAVClient] = None
         self.hf_api: Optional[HfApi] = None
@@ -207,21 +218,33 @@ class BackupManager:
             else:
                 print(f"[Backup] WebDAV upload failed")
                 success = False
-        
+
+            # Keep only latest 10 WebDAV backups
+            try:
+                items = self.webdav.propfind(self.webdav_path)
+                full_backups = sorted([i for i in items if "openclaw_full_" in i.get("href", "")])
+                while len(full_backups) > 10:
+                    oldest = full_backups.pop(0)
+                    oldest_name = oldest.split("/")[-1]
+                    self.webdav.delete(f"{self.webdav_path}/{oldest_name}")
+                    print(f"[Backup] Cleaned old WebDAV backup: {oldest_name}")
+            except Exception as e:
+                print(f"[Backup] WebDAV cleanup error: {e}")
+
         # 备份到 HF Dataset
         if self.hf_api and self.hf_repo:
-            print(f"[Backup] Uploading to HF Dataset: {archive_name}")
+            print(f"[Backup] Uploading to HF Dataset: openclaw_full_latest.tar.gz")
             try:
                 # 确保repo存在
                 try:
                     self.hf_api.repo_info(repo_id=self.hf_repo, repo_type="dataset")
                 except:
                     create_repo(self.hf_repo, repo_type="dataset", token=self.hf_token, private=True)
-                
+
                 # 上传文件
                 upload_file(
                     path_or_fileobj=io.BytesIO(archive_data),
-                    path_in_repo=archive_name,
+                    path_in_repo="openclaw_full_latest.tar.gz",
                     repo_id=self.hf_repo,
                     repo_type="dataset",
                     token=self.hf_token
@@ -291,13 +314,25 @@ class BackupManager:
                 print(f"[Backup] WebDAV incremental upload successful")
             else:
                 success = False
-        
+
+            # Keep only latest 10 WebDAV incremental backups
+            try:
+                items = self.webdav.propfind(self.webdav_path)
+                incr_backups = sorted([i for i in items if "openclaw_incr_" in i.get("href", "")])
+                while len(incr_backups) > 10:
+                    oldest = incr_backups.pop(0)
+                    oldest_name = oldest.split("/")[-1]
+                    self.webdav.delete(f"{self.webdav_path}/{oldest_name}")
+                    print(f"[Backup] Cleaned old WebDAV incremental backup: {oldest_name}")
+            except Exception as e:
+                print(f"[Backup] WebDAV cleanup error: {e}")
+
         if self.hf_api and self.hf_repo:
-            print(f"[Backup] Uploading incremental to HF Dataset: {archive_name}")
+            print(f"[Backup] Uploading incremental to HF Dataset: openclaw_incr_latest.tar.gz")
             try:
                 upload_file(
                     path_or_fileobj=io.BytesIO(archive_data),
-                    path_in_repo=archive_name,
+                    path_in_repo="openclaw_incr_latest.tar.gz",
                     repo_id=self.hf_repo,
                     repo_type="dataset",
                     token=self.hf_token
@@ -369,7 +404,7 @@ class BackupManager:
         try:
             # 列出repo中的文件
             files = self.hf_api.list_repo_files(self.hf_repo, repo_type="dataset")
-            backups = [f for f in files if f.startswith("openclaw_full_")]
+            backups = [f for f in files if f.startswith("openclaw_full_latest")]
             
             if not backups:
                 return False
@@ -430,7 +465,7 @@ class BackupManager:
         """应用 HF Dataset 增量备份"""
         try:
             files = self.hf_api.list_repo_files(self.hf_repo, repo_type="dataset")
-            incr_backups = sorted([f for f in files if f.startswith("openclaw_incr_")])
+            incr_backups = sorted([f for f in files if f.startswith("openclaw_incr_latest")])
             
             for backup_name in incr_backups:
                 print(f"[Backup] Applying incremental: {backup_name}")
@@ -449,17 +484,17 @@ class BackupManager:
     
     # G2.5: 调度器
     def scheduler(self):
-        """后台调度器 - 每小时增量 + 每24小时全量"""
-        print("[Backup] Starting backup scheduler...")
-        
-        # 每小时增量备份
-        schedule.every().hour.do(self.incremental_backup)
-        
-        # 每24小时全量备份
-        schedule.every().day.at("02:00").do(self.full_backup)
-        
-        print("[Backup] Scheduler started (hourly incr, daily full at 02:00)")
-        
+        """后台调度器 - 按配置间隔执行备份"""
+        print(f"[Backup] Starting scheduler: WebDAV every {self.webdav_interval}min, HF every {self.hf_interval}min")
+
+        # WebDAV: full backup at configured interval
+        if self.webdav:
+            schedule.every(self.webdav_interval).minutes.do(self.full_backup)
+
+        # HF Dataset: incremental at configured interval
+        if self.hf_api and self.hf_repo:
+            schedule.every(self.hf_interval).minutes.do(self.incremental_backup)
+
         while True:
             schedule.run_pending()
             time.sleep(60)