diff --git a/src/stowarr/server.py b/src/stowarr/server.py
index abf0e68..20de8f2 100644
--- a/src/stowarr/server.py
+++ b/src/stowarr/server.py
@@ -176,6 +176,8 @@ def do_GET(self):
self.send_json(200, manager.store.move_queue())
elif path == "/api/reconcile-queue":
self.send_json(200, manager.store.reconcile_queue())
+ elif path == "/api/queue-summary":
+ self.send_json(200, manager.store.queue_summary())
elif path == "/api/recovery":
self.send_json(200, manager.recovery_status())
elif path.startswith("/api/operations/") and path.endswith("/events"):
diff --git a/src/stowarr/store.py b/src/stowarr/store.py
index c421c48..5ea6691 100644
--- a/src/stowarr/store.py
+++ b/src/stowarr/store.py
@@ -510,6 +510,26 @@ def move_queue(self, limit: int = 200) -> list[dict]:
for row in rows
]
+ def queue_summary(self) -> dict[str, dict[str, int]]:
+ terminal = ("COMPLETE", "FAILED", "CANCELLED", "INTERRUPTED")
+ result: dict[str, dict[str, int]] = {}
+ with self.lock:
+ for kind, table in (
+ ("move", "move_queue"),
+ ("reconcile", "reconcile_queue"),
+ ):
+ row = self.db.execute(
+ f"""SELECT COUNT(*) AS total,
+ SUM(CASE WHEN state IN (?,?,?,?) THEN 1 ELSE 0 END) AS terminal
+ FROM {table}""", # nosec
+ terminal,
+ ).fetchone()
+ result[kind] = {
+ "total": int(row["total"]),
+ "terminal": int(row["terminal"] or 0),
+ }
+ return result
+
def _clear_queue(self, table: str) -> int:
if table not in {"move_queue", "reconcile_queue"}:
raise ValueError("Unknown queue")
diff --git a/src/stowarr/web/app.js b/src/stowarr/web/app.js
index 29a4e7a..5fa4faf 100644
--- a/src/stowarr/web/app.js
+++ b/src/stowarr/web/app.js
@@ -1,4 +1,4 @@
-const state={authenticated:false,auth:null,config:null,connections:null,serviceStatus:null,runtime:null,recovery:null,recoveryDiagnoses:new Map(),operations:[],queue:[],reconcileQueue:[],operationEvents:new Map(),selectedHistory:new Set(),securityEvents:[],sessions:[],plan:null,movePlan:null,moveTorrent:null,qbitCatalog:null,routingAudit:null,hiddenMoveColumns:new Set(),syncApp:'radarr',sync:{},safeSyncPlans:{},safeWorkflow:null,syncExpanded:new Set(),syncHiddenStatuses:{radarr:new Set(),sonarr:new Set()},operationSections:{completed:false,remaining:false},operationTracking:false,operationTrackingGeneration:0,operationHidden:false,currentOperation:null};
+const state={authenticated:false,auth:null,config:null,connections:null,serviceStatus:null,runtime:null,recovery:null,recoveryDiagnoses:new Map(),operations:[],queue:[],reconcileQueue:[],queueSummary:{move:{total:0,terminal:0},reconcile:{total:0,terminal:0}},operationEvents:new Map(),selectedHistory:new Set(),securityEvents:[],sessions:[],plan:null,movePlan:null,moveTorrent:null,qbitCatalog:null,routingAudit:null,hiddenMoveColumns:new Set(),syncApp:'radarr',sync:{},safeSyncPlans:{},safeWorkflow:null,syncExpanded:new Set(),syncHiddenStatuses:{radarr:new Set(),sonarr:new Set()},operationSections:{completed:false,remaining:false},operationTracking:false,operationTrackingGeneration:0,operationHidden:false,currentOperation:null};
const $=(s,r=document)=>r.querySelector(s);const $$=(s,r=document)=>[...r.querySelectorAll(s)];
const esc=v=>String(v??'').replace(/[&<>'"]/g,c=>({'&':'&','<':'<','>':'>',"'":''','"':'"'}[c]));
const fmtTime=v=>v?new Date(v*1000).toLocaleString(): '—';
@@ -610,13 +610,17 @@ function renderQueue(){
const route=kind==='move'?`${esc(detail.current_pool||'—')} → ${esc(item.target_pool)}`:esc(detail.target_pool||'—');
return `${esc(item.public_id)}${esc(positionLabel)} | ${esc(detail.torrent_name||item.torrent_hash)}${esc(item.torrent_hash)}${error} | ${route} | ${badge(item.state)} | ${operation} | ${fmtTime(item.updated_at)} | ${action} |
`;
}).join(''):`| The ${kind==='move'?'Move':'Reconcile'} queue is empty |
`;
- const removable=rows.filter(item=>QUEUE_TERMINAL_STATES.has(item.state)).length;
+ const removable=state.queueSummary?.[kind]?.terminal??rows.filter(item=>QUEUE_TERMINAL_STATES.has(item.state)).length;
const clearButton=$(`.clear-queue[data-kind="${kind}"]`);
if(clearButton)clearButton.disabled=!removable;
};
render(state.queue||[],'move','#queue-rows');
render(state.reconcileQueue||[],'reconcile','#reconcile-queue-rows');
- const active=[...(state.queue||[]),...(state.reconcileQueue||[])].filter(item=>['QUEUED','RUNNING'].includes(item.state)).length;
+ const summaryKinds=['move','reconcile'];
+ const hasCompleteSummary=summaryKinds.every(kind=>Number.isInteger(state.queueSummary?.[kind]?.total)&&Number.isInteger(state.queueSummary?.[kind]?.terminal));
+ const active=hasCompleteSummary
+ ?summaryKinds.reduce((count,kind)=>count+state.queueSummary[kind].total-state.queueSummary[kind].terminal,0)
+ :[...(state.queue||[]),...(state.reconcileQueue||[])].filter(item=>['QUEUED','RUNNING'].includes(item.state)).length;
$('#queue-count').textContent=(active+(state.recovery?.count||0))||'';
}
@@ -713,7 +717,7 @@ async function refreshQueue(quiet=false,throwOnError=false){
if(!state.authenticated)return;
const previousActiveReconcile=activeReconcileQueueSignature();
try{
- [state.queue,state.reconcileQueue,state.recovery]=await Promise.all([api('/api/queue'),api('/api/reconcile-queue'),api('/api/recovery')]);
+ [state.queue,state.reconcileQueue,state.queueSummary,state.recovery]=await Promise.all([api('/api/queue'),api('/api/reconcile-queue'),api('/api/queue-summary'),api('/api/recovery')]);
renderQueue();
renderRecovery();
automaticallyTrackRunningQueue();
@@ -730,7 +734,7 @@ async function cancelQueue(id,kind='move'){
async function clearQueue(kind){
const label=kind==='reconcile'?'Reconcile':'Move';
const rows=kind==='reconcile'?state.reconcileQueue:state.queue;
- const finished=rows.filter(item=>QUEUE_TERMINAL_STATES.has(item.state)).length;
+ const finished=state.queueSummary?.[kind]?.terminal??rows.filter(item=>QUEUE_TERMINAL_STATES.has(item.state)).length;
if(!finished)return;
const message=`This removes ${finished} finished queue ${finished===1?'entry':'entries'}. Waiting and running work and Operation History are always kept.`;
if(!await confirmAction({title:`Clear finished ${label} jobs?`,message,details:[['Queue',label],['Finished entries removed',String(finished)]],confirmLabel:'Clear finished',danger:true}))return;
@@ -1097,7 +1101,7 @@ async function viewSyncQueue(publicId){
}
async function inspect(hash){navigate('reconcile');$('#torrent-hash').value=hash;$('#global-hash').value=hash;$('#plan-loading').classList.remove('hidden');$('#plan-result').innerHTML='';try{state.plan=await api(`/api/plan/${encodeURIComponent(hash.trim())}`);renderPlan(state.plan)}catch(e){$('#plan-result').innerHTML=`Request failed
${esc(e.message)}