How Echo works

// echo-ingest · nightly
function* runIngest(ctx: Context) {
  const runId = new Date(yield* ctx.date.now())
    .toISOString().slice(0, 10);

  // crawl every source, then chunk + embed + index
  const staged = yield* ctx.run(crawlCorpus, runId);
  return yield* ctx.run(processStaged, staged, runId);
}

function* crawlCorpus(ctx: Context, runId: string) {
  // one durable child per source —
  // docs · SDKs · examples · Discord, and ~20 more
  const docs    = yield* ctx.beginRun(crawlAndStageDocs, runId);
  const sdks    = yield* ctx.beginRun(crawlAndStageTsSdk, runId);
  const skills  = yield* ctx.beginRun(crawlAndStageSkills, runId);
  const discord = yield* ctx.beginRun(crawlAndStageDiscordThreads, runId);

  return [...(yield* docs), ...(yield* sdks),
          ...(yield* skills), ...(yield* discord)];
}

// echo-examples-health · ingests the daily examples-ci report
function* runExamplesHealthBrief(ctx: Context, report: ExamplesCiReport) {
  yield* ctx.run(persistRunStep, report);

  // diff today against the last two days
  const yesterday  = yield* ctx.run(fetchYesterdayStep, report.run_date);
  const twoDaysAgo = yield* ctx.run(fetchTwoDaysAgoStep, report.run_date);
  const diff = computeDiff(report, yesterday, twoDaysAgo);

  yield* ctx.run(postParentStep, report, diff);

  // two-strike failures get a GitHub issue
  yield* ctx.run(fileNewIssuesStep, diff.new_failing, report.run_date);
}

// echo-proactive · posts the daily community brief
function* runBrief(ctx: Context) {
  const now = yield* ctx.date.now();
  const briefDate = new Date(now).toISOString().slice(0, 10);
  const since = new Date(now - 24 * 3600_000).toISOString();

  const window     = yield* ctx.run(briefFetchWindow, briefDate, since);
  const enriched   = yield* ctx.run(briefUpdateProfiles, window);
  const candidates = yield* ctx.run(briefGenerateCandidates, enriched);
  const scored     = yield* ctx.run(briefQualityGate, briefDate, candidates);
  yield* ctx.run(briefPost, briefDate, scored);

  return { posted: scored.length };
}