@@ -840,6 +855,61 @@ export const searchPanelMethods = {
return html;
},
+ wireSearchProgressCancelButtons(container, missing, state = null, { workflowKey = this.getWorkflowScopedQueueKey() } = {}) {
+ if (!container || !missing) return;
+ container.querySelectorAll?.('.mr-search-progress-cancel').forEach(button => {
+ if (button.dataset.mlCancelSearchBound === '1') return;
+ button.dataset.mlCancelSearchBound = '1';
+ button.addEventListener('click', (event) => {
+ event.preventDefault();
+ event.stopPropagation();
+ const source = button.dataset.source || '';
+ const runId = button.dataset.runId || state?.activeSearchRunId || '';
+ this.cancelSearchSource(missing, source, runId, { workflowKey });
+ });
+ });
+ },
+
+ cancelSearchSource(missing, source, runId = '', { workflowKey = this.getWorkflowScopedQueueKey() } = {}) {
+ if (!missing || !source || !runId) return false;
+
+ const missingSearchKey = this.getMissingSearchKey(missing);
+ const state = this.getSearchStateForWorkflow(workflowKey, missing);
+ const job = this.getBackgroundSearchJob(workflowKey, missingSearchKey);
+ if (!state || state.activeSearchRunId !== runId || !job || job.runId !== runId) return false;
+
+ job.cancelledSources = job.cancelledSources || new Set();
+ job.cancelledSources.add(source);
+ const controller = job.sourceControllers?.get(source);
+ if (controller && !controller.signal?.aborted) {
+ controller.abort();
+ }
+
+ this.clearSearchProgressTimer(runId, source);
+ this.setSourceProgress(state, source, {
+ status: 'cancelled',
+ percent: 100,
+ message: 'Cancelled',
+ error: null
+ }, missing, { workflowKey });
+
+ const hasRunningSources = Object.entries(state.sourceProgress || {}).some(([entrySource, progress]) => (
+ entrySource !== source
+ && (progress?.status === 'pending' || progress?.status === 'running')
+ && !job.cancelledSources?.has(entrySource)
+ ));
+
+ if (!hasRunningSources) {
+ state.activeSearchRunId = null;
+ this.clearSearchProgressTimers(runId);
+ this.backgroundSearchJobs?.delete(this.getBackgroundSearchJobKey(workflowKey, missingSearchKey));
+ }
+
+ this.persistSearchStateForWorkflow(workflowKey, missing, state);
+ this.refreshSearchUiForMissing(missing, state, { workflowKey });
+ return true;
+ },
+
/**
* Update source selector buttons and helper text for one card
*/