refresh disk info trigger

pytorrent/services/workers.py

@@ -220,6 +220,29 @@ def _job_event_meta(payload: dict) -> dict:
     return meta
 
 
+
+
+def _remove_job_deletes_data(action_name: str, payload: dict, result: dict | None = None) -> bool:
+    # Note: Disk usage refreshes only when a remove job actually requested data deletion.
+    if str(action_name or "") != "remove":
+        return False
+    if bool((payload or {}).get("remove_data")):
+        return True
+    ctx = (payload or {}).get("job_context") or {}
+    return bool(ctx.get("remove_data") or (result or {}).get("remove_data"))
+
+
+def _emit_disk_refresh_requested(profile_id: int, action_name: str, payload: dict, result: dict | None = None) -> None:
+    if not _remove_job_deletes_data(action_name, payload, result):
+        return
+    # Note: The browser performs the fresh /api/system/disk read so user-specific disk monitor preferences stay respected.
+    _emit("disk_refresh_requested", {
+        "profile_id": int(profile_id),
+        "action": str(action_name or ""),
+        "hash_count": len((payload or {}).get("hashes") or []),
+        "reason": "remove_data_done",
+    })
+
 def _execute(profile: dict, action_name: str, payload: dict, user_id: int | None = None):
     if action_name == "smart_queue_check":
         from . import smart_queue
@@ -350,8 +373,10 @@ def _run(job_id: str):
         _set_job(job_id, "done", result=result, finished=True)
         operation_logs.record_job_event(profile["id"], job["action"], "done", payload, result=result or {}, job_id=job_id, user_id=int(job.get("user_id") or 0))
         _emit("operation_finished", {"job_id": job_id, "action": job["action"], "profile_id": profile["id"], "hashes": payload.get("hashes") or [], "hash_count": len(payload.get("hashes") or []), "bulk": len(payload.get("hashes") or []) > 1, "result": result, **event_meta})
-        # Note: Completed jobs must publish a fresh torrent snapshot/patch so removed or moved torrents disappear without a page reload.
+        # Note: Remove-with-data jobs ask connected browsers to refresh disk usage immediately after filesystem deletion finishes.
         action_name = str(job["action"] or "")
+        _emit_disk_refresh_requested(int(profile["id"]), action_name, payload, result or {})
+        # Note: Completed jobs must publish a fresh torrent snapshot/patch so removed or moved torrents disappear without a page reload.
         _emit_torrent_refresh(profile, action_name)
         _schedule_delayed_torrent_refresh(profile, action_name)
         _emit("job_update", {"id": job_id, "profile_id": profile["id"], "status": "done", "result": result})