Function deriveViews

scripts/dashboard-server.js:232–286

(data)

  }
}

function readPendingIntents(projectRoot) {
  const intents = new Map();
  const directory = path.join(projectRoot, '.planning', 'intents', 'pending');
  try {
    if (!fs.existsSync(directory) || fs.lstatSync(directory).isSymbolicLink()) return intents;
    const realRoot = fs.realpathSync(projectRoot);
    const realDirectory = fs.realpathSync(directory);
    if (escapesRoot(realRoot, realDirectory)) return intents;
    for (const name of fs.readdirSync(realDirectory).filter((entry) => entry.endsWith('.json')).sort()) {
      const file = path.join(realDirectory, name);
      if (fs.lstatSync(file).isSymbolicLink()) continue;
      const record = JSON.parse(fs.readFileSync(file, 'utf8'));
      const intent = record.protocol_intent;
      if (!intent || record.result?.outcome !== 'accepted' || typeof record.capability !== 'string') continue;
      intents.set(intent.operation_id, { intent_id: intent.intent_id, action: record.capability });
    }
  } catch {
    return new Map();
  }
  return intents;
}

function source(pathname, status, detail, count = null, unreadable = []) {
  return { path: pathname.replace(/\\/g, '/'), status, detail, count, unreadable };
}

function inspectDirectory(projectRoot, relativeDir, options = {}) {
  const absolute = path.join(projectRoot, relativeDir);
  if (!fs.existsSync(absolute)) return source(relativeDir, 'unknown', 'source is absent');
  let names;
  try {
    names = fs.readdirSync(absolute).filter((name) => !options.filter || options.filter(name));
  } catch (error) {
    return source(relativeDir, 'unreadable', error.message, null, [relativeDir]);
  }
  if (names.length === 0) return source(relativeDir, 'empty', 'source exists and is empty', 0);
  const unreadable = [];
  if (options.json) {
    for (const name of names) {
      try { JSON.parse(fs.readFileSync(path.join(absolute, name), 'utf8')); }
      catch { unreadable.push(`${relativeDir}/${name}`.replace(/\\/g, '/')); }
    }
  }
  if (options.jsonl) {
    for (const name of names) {
      let lines;
      try { lines = fs.readFileSync(path.join(absolute, name), 'utf8').split(/\r?\n/).filter(Boolean); }
      catch { unreadable.push(`${relativeDir}/${name}`.replace(/\\/g, '/')); continue; }
      if (lines.some((line) => { try { JSON.parse(line); return false; } catch { return true; } })) {
        unreadable.push(`${relativeDir}/${name}`.replace(/\\/g, '/'));
      }
    }
  }
  if (unreadable.length) return source(relativeDir, 'unreadable', `${unreadable.length} file(s) could not be parsed`, names.length, unreadable);
  return source(relativeDir, options.midRun ? 'mid-run' : 'healthy', options.midRun ? 'work is active' : 'source is readable', names.length);
}