Function createServer

scripts/dashboard-server.js:337–414

(options)

    midRun: (data.loops || []).some((loop) => !['done', 'stopped', 'verifier-passed'].includes(loop.status || (loop.state && loop.state.status))),
  });
  const hooksState = inspectDirectory(projectRoot, '.planning/telemetry', {
    filter: (name) => /^(hook-timing|hook-errors|audit|agent-runs|task-events)\.jsonl$/.test(name), jsonl: true,
  });
  const handoffsState = inspectDirectory(projectRoot, '.planning/handoffs', { filter: (name) => name.endsWith('.md') });
  const cost = data.snapshot && data.snapshot.cost;
  const costFileState = inspectDirectory(projectRoot, '.planning/telemetry', {
    filter: (name) => name === 'session-costs.jsonl', jsonl: true,
  });
  const costState = costFileState.status === 'unreadable' ? costFileState
    : cost && (cost.session_count > 0 || cost.real_sessions > 0)
      ? source('.planning/telemetry/session-costs.jsonl', 'healthy', cost.data_source || 'telemetry available', cost.session_count || cost.real_sessions)
      : source('.planning/telemetry/session-costs.jsonl', 'unknown', 'no cost telemetry is available');
  let activationState = inspectFile(projectRoot, '.planning/product-proof/activation-report.json', { json: true, schema: 1 });
  if (activationState.status === 'unknown') {
    activationState = inspectFile(projectRoot, '.planning/product-proof/activation-cohort-report.json', { json: true, schema: 1 });
  }
  if (activationState.status === 'unknown') {
    activationState = inspectDirectory(projectRoot, '.planning/telemetry', {
      filter: (name) => name === 'activation.jsonl', jsonl: true,
    });
    if (activationState.status === 'empty') activationState = source('.planning/telemetry/activation.jsonl', 'unknown', 'source is absent');
  }
  return { campaigns: campaignState, fleet: fleetState, forks: forksState, loops: loopsState, hooks: hooksState, handoffs: handoffsState, cost: costState, activation: activationState };
}

function readActivation(projectRoot, state) {
  let cohort = null;
  let cohortNote = 'No shared cohort has been ingested yet.';
  const cohortPath = path.join(projectRoot, '.planning', 'product-proof', 'activation-cohort-report.json');
  if (fs.existsSync(cohortPath)) {
    try {
      cohort = JSON.parse(fs.readFileSync(cohortPath, 'utf8'));
      if (cohort.schema !== 1 || cohort.kind !== 'activation_cohort_report') throw new Error('cohort report is not schema 1');
      cohortNote = 'Explicit, redacted submissions from the public product-proof cohort.';
    } catch (error) {
      cohortNote = `Shared cohort report is unreadable: ${error.message}`;
    }
  }
  if (!state || state.status === 'unknown') return { mode: cohort ? 'cohort_only' : 'unknown', note: 'No local activation report has been recorded.', report: null, cohort, cohort_note: cohortNote };
  if (state.status === 'unreadable') return { mode: 'unreadable', note: state.detail, report: null, cohort, cohort_note: cohortNote };
  try {
    const reportPath = path.join(projectRoot, '.planning', 'product-proof', 'activation-report.json');
    const value = fs.existsSync(reportPath)
      ? JSON.parse(fs.readFileSync(reportPath, 'utf8'))
      : activationReport(projectRoot);
    if (value.schema !== 1) throw new Error('activation report is not schema 1');
    return { mode: value.total_events > 0 ? 'healthy' : 'empty', note: value.total_events > 0 ? 'local, redacted activation evidence' : 'Activation telemetry is enabled but no events are recorded.', report: value, cohort, cohort_note: cohortNote };
  } catch (error) {
    state.status = 'unreadable';
    state.detail = error.message;
    return { mode: 'unreadable', note: error.message, report: null, cohort, cohort_note: cohortNote };
  }
}

// ---------------------------------------------------------------------------
// View derivations (snapshot -> per-endpoint payloads)
// ---------------------------------------------------------------------------