function buildQueueFingerprint(url: string, streamer: string, date: string, customClip?: CustomClip): string { const clipFingerprint = customClip ? [ 'clip', customClip.startSec, customClip.durationSec, customClip.startPart, customClip.filenameFormat, (customClip.filenameTemplate || '').trim().toLowerCase() ].join(':') : 'vod'; return [ (url || '').trim().toLowerCase().replace(/^https?:\/\/(www\.)?/, ''), (streamer || '').trim().toLowerCase(), (date || '').trim(), clipFingerprint ].join('|'); } let lastQueueRenderFingerprint = ''; function getQueueRenderFingerprint(items: QueueItem[]): string { const lang = typeof currentLanguage === 'string' ? currentLanguage : 'en'; const pieces = items.map((item) => [ item.id, item.status, Math.round((Number(item.progress) || 0) * 10), item.currentPart || 0, item.totalParts || 0, item.speed || '', item.eta || '', item.progressStatus || '', item.last_error || '', item.mergeGroup?.mergePhase || '' ].join(':')); return `${lang}|${pieces.join('|')}`; } function hasActiveQueueDuplicate(url: string, streamer: string, date: string, customClip?: CustomClip): boolean { const target = buildQueueFingerprint(url, streamer, date, customClip); return queue.some((item) => { if (item.status !== 'pending' && item.status !== 'downloading' && item.status !== 'paused') { return false; } return buildQueueFingerprint(item.url, item.streamer, item.date, item.customClip) === target; }); } async function addToQueue(url: string, title: string, date: string, streamer: string, duration: string): Promise { if ((config.prevent_duplicate_downloads as boolean) !== false && hasActiveQueueDuplicate(url, streamer, date)) { alert(UI_TEXT.queue.duplicateSkipped); return; } queue = await window.api.addToQueue({ url, title, date, streamer, duration_str: duration }); renderQueue(); } async function removeFromQueue(id: string): Promise { queue = await window.api.removeFromQueue(id); renderQueue(); } async function clearCompleted(): Promise { queue = await window.api.clearCompleted(); renderQueue(); } async function retryFailedDownloads(): Promise { queue = await window.api.retryFailedDownloads(); renderQueue(); } function getQueueStatusLabel(item: QueueItem): string { if (item.status === 'completed') return UI_TEXT.queue.statusDone; if (item.status === 'error') return UI_TEXT.queue.statusFailed; if (item.status === 'paused') return UI_TEXT.queue.statusPaused; if (item.status === 'downloading') return UI_TEXT.queue.statusRunning; return UI_TEXT.queue.statusWaiting; } function getQueueProgressText(item: QueueItem): string { if (item.status === 'completed') return '100%'; if (item.status === 'error') return UI_TEXT.queue.progressError; if (item.status === 'paused') return UI_TEXT.queue.progressReady; if (item.status === 'pending') return UI_TEXT.queue.progressReady; if (item.progress > 0) return `${Math.max(0, Math.min(100, item.progress)).toFixed(1)}%`; return item.progressStatus || UI_TEXT.queue.progressLoading; } function getQueueMetaText(item: QueueItem): string { if (item.status === 'error' && item.last_error) { return item.last_error; } const parts: string[] = []; if (item.currentPart && item.totalParts) { parts.push(`${UI_TEXT.queue.part} ${item.currentPart}/${item.totalParts}`); } if (item.speed) { parts.push(`${UI_TEXT.queue.speed}: ${item.speed}`); } if (item.eta) { parts.push(`${UI_TEXT.queue.eta}: ${item.eta}`); } if (!parts.length && item.status === 'pending') { parts.push(UI_TEXT.queue.readyToDownload); } if (!parts.length && item.status === 'paused') { parts.push(UI_TEXT.queue.statusPaused); } if (!parts.length && item.status === 'downloading') { parts.push(item.progressStatus || UI_TEXT.queue.started); } if (!parts.length && item.status === 'completed') { parts.push(UI_TEXT.queue.done); } if (!parts.length && item.status === 'error') { parts.push(UI_TEXT.queue.failed); } return parts.join(' | '); } function toggleQueueSelection(id: string): void { const index = selectedQueueIds.indexOf(id); if (index >= 0) { selectedQueueIds.splice(index, 1); } else { selectedQueueIds.push(id); } renderQueue(); updateMergeGroupButton(); } function updateMergeGroupButton(): void { const btn = byId('btnMergeGroup'); if (!btn) return; // Clean up selections: only keep IDs that are still pending in queue const validIds = new Set( queue.filter(item => item.status === 'pending' && !item.mergeGroup).map(item => item.id) ); selectedQueueIds = selectedQueueIds.filter(id => validIds.has(id)); if (selectedQueueIds.length >= 2) { btn.style.display = ''; btn.textContent = `${UI_TEXT.mergeGroup.btn} (${selectedQueueIds.length})`; btn.disabled = false; } else { btn.style.display = 'none'; } } async function createMergeGroupFromSelection(): Promise { if (selectedQueueIds.length < 2) return; const ids = [...selectedQueueIds]; selectedQueueIds = []; queue = await window.api.createMergeGroup(ids); renderQueue(); updateMergeGroupButton(); } function updateQueueItemProgress(progress: DownloadProgress): void { const items = byId('queueList').children; const idx = queue.findIndex(i => i.id === progress.id); if (idx < 0 || idx >= items.length) return; const el = items[idx]; const bar = el.querySelector('.queue-progress-bar') as HTMLElement; const text = el.querySelector('.queue-progress-text') as HTMLElement; const meta = el.querySelector('.queue-meta') as HTMLElement; if (bar) { const pct = progress.progress > 0 ? Math.min(100, progress.progress) : 0; bar.style.width = `${pct}%`; bar.className = `queue-progress-bar${progress.progress <= 0 ? ' indeterminate' : ''}`; } if (text) text.textContent = getQueueProgressText(queue[idx]); if (meta) meta.textContent = getQueueMetaText(queue[idx]); } function toggleQueueDetails(id: string): void { const el = document.getElementById(`details-${id}`); if (el) el.style.display = el.style.display === 'none' ? 'block' : 'none'; } function initQueueDragDrop(): void { const list = byId('queueList'); list.addEventListener('dragstart', (e: DragEvent) => { const el = (e.target as HTMLElement).closest('.queue-item') as HTMLElement; if (!el) return; draggedQueueItemId = el.dataset.id || null; el.classList.add('dragging'); if (e.dataTransfer) e.dataTransfer.effectAllowed = 'move'; }); list.addEventListener('dragover', (e: DragEvent) => { e.preventDefault(); if (e.dataTransfer) e.dataTransfer.dropEffect = 'move'; }); list.addEventListener('drop', (e: DragEvent) => { e.preventDefault(); const target = (e.target as HTMLElement).closest('.queue-item') as HTMLElement; if (!target || !draggedQueueItemId) return; const targetId = target.dataset.id; if (!targetId || targetId === draggedQueueItemId) return; const fromIdx = queue.findIndex(i => i.id === draggedQueueItemId); const toIdx = queue.findIndex(i => i.id === targetId); if (fromIdx < 0 || toIdx < 0) return; const [moved] = queue.splice(fromIdx, 1); queue.splice(toIdx, 0, moved); window.api.reorderQueue(queue.map(i => i.id)); renderQueue(); }); list.addEventListener('dragend', () => { draggedQueueItemId = null; document.querySelectorAll('.queue-item.dragging').forEach(el => el.classList.remove('dragging')); }); } function renderQueue(): void { if (!Array.isArray(queue)) { queue = []; } const list = byId('queueList'); byId('queueCount').textContent = String(queue.length); const retryBtn = byId('btnRetryFailed'); const hasFailed = queue.some((item) => item.status === 'error'); retryBtn.disabled = !hasFailed; const renderFingerprint = getQueueRenderFingerprint(queue); if (renderFingerprint === lastQueueRenderFingerprint) { return; } if (queue.length === 0) { lastQueueRenderFingerprint = renderFingerprint; list.innerHTML = `
${UI_TEXT.queue.empty}
`; return; } list.innerHTML = queue.map((item: QueueItem) => { const safeTitle = escapeHtml(item.title || UI_TEXT.vods.untitled); const safeStatusLabel = escapeHtml(getQueueStatusLabel(item)); const safeProgressText = escapeHtml(getQueueProgressText(item)); const safeMeta = escapeHtml(getQueueMetaText(item)); const isClip = item.customClip ? '* ' : ''; const hasDeterminateProgress = item.progress > 0 && item.progress <= 100; const progressValue = item.status === 'completed' ? 100 : (hasDeterminateProgress ? Math.max(0, Math.min(100, item.progress)) : 0); const progressClass = item.status === 'downloading' && !hasDeterminateProgress ? ' indeterminate' : ''; const isMergeGroup = !!item.mergeGroup; const showSelector = item.status === 'pending' && !isMergeGroup; const selectionIndex = selectedQueueIds.indexOf(item.id); const isSelected = selectionIndex >= 0; const mergeIcon = isMergeGroup ? ' ' : ''; const mergeMetaExtra = isMergeGroup ? ` (${UI_TEXT.mergeGroup.metaLabel.replace('{count}', String(item.mergeGroup!.items.length))})` : ''; return `
${showSelector ? `
${isSelected ? selectionIndex + 1 : ''}
` : '' }
${mergeIcon}${isClip}${safeTitle}
${safeStatusLabel}
${safeMeta}${mergeMetaExtra}
${safeProgressText}
x
`; }).join(''); updateMergeGroupButton(); lastQueueRenderFingerprint = renderFingerprint; } async function toggleDownload(): Promise { if (downloading) { await window.api.pauseDownload(); return; } const started = await window.api.startDownload(); if (!started) { renderQueue(); alert(UI_TEXT.queue.emptyAlert); } }