diff --git a/ta_symlink.py b/ta_symlink.py
index 062f374..65df857 100644
--- a/ta_symlink.py
+++ b/ta_symlink.py
@@ -902,11 +902,45 @@ def api_transcode_logs():
"next_index": len(transcode_log_buffer)
})
+# Global Scan State
+SCAN_CACHE = {
+ "status": "idle", # idle, scanning, done
+ "results": None,
+ "last_run": None
+}
+SCAN_THREAD = None
+
@app.route("/api/recovery/scan", methods=["POST"])
@requires_auth
def api_recovery_scan():
- files = scan_for_unindexed_videos()
- return jsonify({"files": files, "count": len(files)})
+ global SCAN_THREAD
+
+ if SCAN_CACHE["status"] == "scanning":
+ return jsonify({"status": "running", "message": "Scan already in progress"}), 202
+
+ def run_scan_async():
+ global SCAN_CACHE
+ SCAN_CACHE["status"] = "scanning"
+ SCAN_CACHE["results"] = None
+ try:
+ results = scan_for_unindexed_videos()
+ SCAN_CACHE["results"] = results
+ SCAN_CACHE["status"] = "done"
+ SCAN_CACHE["last_run"] = datetime.now().isoformat()
+ except Exception as e:
+ SCAN_CACHE["status"] = "error"
+ SCAN_CACHE["results"] = str(e)
+ log(f"❌ Async scan failed: {e}")
+
+ SCAN_THREAD = threading.Thread(target=run_scan_async)
+ SCAN_THREAD.start()
+
+ return jsonify({"status": "started", "message": "Background scan started"}), 202
+
+@app.route("/api/recovery/poll", methods=["GET"])
+@requires_auth
+def api_recovery_poll():
+ return jsonify(SCAN_CACHE)
@app.route("/api/recovery/start", methods=["POST"])
@requires_auth
diff --git a/templates/dashboard.html b/templates/dashboard.html
index 731ec09..b2c012c 100644
--- a/templates/dashboard.html
+++ b/templates/dashboard.html
@@ -423,8 +423,7 @@
}
async function scanRecoveryFiles() {
- // Loading state for all tabs
- const loadingRow = '
Scanning...
Scanning in background... (This may take a minute)
- ${f.video_id}${f.filename} ${f.size_mb} MB
- `;
+ // 2. Poll for results
+ const pollInterval = setInterval(async () => {
+ try {
+ const res = await fetch('/api/recovery/poll');
+ const state = await res.json();
+
+ if (state.status === 'done') {
+ clearInterval(pollInterval);
+ renderResults(state.results);
+ } else if (state.status === 'error') {
+ clearInterval(pollInterval);
+ alert("Scan Error: " + state.results);
+ resetTables("Error: " + state.results);
+ }
+ // If 'scanning' or 'idle', keep polling...
+ } catch (e) {
+ clearInterval(pollInterval);
+ console.error("Poll error", e);
}
- if (type === 'rescue') {
- return `
- ${f.video_id}${f.filename} Missing from: ${f.ta_source}
- `;
- }
- if (type === 'redundant') {
- return `
- ${f.video_id}${f.filename} Exists at: ${f.ta_source}
- `;
- }
- };
-
- // Clear & Fill
- ids.forEach(id => {
- const el = document.getElementById(id);
- if (el) el.innerHTML = '';
- });
-
- // Update Badges
- document.getElementById('badge-unindexed').innerText = data.files.unindexed.length;
- document.getElementById('badge-rescue').innerText = data.files.rescue.length;
- document.getElementById('badge-redundant').innerText = data.files.redundant.length;
-
- // Populate Tables
- data.files.unindexed.forEach(f => document.getElementById('tbody-unindexed').innerHTML += renderRow(f, 'unindexed'));
- data.files.rescue.forEach(f => document.getElementById('tbody-rescue').innerHTML += renderRow(f, 'rescue'));
- data.files.redundant.forEach(f => document.getElementById('tbody-redundant').innerHTML += renderRow(f, 'redundant'));
-
- if (data.files.unindexed.length === 0) document.getElementById('tbody-unindexed').innerHTML = 'No unindexed files found. No rescue candidates found. No duplicates found. ${msg}
+ ${f.video_id}${f.filename} ${f.size_mb} MB
+ `;
+ }
+ if (type === 'rescue') {
+ return `
+ ${f.video_id}${f.filename} Missing from: ${f.ta_source}
+ `;
+ }
+ if (type === 'redundant') {
+ return `
+ ${f.video_id}${f.filename} Exists at: ${f.ta_source}
+ `;
+ }
+ };
+
+ const ids = ['tbody-unindexed', 'tbody-rescue', 'tbody-redundant'];
+ ids.forEach(id => document.getElementById(id).innerHTML = '');
+
+ // Update Badges
+ document.getElementById('badge-unindexed').innerText = data.unindexed.length;
+ document.getElementById('badge-rescue').innerText = data.rescue.length;
+ document.getElementById('badge-redundant').innerText = data.redundant.length;
+
+ // Populate
+ data.unindexed.forEach(f => document.getElementById('tbody-unindexed').innerHTML += renderRow(f, 'unindexed'));
+ data.rescue.forEach(f => document.getElementById('tbody-rescue').innerHTML += renderRow(f, 'rescue'));
+ data.redundant.forEach(f => document.getElementById('tbody-redundant').innerHTML += renderRow(f, 'redundant'));
+
+ if (data.unindexed.length === 0) document.getElementById('tbody-unindexed').innerHTML = 'No unindexed files found. No rescue candidates found. No duplicates found.