stackchain-dashboard/frontend/search-batch-plan.js

(function (root, factory) {
  const createSearchBatchPlan = factory();
  if (typeof module === 'object' && module.exports) module.exports = createSearchBatchPlan;
  if (root) {
    root.createSearchBatchPlan = createSearchBatchPlan;
    root.mountSearchBatchPlanning = createSearchBatchPlan.mount;
  }
})(typeof globalThis !== 'undefined' ? globalThis : this, function () {
  function createSearchBatchPlan({
    limit = 50,
    resolve = item => Promise.resolve(item),
    claim = item => Promise.resolve(item),
    onChange = () => {},
  } = {}) {
    const maximum = Number.isInteger(limit) && limit > 0 ? limit : 50;
    const selected = new Map();
    let active = false;

    const identity = item => [item?.kind || '', item?.repository || '', item?.number || ''].join(':');
    const eligible = item => item?.kind === 'issue' && item?.state === 'open' &&
      Boolean(item.repository) && Number.isInteger(item.number);
    function snapshot() {
      return { active, count:selected.size, items:Array.from(selected.values()) };
    }
    function changed() {
      const state = snapshot();
      onChange(state);
      return state;
    }
    function start() {
      active = true;
      selected.clear();
      return changed();
    }
    function cancel() {
      active = false;
      selected.clear();
      return changed();
    }
    function toggle(item) {
      if (!active) return 'inactive';
      if (!eligible(item)) return 'ineligible';
      const key = identity(item);
      if (selected.has(key)) {
        selected.delete(key);
        changed();
        return 'removed';
      }
      if (selected.size >= maximum) return 'limit';
      selected.set(key, { ...item });
      changed();
      return 'selected';
    }
    async function prepare(item) {
      const detail = await resolve(item);
      if (detail?.assigned_to_me) return detail;
      if (detail?.claimable) return claim(detail);
      throw new Error('This issue is no longer available to assign.');
    }
    return { identity, eligible, start, cancel, toggle, snapshot, prepare, limit:maximum };
  }

  createSearchBatchPlan.mount = function mountSearchBatchPlanning(
    document, batchFactory, todayWork, getOwner, fetchJson, previewPath, queueToday,
    todaySync, acceptIssue, lookup, render, escapeHtml, escapeAttribute
  ) {
    const get = selector => document.querySelector(selector);
    let processor;
    const plan = createSearchBatchPlan({
      resolve:item => fetchJson(previewPath(item), {headers:{Accept:'application/json'}}),
      claim:detail => fetchJson(
        'api/v1/repos/' + detail.repository.split('/').map(encodeURIComponent).join('/') +
        '/issues/' + encodeURIComponent(detail.number) + '/claim',
        {method:'PATCH', headers:{Accept:'application/json'}}
      ),
      onChange:state => {
        get('#search-batch-actions').hidden = !state.active;
        get('#select-search-results').hidden = state.active;
        get('#queue-selected-search-results').disabled = state.count === 0;
        get('#search-selection-status').textContent = state.count ?
          state.count + ' issue' + (state.count === 1 ? '' : 's') + ' selected.' : 'No issues selected.';
        render();
      },
    });
    processor = batchFactory({
      capacity:() => Math.max(0, todayWork.limit - todayWork.read().length),
      owner:getOwner,
      timeBudget:() => {
        const planning = todayWork.planning();
        return {
          capacity_minutes:planning.capacity_minutes,
          planned_minutes:Object.values(planning.estimates || {}).reduce((sum, minutes) => sum + minutes, 0),
        };
      },
      journalName:'search-today-batch',
      autoMount:false,
      claim:item => plan.prepare(item),
      queue:confirmed => queueToday(acceptIssue(confirmed)),
      persistEstimate:(confirmed, minutes) => {
        const planning = todayWork.planning();
        planning.estimates[todayWork.identity(confirmed)] = minutes;
        todayWork.replacePlanning(planning);
        todaySync.enqueueConfiguration(planning.capacity_minutes, planning.estimates);
        todaySync.flush();
      },
      onProgress:progress => {
        get('#queue-selected-search-results').disabled = progress.status === 'running';
        if (progress.status === 'running') {
          get('#search-selection-status').textContent = 'Planning ' + progress.processed + ' of ' + progress.selected + '…';
        } else if (progress.status === 'full') {
          get('#search-selection-status').textContent = 'Today has ' + progress.available + ' remaining slot' +
            (progress.available === 1 ? '.' : 's.');
        } else if (progress.status === 'estimates-required') {
          get('#search-batch-estimate-summary').textContent = 'Estimate every selected issue.';
        } else if (progress.status === 'over-budget') {
          get('#search-batch-estimate-summary').textContent = progress.requested_minutes +
            ' min selected · ' + progress.remaining_minutes + ' min remain.';
        } else if (progress.status === 'complete') {
          get('#cmd-search-action-status').textContent = progress.failed.length ?
            progress.queued.length + ' queued · ' + progress.failed.length + ' need retry.' :
            progress.queued.length + ' added to Today.';
          get('#resume-search-batch').hidden = processor.pending() === 0;
          closeEstimateReview();
          if (!progress.failed.length) plan.cancel();
        }
      },
    });
    function estimateValues() {
      return Object.fromEntries(Array.from(document.querySelectorAll('[data-search-batch-estimate]')).map(input =>
        [input.dataset.searchBatchEstimate, Number(input.value)]
      ));
    }
    function closeEstimateReview() {
      get('#search-batch-estimate-review').hidden = true;
      get('#search-batch-actions').hidden = !plan.snapshot().active;
    }
    function openEstimateReview(items) {
      const planning = todayWork.planning();
      const planned = Object.values(planning.estimates || {}).reduce((sum, minutes) => sum + minutes, 0);
      const remaining = Math.max(0, planning.capacity_minutes - planned);
      get('#search-batch-estimate-summary').textContent = remaining +
        ' min remain. Estimate before assigning.';
      get('#search-batch-estimate-list').innerHTML = items.map(item => {
        const id = String(item.repository || '') + '#' + String(item.number || '');
        const estimate = planning.estimates?.[id] || '';
        return '<div class="search-batch-estimate-row"><div><span class="small">' + escapeHtml(id) +
          '</span><strong>' + escapeHtml(item.title || 'Untitled work') + '</strong></div><label class="small">' +
          '<input type="number" inputmode="numeric" min="5" max="1440" step="5" value="' +
          escapeAttribute(estimate) + '" data-search-batch-estimate="' + escapeAttribute(id) +
          '" aria-label="Estimate for ' + escapeAttribute(item.title || id) + ' in minutes" /> min</label></div>';
      }).join('');
      get('#search-batch-actions').hidden = true;
      get('#search-batch-estimate-review').hidden = false;
      document.querySelector('[data-search-batch-estimate]')?.focus();
    }
    get('#select-search-results').addEventListener('click', () => plan.start());
    get('#cancel-search-selection').addEventListener('click', () => plan.cancel());
    get('#queue-selected-search-results').addEventListener('click', () => {
      const items = plan.snapshot().items;
      const capacity = todayWork.planning().capacity_minutes;
      if (Number.isInteger(capacity) && capacity > 0) openEstimateReview(items);
      else processor.run(items);
    });
    get('#cancel-search-batch-estimates').addEventListener('click', closeEstimateReview);
    get('#confirm-search-batch-estimates').addEventListener('click', () =>
      processor.run(plan.snapshot().items, estimateValues())
    );
    get('#resume-search-batch').addEventListener('click', () => processor.resume());
    get('#open-palette').addEventListener('click', () => restore());
    get('#cmd-results').addEventListener('change', event => {
      const index = event.target?.dataset?.searchSelect;
      if (index === undefined) return;
      const result = lookup(Number(index));
      if (result) plan.toggle(result);
    });
    function restore() {
      const pending = processor.pending();
      get('#resume-search-batch').hidden = pending === 0;
      get('#resume-search-batch').textContent = 'Resume ' + pending + ' interrupted';
    }
    function resultHtml(result, index) {
      const allowed = result.kind === 'issue' && result.state === 'open';
      const selected = plan.snapshot().items.some(item => plan.identity(item) === plan.identity(result));
      return '<label class="cmd-select-result"' + (allowed ? '' : ' aria-disabled="true"') + '>' +
        '<input type="checkbox" data-search-select="' + index + '" ' + (selected ? 'checked ' : '') +
        (allowed ? '' : 'disabled ') + 'aria-label="Select ' + escapeAttribute(result.title) + '" />' +
        '<span>' + escapeHtml(result.title) + '</span><span class="cmd-meta">' +
        escapeHtml(result.repository) + ' #' + escapeHtml(result.number) + ' · ' +
        (allowed ? 'Open issue' : 'Not eligible') + '</span></label>';
    }
    return { plan, processor, restore, resultHtml };
  };

  return createSearchBatchPlan;
});