File size: 5,797 Bytes
e4fd6e0 46811bc e4fd6e0 e3566c9 e4fd6e0 46811bc e4fd6e0 46811bc e4fd6e0 46811bc e4fd6e0 46811bc e4fd6e0 46811bc e4fd6e0 c4436fb e4fd6e0 e3566c9 46811bc e4fd6e0 46811bc e4fd6e0 c4436fb 46811bc e4fd6e0 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 | (function () {
function initBatchProgress() {
var page = document.querySelector('.batch-page');
if (!page) {
return;
}
var statusUrl = page.dataset.statusUrl;
var pollMs = 1000;
var expectedTotal = parseInt(page.dataset.expectedTotal || '0', 10) || 0;
var cancelUrl = page.dataset.cancelUrl;
var title = document.getElementById('batchTitle');
var subtitle = document.getElementById('batchSubtitle');
var queueStatus = document.getElementById('queueStatus');
var fill = document.getElementById('progressFill');
var pctLabel = document.getElementById('progressPct');
var currentFile = document.getElementById('currentFile');
var statTotal = document.getElementById('statTotal');
var statProc = document.getElementById('statProcessed');
var statOK = document.getElementById('statSucceeded');
var statFail = document.getElementById('statFailed');
var feedPanel = document.getElementById('feedPanel');
var feedList = document.getElementById('batchFeed');
var donePanel = document.getElementById('donePanel');
var doneSummary = document.getElementById('doneSummary');
var failPanel = document.getElementById('failPanel');
var failList = document.getElementById('failList');
var cancelBtn = document.getElementById('cancelBatch');
var prevIds = [];
var canceled = false;
if (!statusUrl || !title || !subtitle || !fill || !pctLabel || !currentFile || !statTotal || !statProc || !statOK || !statFail || !feedPanel || !feedList || !donePanel || !doneSummary || !failPanel || !failList) {
return;
}
if (cancelBtn && cancelUrl) {
cancelBtn.addEventListener('click', function () {
if (!confirm('Cancel this batch? Any in-progress file may not complete.')) {
return;
}
cancelBtn.disabled = true;
fetch(cancelUrl, { method: 'POST' })
.then(function (response) { return response.json(); })
.then(function (data) {
canceled = true;
title.textContent = 'Batch Canceled';
subtitle.textContent = 'The batch was canceled. You can start a new upload anytime.';
currentFile.textContent = '';
if (queueStatus) {
queueStatus.textContent = '';
}
})
.catch(function () {
cancelBtn.disabled = false;
});
});
}
function poll() {
fetch(statusUrl)
.then(function (response) {
return response.json();
})
.then(function (data) {
if (canceled) {
return;
}
var total = data.total > 0 ? data.total : expectedTotal;
var pct = total > 0 ? Math.round(data.processed / total * 100) : 0;
statTotal.textContent = total;
statProc.textContent = data.processed;
statOK.textContent = data.succeeded;
statFail.textContent = data.failed_ids ? data.failed_ids.length : 0;
if (queueStatus) {
if (typeof data.queue_size === 'number') {
queueStatus.textContent = 'Queue size: ' + data.queue_size;
} else if (data.status === 'pending') {
queueStatus.textContent = 'Queued for processing...';
} else {
queueStatus.textContent = '';
}
}
if (data.status === 'pending' && expectedTotal > 0) {
subtitle.textContent = 'Queued - waiting for a worker. Total files: ' + expectedTotal + '.';
}
fill.style.width = pct + '%';
pctLabel.textContent = pct + '%';
currentFile.textContent = data.current_file ? 'Processing: ' + data.current_file : '';
if (data.image_ids && data.image_ids.length) {
feedPanel.style.display = 'block';
data.image_ids.forEach(function (imageId) {
if (prevIds.indexOf(imageId) === -1) {
prevIds.push(imageId);
var li = document.createElement('li');
var link = document.createElement('a');
link.href = '/case/' + imageId;
link.textContent = imageId;
li.appendChild(link);
feedList.insertBefore(li, feedList.firstChild);
while (feedList.children.length > 20) {
feedList.removeChild(feedList.lastChild);
}
}
});
}
if (data.status === 'canceled') {
title.textContent = 'Batch Canceled';
subtitle.textContent = 'The batch was canceled.';
return;
}
if (data.status === 'completed' || data.status === 'failed') {
title.textContent = 'Batch Complete';
subtitle.textContent = '';
donePanel.style.display = 'block';
var failCount = data.failed_ids ? data.failed_ids.length : 0;
doneSummary.textContent = data.succeeded + ' of ' + total + ' files processed successfully' + (failCount > 0 ? ', ' + failCount + ' failed' : '') + '.';
if (data.failed_ids && data.failed_ids.length) {
failPanel.style.display = 'block';
data.failed_ids.forEach(function (failedId) {
var li = document.createElement('li');
li.textContent = failedId;
failList.appendChild(li);
});
}
return;
}
setTimeout(poll, pollMs);
})
.catch(function () {
setTimeout(poll, pollMs * 3);
});
}
poll();
}
if (document.readyState === 'loading') {
document.addEventListener('DOMContentLoaded', initBatchProgress);
} else {
initBatchProgress();
}
})();
|