Function parseWorkQueue

core/fleet/session.js:60–99

(content)

  return String(task.id || '').replace(/^#/, '').trim();
}

function parseWorkQueue(content) {
  const lines = String(content || '').split(/\r?\n/);
  const start = lines.findIndex((line) => /^##\s+Work Queue\s*$/i.test(line.trim()));
  if (start === -1) return [];

  const tableLines = [];
  for (let i = start + 1; i < lines.length; i++) {
    const line = lines[i];
    if (/^##\s+/.test(line.trim())) break;
    if (line.trim().startsWith('|')) tableLines.push(line);
  }

  const headerLine = tableLines.find((line) => !isSeparatorRow(line));
  if (!headerLine) return [];

  const headers = splitCells(headerLine).map(normalizeHeader);
  return tableLines
    .slice(tableLines.indexOf(headerLine) + 1)
    .filter((line) => !isSeparatorRow(line))
    .map((line) => {
      const cells = splitCells(line);
      const row = {};
      headers.forEach((header, index) => {
        row[header] = cells[index] || '';
      });

      return {
        id: taskId({ id: row.id }),
        campaign: row.campaign || '',
        scope: parseList(row.scope),
        deps: parseDeps(row.deps),
        status: normalizeStatus(row.status),
        wave: parseWave(row.wave),
        agent: row.agent || '',
        branch: row.branch || '',
        evidence: row.evidence || '',
      };
    })
    .filter((task) => task.id);
}

function formatList(items) {