Update storage_handler.py

storage_handler.py

@@ -99,6 +99,27 @@ def ensure_bucket():
 
 ensure_bucket()
 
+# storage_handler.py – add after ensure_bucket() call at bottom of file
+import threading
+
+def _sync_bucket_interval():
+    """
+    Periodic sync task: runs every 60 seconds.
+    Uses HfFileSystem which already writes directly to the bucket,
+    so this function logs stats and verifies the connection is alive.
+    """
+    def _sync():
+        while True:
+            time.sleep(60)
+            try:
+                stats = get_storage_stats()
+                logger.info(f"📦 Bucket sync heartbeat — {stats['file_count']} files / {stats['total_size_mb']} MB")
+            except Exception as e:
+                logger.warning(f"⚠️  Bucket sync heartbeat failed: {e}")
+    t = threading.Thread(target=_sync, daemon=True)
+    t.start()
+
+_sync_bucket_interval()
 # ------------------------------------------------------------------------
 # Encryption / Decryption
 # ------------------------------------------------------------------------