Mirrors/Dispatcharr
1
0
Fork 1
mirror of https://github.com/Dispatcharr/Dispatcharr.git synced 2026-01-23 02:35:14 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 2

ytre

Browse source
This commit is contained in:
Dispatcharr 2025-10-10 14:24:22 -05:00
parent 607fb28ad8
commit 92d8ccd257
2 changed files with 25 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

1
apps/media_library/tasks.py
View file

@ -424,6 +424,7 @@ def scan_library_task(
for file_id in sorted(pending_probe_ids):
probe_media_task.apply_async(args=(file_id,), **options)
probes_scheduled = True
pending_probe_ids.clear()
def refresh_stage_counters() -> None:
nonlocal metadata_total_count, metadata_processed_count, artwork_total_count, artwork_processed_count

35
frontend/src/components/library/LibraryScanDrawer.jsx
View file

@ -68,6 +68,9 @@ const stageColorMap = {
artwork: 'red',
};
const PROGRESS_REFRESH_DELTA = 25;
const PROGRESS_REFRESH_INTERVAL_MS = 15000;
const LibraryScanDrawer = ({
opened,
onClose,
@ -89,6 +92,7 @@ const LibraryScanDrawer = ({
const hasQueuedRef = useRef(false);
const lastProcessedRef = useRef(0);
const lastLibraryRefreshRef = useRef(0);
const refreshInFlightRef = useRef(false);
const handleRefresh = useCallback(
() => fetchScans(libraryId),
@ -170,28 +174,37 @@ const LibraryScanDrawer = ({
useEffect(() => {
if (!opened) return;
if (!hasRunningScan && !hasQueuedScan) {
lastProcessedRef.current = totalProcessed;
return;
}
const now = Date.now();
const prevProcessed = lastProcessedRef.current;
const shouldRefreshLibrary =
(hasRunningScan || hasQueuedScan) &&
(totalProcessed > prevProcessed ||
now - lastLibraryRefreshRef.current > 15000);
const processedDelta = Math.max(0, totalProcessed - prevProcessed);
const elapsedSinceRefresh = now - lastLibraryRefreshRef.current;
if (!shouldRefreshLibrary) {
if (totalProcessed > prevProcessed) {
lastProcessedRef.current = totalProcessed;
}
const shouldRefreshLibrary =
processedDelta >= PROGRESS_REFRESH_DELTA ||
elapsedSinceRefresh >= PROGRESS_REFRESH_INTERVAL_MS;
if (!shouldRefreshLibrary || refreshInFlightRef.current) {
return;
}
lastProcessedRef.current = totalProcessed;
lastLibraryRefreshRef.current = now;
refreshInFlightRef.current = true;
const mediaStore = useMediaLibraryStore.getState();
const activeIds = mediaStore.activeLibraryIds || [];
void mediaStore.fetchItems(
activeIds.length > 0 ? activeIds : undefined
);
void mediaStore
.fetchItems(activeIds.length > 0 ? activeIds : undefined)
.finally(() => {
refreshInFlightRef.current = false;
});
}, [opened, hasRunningScan, hasQueuedScan, totalProcessed]);
useEffect(() => {