Function runSearchEverywhereAcrossSources

public/js/fileListView.js:5441–5546

(term, limit, sources, runId)

}

async function runSearchEverywhereAcrossSources(term, limit, sources, runId) {
  const uniqSources = [];
  const seen = new Set();
  sources.forEach((src) => {
    const id = String(src?.id || '').trim();
    if (!id || seen.has(id)) return;
    seen.add(id);
    uniqSources.push({
      id,
      name: String(src?.name || id),
      type: String(src?.type || ''),
    });
  });

  if (!uniqSources.length) {
    renderSearchEverywhereResults([]);
    if (searchEverywhereStatusEl) searchEverywhereStatusEl.textContent = '';
    return;
  }

  const perSourceLimit = Math.min(limit, 50);
  const statusById = {};
  const labelById = {};
  uniqSources.forEach((src) => {
    statusById[src.id] = 'pending';
    labelById[src.id] = formatSourceBadgeText(src) || src.name || src.id;
  });

  const resultsMap = new Map();
  const reindexedSources = new Set();

  const updateStatus = () => {
    if (!searchEverywhereStatusEl) return;
    const ids = Object.keys(statusById);
    if (!ids.length) {
      searchEverywhereStatusEl.textContent = '';
      return;
    }
    const doneCount = ids.filter(id => statusById[id] !== 'pending').length;
    const pendingLabels = ids.filter(id => statusById[id] === 'pending').map(id => labelById[id]).filter(Boolean);
    const failedLabels = ids.filter(id => statusById[id] === 'error').map(id => labelById[id]).filter(Boolean);

    if (doneCount >= ids.length && pendingLabels.length === 0) {
      if (failedLabels.length) {
        searchEverywhereStatusEl.textContent = `Failed: ${failedLabels.join(', ')}`;
      } else {
        searchEverywhereStatusEl.textContent = '';
      }
      return;
    }

    let text = `${t("loading") || "Loading..."} (${doneCount}/${ids.length})`;
    if (pendingLabels.length) {
      text += ` - Waiting on: ${pendingLabels.join(', ')}`;
    }
    if (failedLabels.length) {
      text += ` - Failed: ${failedLabels.join(', ')}`;
    }