Both Agents Dream — Implementation Plan

// Seed/refresh a fixed core list idempotently: confidence/status set only on a
// brand-new key; on re-seed they're omitted so upsertYearning's COALESCE preserves
// any value the agent has since reweighted. source defaults to 'core'.
export async function seedCoreYearnings(
  sql: Sql,
  core: ReadonlyArray<{ key: string; prompt: string }>,
  now: string = new Date().toISOString(),
): Promise<void> {
  const existing = new Set(sql.exec(`SELECT key FROM yearnings`).toArray().map((r) => String(r.key)));
  for (const c of core) {
    const fresh = !existing.has(c.key);
    await upsertYearning(sql, { key: c.key, prompt: c.prompt, source: 'core',
      ...(fresh ? { confidence: 0.2, status: 'open' } : {}) }, now);
  }
}

import type { Sql } from '../sqlh';
import { writeFileRow, readFileRow, listFilePaths } from './files';

export const WIKI_PREFIX = 'wiki';
export const WIKI_INDEX = `${WIKI_PREFIX}/index.md`;
export interface WikiPage { slug: string; title: string; body: string; links?: string[]; }
const pagePath = (slug: string) => `${WIKI_PREFIX}/${slug}.md`;

export async function writeWikiPage(sql: Sql, p: WikiPage, now = new Date().toISOString()) {
  const links = (p.links ?? []).filter(Boolean);
  const linkLine = links.length ? `links: ${links.map((s) => `[[${s}]]`).join(' ')}\n` : '';
  await writeFileRow(sql, pagePath(p.slug), `# ${p.title}\nslug: ${p.slug}\n${linkLine}\n${p.body}\n`, now);
}
export const readWikiPage = (sql: Sql, slug: string) => readFileRow(sql, pagePath(slug));
export async function listWikiSlugs(sql: Sql): Promise<string[]> {
  return (await listFilePaths(sql, WIKI_PREFIX))
    .filter((p) => p !== WIKI_INDEX && p.endsWith('.md'))
    .map((p) => p.slice(WIKI_PREFIX.length + 1, -3));
}
export async function addBacklink(sql: Sql, slug: string, linkTo: string, now = new Date().toISOString()) {
  const body = await readWikiPage(sql, slug);
  if (body === null || body.includes(`[[${linkTo}]]`)) return;
  await writeFileRow(sql, pagePath(slug), `${body.trimEnd()}\nlinks: [[${linkTo}]]\n`, now);
}
export async function rebuildIndex(sql: Sql, now = new Date().toISOString()): Promise<string> {
  const slugs = (await listWikiSlugs(sql)).sort();
  const lines = ['# Wiki index', ''];
  for (const slug of slugs) {
    const body = (await readWikiPage(sql, slug)) ?? '';
    const t = body.match(/^#\s+(.+)$/m);
    lines.push(`- [[${slug}]] ${t ? t[1].trim() : slug}`);
  }
  const content = lines.join('\n') + '\n';
  await writeFileRow(sql, WIKI_INDEX, content, now);
  return content;
}

import type { Sql } from '../sqlh';
import { SqliteEventStreamStore } from '@flue/runtime'; // pinned in the spike

export const sessionStreamPath = (agentType: string, id: string) => `agents/${agentType}/${id}`;

// Read up to `limit` events from this agent's OWN durable stream. The store reads
// the same SQLite Flue persists the conversation to; we never touch flue_session_entries.
export async function readSessionEvents(
  sql: Sql, agentType: string, id: string,
  opts?: { offset?: string; limit?: number },
): Promise<unknown[]> {
  const store = new SqliteEventStreamStore(sql as never);
  const res = await store.readEvents(sessionStreamPath(agentType, id), {
    offset: opts?.offset ?? '-1', limit: opts?.limit ?? 100,
  });
  return (res as { events?: unknown[] }).events ?? [];
}