f1b4d69 · daf5573 · 65654ce · 8bdc877 · 23b4bec · 77cbaa8
@@ -18,6 +18,8 @@
- `.talk-copy` — a quiet text button that copies a message or a code block.
- `.talk-suggest` — the starter questions on an empty chat; each fills the composer.
- `.talk-jump` — "Latest" button, shown when you have scrolled up from the end.
- `.talk-chats` — the conversations list above the chat (#8814): New, the person's conversations newest first, and the Archived filter link.
- `.talk-here` — the line naming the open conversation, with its Rename and Archive forms.
- `.talk-steps` — the quiet steps line under a reply ("read 3 files, opened #12").
- `.talk-links` — the links under a reply to what the turn opened or changed.
- `.talk-replaced` — a turn the person edited, regenerated or retried past: kept in the log, dimmer, labelled "replaced".
@@ -18,6 +18,16 @@
A reply streams in over `GET /talk/stream?after=<turn id>` (server-sent events,
When the agent asks first (`needs_confirm`), the turn draws **Confirm** (the existing yes) and **Cancel** (a no: the confirm is spent, nothing runs, a turn says it was cancelled). A result shown once (an invite link) is drawn by Settings → Confirms instead, where Confirm leads.
## Many conversations (#8814)
A person has any number. `/talk` is their latest, with the list above it (newest activity first), **New**, and **Archived (n)** as the one filter (`/talk?archived=1`). Each opens at `/talk/<id>`, stable across reloads; Rename and Archive/Restore are plain forms (`POST /talk/:id/rename`, `/talk/:id/archive`, `POST /talk/new`), so they work without the script. Another person's id is 404 everywhere. A message with no conversation named goes to the latest one that is not archived.
- **Cap:** a person holds at most 100 conversations, archived ones counted; past it New is refused (page flash, API 409 `too_many`, MCP `too_many`). Stop ends every reply the person has running, in any conversation.
- **API:** `GET /api/v1/conversations[?archived=1]`, `POST /api/v1/conversations {title?}`, `PATCH /api/v1/conversations/:id {title?, archived?}`; `conversation` on `POST …/messages` and `GET …/turns?conversation=` picks one.
- **MCP:** `say` with `action` list | new | rename | archive | restore, and `conversation` to speak in one.
- **Terminal:** Palette → Conversations: `n` new, `r` rename, `x` archive or restore, `a` the archived list, Enter opens one (its last 50 turns; `s` says something in it, `r` reloads); the same calls, so the web list and stream read what it writes.
- Sending to an archived conversation keeps it archived; the page says so above the composer.
## Edit, regenerate, retry (#8817)
Three actions on the last exchange, one door, `talkAgain()` in `src/actions/talk.ts` (the same 12-a-minute throttle and refusals as sending):
@@ -28,6 +38,7 @@
Three actions on the last exchange, one door, `talkAgain()` in `src/actions/talk
- Refused while a turn runs (`running`, 409), or when there is nothing to act on (`nothing`, 409).
- **Web:** Edit under your last message (opens the composer holding it, `/talk?edit=1`; Send resends), Regenerate under the last reply, Retry under a failed one. All are plain forms or links, so they work without the script, which only does them in place. They post to `POST /talk/again/edit|regenerate|retry`, from your own signed-in browser only.
- **Terminal:** `ssh <forge> talk-again edit <words>`, `ssh <forge> talk-again regenerate`, `ssh <forge> talk-again retry`.
- With several conversations they act on the one open: the forms post to `/talk/<id>/again/<how>` (`/talk/again/<how>` on the latest); the action takes the conversation as an optional argument.
- There is no API or MCP door for these yet.
## Stop
@@ -64,7 +75,7 @@
Prior art read: Vercel AI Elements (Apache-2.0 React on shadcn; anatomy and beha
| Starter questions on an empty chat (links to `/talk?q=`, so they work without the script) | this pull | AI Elements `Suggestion` |
| Stick to bottom, "Latest" jump button | this pull | AI Elements `Conversation` |
| Thinking as one closed line; a steps line under a reply ("read 3 files, opened #12"); links to each issue, pull, file or app the turn opened or changed | this pull | AI Elements `Reasoning`, `ChainOfThought` |
| Many conversations: new, list, search, rename, archive, URL each | next pull | needs a migration: today one row per person |
| Many conversations: new, list, rename, archive, URL each | have (#8814) | search is not added yet |
| Edit and resend, regenerate, Retry (see below) | have (#8817) | replaced turns are kept and marked, not deleted |
| Queue and Steer while an answer runs | #8819 | `Queue` / `PromptInput` |
| Cost under each reply and how full the context is (header, and in the terminal) | this pull | the run's own usage record, never an estimate |
@@ -6,6 +6,7 @@
 */
import type { App } from "../app.ts";
import { getConversation } from "../core/conversations.ts";
import type { ConversationFile } from "../core/conversation_files.ts";
import { RateLimiter } from "../core/ratelimit.ts";
import type { User } from "../core/users.ts";
@@ -19,6 +20,7 @@
export type TalkRefusal = SayRefusal | RedoRefusal | "off" | "rate_limited";
/** What each refusal says, with its status. */
export const TALK_WORDS: Readonly<Record<TalkRefusal, readonly [number, string]>> = {
  not_found: [404, "no such conversation"],
  unauthorized: [401, "sign in to talk to the forge"],
  empty: [422, "say something"],
  too_long: [422, "the message is too long"],
@@ -50,23 +52,24 @@
const watch = (app: App, said: Said): void => {
  said.done?.catch((error: unknown) => app.log.error("conversation turn crashed", { error: String(error) }));
};
export function talk(app: App, user: User | undefined, text: string, files: readonly ConversationFile[] = [], during: During = "inject"): Result<Said, TalkRefusal> {
export function talk(app: App, user: User | undefined, text: string, files: readonly ConversationFile[] = [], during: During = "inject", conversationId?: string): Result<Said, TalkRefusal> {
  if (user === undefined) return err("unauthorized");
  if (conversationId !== undefined && getConversation(app.db, user.id, conversationId) === undefined) return err("not_found");
  const options = conversationOptions(app);
  if (options === undefined) return err("off");
  if (!take(app, user)) return err("rate_limited");
  const said = say(app, options, user.id, text, files, during);
  const said = say(app, options, user.id, text, files, during, conversationId);
  if (said.ok) watch(app, said.value);
  return said;
}
/** Edit the last message and resend it, regenerate the last reply, or retry a failed turn (#8817). */
export function talkAgain(app: App, user: User | undefined, how: RedoHow, text = ""): Result<Said, TalkRefusal> {
/** Edit the last message and resend it, regenerate the last reply, or retry a failed turn (#8817), in the named conversation or the latest. */
export function talkAgain(app: App, user: User | undefined, how: RedoHow, text = "", conversationId?: string): Result<Said, TalkRefusal> {
  if (user === undefined) return err("unauthorized");
  const options = conversationOptions(app);
  if (options === undefined) return err("off");
  if (!take(app, user)) return err("rate_limited");
  const said = redo(app, options, user.id, how, text);
  const said = redo(app, options, user.id, how, text, conversationId);
  if (said.ok) watch(app, said.value);
  return said;
}
@@ -82,5 +85,5 @@
export function stopTalk(app: App, user: User | undefined): Result<true, "unauth
export const cancelTalk = (app: App, user: User | undefined, queuedId: string): boolean => user !== undefined && cancelQueued(app, user.id, queuedId);
/** The person's waiting messages, oldest first. */
export const queuedTalk = (app: App, user: User | undefined): readonly { id: string; text: string }[] =>
  user === undefined ? [] : queuedOf(app, user.id).map((q) => ({ id: q.id, text: q.text }));
export const queuedTalk = (app: App, user: User | undefined, conversationId?: string): readonly { id: string; text: string }[] =>
  user === undefined ? [] : queuedOf(app, user.id, conversationId).map((q) => ({ id: q.id, text: q.text }));
@@ -5,6 +5,6 @@
export const route: Route = {
  path: "/api/v1/conversation/turns",
  summary: "The signed-in person's conversation with the forge's agent: the latest turns, oldest first, and whether an answer is being written now",
  auth: true,
  query: { limit: "integer", before: "string" },
  query: { limit: "integer", before: "string", conversation: "string" },
  reply: { running: "boolean", turns: "array" },
};
@@ -0,0 +1,10 @@
import type { Route } from "../shared.ts";
export const route: Route = {
  method: "get",
  path: "/api/v1/conversations",
  summary: "The signed-in person's conversations with the forge's agent, newest activity first; archived: 1 lists the put-away ones",
  auth: true,
  query: { archived: "string" },
  reply: { conversations: "array" },
};
@@ -58,6 +58,7 @@
export { route as getApiV1CloudAccounts } from "./getApiV1CloudAccounts.ts";
export { route as getApiV1Contribute } from "./getApiV1Contribute.ts";
export { route as getApiV1ConversationFilesId } from "./getApiV1ConversationFilesId.ts";
export { route as getApiV1ConversationTurns } from "./getApiV1ConversationTurns.ts";
export { route as getApiV1Conversations } from "./getApiV1Conversations.ts";
export { route as getApiV1CrewNow } from "./getApiV1CrewNow.ts";
export { route as getApiV1CrewScorecard } from "./getApiV1CrewScorecard.ts";
export { route as getApiV1Explore } from "./getApiV1Explore.ts";
@@ -184,6 +185,7 @@
export { route as getContractOpenapiJson } from "./getContractOpenapiJson.ts";
export { route as getMetrics } from "./getMetrics.ts";
export { route as patchApiV1AdminSettings } from "./patchApiV1AdminSettings.ts";
export { route as patchApiV1AgentsUsername } from "./patchApiV1AgentsUsername.ts";
export { route as patchApiV1ConversationsId } from "./patchApiV1ConversationsId.ts";
export { route as patchApiV1ForgeFollowing } from "./patchApiV1ForgeFollowing.ts";
export { route as patchApiV1ReposOwnerName } from "./patchApiV1ReposOwnerName.ts";
export { route as patchApiV1ReposOwnerNameApp } from "./patchApiV1ReposOwnerNameApp.ts";
@@ -218,6 +220,7 @@
export { route as postApiV1ConversationFiles } from "./postApiV1ConversationFile
export { route as postApiV1ConversationMessages } from "./postApiV1ConversationMessages.ts";
export { route as postApiV1ConversationStop } from "./postApiV1ConversationStop.ts";
export { route as postApiV1ConversationTokens } from "./postApiV1ConversationTokens.ts";
export { route as postApiV1Conversations } from "./postApiV1Conversations.ts";
export { route as postApiV1Drills } from "./postApiV1Drills.ts";
export { route as postApiV1FeedChips } from "./postApiV1FeedChips.ts";
export { route as postApiV1FeedInteractions } from "./postApiV1FeedInteractions.ts";
@@ -0,0 +1,11 @@
import type { Route } from "../shared.ts";
export const route: Route = {
  method: "patch",
  path: "/api/v1/conversations/{id}",
  summary: "Rename a conversation (title) or put it away and bring it back (archived: true or false); another person's id is 404",
  auth: true,
  body: { title: "string", archived: "boolean" },
  reply: { conversation: "object" },
  refusals: { invalid_title: "title is over 80 characters or has a line break (422)", not_found: "no such conversation of yours (404)", forbidden: "the request is cross-origin, or the token is read-only" },
};
@@ -6,9 +6,10 @@
export const route: Route = {
  summary: "Say something to the forge's own agent, as the signed-in person: it answers through the forge's MCP with that person's permissions, resuming their conversation; a message sent while it answers is handed to the turn, or with `during` (optional) set to `queue` waits for it (at most 5), or set to `steer` stops it and goes at once; answers 202 at once, read the answer from the turns; at most 12 a minute per person",
  auth: true,
  status: 202,
  body: { text: "string" },
  body: { text: "string", conversation: "string" },
  reply: { how: "string" },
  refusals: {
    not_found: "conversation names none of the person's (404)",
    invalid_text: "text is not a string of 1 to 20000 characters",
    invalid_during: "during is not queue or steer",
    file_taken: "an attached file already waits in a queued message (409)",
@@ -0,0 +1,12 @@
import type { Route } from "../shared.ts";
export const route: Route = {
  method: "post",
  path: "/api/v1/conversations",
  summary: "Start a new, empty conversation with the forge's agent; answers it, and it opens at /talk/<id>",
  auth: true,
  status: 201,
  body: { title: "string" },
  reply: { conversation: "object" },
  refusals: { invalid_title: "title is over 80 characters or has a line break (422)", forbidden: "the request is cross-origin, or the token is read-only" },
};
@@ -1,8 +1,9 @@
/**
 * A person's conversation with the forge: one per person, stored turn by turn
 * in the database so it reads back after a restart. Every call takes the
 * person's id and answers only for their own conversation; another person's
 * conversation is `not_found`. Plain data in, plain data out, no authz beyond
 * A person's conversations with the forge, stored turn by turn in the
 * database so they read back after a restart. A person has any number: each
 * has an id (its URL), a title they may change, and may be archived. Every
 * call takes the person's id and answers only for their own conversation;
 * another person's conversation is `not_found`. Plain data in, plain data out, no authz beyond
 * that ownership.
 */
import type { Database } from "bun:sqlite";
@@ -25,8 +26,14 @@
export interface Conversation {
  readonly claudeSessionId: string;
  readonly createdAt: string;
  readonly updatedAt: string;
  readonly title: string;
  /** When it was put away; null while it is in the list. */
  readonly archivedAt: string | null;
}
/** Longest title kept, in characters; longer is refused, not cut. */
export const TITLE_MAX = 80;
export interface Turn {
  readonly id: string;
  readonly conversationId: string;
@@ -45,6 +52,8 @@
interface ConversationRow {
  claude_session_id: string;
  created_at: string;
  updated_at: string;
  title: string;
  archived_at: string | null;
}
interface TurnRow {
@@ -63,6 +72,8 @@
const conversationOf = (r: ConversationRow): Conversation => ({
  claudeSessionId: r.claude_session_id,
  createdAt: r.created_at,
  updatedAt: r.updated_at,
  title: r.title,
  archivedAt: r.archived_at,
});
const turnOf = (r: TurnRow): Turn => ({
@@ -75,18 +86,87 @@
const turnOf = (r: TurnRow): Turn => ({
  failed: r.failed === 1,
});
/** The person's conversation, made on first use. */
export function openConversation(db: Database, userId: string): Conversation {
/** Most conversations a person holds, archived ones included; past it, New is refused. */
export const CONVERSATIONS_MAX = 100;
/** What every door says when New is refused. */
export const TOO_MANY_WORDS = `you hold ${CONVERSATIONS_MAX} conversations, the most there can be; keep talking in one of them`;
/** Start a new conversation at a person's request: refused past `CONVERSATIONS_MAX`. */
export function createConversation(db: Database, userId: string): Result<Conversation, "too_many"> {
      
        sentinelcrew
        11d ago
        
      
      Count then insert outside a transaction: concurrent New can exceed the cap. Wrap in db.transaction.
    
  return db.transaction((): Result<Conversation, "too_many"> => {
    const held = db.query("SELECT COUNT(*) AS n FROM conversation WHERE user_id = ?1").get(userId) as { n: number };
    return held.n >= CONVERSATIONS_MAX ? err("too_many") : ok(newConversation(db, userId));
  }).immediate();
}
/** Start a new, empty conversation. */
export function newConversation(db: Database, userId: string): Conversation {
  const now = new Date().toISOString();
  const row: ConversationRow = { id: id(), user_id: userId, claude_session_id: "", created_at: now, updated_at: now, title: "", archived_at: null };
  db.query(
    "INSERT OR IGNORE INTO conversation (id, user_id, claude_session_id, created_at, updated_at) VALUES (?1,?2,'',?3,?3)",
  ).run(id(), userId, now);
  const row = db
    .query("SELECT * FROM conversation WHERE user_id = ?1")
    .get(userId) as ConversationRow;
    "INSERT INTO conversation (id, user_id, claude_session_id, created_at, updated_at) VALUES (?1,?2,'',?3,?3)",
  ).run(row.id, userId, now);
  return conversationOf(row);
}
/**
 * Where a message with no conversation named goes: the person's most recently
 * active conversation that is not archived, made on first use.
 */
export function openConversation(db: Database, userId: string): Conversation {
  const row = db
    .query("SELECT * FROM conversation WHERE user_id = ?1 AND archived_at IS NULL ORDER BY updated_at DESC, rowid DESC LIMIT 1")
    .get(userId) as ConversationRow | null;
  return row === null ? newConversation(db, userId) : conversationOf(row);
}
/** One of the person's conversations by id; another person's is nothing. */
export function getConversation(db: Database, userId: string, conversationId: string): Conversation | undefined {
  const row = db
    .query("SELECT * FROM conversation WHERE id = ?1 AND user_id = ?2")
    .get(conversationId, userId) as ConversationRow | null;
  return row === null ? undefined : conversationOf(row);
}
/** The person's conversations, newest activity first; `archived` picks the put-away ones instead. */
export function listConversations(db: Database, userId: string, opts: { readonly archived?: boolean } = {}): Conversation[] {
  const rows = db
    .query(
      `SELECT * FROM conversation WHERE user_id = ?1 AND archived_at IS ${opts.archived === true ? "NOT" : ""} NULL ORDER BY updated_at DESC, rowid DESC LIMIT 200`,
    )
    .all(userId) as ConversationRow[];
  return rows.map(conversationOf);
}
/** Give a conversation a title (1 to `TITLE_MAX` characters, no line breaks); an empty one clears it. */
export function renameConversation(
  db: Database,
  userId: string,
  conversationId: string,
  title: string,
): Result<Conversation, "not_found" | "bad_title"> {
  const clean = title.trim();
  if (clean.length > TITLE_MAX || /[\u0000-\u001f\u007f]/.test(clean)) return err("bad_title");
  const changed = db.query("UPDATE conversation SET title = ?3 WHERE id = ?1 AND user_id = ?2").run(conversationId, userId, clean).changes;
  const found = changed === 0 ? undefined : getConversation(db, userId, conversationId);
  return found === undefined ? err("not_found") : ok(found);
}
/** Put a conversation away, or bring it back (`archived` false). It keeps its turns and its URL. */
export function archiveConversation(
  db: Database,
  userId: string,
  conversationId: string,
  archived: boolean,
): Result<Conversation, "not_found"> {
  const changed = db
    .query("UPDATE conversation SET archived_at = ?3 WHERE id = ?1 AND user_id = ?2")
    .run(conversationId, userId, archived ? new Date().toISOString() : null).changes;
  const found = changed === 0 ? undefined : getConversation(db, userId, conversationId);
  return found === undefined ? err("not_found") : ok(found);
}
const owned = (db: Database, userId: string, conversationId: string): boolean =>
  db
    .query("SELECT 1 FROM conversation WHERE id = ?1 AND user_id = ?2")
@@ -0,0 +1,1 @@
9377b1d4965fc75f3dc2cc16d200869bb905c2de6cef959967845ea8347d5f67
@@ -0,0 +1,30 @@
// Many conversations a person (#8814): the one-per-person UNIQUE goes, and a
// conversation gains a title and an archived mark. SQLite cannot drop a
// UNIQUE in place, so the table is copied; its turns and runs are held aside
// first (and the attachments, which hang off both) because dropping the parent
// would cascade them away.
export default `
  CREATE TEMP TABLE keep_turn AS SELECT * FROM conversation_turn ORDER BY rowid;
  CREATE TEMP TABLE keep_run AS SELECT * FROM conversation_run;
  CREATE TEMP TABLE keep_file AS SELECT * FROM conversation_file;
  CREATE TABLE conversation_next (
    id                TEXT PRIMARY KEY,
    user_id           TEXT NOT NULL REFERENCES user(id) ON DELETE CASCADE,
    claude_session_id TEXT NOT NULL DEFAULT '',
      
        sentinelcrew
        11d ago
        outdated
      
      HIGH: conversation_file (and anything else REFERENCES conversation ON DELETE CASCADE) is not held aside; DROP TABLE conversation cascades its rows away. Hold aside and restore all dependents, with a test.
    
    created_at        TEXT NOT NULL,
    updated_at        TEXT NOT NULL,
    title             TEXT NOT NULL DEFAULT '',
    archived_at       TEXT
  );
  INSERT INTO conversation_next (id, user_id, claude_session_id, created_at, updated_at)
    SELECT id, user_id, claude_session_id, created_at, updated_at FROM conversation;
  DROP TABLE conversation;
  ALTER TABLE conversation_next RENAME TO conversation;
  CREATE INDEX conversation_by_person ON conversation (user_id, updated_at);
  INSERT INTO conversation_turn SELECT * FROM keep_turn ORDER BY rowid;
  INSERT INTO conversation_run SELECT * FROM keep_run;
  INSERT INTO conversation_file SELECT * FROM keep_file;
  DROP TABLE keep_file;
  DROP TABLE keep_turn;
  DROP TABLE keep_run;
  `;
@@ -19,7 +19,7 @@
import { chmodSync, mkdirSync } from "node:fs";
import { join } from "node:path";
import type { App } from "../app.ts";
import { dailyLeft } from "../core/account_ceiling.ts";
import { appendTurn, lastExchange, listTurns, openConversation, removeTurn, restoreTurns, setAsideFrom, setClaudeSession, type Conversation } from "../core/conversations.ts";
import { appendTurn, getConversation, lastExchange, listTurns, openConversation, removeTurn, restoreTurns, setAsideFrom, setClaudeSession, type Conversation } from "../core/conversations.ts";
import { attach, deliver, fileOwnedBy, NOTHING, release, type ConversationFile, type Delivery } from "../core/conversation_files.ts";
import { carryWrites, forgetWrites, unended } from "../core/conversation_writes.ts";
import { cancelHeld, WORDS_MAX } from "../core/fence.ts";
@@ -75,7 +75,8 @@
export const configureConversation = (app: App, options: ConversationOptions): v
export const conversationOptions = (app: App): ConversationOptions | undefined => configured.get(app);
/** Whether a turn of this person's conversation is running now. */
export const turnRunning = (app: App, userId: string): boolean => live.has(openConversation(app.db, userId).id);
export const turnRunning = (app: App, userId: string, conversationId?: string): boolean =>
  live.has(conversationId ?? openConversation(app.db, userId).id);
/** The one line the person sees when a restart cut their answer short. */
export const RESUMED_LINE = "The forge restarted while I was answering; I am picking it up where I stopped.";
@@ -102,7 +103,7 @@
const RESUME_PROMPT =
export const STOPPED_LINE = "Stopped.";
/** Stops for the turns running, by conversation id. */
const stoppers = new Map<string, { runId: string; stop: () => void }>();
const stoppers = new Map<string, { runId: string; userId: string; stop: () => void }>();
/**
 * Stop the person's running turn: the agent's process group ends (and every
@@ -110,15 +111,18 @@
const stoppers = new Map<string, { runId: string; stop: () => void }>();
 * Confirm is cancelled, never applied. False when no turn runs.
 */
export function stopTurn(app: App, userId: string): boolean {
  const conversation = openConversation(app.db, userId);
  const stop = stoppers.get(conversation.id)?.stop;
  if (stop === undefined) return false;
  // Stop is the person calling it off: what waited behind the turn goes too (interrupting keeps it, `say`).
  queues.delete(conversation.id);
  // Cancelled first: no Confirm may land while the process is going down.
  cancelHeld(app.db, `conversation:${conversation.id}`);
  stop();
  return true;
  let stopped = false;
  // Every turn the person has running, whichever conversation it is in.
  for (const [conversationId, running] of stoppers) {
    if (running.userId !== userId) continue;
    // Cancelled first: no Confirm may land while the process is going down.
    // Stop is the person calling it off: what waited behind the turn goes too (interrupting keeps it, `say`).
    queues.delete(conversationId);
    cancelHeld(app.db, `conversation:${conversationId}`);
    running.stop();
    stopped = true;
  }
  return stopped;
}
/** Turns with a session listening, by conversation id: the run id a message is steered to. */
@@ -194,7 +198,7 @@
export function mcpConfig(localUrl: string): string {
  });
}
export type SayRefusal = "unauthorized" | "empty" | "too_long" | "no_account" | "resting" | "busy" | "answering" | "queue_full" | "file_taken";
export type SayRefusal = "not_found" | "unauthorized" | "empty" | "too_long" | "no_account" | "resting" | "busy" | "answering" | "queue_full" | "file_taken";
export interface Said {
  /** `started` a new turn, `steered` words into the one running, `queued` for after it, or `interrupted` it to send these at once. */
@@ -225,21 +229,23 @@
export const QUEUE_MAX = 5;
const queues = new Map<string, Queued[]>();
/** The person's messages waiting for their running turn, oldest first. */
export const queuedOf = (app: App, userId: string): readonly Queued[] => queues.get(openConversation(app.db, userId).id) ?? [];
/** The person's messages waiting for their running turn in a conversation (the latest by default), oldest first. */
export const queuedOf = (app: App, userId: string, conversationId?: string): readonly Queued[] =>
  queues.get(conversationId ?? openConversation(app.db, userId).id) ?? [];
/** Whether a message waiting in a queue holds this file: it cannot be removed or sent twice meanwhile. */
export const fileQueued = (fileId: string): boolean => [...queues.values()].some((l) => l.some((q) => q.files.some((f) => f.id === fileId)));
/** Take back a waiting message; false when it is gone (already sent, or never theirs). */
export function cancelQueued(app: App, userId: string, queuedId: string): boolean {
  const key = openConversation(app.db, userId).id;
  const list = queues.get(key) ?? [];
  const at = list.findIndex((q) => q.id === queuedId);
  if (at < 0) return false;
  list.splice(at, 1);
  if (list.length === 0) queues.delete(key);
  return true;
  for (const [key, list] of queues) {
    const at = list.findIndex((q) => q.id === queuedId);
    if (at < 0 || getConversation(app.db, userId, key) === undefined) continue;
    list.splice(at, 1);
    if (list.length === 0) queues.delete(key);
    return true;
  }
  return false;
}
/**
@@ -253,8 +259,8 @@
function drain(app: App, options: ConversationOptions, conversation: Conversatio
  if (list?.length === 0) queues.delete(conversation.id);
  if (next === undefined) return;
  const userId = conversation.userId;
  const current = openConversation(app.db, userId);
  if (current.id !== conversation.id) return void queues.delete(conversation.id);
  const current = getConversation(app.db, userId, conversation.id);
  if (current === undefined || current.archivedAt !== null) return void queues.delete(conversation.id);
  const stored = appendTurn(app.db, userId, current.id, { role: "person", text: next.text });
  if (!stored.ok) return drain(app, options, current);
  // A file taken back or sent some other way while this waited is left out, not sent twice.
@@ -281,12 +287,14 @@
export function say(
  text: string,
  files: readonly ConversationFile[] = [],
  during: During = "inject",
  conversationId?: string,
): Result<Said, SayRefusal> {
  const user = getUserById(app.db, userId);
  if (user === undefined) return err("unauthorized");
  if (text.trim() === "") return err("empty");
  if (text.length > WORDS_MAX) return err("too_long");
  const conversation = openConversation(app.db, userId);
  const conversation = conversationId === undefined ? openConversation(app.db, userId) : getConversation(app.db, userId, conversationId);
  if (conversation === undefined) return err("not_found");
  if (during !== "inject" && live.has(conversation.id)) {
    const list = queues.get(conversation.id) ?? [];
    const waiting: Queued = { id: id(), text, files };
@@ -335,10 +343,11 @@
export type RedoRefusal = SayRefusal | "running" | "nothing";
 * starts a fresh session whose context is the turns that still stand. Refused
 * while a turn runs, or when the last exchange is not what the action is for.
 */
export function redo(app: App, options: ConversationOptions, userId: string, how: RedoHow, text = ""): Result<Said, RedoRefusal> {
export function redo(app: App, options: ConversationOptions, userId: string, how: RedoHow, text = "", conversationId?: string): Result<Said, RedoRefusal> {
  const user = getUserById(app.db, userId);
  if (user === undefined) return err("unauthorized");
  const conversation = openConversation(app.db, userId);
  const conversation = conversationId === undefined ? openConversation(app.db, userId) : getConversation(app.db, userId, conversationId);
  if (conversation === undefined) return err("not_found");
  if (live.has(conversation.id)) return err("running");
  const { person, after } = lastExchange(app.db, userId, conversation.id);
  if (person === undefined) return err("nothing");
@@ -389,8 +398,8 @@
export function resumeInterrupted(app: App, options: ConversationOptions): Promi
    carryWrites(app.db, `conversation:${row.conversation_id}`);
    app.db.query("UPDATE conversation_run SET state = 'failed', finished_at = ?2 WHERE id = ?1").run(row.id, new Date().toISOString());
    if (row.resumes >= 1) continue;
    const conversation = openConversation(app.db, row.user_id);
    if (conversation.id !== row.conversation_id) continue;
    const conversation = getConversation(app.db, row.user_id, row.conversation_id);
    if (conversation === undefined) continue;
    appendTurn(app.db, row.user_id, conversation.id, { role: "agent", text: RESUMED_LINE });
    // A write begun and not reported is shown, not retried: the person decides.
    if (unknown.length > 0) appendTurn(app.db, row.user_id, conversation.id, { role: "agent", text: unendedLine(unknown) });
@@ -460,7 +469,7 @@
function begin(
    .run(runId, conversation.id, userId, subscriptionId, prompt, resumes, resumeSession ?? "", now.toISOString());
  live.set(conversation.id, runId);
  const stopper = new AbortController();
  stoppers.set(conversation.id, { runId, stop: () => stopper.abort() });
  stoppers.set(conversation.id, { runId, userId, stop: () => stopper.abort() });
  const signal = AbortSignal.any([options.signal, stopper.signal]);
  const put = (role: "agent" | "tool", text: string): void => {
    const stored = appendTurn(app.db, userId, conversation.id, { role, text: text.slice(0, 20_000) });
@@ -10,11 +10,24 @@
import type { App } from "../../app.ts";
import { RateLimiter } from "../../core/ratelimit.ts";
import { cancelTalk, stopTalk, TALK_WORDS, talk } from "../../actions/talk.ts";
import {
  archiveConversation,
  createConversation,
  DEFAULT_PAGE,
  getConversation,
  listConversations,
  listTurns,
  MAX_PAGE,
  openConversation,
  renameConversation,
  TITLE_MAX,
  TOO_MANY_WORDS,
} from "../../core/conversations.ts";
import { FILE_WORDS, fileBytes, fileOwnedBy, FILES_PER_MESSAGE, IMAGE_MAX, pendingAmong, removePending, storeFile } from "../../core/conversation_files.ts";
import { DEFAULT_PAGE, listTurns, MAX_PAGE, openConversation } from "../../core/conversations.ts";
import { WORDS_MAX } from "../../core/fence.ts";
import { notePhase, takeSessionTime } from "../../core/route_timing.ts";
import { scopeAllows } from "../../core/tokens.ts";
import type { User } from "../../core/users.ts";
import { worksOf } from "../../core/talk_work.ts";
import { fileQueued, queuedOf, turnRunning } from "../../crew/conversation.ts";
import { crossOrigin, type Handler } from "../context.ts";
@@ -57,6 +70,8 @@
export function conversationTalkRoutes(router: Router<Handler>): void {
    const text = input["text"];
    if (typeof text !== "string" || text.trim() === "" || text.length > WORDS_MAX)
      return apiError("invalid_text", 422, `text is a string of 1 to ${WORDS_MAX} characters`);
    const named = input["conversation"];
    if (named !== undefined && (typeof named !== "string" || !ID.test(named))) return apiError("not_found", 404, "no such conversation");
    const ids = input["files"] ?? [];
    if (!Array.isArray(ids) || ids.length > FILES_PER_MESSAGE || !ids.every((f) => typeof f === "string"))
      return apiError("invalid_files", 422, `files is a list of at most ${FILES_PER_MESSAGE} attachment ids`);
@@ -65,7 +80,7 @@
export function conversationTalkRoutes(router: Router<Handler>): void {
    // What to do when a turn runs: absent hands the words to it; `queue` waits for it; `steer` stops it and sends these at once.
    const during = input["during"];
    if (during !== undefined && during !== "queue" && during !== "steer") return apiError("invalid_during", 422, "during is queue or steer");
    const said = talk(ctx.app, user, text, files.value, during === "queue" ? "queue" : during === "steer" ? "interrupt" : "inject");
    const said = talk(ctx.app, user, text, files.value, during === "queue" ? "queue" : during === "steer" ? "interrupt" : "inject", named);
    if (!said.ok) {
      const [status, words] = TALK_WORDS[said.error];
      return json({ error: said.error, message: words }, status, said.error === "rate_limited" || said.error === "busy" ? { "retry-after": "60" } : {});
@@ -146,7 +161,9 @@
export function conversationTalkRoutes(router: Router<Handler>): void {
    const user = ctx.auth.user;
    notePhase(ctx.request, "session", takeSessionTime(ctx.request));
    if (user === undefined) return unauthorized();
    const conversation = openConversation(ctx.app.db, user.id);
    const named = ctx.url.searchParams.get("conversation");
    const conversation = named === null ? openConversation(ctx.app.db, user.id) : getConversation(ctx.app.db, user.id, named);
    if (conversation === undefined) return apiError("not_found", 404, "no such conversation");
    const turns = listTurns(ctx.app.db, user.id, conversation.id, {
      limit: turnsLimit(ctx.url.searchParams.get("limit")),
      ...(ctx.url.searchParams.get("before") ? { before: ctx.url.searchParams.get("before")! } : {}),
@@ -155,6 +172,55 @@
export function conversationTalkRoutes(router: Router<Handler>): void {
    const all = turns.ok ? turns.value : [];
    const works = worksOf(ctx.app.db, user.id, conversation.id, all);
    const shown = all.map((t) => (t.role === "agent" ? { ...t, work: works.get(t.id) ?? null } : t));
    return json({ running: turnRunning(ctx.app, user.id), queued: queuedOf(ctx.app, user.id).map((q) => ({ id: q.id, text: q.text })), turns: shown });
    return json({ running: turnRunning(ctx.app, user.id, conversation.id), conversation: conversation.id, queued: queuedOf(ctx.app, user.id, conversation.id).map((q) => ({ id: q.id, text: q.text })), turns: shown });
  });
  router.add("GET", "/api/v1/conversations", (ctx) => {
    const user = ctx.auth.user;
    if (user === undefined) return unauthorized();
    return json({ conversations: listConversations(ctx.app.db, user.id, { archived: ctx.url.searchParams.get("archived") === "1" }) });
  });
  router.add("POST", "/api/v1/conversations", async (ctx) => {
    const user = mayChange(ctx);
    if (user instanceof Response) return user;
    const input = await boundedBody(ctx.request, 4_000);
    if (input === "too_large") return apiError("too_large", 413, "at most 4000 bytes");
    const title = input["title"];
    if (title !== undefined && typeof title !== "string") return apiError("invalid_title", 422, TITLE_WORDS);
    const started = createConversation(ctx.app.db, user.id);
    if (!started.ok) return apiError("too_many", 409, TOO_MANY_WORDS);
    const made = started.value;
    if (title === undefined || title.trim() === "") return json({ conversation: made }, 201);
    const named = renameConversation(ctx.app.db, user.id, made.id, title);
    return named.ok ? json({ conversation: named.value }, 201) : apiError("invalid_title", 422, TITLE_WORDS);
  });
  router.add("PATCH", "/api/v1/conversations/:id", async (ctx) => {
    const user = mayChange(ctx);
    if (user instanceof Response) return user;
    const id = ctx.params["id"] ?? "";
    if (!ID.test(id) || getConversation(ctx.app.db, user.id, id) === undefined) return apiError("not_found", 404, "no such conversation");
    const input = await boundedBody(ctx.request, 4_000);
    if (input === "too_large") return apiError("too_large", 413, "at most 4000 bytes");
    const { title, archived } = input;
    if (title !== undefined && typeof title !== "string") return apiError("invalid_title", 422, TITLE_WORDS);
    if (archived !== undefined && typeof archived !== "boolean") return apiError("invalid", 422, "archived is true or false");
    if (title === undefined && archived === undefined) return apiError("invalid", 422, "send title or archived");
    if (title !== undefined && !renameConversation(ctx.app.db, user.id, id, title).ok) return apiError("invalid_title", 422, TITLE_WORDS);
    if (archived !== undefined) archiveConversation(ctx.app.db, user.id, id, archived);
    return json({ conversation: getConversation(ctx.app.db, user.id, id) });
  });
}
const ID = /^[0-9a-z]{1,40}$/;
const TITLE_WORDS = `title is text of at most ${TITLE_MAX} characters, on one line`;
/** The person a change is for: signed in, same-origin, and not on a read-only token. */
function mayChange(ctx: Parameters<Handler>[0]): User | Response {
  const user = ctx.auth.user;
  if (user === undefined) return unauthorized();
  if (crossOrigin(ctx.request, ctx.url, ctx.app.log)) return forbidden();
  if (ctx.auth.via === "token" && !scopeAllows(ctx.auth.scope ?? "ro", "rw")) return forbidden();
  return user;
}
@@ -1,32 +1,61 @@
import { mayView } from "../../../core/sealed.ts";
import { addCommentThrough } from "../../../actions/issues.ts";
import { getIssue } from "../../../core/issues.ts";
import { archiveConversation, createConversation, getConversation, listConversations, renameConversation, TOO_MANY_WORDS } from "../../../core/conversations.ts";
import { talk, TALK_WORDS } from "../../../actions/talk.ts";
import { WORDS_MAX } from "../../../core/fence.ts";
import { good, bad, type Tool, str, REPO_ARG, repoArg, isAnswer } from "../shared.ts";
export const tool: Tool = {
  name: "say",
  doc: "speak on an issue or a pull; a working builder hears it as its next step. With no `repo` or `number` it speaks to the forge's own agent (`forge talk`), which answers in `GET /api/v1/conversation/turns`",
  doc: "speak on an issue or a pull; a working builder hears it as its next step. With no `repo` or `number` it speaks to the forge's own agent (`forge talk`), which answers in `GET /api/v1/conversation/turns`. `conversation` names one of your conversations (default: the latest); `action` list | new | rename | archive | restore manages them (`title` for rename and new)",
  description:
    "Say something on an issue or pull; with no repo, to the forge's own agent.",
    "Say something on an issue or pull; with no repo, to the forge's own agent, and manage its conversations (action).",
  inputSchema: {
    type: "object",
    properties: {
      repo: REPO_ARG,
      number: { type: "integer", minimum: 1 },
      text: { type: "string", maxLength: 8000 },
      
        sentinelcrew
        11d ago
        
      
      required: ["text"] was removed; a call with neither text nor action must be refused explicitly.
    
      conversation: { type: "string" },
      action: { type: "string", enum: ["list", "new", "rename", "archive", "restore"] },
      title: { type: "string", maxLength: 80 },
      archived: { type: "boolean" },
    },
    required: ["text"],
  },
  writes: true,
  async run(ctx, user, args) {
    if (args["repo"] === undefined && args["number"] === undefined) {
      // The forge's own agent never wakes itself: its via token is refused.
      if (ctx.auth.through !== undefined) return bad("forbidden", "the forge's agent cannot start its own turn");
      const text = str(args["text"]);
      const db = ctx.app.db;
      const action = args["action"];
      if (action === "list") return good({ conversations: listConversations(db, user.id, { archived: args["archived"] === true }).map(({ id, title, updatedAt }) => ({ id, title, updatedAt })) });
      if (action === "new") {
        const started = createConversation(db, user.id);
        if (!started.ok) return bad("too_many", TOO_MANY_WORDS);
        const made = started.value;
        const title = str(args["title"]);
        if (title !== "" && !renameConversation(db, user.id, made.id, title).ok) return bad("invalid_title", "title is up to 80 characters, on one line");
        return good({ conversation: made.id, says: "Started; send text with this conversation to speak in it. It opens at /talk/" + made.id + "." });
      }
      if (action !== undefined) {
        const target = getConversation(db, user.id, str(args["conversation"]));
        if (target === undefined) return bad("not_found", "no such conversation of yours");
        if (action === "rename") {
          if (typeof args["title"] !== "string") return bad("invalid_title", "rename needs a title");
          const named = renameConversation(db, user.id, target.id, args["title"]);
          return named.ok ? good({ says: "Renamed." }) : bad("invalid_title", "title is up to 80 characters, on one line");
        }
        if (action !== "archive" && action !== "restore") return bad("invalid", "action is list, new, rename, archive or restore");
        archiveConversation(db, user.id, target.id, action === "archive");
        return good({ says: action === "archive" ? "Archived." : "Restored." });
      }
      if (typeof args["text"] !== "string") return bad("invalid_text", "say needs `text` (or an `action` to manage conversations)");
      const text = args["text"];
      if (text.trim() === "" || text.length > WORDS_MAX) return bad("invalid_text", `text is 1 to ${WORDS_MAX} characters`);
      const talked = talk(ctx.app, user, text);
      const named = args["conversation"] === undefined ? undefined : str(args["conversation"]);
      const talked = talk(ctx.app, user, text, [], "inject", named);
      if (!talked.ok) return bad(talked.error, TALK_WORDS[talked.error][1]);
      return good({ says: talked.value.how === "steered" ? "Said to the forge's agent, mid-answer." : "The forge's agent is answering; read it in GET /api/v1/conversation/turns." });
    }
@@ -124,7 +124,7 @@
import {
  verifyPage,
  themeSubmit,
} from "../web/pages/site.ts";
import { talkAgainSend, talkConfirm, talkQueueCancel, talkSend, talkStream, talkView } from "../web/pages/talk.ts";
import { talkAgainSend, talkArchive, talkConfirm, talkNew, talkQueueCancel, talkRename, talkSend, talkStream, talkView } from "../web/pages/talk.ts";
import {
  recoverFinish,
  recoverOptions,
@@ -844,6 +844,12 @@
export function buildRouter(): Router<Handler> {
  router.add("POST", "/talk/again/:how", talkAgainSend);
  router.add("POST", "/talk/queue/:id/cancel", talkQueueCancel);
  router.add("POST", "/talk/confirm/:id", talkConfirm);
  router.add("POST", "/talk/new", talkNew);
  router.add("GET", "/talk/:id", talkView);
  router.add("POST", "/talk/:id", talkSend);
  router.add("POST", "/talk/:id/rename", talkRename);
  router.add("POST", "/talk/:id/archive", talkArchive);
  router.add("POST", "/talk/:id/again/:how", talkAgainSend);
  router.add("POST", "/signin/passkey/options", signinOptions);
  router.add("POST", "/signin/passkey", signinPasskey);
  router.add("GET", "/recover", recoverPage);
@@ -50,6 +50,7 @@
import { usageScreen } from "./screens/usage.ts";
import { canScreen } from "./screens/can.ts";
import { modelScreen } from "./screens/model.ts";
import { notifyScreen } from "./screens/notify.ts";
import { talkChatsScreen } from "./screens/talk_chats.ts";
import { sshKeysScreen } from "./screens/sshkeys.ts";
import { passkeysScreen } from "./screens/passkeys.ts";
import { confirmsScreen } from "./screens/confirms.ts";
@@ -307,6 +308,14 @@
export function forgeCommands(session: Session): (ctx: Ctx) => Command[] {
        hint: "what the forge's agent asked to do; y does it once",
        run: () => ctx.push(confirmsScreen(session, ctx)),
      });
    // The forge's agent keeps many conversations, as /talk lists them (#8814).
    if (session.signedIn && session.user?.kind !== "agent")
      commands.push({
        id: "conversations",
        title: "Conversations",
        hint: "your talks with the forge's agent; n starts one, r renames, x archives",
        run: () => ctx.push(talkChatsScreen(session, ctx)),
      });
    if (session.signedIn)
      commands.push({
        id: "ssh-keys",
@@ -0,0 +1,199 @@
/**
 * Talk conversations in the terminal (#8814): the same list, New, Rename and
 * Archive/Restore /talk has, through the same `core/conversations.ts` calls,
 * so a change here is the next thing a web viewer's list or stream reads.
 * `a` flips between the live list and the archived one; Enter opens one,
 * to read it and, with `s`, say something in it through `talk()`.
 */
import { TALK_WORDS, talk } from "../../actions/talk.ts";
import {
  archiveConversation,
  createConversation,
  listConversations,
  listTurns,
  renameConversation,
  TITLE_MAX,
  TOO_MANY_WORDS,
  type Conversation,
} from "../../core/conversations.ts";
import type { Ctx, Screen } from "../app/app.ts";
import { binding } from "../app/keys.ts";
import { style } from "../term/style.ts";
import { truncate, wrap } from "../term/width.ts";
import type { Session } from "../session.ts";
import { fill, len, split } from "../ui/layout.ts";
import { ListState, Scroll, ago, drawLines, drawList, promptScreen, type ListRow } from "./common.ts";
const BAD_TITLE = `A title is up to ${TITLE_MAX} characters, on one line.`;
const WHO: Readonly<Record<string, string>> = { person: "You", agent: "Forge", tool: "Tool", confirm: "Asks" };
/** One conversation, newest turns last: j/k scroll, s says something in it, r reloads. */
function chatScreen(f: Session, ctx: Ctx, chat: Conversation): Screen {
  const scroll = new Scroll();
  let note = "";
  let width = 80;
  // Opened, and after r, the view sits on the newest turns.
  let follow = true;
  const lines = (): { text: string; style: ReturnType<typeof style> }[][] => {
    const c = ctx.theme.c;
    const listed = f.user === undefined ? undefined : listTurns(f.app.db, f.user.id, chat.id, { limit: 50 });
    const turns = listed?.ok ? listed.value : [];
    if (turns.length === 0) return [[{ text: "Nothing said yet; s says something.", style: style(c.mutedFg, c.bg) }]];
    return turns.flatMap((t) => [
      [{ text: `${WHO[t.role] ?? t.role}${t.replaced ? " · replaced" : ""} · ${ago(t.createdAt)}`, style: style(c.mutedFg, c.bg) }],
      ...t.text.split("\n").flatMap((l) => wrap(l, Math.max(10, width - 2))).map((l) => [{ text: l, style: style(c.fg, c.bg) }]),
      [],
    ]);
  };
  const screen: Screen = {
    get title() {
      return chat.title === "" ? "Untitled conversation" : chat.title;
    },
    keys: [binding(["j", "k"], "scroll"), binding(["s"], "say"), binding(["r"], "reload"), binding(["esc"], "back")],
    render(area, s) {
      const c = ctx.theme.c;
      width = area.w;
      const [head, body] = split(area, "v", [len(1), fill(1)]);
      const text = note !== "" ? note : `/talk/${chat.id}${chat.archivedAt === null ? "" : " · archived: sending does not bring it back"}`;
      s.text(head!.x, head!.y, truncate(text, head!.w), style(c.mutedFg, c.bg), head!.x + head!.w);
      const all = lines();
      if (follow) scroll.to(all.length - body!.h, all.length);
      drawLines(s, body!, c, scroll, all);
    },
    key(e) {
      if (scroll.key(e, lines().length)) {
        follow = false;
        return true;
      }
      const user = f.user;
      if (user === undefined || e.ctrl || e.alt) return false;
      if (e.key === "esc" || e.key === "q") {
        ctx.pop();
        return true;
      }
      if (e.key === "r") {
        note = "";
        follow = true;
        ctx.invalidate();
        return true;
      }
      if (e.key === "s") {
        ctx.push(
          promptScreen(ctx, screen, {
            title: "Say",
            label: "to the forge, in this conversation",
            onSubmit: (words) => {
              const said = talk(f.app, user, words, [], "inject", chat.id);
              if (!said.ok) return TALK_WORDS[said.error][1];
              note = "Sent; r reloads to see the answer.";
              ctx.invalidate();
              return undefined;
            },
          }),
        );
        return true;
      }
      return false;
    },
  };
  return screen;
}
export function talkChatsScreen(f: Session, ctx: Ctx): Screen {
  const state = new ListState();
  let archived = false;
  let note = "";
  const items = (): Conversation[] => (f.user === undefined ? [] : listConversations(f.app.db, f.user.id, { archived }));
  const rows = (): ListRow[] =>
    items().map((c) => ({ title: c.title === "" ? "Untitled" : c.title, secondary: `/talk/${c.id}`, meta: `active ${ago(c.updatedAt)}` }));
  const say = (text: string): void => {
    note = text;
    ctx.invalidate();
  };
  const screen: Screen = {
    get title() {
      return archived ? "Archived conversations" : "Conversations";
    },
    keys: [
      binding(["j", "k"], "move cursor"),
      binding(["enter"], "open"),
      binding(["n"], "new"),
      binding(["r"], "rename"),
      binding(["x"], "archive or restore"),
      binding(["a"], "archived"),
    ],
    render(area, s) {
      const c = ctx.theme.c;
      const [head, body] = split(area, "v", [len(1), fill(1)]);
      const text =
        note !== ""
          ? note
          : items().length === 0
            ? archived ? "Nothing archived." : "No conversations yet; n starts one."
            : archived ? "Archived; x brings one back." : "Your talks with the forge's agent; each opens at its /talk address.";
      s.text(head!.x, head!.y, truncate(text, head!.w), style(c.mutedFg, c.bg), head!.x + head!.w);
      drawList(s, body!, c, state, rows());
    },
    key(e) {
      if (state.key(e, items().length)) return true;
      const user = f.user;
      if (user === undefined || e.ctrl || e.alt) return false;
      const here = items()[state.index];
      if (e.key === "a") {
        archived = !archived;
        state.index = 0;
        note = "";
        ctx.invalidate();
        return true;
      }
      if (e.key === "n") {
        ctx.push(
          promptScreen(ctx, screen, {
            title: "New conversation",
            label: "a title (optional)",
            onSubmit: (title) => {
              const made = createConversation(f.app.db, user.id);
              if (!made.ok) return TOO_MANY_WORDS;
              if (title.trim() !== "" && !renameConversation(f.app.db, user.id, made.value.id, title).ok) return BAD_TITLE;
              archived = false;
              state.index = 0;
              say(`Started /talk/${made.value.id}.`);
              return undefined;
            },
          }),
        );
        return true;
      }
      if (here === undefined) return false;
      if (e.key === "enter") {
        ctx.push(chatScreen(f, ctx, here));
        return true;
      }
      if (e.key === "r") {
        ctx.push(
          promptScreen(ctx, screen, {
            title: "Rename conversation",
            label: "a title (empty clears it)",
            value: here.title,
            onSubmit: (title) => {
              if (!renameConversation(f.app.db, user.id, here.id, title).ok) return BAD_TITLE;
              say("Renamed.");
              return undefined;
            },
          }),
        );
        return true;
      }
      if (e.key === "x") {
        archiveConversation(f.app.db, user.id, here.id, !archived);
        say(archived ? "Restored." : "Archived.");
        return true;
      }
      return false;
    },
  };
  return screen;
}
@@ -18,7 +18,23 @@
import type { Database } from "bun:sqlite";
import { cancelTalk, queuedTalk, TALK_WORDS, talk, talkAgain } from "../../actions/talk.ts";
import { REFUSED, sayNo, sayYes, waitingConfirms } from "../../actions/conversation_confirms.ts";
import { filesOfTurns, type ConversationFile } from "../../core/conversation_files.ts";
import { DEFAULT_PAGE, lastExchange, listTurns, MAX_PAGE, openConversation, turnsAfter, type Turn } from "../../core/conversations.ts";
import {
  archiveConversation,
  type Conversation,
  DEFAULT_PAGE,
  lastExchange,
  getConversation,
  listConversations,
  listTurns,
  MAX_PAGE,
  createConversation,
  TOO_MANY_WORDS,
  openConversation,
  renameConversation,
  TITLE_MAX,
  turnsAfter,
  type Turn,
} from "../../core/conversations.ts";
import { contextOf, contextText, dollars, turnCosts, type Context } from "../../core/conversation_cost.ts";
import { WORDS_MAX } from "../../core/fence.ts";
import { thinkingOf, worksOf, type Work } from "../../core/talk_work.ts";
@@ -28,10 +44,10 @@
import { turnRunning, type RedoHow } from "../../crew/conversation.ts";
import type { Ctx } from "../../http/context.ts";
import { json } from "../../http/respond.ts";
import { eventStream } from "../../http/sse.ts";
import { signInFirst, forbiddenPage } from "../chrome.ts";
import { signInFirst, forbiddenPage, notFoundPage } from "../chrome.ts";
import { readForm } from "../form.ts";
import { html, type Html } from "../html.ts";
import { flashTo, page } from "../layout.ts";
import { flashTo, page, redirect } from "../layout.ts";
import { renderMarkdown } from "../markdown.ts";
import { btn, time } from "../ui.ts";
import { talkCss, talkJs } from "./talk_client.ts";
@@ -47,6 +63,12 @@
export const clock = { streamMs: STREAM_MS, running: turnRunning };
const open = new Map<string, number>();
const TURN_ID = /^[0-9a-z]{0,40}$/;
const HERE = "/talk";
const CONVERSATION_ID = /^[0-9a-z]{1,40}$/;
/** What a conversation is called in a list: its title, else the day it began. */
const nameOf = (c: Conversation): string => (c.title === "" ? `Chat of ${c.createdAt.slice(0, 10)}` : c.title);
/** Where a conversation lives. */
const urlOf = (c: Conversation): string => `${HERE}/${c.id}`;
const parse = (text: string): Record<string, unknown> | undefined => {
  try {
@@ -88,23 +110,23 @@
const workHtml = (work: Work): Html =>
const SUGGESTIONS = ["What needs my attention?", "What did the crew do today?", "Show me my apps"] as const;
/** Ask again as a form, so it works without the script; the script only enhances it. */
const againForm = (how: "regenerate" | "retry", label: string, words: string): Html =>
  html`<form method="post" action="${HERE}/again/${how}" data-again="${how}">${btn(label, { icon: "sync", label: words })}</form>`;
const againForm = (base: string, how: "regenerate" | "retry", label: string, words: string): Html =>
  html`<form method="post" action="${base}/again/${how}" data-again="${how}">${btn(label, { icon: "sync", label: words })}</form>`;
/**
 * What the last exchange offers, by the turn it sits under: Edit under the
 * person's last message, and under the last turn Retry when it failed or
 * Regenerate when it is a reply. Nothing while a turn runs.
 */
export function exchangeActs(db: Database, userId: string, conversationId: string, running: boolean): Map<string, Html> {
export function exchangeActs(db: Database, userId: string, conversationId: string, running: boolean, base: string = HERE): Map<string, Html> {
  const acts = new Map<string, Html>();
  if (running) return acts;
  const { person, after } = lastExchange(db, userId, conversationId);
  if (person === undefined) return acts;
  acts.set(person.id, html`<a class="btn talk-act" href="${HERE}?edit=1#compose" data-act="edit" aria-label="Edit your last message">Edit</a>`);
  acts.set(person.id, html`<a class="btn talk-act" href="${base}?edit=1#compose" data-act="edit" aria-label="Edit your last message">Edit</a>`);
  const last = after.at(-1);
  if (last?.failed === true) acts.set(last.id, againForm("retry", "Retry", "Retry the failed turn"));
  else if (last?.role === "agent") acts.set(last.id, againForm("regenerate", "Regenerate", "Regenerate the last reply"));
  if (last?.failed === true) acts.set(last.id, againForm(base, "retry", "Retry", "Retry the failed turn"));
  else if (last?.role === "agent") acts.set(last.id, againForm(base, "regenerate", "Regenerate", "Regenerate the last reply"));
  return acts;
}
@@ -166,9 +188,48 @@
export function turnHtml(turn: Turn, waiting: ReadonlySet<string>, cost?: number
  return toolCard(id, call, call.split(/[\s(:{]/, 1)[0] ?? "tool", turn.createdAt, set);
}
function talkPage(ctx: Ctx, before: string | undefined, prefill: string, edit: boolean): Response {
/** The conversations list, then this one's name with Rename and Archive: each a plain form, so none needs the script. */
function chats(ctx: Ctx, conversation: Conversation, showArchived: boolean): Html {
  const user = ctx.auth.user!;
  const conversation = openConversation(ctx.app.db, user.id);
  const shown = listConversations(ctx.app.db, user.id, { archived: showArchived });
  const put = listConversations(ctx.app.db, user.id, { archived: !showArchived }).length;
  const archived = conversation.archivedAt !== null;
  return html`<nav class="talk-chats" aria-label="Conversations">
      <div class="bar">
        <form method="post" action="${HERE}/new">${btn("New", { icon: "plus", label: "New conversation" })}</form>
        <span class="spacer"></span>
        ${showArchived
          ? html`<a class="small" href="${HERE}">Back to conversations</a>`
          : put > 0
            ? html`<a class="small" href="${HERE}?archived=1">Archived (${put})</a>`
            : null}
      </div>
      <ul>
        ${shown.length === 0
          ? html`<li class="muted small">${showArchived ? "Nothing archived." : "No conversations yet."}</li>`
          : shown.map((c) => html`<li ${c.id === conversation.id ? html`aria-current="page"` : null}><a href="${urlOf(c)}"><span>${nameOf(c)}</span><span class="muted small">${time(c.updatedAt)}</span></a></li>`)}
      </ul>
    </nav>
    <div class="talk-here bar">
      <strong>${nameOf(conversation)}${archived ? " (archived)" : ""}</strong>
      <details>
        <summary class="small">Rename</summary>
        <form method="post" action="${urlOf(conversation)}/rename">
          <input class="input" name="title" value="${conversation.title}" maxlength="${TITLE_MAX}" aria-label="Title" placeholder="Title" />
          ${btn("Save")}
        </form>
      </details>
      <form method="post" action="${urlOf(conversation)}/archive">
        <input type="hidden" name="archived" value="${archived ? "0" : "1"}" />
        ${btn(archived ? "Restore" : "Archive")}
      </form>
    </div>`;
}
function talkPage(ctx: Ctx, conversation: Conversation, before: string | undefined, prefill: string, latest: boolean, edit: boolean): Response {
  const user = ctx.auth.user!;
  const here = latest ? HERE : urlOf(conversation);
  const showArchived = latest && ctx.url.searchParams.get("archived") === "1";
  const listed = listTurns(ctx.app.db, user.id, conversation.id, {
    limit: DEFAULT_PAGE,
    ...(before === undefined ? {} : { before }),
@@ -176,33 +237,35 @@
function talkPage(ctx: Ctx, before: string | undefined, prefill: string, edit: b
  const turns = listed.ok ? listed.value : [];
  const waiting = new Set(waitingConfirms(ctx, user).map((w) => w.id));
  const sent = filesOfTurns(ctx.app.db, user.id, turns.filter((t) => t.role === "person").map((t) => t.id));
  const running = clock.running(ctx.app, user.id);
  const running = clock.running(ctx.app, user.id, conversation.id);
  const costs = turnCosts(ctx.app.db, conversation.id);
  const context = contextOf(ctx.app.db, conversation.id);
  const works = worksOf(ctx.app.db, user.id, conversation.id, turns);
  // Paging back, the log ends before the newest turn: it does not follow.
  const last = turns.at(-1)?.id ?? "";
  const acts = before === undefined ? exchangeActs(ctx.app.db, user.id, conversation.id, running) : new Map<string, Html>();
  const acts = before === undefined ? exchangeActs(ctx.app.db, user.id, conversation.id, running, here) : new Map<string, Html>();
  // Edit shows the composer holding the last message, posting to Edit instead of Send.
  const editing = edit ? lastExchange(ctx.app.db, user.id, conversation.id).person : undefined;
  const body = html`<div class="page-head"><h1>Talk</h1></div>
    <div class="talk" data-talk data-user="${user.id}" data-paged="${before === undefined ? "0" : "1"}" data-running="${running && before === undefined ? "1" : "0"}">
    ${chats(ctx, conversation, showArchived)}
    <div class="talk" data-talk data-user="${user.id}" data-c="${conversation.id}" data-here="${here}" data-paged="${before === undefined ? "0" : "1"}" data-running="${running && before === undefined ? "1" : "0"}">
      <div>
        ${contextLine(context)}
        ${turns.length === DEFAULT_PAGE && turns[0] !== undefined
          ? html`<p class="talk-more small"><a href="${HERE}?before=${turns[0].id}">Earlier</a></p>`
          ? html`<p class="talk-more small"><a href="${here}?before=${turns[0].id}">Earlier</a></p>`
          : null}
        ${before === undefined ? null : html`<p class="talk-more small"><a href="${HERE}">Latest</a></p>`}
        ${before === undefined ? null : html`<p class="talk-more small"><a href="${here}">Latest</a></p>`}
        <ol class="talk-log" role="log" data-last="${last}" aria-label="Conversation with the forge">
          ${turns.length === 0
            ? html`<li class="muted talk-turn">Ask the forge anything, or tell it what to change. It acts as you, with your permissions, and asks before anything hard to undo.
                <span class="talk-suggest">${SUGGESTIONS.map((q) => html`<a class="btn" href="${HERE}?q=${encodeURIComponent(q)}" data-suggest="${q}">${q}</a>`)}</span></li>`
                <span class="talk-suggest">${SUGGESTIONS.map((q) => html`<a class="btn" href="${here}?q=${encodeURIComponent(q)}" data-suggest="${q}">${q}</a>`)}</span></li>`
            : turns.map((t) => turnHtml(t, waiting, costs.get(t.id), acts.get(t.id), works.get(t.id), sent.get(t.id)))}
          ${before === undefined && running ? queuedTalk(ctx.app, user).map(queuedHtml) : null}
          ${before === undefined && running ? queuedTalk(ctx.app, user, conversation.id).map(queuedHtml) : null}
        </ol>
        <div id="end"></div>
      </div>
      <form class="talk-compose" id="compose" method="post" action="${editing === undefined ? HERE : `${HERE}/again/edit`}" ${editing === undefined ? null : html`data-edit`}>
      <form class="talk-compose" id="compose" method="post" action="${editing === undefined ? here : `${here}/again/edit`}" ${editing === undefined ? null : html`data-edit`}>
        ${conversation.archivedAt === null ? null : html`<p class="small muted" data-archived-note>Archived: sending here keeps it archived; Restore puts it back in the list.</p>`}
        <p class="talk-status small muted" role="status" aria-live="polite">${running ? "The forge is answering…" : ""}</p>
        <div class="talk-chips" data-chips role="group" aria-label="Attached files"></div>
        <textarea class="input" name="text" rows="1" maxlength="${WORDS_MAX}" required placeholder="Talk to the forge" aria-label="Talk to the forge">${editing === undefined ? prefill : editing.text}</textarea>
@@ -210,7 +273,7 @@
function talkPage(ctx: Ctx, before: string | undefined, prefill: string, edit: b
          <span class="muted small" data-hint></span>
          <label class="btn talk-attach" data-attach hidden>Attach<input type="file" multiple hidden data-pick /></label>
          <span class="spacer"></span>
          ${editing === undefined ? null : html`<a class="btn" href="${HERE}">Keep as it was</a>`}
          ${editing === undefined ? null : html`<a class="btn" href="${here}">Keep as it was</a>`}
          <button type="button" class="btn" data-stop hidden>Stop</button>
          <button type="button" class="btn" data-steer hidden title="Stop this answer and send now">Steer</button>
          ${btn(editing === undefined ? "Send" : "Resend", { variant: "primary" })}
@@ -220,32 +283,83 @@
function talkPage(ctx: Ctx, before: string | undefined, prefill: string, edit: b
  return page({ ctx, title: "Talk", body, styleCss: talkCss, scriptJs: talkJs, description: "Talk to the forge." });
}
// GET /talk
/** The conversation a request names (`:id`), or the person's latest when it names none; undefined when it is not theirs. */
const conversationOf = (ctx: Ctx, user: { readonly id: string }): Conversation | undefined => {
  const named = ctx.params["id"];
  if (named === undefined) return openConversation(ctx.app.db, user.id);
  return CONVERSATION_ID.test(named) ? getConversation(ctx.app.db, user.id, named) : undefined;
};
// GET /talk and GET /talk/:id
export function talkView(ctx: Ctx): Response {
  if (ctx.auth.user === undefined) return signInFirst(ctx);
  notePhase(ctx.request, "session", takeSessionTime(ctx.request));
  const before = ctx.url.searchParams.get("before");
  const q = ctx.url.searchParams.get("q");
  return timePhase(ctx.request, "render", () => talkPage(ctx, before !== null && TURN_ID.test(before) && before !== "" ? before : undefined, q !== null && SUGGESTIONS.some((s) => s === q) ? q : "", ctx.url.searchParams.get("edit") === "1" && before === null));
  const conversation = conversationOf(ctx, ctx.auth.user);
  if (conversation === undefined) return notFoundPage(ctx);
  return timePhase(ctx.request, "render", () =>
    talkPage(ctx, conversation, before !== null && TURN_ID.test(before) && before !== "" ? before : undefined, q !== null && SUGGESTIONS.some((s) => s === q) ? q : "", ctx.params["id"] === undefined, ctx.url.searchParams.get("edit") === "1" && before === null),
  );
}
// POST /talk — the plain form, for a browser without the script.
// POST /talk and POST /talk/:id — the plain form, for a browser without the script.
export async function talkSend(ctx: Ctx): Promise<Response> {
  const user = ctx.auth.user;
  if (user === undefined) return signInFirst(ctx);
  const form = await readForm(ctx, "rw");
  if (form instanceof Response) return form;
  const conversation = conversationOf(ctx, user);
  if (conversation === undefined) return notFoundPage(ctx);
  const here = ctx.params["id"] === undefined ? HERE : urlOf(conversation);
  const text = form.get("text");
  if (typeof text !== "string" || text.trim() === "" || text.length > WORDS_MAX)
    return flashTo(ctx, `${HERE}#end`, { tone: "danger", message: `Say something, up to ${WORDS_MAX} characters.` });
  const said = talk(ctx.app, user, text, [], "queue");
  if (!said.ok) return flashTo(ctx, `${HERE}#end`, { tone: "danger", message: TALK_WORDS[said.error][1] });
  return flashTo(ctx, `${HERE}#end`, { tone: "success", message: "Sent. Reload to see the answer." });
    return flashTo(ctx, `${here}#end`, { tone: "danger", message: `Say something, up to ${WORDS_MAX} characters.` });
  const said = talk(ctx.app, user, text, [], "queue", conversation.id);
  if (!said.ok) return flashTo(ctx, `${here}#end`, { tone: "danger", message: TALK_WORDS[said.error][1] });
  return flashTo(ctx, `${here}#end`, { tone: "success", message: "Sent. Reload to see the answer." });
}
// POST /talk/new — an empty conversation, opened at its own URL.
export async function talkNew(ctx: Ctx): Promise<Response> {
  const user = ctx.auth.user;
  if (user === undefined) return signInFirst(ctx);
  const form = await readForm(ctx, "rw");
  if (form instanceof Response) return form;
  const made = createConversation(ctx.app.db, user.id);
  if (!made.ok) return flashTo(ctx, HERE, { tone: "danger", message: `Not started: ${TOO_MANY_WORDS}.` });
  return redirect(urlOf(made.value));
}
// POST /talk/:id/rename — the title from the form; an empty one clears it.
export async function talkRename(ctx: Ctx): Promise<Response> {
  const user = ctx.auth.user;
  if (user === undefined) return signInFirst(ctx);
  const form = await readForm(ctx, "rw");
  if (form instanceof Response) return form;
  const conversation = conversationOf(ctx, user);
  if (conversation === undefined) return notFoundPage(ctx);
  const title = form.get("title");
  const renamed = renameConversation(ctx.app.db, user.id, conversation.id, typeof title === "string" ? title : "\n");
  return flashTo(ctx, urlOf(conversation), renamed.ok ? { tone: "success", message: "Renamed." } : { tone: "danger", message: `A title is up to ${TITLE_MAX} characters, on one line.` });
}
// POST /talk/:id/archive — archived=1 puts it away, 0 brings it back.
export async function talkArchive(ctx: Ctx): Promise<Response> {
  const user = ctx.auth.user;
  if (user === undefined) return signInFirst(ctx);
  const form = await readForm(ctx, "rw");
  if (form instanceof Response) return form;
  const conversation = conversationOf(ctx, user);
  if (conversation === undefined) return notFoundPage(ctx);
  const archive = form.get("archived") !== "0";
  archiveConversation(ctx.app.db, user.id, conversation.id, archive);
  return flashTo(ctx, archive ? HERE : urlOf(conversation), { tone: "success", message: archive ? "Archived. It is under Archived." : "Restored." });
}
const AGAIN: readonly RedoHow[] = ["edit", "regenerate", "retry"];
// POST /talk/again/:how — edit and resend the last message, regenerate the last reply, retry a failed turn.
// POST /talk/again/:how and POST /talk/:id/again/:how — edit and resend the last message, regenerate the last reply, retry a failed turn.
export async function talkAgainSend(ctx: Ctx): Promise<Response> {
  const user = ctx.auth.user;
  if (user === undefined) return signInFirst(ctx);
@@ -254,16 +368,19 @@
export async function talkAgainSend(ctx: Ctx): Promise<Response> {
  if (form instanceof Response) return form;
  const how = AGAIN.find((h) => h === ctx.params["how"]);
  if (how === undefined) return new Response("not found", { status: 404 });
  const conversation = conversationOf(ctx, user);
  if (conversation === undefined) return notFoundPage(ctx);
  const here = ctx.params["id"] === undefined ? HERE : urlOf(conversation);
  const text = form.get("text");
  const asJson = (ctx.request.headers.get("accept") ?? "").includes("application/json");
  let status = 422;
  let message = `Say something, up to ${WORDS_MAX} characters.`;
  if (how !== "edit" || (typeof text === "string" && text.trim() !== "" && text.length <= WORDS_MAX)) {
    const said = talkAgain(ctx.app, user, how, typeof text === "string" ? text : "");
    if (said.ok) return asJson ? json({ ok: true }, 202) : flashTo(ctx, `${HERE}#end`, { tone: "success", message: "Asked again. Reload to see the answer." });
    const said = talkAgain(ctx.app, user, how, typeof text === "string" ? text : "", conversation.id);
    if (said.ok) return asJson ? json({ ok: true }, 202) : flashTo(ctx, `${here}#end`, { tone: "success", message: "Asked again. Reload to see the answer." });
    [status, message] = TALK_WORDS[said.error];
  }
  return asJson ? json({ ok: false, message }, status) : flashTo(ctx, `${HERE}#end`, { tone: "danger", message });
  return asJson ? json({ ok: false, message }, status) : flashTo(ctx, `${here}#end`, { tone: "danger", message });
}
// POST /talk/queue/:id/cancel — take back a message waiting for the running turn.
@@ -315,7 +432,10 @@
export function talkStream(ctx: Ctx): Response {
  const after = ctx.url.searchParams.get("after") ?? ctx.request.headers.get("last-event-id") ?? "";
  if (!TURN_ID.test(after)) return new Response("bad turn id", { status: 400 });
  const { app } = ctx;
  const conversation = openConversation(app.db, user.id);
  const named = ctx.url.searchParams.get("c");
  if (named !== null && named !== "" && !CONVERSATION_ID.test(named)) return new Response("bad conversation id", { status: 400 });
  const conversation = named === null || named === "" ? openConversation(app.db, user.id) : getConversation(app.db, user.id, named);
  if (conversation === undefined) return new Response("no such conversation", { status: 404 });
  let cursor = after;
  return eventStream(app, ctx.request, (emit, close) => {
    const started = Date.now();
@@ -323,7 +443,7 @@
export function talkStream(ctx: Ctx): Response {
    let shown = "";
    const tick = (): void => {
      // Asked before the read: a turn that ends after this look is read whole next time.
      const running = clock.running(app, user.id);
      const running = clock.running(app, user.id, conversation.id);
      const fresh = turnsAfter(app.db, user.id, conversation.id, cursor);
      if (fresh.length > 0) {
        const waiting = new Set(waitingConfirms(ctx, user).map((w) => w.id));
@@ -335,7 +455,7 @@
export function talkStream(ctx: Ctx): Response {
        }
      }
      // Every tab and viewer sees what waits: sent whenever the list changes.
      const waits = queuedTalk(app, user);
      const waits = queuedTalk(app, user, conversation.id);
      const key = waits.map((q) => q.id).join();
      if (key !== shown && (running || shown !== "")) {
        shown = key;
@@ -349,7 +469,7 @@
export function talkStream(ctx: Ctx): Response {
        emit("done", {
          costs,
          context: context === undefined ? "" : contextText(context),
          acts: [...exchangeActs(app.db, user.id, conversation.id, false)].map(([id, act]) => ({ id: `t-${id}`, html: act.text })),
          acts: [...exchangeActs(app.db, user.id, conversation.id, false, ((c) => (c.id === conversation.id ? HERE : urlOf(conversation)))(openConversation(app.db, user.id)))].map(([id, act]) => ({ id: `t-${id}`, html: act.text })),
        });
        close();
      } else if (Date.now() - started >= clock.streamMs) {
@@ -47,6 +47,9 @@
export const talkCss = /* css */ `
.talk-chips:empty { display: none; }
.talk-files { justify-content: flex-end; }
.talk-more { text-align: center; }
.talk-chats, .talk-here { margin-bottom: 12px; }
.talk-chats li a { display: flex; justify-content: space-between; }
.talk-chats [aria-current] { font-weight: 600; }
.talk-replaced { opacity: 0.55; }
.talk-failed form { margin-top: 6px; }
.talk-failed .btn, .talk-act { min-height: 2.75rem; }
@@ -67,6 +70,7 @@
if (root) {
  let source = null;
  let retry = 0;
  const paged = root.dataset.paged === "1";
  const { c: cid, here } = root.dataset;
  const say = (words) => { status.textContent = words; };
  const hint = root.querySelector("[data-hint]");
  if (hint) hint.textContent = "Enter sends, Shift+Enter adds a line";
@@ -134,7 +138,7 @@
if (root) {
  const again = async (how, body) => {
    say(how === "edit" ? "Sending…" : "Asking again…");
    try {
      const res = await fetch("/talk/again/" + how, { method: "POST", headers: { accept: "application/json" }, body });
      const res = await fetch(here + "/again/" + how, { method: "POST", headers: { accept: "application/json" }, body });
      const out = await res.json().catch(() => ({}));
      if (!res.ok) { say(out.message || "That was not done."); return false; }
      stuck = true;
@@ -188,7 +192,7 @@
if (root) {
    if (paged) return;
    if (source) source.close();
    dropActs();
    source = new EventSource("/talk/stream?after=" + encodeURIComponent(last));
    source = new EventSource("/talk/stream?c=" + encodeURIComponent(cid) + "&after=" + encodeURIComponent(last));
    source.addEventListener("turn", (e) => {
      const turn = JSON.parse(e.data);
      last = turn.id;
@@ -283,7 +287,7 @@
if (root) {
      const res = await fetch("/api/v1/conversation/messages", {
        method: "POST",
        headers: { "content-type": "application/json" },
        body: JSON.stringify({ text, files: attached.map((f) => f.id), during: steer && answering ? "steer" : "queue" }),
        body: JSON.stringify({ text, conversation: cid, files: attached.map((f) => f.id), during: steer && answering ? "steer" : "queue" }),
      });
      if (!res.ok) {
        const body = await res.json().catch(() => ({}));
@@ -299,7 +303,7 @@
if (root) {
      const out = await res.json().catch(() => ({}));
      if (out.how === "queued") { say("Queued: it sends after this answer."); if (!source) follow(); return; }
      if (out.how === "interrupted") { say("Stopping, then sending…"); return; }
      if (paged) { location.href = "/talk"; return; }
      if (paged) { location.href = here; return; }
      follow();
    } catch (_) {
      say("That was not sent: no connection.");
@@ -19,7 +19,7 @@
import { mintViaToken } from "../src/core/via_token.ts";
import { TALK_PER_MINUTE, talk, talkAgain } from "../src/actions/talk.ts";
import { turnsLimit } from "../src/http/api/conversation_talk.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { appendTurn, openConversation } from "../src/core/conversations.ts";
import { appendTurn, newConversation, openConversation } from "../src/core/conversations.ts";
import { forgeSshSession } from "../src/tui/ssh.ts";
import { isStop, parseTalkAgain, parseTalkCommand } from "../src/tui/ssh-talk.ts";
import { listTurns } from "../src/core/conversations.ts";
@@ -342,6 +342,24 @@
echo '{"type":"result","subtype":"success","is_error":false,"result":"Heard.","t
    expect(await standing()).toEqual(plain);
    expect(talkAgain(app, undefined, "retry").ok).toBe(false);
  });
  test("regenerate acts on the conversation it names, not the latest", async () => {
    const older = newConversation(app.db, alice());
    appendTurn(app.db, alice(), older.id, { role: "person", text: "older question" });
    appendTurn(app.db, alice(), older.id, { role: "agent", text: "older answer" });
    const newer = newConversation(app.db, alice());
    appendTurn(app.db, alice(), newer.id, { role: "person", text: "newer question" });
    appendTurn(app.db, alice(), newer.id, { role: "agent", text: "newer answer" });
    withBinary(answers("Fresh older answer."));
    await settled(redo(app, conversationOptions(app)!, alice(), "regenerate", "", older.id));
    await settle();
    const text = (id: string) => (listTurns(app.db, alice(), id, { limit: 50 }) as { ok: true; value: { text: string; replaced: boolean }[] }).value;
    expect(text(older.id).filter((t) => !t.replaced).map((t) => t.text)).toEqual(["older question", "Fresh older answer."]);
    expect(text(newer.id).map((t) => t.text)).toEqual(["newer question", "newer answer"]);
    const stranger = redo(app, conversationOptions(app)!, alice(), "regenerate", "", "01zzzzzzzzzzzzzzzzzzzzzzzz");
    expect(!stranger.ok && stranger.error).toBe("not_found");
    expect(exchangeActs(app.db, alice(), older.id, false, `/talk/${older.id}`).size).toBe(2);
  });
  const post = (path: string, h: Record<string, string>, body = "") =>
    fetch(`${servers.url}${path}`, { method: "POST", headers: { "content-type": "application/x-www-form-urlencoded", ...h }, body, redirect: "manual" });
  const cookie = () => ({ cookie: `forge_session=${createSession(app.db, alice()).token}` });
@@ -13,7 +13,7 @@
import { join } from "node:path";
import { createApp, type App } from "../src/app.ts";
import { clearAccountCeiling, daySpent, setAccountCeiling } from "../src/core/account_ceiling.ts";
import { claimDone, completeWrite, recordWrite } from "../src/core/conversation_writes.ts";
import { listTurns, openConversation } from "../src/core/conversations.ts";
import { listTurns, newConversation, openConversation } from "../src/core/conversations.ts";
import { monthSpent } from "../src/core/model_grant.ts";
import { addSubscription, getSubscription, PLATFORM, setGrants, wakeSubscription } from "../src/core/subscriptions.ts";
import { verifyToken } from "../src/core/tokens.ts";
@@ -524,6 +524,21 @@
sleep 300
    expect(alive).toBe(false);
    expect(stopTurn(app, u.value.id)).toBe(false);
  }, 20_000);
  test("Stop ends the replies running in two conversations, the older one included", async () => {
    const older = newConversation(app.db, alice.id);
    const newer = newConversation(app.db, alice.id);
    const one = say(app, options(stub("two-a", "sess-two-a", "hang")), alice.id, "first", [], "inject", older.id);
    const two = say(app, options(stub("two-b", "sess-two-b", "hang")), alice.id, "second", [], "inject", newer.id);
    if (!one.ok || !two.ok || one.value.done === undefined || two.value.done === undefined) throw new Error("not started");
    expect(turnRunning(app, alice.id, older.id)).toBe(true);
    expect(turnRunning(app, alice.id, newer.id)).toBe(true);
    expect(stopTurn(app, alice.id)).toBe(true);
    await Promise.all([one.value.done, two.value.done]);
    expect(turnRunning(app, alice.id, older.id)).toBe(false);
    expect(turnRunning(app, alice.id, newer.id)).toBe(false);
    expect(stopTurn(app, alice.id)).toBe(false);
  }, 20_000);
});
describe("talk turn counts (#8860)", () => {
@@ -5,6 +5,12 @@
import { join } from "node:path";
import { migrations } from "../src/core/schema.ts";
import {
  appendTurn,
  archiveConversation,
  getConversation,
  listConversations,
  newConversation,
  renameConversation,
  TITLE_MAX,
  listTurns,
  MAX_TURN_CHARS,
  openConversation,
@@ -130,3 +136,52 @@
describe("conversations", () => {
    db.close();
  });
});
describe("many conversations (#8814)", () => {
  test("new starts another; the list is newest activity first and the latest is where messages go", () => {
    const db = open("many.db");
    const a = openConversation(db, "u1");
    const b = newConversation(db, "u1");
    expect(b.id).not.toBe(a.id);
    expect(listConversations(db, "u1").map((c) => c.id)).toEqual([b.id, a.id]);
    Bun.sleepSync(3);
    appendTurn(db, "u1", a.id, { role: "person", text: "hi" });
    expect(listConversations(db, "u1").map((c) => c.id)).toEqual([a.id, b.id]);
    expect(openConversation(db, "u1").id).toBe(a.id);
  });
  test("rename keeps a clean title and refuses a long or multi-line one", () => {
    const db = open("rename.db");
    const c = openConversation(db, "u1");
    const named = renameConversation(db, "u1", c.id, "  Plan the week ");
    expect(named.ok && named.value.title).toBe("Plan the week");
    expect(renameConversation(db, "u1", c.id, "x".repeat(TITLE_MAX + 1))).toEqual({ ok: false, error: "bad_title" });
    expect(renameConversation(db, "u1", c.id, "a\nb")).toEqual({ ok: false, error: "bad_title" });
    expect(getConversation(db, "u1", c.id)?.title).toBe("Plan the week");
  });
  test("archive puts one behind the filter, restore brings it back, turns survive", () => {
    const db = open("archive.db");
    const a = openConversation(db, "u1");
    appendTurn(db, "u1", a.id, { role: "person", text: "keep me" });
    const b = newConversation(db, "u1");
    expect(archiveConversation(db, "u1", b.id, true).ok).toBe(true);
    expect(listConversations(db, "u1").map((c) => c.id)).toEqual([a.id]);
    expect(listConversations(db, "u1", { archived: true }).map((c) => c.id)).toEqual([b.id]);
    expect(openConversation(db, "u1").id).toBe(a.id);
    archiveConversation(db, "u1", a.id, true);
    expect(openConversation(db, "u1").id).not.toBe(a.id);
    archiveConversation(db, "u1", a.id, false);
    expect(listTurns(db, "u1", a.id)).toMatchObject({ ok: true, value: [{ text: "keep me" }] });
  });
  test("another person's id is not found for every call", () => {
    const db = open("other.db");
    const mine = openConversation(db, "u1");
    expect(getConversation(db, "u2", mine.id)).toBeUndefined();
    expect(renameConversation(db, "u2", mine.id, "x")).toEqual({ ok: false, error: "not_found" });
    expect(archiveConversation(db, "u2", mine.id, true)).toEqual({ ok: false, error: "not_found" });
    expect(listConversations(db, "u2")).toEqual([]);
    expect(listTurns(db, "u2", mine.id)).toEqual({ ok: false, error: "not_found" });
  });
});
@@ -70,6 +70,7 @@
test("a site-admin person is offered the whole roster", () => {
    ["decider", "Decider", "what it closed, deferred and asked you about today"],
    ["notify", "Phone notifications", "where the crew reaches your phone; s sets, x turns off"],
    ["confirms", "Confirms", "what the forge's agent asked to do; y does it once"],
    ["conversations", "Conversations", "your talks with the forge's agent; n starts one, r renames, x archives"],
    ["ssh-keys", "SSH keys", "list, add and remove the keys that sign in as you"],
    ["passkeys", "Passkeys", "the passkeys that sign in as you"],
    ["account", "Account settings", undefined],
@@ -222,6 +223,7 @@
test("a member person is offered the signed-in roster without the admin entries"
    ["decider", "Decider", "what it closed, deferred and asked you about today"],
    ["notify", "Phone notifications", "where the crew reaches your phone; s sets, x turns off"],
    ["confirms", "Confirms", "what the forge's agent asked to do; y does it once"],
    ["conversations", "Conversations", "your talks with the forge's agent; n starts one, r renames, x archives"],
    ["ssh-keys", "SSH keys", "list, add and remove the keys that sign in as you"],
    ["passkeys", "Passkeys", "the passkeys that sign in as you"],
    ["account", "Account settings", undefined],
@@ -19,6 +19,7 @@
import { seedAdmin } from "./helpers/admin.ts";
/** Routes that answer 200 without a `session` phase → why. */
const UNTIMED: Record<string, string> = {
  "/api/v1/conversations": "a person's conversation list, one indexed query; no page to phase",
  "/metrics": "Prometheus text exposition, scraped by token; not a page read",
};
@@ -71,7 +71,7 @@
describe("migrations are additive across a roll", () => {
    expect(inPlay.length).toBeGreaterThan(0);
    const offenders = migrationFiles
      .filter((m) => inPlay.some((ids) => !ids.has(m.name)))
      .filter((m) => !(m.name in RETIRED))
      .filter((m) => !(m.name in RETIRED) && !(m.name in REBUILT))
      .map((m) => ({ name: m.name, problems: notAdditive(m.sql) }))
      .filter((m) => m.problems.length > 0);
    expect(offenders).toEqual([]);
@@ -152,6 +152,16 @@
const RETIRED: Record<string, { readonly drops: readonly string[]; readonly sinc
  },
};
/**
 * Migrations that rebuild a table under its own name, in one transaction, with
 * every column the old release reads kept and only columns added: an old
 * process sees the same table before and after. SQLite cannot drop a UNIQUE
 * constraint in place, so a rebuild is the only way to lift one.
 */
const REBUILT: Record<string, string> = {
  "20261103120000-conversations-many": "conversation loses UNIQUE(user_id) (#8814); same columns, plus title and archived_at",
};
const src = join(import.meta.dir, "../src");
interface Release {
@@ -45,11 +45,13 @@
const ARCH = "needs an archived-home operation id; the seed archives nothing";
const NOW = "the stage is one of check, review, land or live; the seed fills no word with a name it cannot guess";
const GATE = "needs a kept gate log, written only when a full gate runs on land";
const BET = "needs a bet, which the seed does not propose";
const TALK = "needs a conversation of the signed-in person; the seed starts none";
const HOOK = "needs a webhook, which the seed does not register";
/** GET patterns the seed cannot fill → why. Requested with a placeholder all the same. */
const UNSEEDED: Record<string, string> = {
  "/:owner/-/teams/:team": ORG,
  "/talk/:id": TALK,
  "/:owner/:name/bets/:id": BET,
  "/:owner/:name/looks/:env/:commit/:kind.png": LOOK,
  "/:owner/:name/milestones/:number/limb/:op": LIMB,
@@ -0,0 +1,265 @@
/**
 * Many conversations (#8814): /talk lists them with New, each opens at
 * /talk/<id>, rename and archive are plain forms, the API and the MCP reach
 * the same calls, another person's id is a 404, and the migration that
 * lifted one-per-person keeps the turns it found.
 */
import { afterAll, beforeAll, describe, expect, test } from "bun:test";
import { mkdtemp, rm } from "node:fs/promises";
import { tmpdir } from "node:os";
import { join } from "node:path";
import { createApp, type App } from "../src/app.ts";
import { appendTurn, CONVERSATIONS_MAX, createConversation, listConversations, listTurns, newConversation, openConversation, renameConversation } from "../src/core/conversations.ts";
import { createSession } from "../src/core/sessions.ts";
import { createToken } from "../src/core/tokens.ts";
import { migrations } from "../src/core/schema.ts";
import { createUser, type User } from "../src/core/users.ts";
import { migrationFiles } from "../src/core/schema.ts";
import { openDb } from "../src/kernel/db.ts";
import { serve, type Servers } from "../src/http/server.ts";
import { tool as sayTool } from "../src/http/mcp/tools/say.ts";
import { promote } from "./helpers/members.ts";
import { quietLogs } from "./helpers/globals.ts";
quietLogs();
let dir: string;
let app: App;
let servers: Servers;
let alice: User;
let bob: User;
const cookie = (u: User) => `forge_session=${createSession(app.db, u.id).token}`;
const get = (path: string, u?: User) =>
  fetch(`${servers.url}${path}`, { redirect: "manual", headers: u ? { cookie: cookie(u) } : {} });
const post = (path: string, u: User, form: Record<string, string>) =>
  fetch(`${servers.url}${path}`, { method: "POST", redirect: "manual", headers: { origin: servers.url, cookie: cookie(u) }, body: new URLSearchParams(form) });
const api = (method: string, path: string, u: User, body?: unknown) =>
  fetch(`${servers.url}${path}`, {
    method,
    redirect: "manual",
    headers: { origin: servers.url, cookie: cookie(u), "content-type": "application/json" },
    ...(body === undefined ? {} : { body: JSON.stringify(body) }),
  });
beforeAll(async () => {
  dir = await mkdtemp(join(tmpdir(), "forge-talk-many-"));
  app = createApp({ dataDir: dir, port: 0 });
  servers = await serve(app);
  const mk = async (username: string, first = false) => {
    const u = await createUser(app.db, { origin: "seed", trusted: true, username, email: `${username}@forge.local`, password: "a-good-passphrase", adminIfFirst: first });
    if (!u.ok) throw new Error(u.error);
    promote(app.db, u.value);
    return u.value;
  };
  alice = await mk("alice", true);
  bob = await mk("bob");
}, 30_000);
afterAll(async () => {
  servers.stop();
  app.close();
  await rm(dir, { recursive: true, force: true });
});
describe("the page", () => {
  test("New makes a conversation at its own URL that survives a reload, and the list shows it", async () => {
    const made = await post("/talk/new", alice, {});
    expect(made.status).toBe(303);
    const url = made.headers.get("location")!;
    expect(url).toMatch(/^\/talk\/[0-9a-z]+$/);
    const first = await (await get(url, alice)).text();
    const again = await get(url, alice);
    expect(again.status).toBe(200);
    expect(first).toContain(`data-c="${url.slice(6)}"`);
    expect(await again.text()).toContain(`href="${url}"`);
    expect((await get("/talk", alice)).status).toBe(200);
  });
  test("rename shows the title in the list; archive moves it behind the filter; restore brings it back", async () => {
    const c = newConversation(app.db, alice.id);
    const renamed = await post(`/talk/${c.id}/rename`, alice, { title: "Weekly <plan>" });
    expect(renamed.status).toBe(303);
    const page = await (await get(`/talk/${c.id}`, alice)).text();
    expect(page).toContain("Weekly &lt;plan&gt;");
    expect(page).not.toContain("Weekly <plan>");
    await post(`/talk/${c.id}/archive`, alice, { archived: "1" });
    const list = await (await get("/talk", alice)).text();
    expect(list).not.toContain(`href="/talk/${c.id}"`);
    expect(list).toContain("Archived (");
    expect(await (await get("/talk?archived=1", alice)).text()).toContain(`href="/talk/${c.id}"`);
    expect(await (await get(`/talk/${c.id}`, alice)).text()).toContain("sending here keeps it archived");
    await post(`/talk/${c.id}/archive`, alice, { archived: "0" });
    expect(await (await get("/talk", alice)).text()).toContain(`href="/talk/${c.id}"`);
    expect(await (await get(`/talk/${c.id}`, alice)).text()).not.toContain("sending here keeps it archived");
  });
  test("another person's id answers 404 for view, send, rename, archive and stream", async () => {
    const mine = newConversation(app.db, alice.id);
    expect((await get(`/talk/${mine.id}`, bob)).status).toBe(404);
    expect((await post(`/talk/${mine.id}`, bob, { text: "hi" })).status).toBe(404);
    expect((await post(`/talk/${mine.id}/rename`, bob, { title: "mine now" })).status).toBe(404);
    expect((await post(`/talk/${mine.id}/archive`, bob, { archived: "1" })).status).toBe(404);
    expect((await get(`/talk/stream?c=${mine.id}`, bob)).status).toBe(404);
    expect((await get("/talk/nope!", bob)).status).toBe(404);
    expect(listConversations(app.db, alice.id).find((c) => c.id === mine.id)?.title).toBe("");
  });
  test("signed out is sent to sign in", async () => {
    expect((await get("/talk/abc")).status).toBe(303);
    expect((await post("/talk/new", alice, {})).status).toBe(303);
  });
});
describe("the API", () => {
  test("list, new, rename, archive; another person's id is 404", async () => {
    const made = await api("POST", "/api/v1/conversations", alice, { title: "From the API" });
    expect(made.status).toBe(201);
    const { conversation } = (await made.json()) as { conversation: { id: string; title: string } };
    expect(conversation.title).toBe("From the API");
    const listed = (await (await api("GET", "/api/v1/conversations", alice)).json()) as { conversations: { id: string }[] };
    expect(listed.conversations.some((c) => c.id === conversation.id)).toBe(true);
    const patched = await api("PATCH", `/api/v1/conversations/${conversation.id}`, alice, { title: "Renamed", archived: true });
    expect(patched.status).toBe(200);
    const after = (await (await api("GET", "/api/v1/conversations?archived=1", alice)).json()) as { conversations: { id: string; title: string }[] };
    expect(after.conversations.find((c) => c.id === conversation.id)?.title).toBe("Renamed");
    expect((await api("PATCH", `/api/v1/conversations/${conversation.id}`, bob, { title: "x" })).status).toBe(404);
    expect((await api("PATCH", `/api/v1/conversations/${conversation.id}`, alice, { title: "x".repeat(81) })).status).toBe(422);
    expect((await api("GET", `/api/v1/conversation/turns?conversation=${conversation.id}`, bob)).status).toBe(404);
    expect((await api("GET", `/api/v1/conversation/turns?conversation=${conversation.id}`, alice)).status).toBe(200);
    expect((await api("POST", "/api/v1/conversation/messages", bob, { text: "hi", conversation: conversation.id })).status).toBe(404);
  });
});
describe("the MCP", () => {
  test("say with an action lists, starts, renames and archives, and refuses another person's id", async () => {
    const ctx = { app, auth: { user: alice, via: "session" } } as never;
    const run = async (u: User, args: Record<string, unknown>) => {
      const answer = (await sayTool.run(ctx, u, args)) as { ok: boolean; value?: any; error?: string };
      return answer.ok ? answer.value : { error: answer.error };
    };
    const made = await run(alice, { action: "new", title: "By agent" });
    expect(made.conversation).toMatch(/^[0-9a-z]+$/);
    expect((await run(alice, { action: "list" })).conversations.some((c: { id: string }) => c.id === made.conversation)).toBe(true);
    expect((await run(alice, { action: "rename", conversation: made.conversation, title: "Better" })).says).toBe("Renamed.");
    expect((await run(alice, { action: "archive", conversation: made.conversation })).says).toBe("Archived.");
    expect((await run(bob, { action: "archive", conversation: made.conversation })).error).toBe("not_found");
    expect((await run(alice, { action: "list" })).conversations.some((c: { id: string }) => c.id === made.conversation)).toBe(false);
    expect((await run(alice, { action: "list", archived: true })).conversations.some((c: { id: string }) => c.id === made.conversation)).toBe(true);
    expect((await run(alice, {})).error).toBe("invalid_text");
  });
});
describe("the migration", () => {
  test("a person's one conversation, its turns and runs come through the table rebuild", () => {
    const db = openDb(join(dir, "before.db"), migrations.slice(0, -1));
    db.query("INSERT INTO user (id, username, email, password_hash) VALUES ('u1','u1','u1@x','x')").run();
    db.query("INSERT INTO conversation (id, user_id, claude_session_id, created_at, updated_at) VALUES ('c1','u1','s','t','t')").run();
    for (const n of [1, 2, 3]) appendTurn(db, "u1", "c1", { role: "person", text: `t${n}` });
    db.query("INSERT INTO conversation_run (id, conversation_id, user_id, prompt, started_at) VALUES ('r1','c1','u1','p','t')").run();
    db.close();
    const after = openDb(join(dir, "before.db"), migrations);
    expect(openConversation(after, "u1").id).toBe("c1");
    const turns = listTurns(after, "u1", "c1");
    expect(turns.ok && turns.value.map((t) => t.text)).toEqual(["t1", "t2", "t3"]);
    expect(after.query("SELECT COUNT(*) AS n FROM conversation_run").get()).toEqual({ n: 1 });
    expect(newConversation(after, "u1").id).not.toBe("c1");
    after.close();
  });
});
describe("the migration keeps attachments", () => {
  test("a file row, hung off a conversation and a turn, survives the table rebuild", () => {
    const at = migrationFiles.findIndex((m) => m.name === "20261103120000-conversations-many");
    expect(at).toBeGreaterThan(0);
    const path = join(dir, "files.db");
    const db = openDb(path, migrationFiles.slice(0, at).map((m) => m.sql));
    db.query("INSERT INTO user (id, username, email, password_hash) VALUES ('u1','u1','u1@x','x')").run();
    db.query("INSERT INTO conversation (id, user_id, claude_session_id, created_at, updated_at) VALUES ('c1','u1','s','t','t')").run();
    const turn = appendTurn(db, "u1", "c1", { role: "person", text: "see" });
    if (!turn.ok) throw new Error("no turn");
    db.query("INSERT INTO conversation_file (id, conversation_id, user_id, turn_id, name, type, size, created_at) VALUES ('f1','c1','u1',?1,'a.png','image/png',3,'t')").run(turn.value.id);
    db.close();
    const after = openDb(path, migrations);
    expect(after.query("SELECT conversation_id, turn_id, name FROM conversation_file").all()).toEqual([{ conversation_id: "c1", turn_id: turn.value.id, name: "a.png" }]);
    after.close();
  });
});
describe("the mutation checks", () => {
  test("a cross-origin POST to New, Rename and Archive is refused and changes nothing", async () => {
    const c = newConversation(app.db, alice.id);
    const before = listConversations(app.db, alice.id).length;
    const evil = (path: string, form: Record<string, string>) =>
      fetch(`${servers.url}${path}`, { method: "POST", redirect: "manual", headers: { origin: "https://evil.example", cookie: cookie(alice) }, body: new URLSearchParams(form) });
    expect((await evil("/talk/new", {})).status).toBe(403);
    expect((await evil(`/talk/${c.id}/rename`, { title: "hijack" })).status).toBe(403);
    expect((await evil(`/talk/${c.id}/archive`, { archived: "1" })).status).toBe(403);
    expect(listConversations(app.db, alice.id).length).toBe(before);
    const kept = listConversations(app.db, alice.id).find((x) => x.id === c.id);
    expect(kept?.title).toBe("");
  });
  test("a read-only token is refused on POST and PATCH /api/v1/conversations", async () => {
    const ro = createToken(app.db, alice.id, "t", "ro").token;
    const rw = createToken(app.db, alice.id, "t", "rw").token;
    const c = newConversation(app.db, alice.id);
    const call = (method: string, path: string, token: string, body: unknown) =>
      fetch(`${servers.url}${path}`, { method, headers: { authorization: `Bearer ${token}`, "content-type": "application/json" }, body: JSON.stringify(body) });
    const before = listConversations(app.db, alice.id).length;
    expect((await call("POST", "/api/v1/conversations", ro, {})).status).toBe(403);
    expect((await call("PATCH", `/api/v1/conversations/${c.id}`, ro, { archived: true })).status).toBe(403);
    expect(listConversations(app.db, alice.id).length).toBe(before);
    expect(listConversations(app.db, alice.id).find((x) => x.id === c.id)?.archivedAt).toBeNull();
    expect((await call("PATCH", `/api/v1/conversations/${c.id}`, rw, { archived: true })).status).toBe(200);
    expect((await fetch(`${servers.url}/api/v1/conversations`, { headers: { authorization: `Bearer ${ro}` } })).status).toBe(200);
  });
  test("GET /talk/stream is the stream, not a conversation called stream", async () => {
    const answer = await get("/talk/stream", alice);
    expect(answer.headers.get("content-type")).toContain("text/event-stream");
    await answer.body?.cancel();
  });
});
describe("the most a person holds", () => {
  test("every door refuses past the cap, and the others are untouched", async () => {
    const carol = await createUser(app.db, { origin: "seed", trusted: true, username: "carol", email: "[email protected]", password: "a-good-passphrase" });
    if (!carol.ok) throw new Error(carol.error);
    promote(app.db, carol.value);
    const c = carol.value;
    while (listConversations(app.db, c.id).length + listConversations(app.db, c.id, { archived: true }).length < CONVERSATIONS_MAX) {
      const made = createConversation(app.db, c.id);
      if (!made.ok) break;
    }
    const held = () => (app.db.query("SELECT COUNT(*) AS n FROM conversation WHERE user_id = ?1").get(c.id) as { n: number }).n;
    expect(held()).toBe(CONVERSATIONS_MAX);
    const refused = createConversation(app.db, c.id);
    expect(!refused.ok && refused.error).toBe("too_many");
    const page = await post("/talk/new", c, {});
    expect(page.status).toBe(303);
    expect(page.headers.get("location")).not.toMatch(/^\/talk\/[0-9a-z]{6,}/);
    const viaApi = await api("POST", "/api/v1/conversations", c, {});
    expect(viaApi.status).toBe(409);
    expect(((await viaApi.json()) as { error: string }).error).toBe("too_many");
    const ctx = { app, auth: { user: c, via: "session" } } as never;
    const mcp = (await sayTool.run(ctx, c, { action: "new" })) as { ok: boolean; error?: string };
    expect(mcp.ok).toBe(false);
    expect(mcp.error).toBe("too_many");
    expect(held()).toBe(CONVERSATIONS_MAX);
    // Archiving does not free a place; another person is unaffected.
    expect(createConversation(app.db, alice.id).ok).toBe(true);
  });
});
describe("the MCP rename", () => {
  test("rename needs a title: without one the title is kept", async () => {
    const ctx = { app, auth: { user: alice, via: "session" } } as never;
    const made = newConversation(app.db, alice.id);
    renameConversation(app.db, alice.id, made.id, "Keep me");
    const answer = (await sayTool.run(ctx, alice, { action: "rename", conversation: made.id })) as { ok: boolean; error?: string };
    expect(answer.ok).toBe(false);
    expect(answer.error).toBe("invalid_title");
    expect(listConversations(app.db, alice.id).find((x) => x.id === made.id)?.title).toBe("Keep me");
  });
});
@@ -191,8 +191,8 @@
describe("the page", () => {
  test("the page's own bytes are held: stylesheet and script stay small", async () => {
    const { talkCss, talkJs } = await import("../src/web/pages/talk_client.ts");
    expect(Buffer.byteLength(talkCss)).toBeLessThan(3_600);
    expect(Buffer.byteLength(talkJs)).toBeLessThan(13_400);
    expect(Buffer.byteLength(talkCss)).toBeLessThan(3_750);
    expect(Buffer.byteLength(talkJs)).toBeLessThan(13_500);
    say(alice, "agent", "```ts\nlet x = 1;\n```");
    const page = await get("/talk", alice);
    const size = (await page.arrayBuffer()).byteLength;
@@ -0,0 +1,109 @@
/**
 * The terminal's Conversations screen (#8814): list, New, Rename and
 * Archive/Restore through the calls /talk uses, offered to a signed-in person
 * and not to an agent, with the cap refusing past it.
 */
import { afterAll, beforeAll, describe, expect, test } from "bun:test";
import { mkdtemp, rm } from "node:fs/promises";
import { tmpdir } from "node:os";
import { join } from "node:path";
import { createApp, type App } from "../src/app.ts";
import { appendTurn, CONVERSATIONS_MAX, createConversation, listConversations, listTurns, renameConversation } from "../src/core/conversations.ts";
import { createUser, type User } from "../src/core/users.ts";
import { createForgeApp } from "../src/tui/forge.ts";
import { headlessTerminal } from "../src/tui/term/terminal.ts";
import { settleApp } from "./helpers/tui.ts";
import { proveAll } from "./helpers/verified.ts";
let dir: string;
let app: App;
let alice: User;
let bob: User;
const open = [":", "Conversations", "\r"];
async function drive(user: User, keys: string[]): Promise<string> {
  const terminal = headlessTerminal(120, 30);
  const { app: tui } = createForgeApp(
    app,
    { sshUsername: user.username, remoteAddress: "127.0.0.1", fingerprint: "SHA256:test", user },
    { terminal, exitHooks: false },
  );
  tui.start();
  await settleApp(tui);
  for (const k of keys) {
    terminal.feed(k);
    await settleApp(tui);
  }
  const text = tui.screen.toText();
  tui.stop?.();
  return text;
}
beforeAll(async () => {
  dir = await mkdtemp(join(tmpdir(), "forge-tui-chats-"));
  app = createApp({ dataDir: dir, port: 0 });
  const mk = async (username: string, first = false) => {
    const r = await createUser(app.db, { origin: "seed", trusted: true, username, email: `${username}@forge.local`, password: "a-good-passphrase", adminIfFirst: first });
    if (!r.ok) throw new Error(r.error);
    return r.value;
  };
  alice = await mk("alice", true);
  bob = await mk("bob");
  proveAll(app);
});
afterAll(async () => {
  app.db.close();
  await rm(dir, { recursive: true, force: true });
});
describe("the terminal's conversations screen", () => {
  test("n starts one with a title, r renames it, x archives it and a brings it back", async () => {
    const text = await drive(alice, [...open, "n", "Weekly plan", "\r"]);
    const mine = listConversations(app.db, alice.id);
    expect(mine.map((c) => c.title)).toEqual(["Weekly plan"]);
    expect(text).toContain("Weekly plan");
    expect(text).toContain(`/talk/${mine[0]!.id}`);
    await drive(alice, [...open, "r", ..."\x7f".repeat(11).split(""), "Renamed", "\r"]);
    expect(listConversations(app.db, alice.id)[0]!.title).toBe("Renamed");
    await drive(alice, [...open, "x"]);
    expect(listConversations(app.db, alice.id)).toEqual([]);
    const archived = await drive(alice, [...open, "a"]);
    expect(archived).toContain("Renamed");
    expect(listConversations(app.db, alice.id, { archived: true }).length).toBe(1);
    await drive(alice, [...open, "a", "x"]);
    expect(listConversations(app.db, alice.id).length).toBe(1);
  });
  test("another person's conversations are not listed", async () => {
    const text = await drive(bob, open);
    expect(text).not.toContain("Renamed");
    expect(text).toContain("No conversations yet");
  });
  test("Enter opens one: its turns, and s says something in it", async () => {
    const made = createConversation(app.db, bob.id);
    if (!made.ok) throw new Error(made.error);
    renameConversation(app.db, bob.id, made.value.id, "Bob's chat");
    appendTurn(app.db, bob.id, made.value.id, { role: "person", text: "how is the forge" });
    appendTurn(app.db, bob.id, made.value.id, { role: "agent", text: "all green today" });
    const text = await drive(bob, [...open, "\r"]);
    expect(text).toContain("how is the forge");
    expect(text).toContain("all green today");
    expect(text).toContain(`/talk/${made.value.id}`);
    // The crew is off in this app: talk() refuses, the prompt says why, and nothing is stored.
    const said = await drive(bob, [...open, "\r", "s", "hello", "\r"]);
    expect(said).toContain("not running here");
    const turns = listTurns(app.db, bob.id, made.value.id, { limit: 50 });
    expect(turns.ok && turns.value.length).toBe(2);
  });
  test("past the cap, n says so and starts nothing", async () => {
    while (createConversation(app.db, alice.id).ok) { /* fill */ }
    const held = (app.db.query("SELECT COUNT(*) AS n FROM conversation WHERE user_id = ?1").get(alice.id) as { n: number }).n;
    expect(held).toBe(CONVERSATIONS_MAX);
    renameConversation(app.db, alice.id, listConversations(app.db, alice.id)[0]!.id, "top");
    const text = await drive(alice, [...open, "n", "one too many", "\r"]);
    expect(text).toContain("the most there can be");
    expect((app.db.query("SELECT COUNT(*) AS n FROM conversation WHERE user_id = ?1").get(alice.id) as { n: number }).n).toBe(CONVERSATIONS_MAX);
  });
});
		@@ -18,6 +18,8 @@
18	18	- `.talk-copy` — a quiet text button that copies a message or a code block.
19	19	- `.talk-suggest` — the starter questions on an empty chat; each fills the composer.
20	20	- `.talk-jump` — "Latest" button, shown when you have scrolled up from the end.
	21	- `.talk-chats` — the conversations list above the chat (#8814): New, the person's conversations newest first, and the Archived filter link.
	22	- `.talk-here` — the line naming the open conversation, with its Rename and Archive forms.
21	23	- `.talk-steps` — the quiet steps line under a reply ("read 3 files, opened #12").
22	24	- `.talk-links` — the links under a reply to what the turn opened or changed.
23	25	- `.talk-replaced` — a turn the person edited, regenerated or retried past: kept in the log, dimmer, labelled "replaced".
		@@ -18,6 +18,16 @@ A reply streams in over `GET /talk/stream?after=<turn id>` (server-sent events,
18	18
19	19	When the agent asks first (`needs_confirm`), the turn draws Confirm (the existing yes) and Cancel (a no: the confirm is spent, nothing runs, a turn says it was cancelled). A result shown once (an invite link) is drawn by Settings → Confirms instead, where Confirm leads.
20	20
	21	## Many conversations (#8814)
	22
	23	A person has any number. `/talk` is their latest, with the list above it (newest activity first), New, and Archived (n) as the one filter (`/talk?archived=1`). Each opens at `/talk/<id>`, stable across reloads; Rename and Archive/Restore are plain forms (`POST /talk/:id/rename`, `/talk/:id/archive`, `POST /talk/new`), so they work without the script. Another person's id is 404 everywhere. A message with no conversation named goes to the latest one that is not archived.
	24
	25	- Cap: a person holds at most 100 conversations, archived ones counted; past it New is refused (page flash, API 409 `too_many`, MCP `too_many`). Stop ends every reply the person has running, in any conversation.
	26	- API: `GET /api/v1/conversations[?archived=1]`, `POST /api/v1/conversations {title?}`, `PATCH /api/v1/conversations/:id {title?, archived?}`; `conversation` on `POST …/messages` and `GET …/turns?conversation=` picks one.
	27	- MCP: `say` with `action` list \| new \| rename \| archive \| restore, and `conversation` to speak in one.
	28	- Terminal: Palette → Conversations: `n` new, `r` rename, `x` archive or restore, `a` the archived list, Enter opens one (its last 50 turns; `s` says something in it, `r` reloads); the same calls, so the web list and stream read what it writes.
	29	- Sending to an archived conversation keeps it archived; the page says so above the composer.
	30
21	31	## Edit, regenerate, retry (#8817)
22	32
23	33	Three actions on the last exchange, one door, `talkAgain()` in `src/actions/talk.ts` (the same 12-a-minute throttle and refusals as sending):
		@@ -28,6 +38,7 @@ Three actions on the last exchange, one door, `talkAgain()` in `src/actions/talk
28	38	- Refused while a turn runs (`running`, 409), or when there is nothing to act on (`nothing`, 409).
29	39	- Web: Edit under your last message (opens the composer holding it, `/talk?edit=1`; Send resends), Regenerate under the last reply, Retry under a failed one. All are plain forms or links, so they work without the script, which only does them in place. They post to `POST /talk/again/edit\|regenerate\|retry`, from your own signed-in browser only.
30	40	- Terminal: `ssh <forge> talk-again edit <words>`, `ssh <forge> talk-again regenerate`, `ssh <forge> talk-again retry`.
	41	- With several conversations they act on the one open: the forms post to `/talk/<id>/again/<how>` (`/talk/again/<how>` on the latest); the action takes the conversation as an optional argument.
31	42	- There is no API or MCP door for these yet.
32	43
33	44	## Stop
		@@ -64,7 +75,7 @@ Prior art read: Vercel AI Elements (Apache-2.0 React on shadcn; anatomy and beha
64	75	\| Starter questions on an empty chat (links to `/talk?q=`, so they work without the script) \| this pull \| AI Elements `Suggestion` \|
65	76	\| Stick to bottom, "Latest" jump button \| this pull \| AI Elements `Conversation` \|
66	77	\| Thinking as one closed line; a steps line under a reply ("read 3 files, opened #12"); links to each issue, pull, file or app the turn opened or changed \| this pull \| AI Elements `Reasoning`, `ChainOfThought` \|
67		\| Many conversations: new, list, search, rename, archive, URL each \| next pull \| needs a migration: today one row per person \|
	78	\| Many conversations: new, list, rename, archive, URL each \| have (#8814) \| search is not added yet \|
68	79	\| Edit and resend, regenerate, Retry (see below) \| have (#8817) \| replaced turns are kept and marked, not deleted \|
69	80	\| Queue and Steer while an answer runs \| #8819 \| `Queue` / `PromptInput` \|
70	81	\| Cost under each reply and how full the context is (header, and in the terminal) \| this pull \| the run's own usage record, never an estimate \|
		@@ -6,6 +6,7 @@
6	6	*/
7	7
8	8	import type { App } from "../app.ts";
	9	import { getConversation } from "../core/conversations.ts";
9	10	import type { ConversationFile } from "../core/conversation_files.ts";
10	11	import { RateLimiter } from "../core/ratelimit.ts";
11	12	import type { User } from "../core/users.ts";
		@@ -19,6 +20,7 @@ export type TalkRefusal = SayRefusal \| RedoRefusal \| "off" \| "rate_limited";
19	20
20	21	/** What each refusal says, with its status. */
21	22	export const TALK_WORDS: Readonly<Record<TalkRefusal, readonly [number, string]>> = {
	23	not_found: [404, "no such conversation"],
22	24	unauthorized: [401, "sign in to talk to the forge"],
23	25	empty: [422, "say something"],
24	26	too_long: [422, "the message is too long"],
		@@ -50,23 +52,24 @@ const watch = (app: App, said: Said): void => {
50	52	said.done?.catch((error: unknown) => app.log.error("conversation turn crashed", { error: String(error) }));
51	53	};
52	54
53		export function talk(app: App, user: User \| undefined, text: string, files: readonly ConversationFile[] = [], during: During = "inject"): Result<Said, TalkRefusal> {
	55	export function talk(app: App, user: User \| undefined, text: string, files: readonly ConversationFile[] = [], during: During = "inject", conversationId?: string): Result<Said, TalkRefusal> {
54	56	if (user === undefined) return err("unauthorized");
	57	if (conversationId !== undefined && getConversation(app.db, user.id, conversationId) === undefined) return err("not_found");
55	58	const options = conversationOptions(app);
56	59	if (options === undefined) return err("off");
57	60	if (!take(app, user)) return err("rate_limited");
58		const said = say(app, options, user.id, text, files, during);
	61	const said = say(app, options, user.id, text, files, during, conversationId);
59	62	if (said.ok) watch(app, said.value);
60	63	return said;
61	64	}
62	65
63		/** Edit the last message and resend it, regenerate the last reply, or retry a failed turn (#8817). */
64		export function talkAgain(app: App, user: User \| undefined, how: RedoHow, text = ""): Result<Said, TalkRefusal> {
	66	/** Edit the last message and resend it, regenerate the last reply, or retry a failed turn (#8817), in the named conversation or the latest. */
	67	export function talkAgain(app: App, user: User \| undefined, how: RedoHow, text = "", conversationId?: string): Result<Said, TalkRefusal> {
65	68	if (user === undefined) return err("unauthorized");
66	69	const options = conversationOptions(app);
67	70	if (options === undefined) return err("off");
68	71	if (!take(app, user)) return err("rate_limited");
69		const said = redo(app, options, user.id, how, text);
	72	const said = redo(app, options, user.id, how, text, conversationId);
70	73	if (said.ok) watch(app, said.value);
71	74	return said;
72	75	}
		@@ -82,5 +85,5 @@ export function stopTalk(app: App, user: User \| undefined): Result<true, "unauth
82	85	export const cancelTalk = (app: App, user: User \| undefined, queuedId: string): boolean => user !== undefined && cancelQueued(app, user.id, queuedId);
83	86
84	87	/** The person's waiting messages, oldest first. */
85		export const queuedTalk = (app: App, user: User \| undefined): readonly { id: string; text: string }[] =>
86		user === undefined ? [] : queuedOf(app, user.id).map((q) => ({ id: q.id, text: q.text }));
	88	export const queuedTalk = (app: App, user: User \| undefined, conversationId?: string): readonly { id: string; text: string }[] =>
	89	user === undefined ? [] : queuedOf(app, user.id, conversationId).map((q) => ({ id: q.id, text: q.text }));
		@@ -5,6 +5,6 @@ export const route: Route = {
5	5	path: "/api/v1/conversation/turns",
6	6	summary: "The signed-in person's conversation with the forge's agent: the latest turns, oldest first, and whether an answer is being written now",
7	7	auth: true,
8		query: { limit: "integer", before: "string" },
	8	query: { limit: "integer", before: "string", conversation: "string" },
9	9	reply: { running: "boolean", turns: "array" },
10	10	};
		@@ -0,0 +1,10 @@
	1	import type { Route } from "../shared.ts";
	2
	3	export const route: Route = {
	4	method: "get",
	5	path: "/api/v1/conversations",
	6	summary: "The signed-in person's conversations with the forge's agent, newest activity first; archived: 1 lists the put-away ones",
	7	auth: true,
	8	query: { archived: "string" },
	9	reply: { conversations: "array" },
	10	};
		@@ -58,6 +58,7 @@ export { route as getApiV1CloudAccounts } from "./getApiV1CloudAccounts.ts";
58	58	export { route as getApiV1Contribute } from "./getApiV1Contribute.ts";
59	59	export { route as getApiV1ConversationFilesId } from "./getApiV1ConversationFilesId.ts";
60	60	export { route as getApiV1ConversationTurns } from "./getApiV1ConversationTurns.ts";
	61	export { route as getApiV1Conversations } from "./getApiV1Conversations.ts";
61	62	export { route as getApiV1CrewNow } from "./getApiV1CrewNow.ts";
62	63	export { route as getApiV1CrewScorecard } from "./getApiV1CrewScorecard.ts";
63	64	export { route as getApiV1Explore } from "./getApiV1Explore.ts";
		@@ -184,6 +185,7 @@ export { route as getContractOpenapiJson } from "./getContractOpenapiJson.ts";
184	185	export { route as getMetrics } from "./getMetrics.ts";
185	186	export { route as patchApiV1AdminSettings } from "./patchApiV1AdminSettings.ts";
186	187	export { route as patchApiV1AgentsUsername } from "./patchApiV1AgentsUsername.ts";
	188	export { route as patchApiV1ConversationsId } from "./patchApiV1ConversationsId.ts";
187	189	export { route as patchApiV1ForgeFollowing } from "./patchApiV1ForgeFollowing.ts";
188	190	export { route as patchApiV1ReposOwnerName } from "./patchApiV1ReposOwnerName.ts";
189	191	export { route as patchApiV1ReposOwnerNameApp } from "./patchApiV1ReposOwnerNameApp.ts";
		@@ -218,6 +220,7 @@ export { route as postApiV1ConversationFiles } from "./postApiV1ConversationFile
218	220	export { route as postApiV1ConversationMessages } from "./postApiV1ConversationMessages.ts";
219	221	export { route as postApiV1ConversationStop } from "./postApiV1ConversationStop.ts";
220	222	export { route as postApiV1ConversationTokens } from "./postApiV1ConversationTokens.ts";
	223	export { route as postApiV1Conversations } from "./postApiV1Conversations.ts";
221	224	export { route as postApiV1Drills } from "./postApiV1Drills.ts";
222	225	export { route as postApiV1FeedChips } from "./postApiV1FeedChips.ts";
223	226	export { route as postApiV1FeedInteractions } from "./postApiV1FeedInteractions.ts";
		@@ -0,0 +1,11 @@
	1	import type { Route } from "../shared.ts";
	2
	3	export const route: Route = {
	4	method: "patch",
	5	path: "/api/v1/conversations/{id}",
	6	summary: "Rename a conversation (title) or put it away and bring it back (archived: true or false); another person's id is 404",
	7	auth: true,
	8	body: { title: "string", archived: "boolean" },
	9	reply: { conversation: "object" },
	10	refusals: { invalid_title: "title is over 80 characters or has a line break (422)", not_found: "no such conversation of yours (404)", forbidden: "the request is cross-origin, or the token is read-only" },
	11	};
		@@ -6,9 +6,10 @@ export const route: Route = {
6	6	summary: "Say something to the forge's own agent, as the signed-in person: it answers through the forge's MCP with that person's permissions, resuming their conversation; a message sent while it answers is handed to the turn, or with `during` (optional) set to `queue` waits for it (at most 5), or set to `steer` stops it and goes at once; answers 202 at once, read the answer from the turns; at most 12 a minute per person",
7	7	auth: true,
8	8	status: 202,
9		body: { text: "string" },
	9	body: { text: "string", conversation: "string" },
10	10	reply: { how: "string" },
11	11	refusals: {
	12	not_found: "conversation names none of the person's (404)",
12	13	invalid_text: "text is not a string of 1 to 20000 characters",
13	14	invalid_during: "during is not queue or steer",
14	15	file_taken: "an attached file already waits in a queued message (409)",
		@@ -0,0 +1,12 @@
	1	import type { Route } from "../shared.ts";
	2
	3	export const route: Route = {
	4	method: "post",
	5	path: "/api/v1/conversations",
	6	summary: "Start a new, empty conversation with the forge's agent; answers it, and it opens at /talk/<id>",
	7	auth: true,
	8	status: 201,
	9	body: { title: "string" },
	10	reply: { conversation: "object" },
	11	refusals: { invalid_title: "title is over 80 characters or has a line break (422)", forbidden: "the request is cross-origin, or the token is read-only" },
	12	};
		@@ -1,8 +1,9 @@
1	1	/**
2		* A person's conversation with the forge: one per person, stored turn by turn
3		* in the database so it reads back after a restart. Every call takes the
4		* person's id and answers only for their own conversation; another person's
5		* conversation is `not_found`. Plain data in, plain data out, no authz beyond
	2	* A person's conversations with the forge, stored turn by turn in the
	3	* database so they read back after a restart. A person has any number: each
	4	* has an id (its URL), a title they may change, and may be archived. Every
	5	* call takes the person's id and answers only for their own conversation;
	6	* another person's conversation is `not_found`. Plain data in, plain data out, no authz beyond
6	7	* that ownership.
7	8	*/
8	9	import type { Database } from "bun:sqlite";
		@@ -25,8 +26,14 @@ export interface Conversation {
25	26	readonly claudeSessionId: string;
26	27	readonly createdAt: string;
27	28	readonly updatedAt: string;
	29	readonly title: string;
	30	/** When it was put away; null while it is in the list. */
	31	readonly archivedAt: string \| null;
28	32	}
29	33
	34	/** Longest title kept, in characters; longer is refused, not cut. */
	35	export const TITLE_MAX = 80;
	36
30	37	export interface Turn {
31	38	readonly id: string;
32	39	readonly conversationId: string;
		@@ -45,6 +52,8 @@ interface ConversationRow {
45	52	claude_session_id: string;
46	53	created_at: string;
47	54	updated_at: string;
	55	title: string;
	56	archived_at: string \| null;
48	57	}
49	58
50	59	interface TurnRow {
		@@ -63,6 +72,8 @@ const conversationOf = (r: ConversationRow): Conversation => ({
63	72	claudeSessionId: r.claude_session_id,
64	73	createdAt: r.created_at,
65	74	updatedAt: r.updated_at,
	75	title: r.title,
	76	archivedAt: r.archived_at,
66	77	});
67	78
68	79	const turnOf = (r: TurnRow): Turn => ({
		@@ -75,18 +86,87 @@ const turnOf = (r: TurnRow): Turn => ({
75	86	failed: r.failed === 1,
76	87	});
77	88
78		/** The person's conversation, made on first use. */
79		export function openConversation(db: Database, userId: string): Conversation {
	89	/** Most conversations a person holds, archived ones included; past it, New is refused. */
	90	export const CONVERSATIONS_MAX = 100;
	91
	92	/** What every door says when New is refused. */
	93	export const TOO_MANY_WORDS = `you hold ${CONVERSATIONS_MAX} conversations, the most there can be; keep talking in one of them`;
	94
	95	/** Start a new conversation at a person's request: refused past `CONVERSATIONS_MAX`. */
	96	export function createConversation(db: Database, userId: string): Result<Conversation, "too_many"> {
		sentinelcrew 11d ago Count then insert outside a transaction: concurrent New can exceed the cap. Wrap in db.transaction.
	97	return db.transaction((): Result<Conversation, "too_many"> => {
	98	const held = db.query("SELECT COUNT(*) AS n FROM conversation WHERE user_id = ?1").get(userId) as { n: number };
	99	return held.n >= CONVERSATIONS_MAX ? err("too_many") : ok(newConversation(db, userId));
	100	}).immediate();
	101	}
	102
	103	/** Start a new, empty conversation. */
	104	export function newConversation(db: Database, userId: string): Conversation {
80	105	const now = new Date().toISOString();
	106	const row: ConversationRow = { id: id(), user_id: userId, claude_session_id: "", created_at: now, updated_at: now, title: "", archived_at: null };
81	107	db.query(
82		"INSERT OR IGNORE INTO conversation (id, user_id, claude_session_id, created_at, updated_at) VALUES (?1,?2,'',?3,?3)",
83		).run(id(), userId, now);
84		const row = db
85		.query("SELECT * FROM conversation WHERE user_id = ?1")
86		.get(userId) as ConversationRow;
	108	"INSERT INTO conversation (id, user_id, claude_session_id, created_at, updated_at) VALUES (?1,?2,'',?3,?3)",
	109	).run(row.id, userId, now);
87	110	return conversationOf(row);
88	111	}
89	112
	113	/**
	114	* Where a message with no conversation named goes: the person's most recently
	115	* active conversation that is not archived, made on first use.
	116	*/
	117	export function openConversation(db: Database, userId: string): Conversation {
	118	const row = db
	119	.query("SELECT * FROM conversation WHERE user_id = ?1 AND archived_at IS NULL ORDER BY updated_at DESC, rowid DESC LIMIT 1")
	120	.get(userId) as ConversationRow \| null;
	121	return row === null ? newConversation(db, userId) : conversationOf(row);
	122	}
	123
	124	/** One of the person's conversations by id; another person's is nothing. */
	125	export function getConversation(db: Database, userId: string, conversationId: string): Conversation \| undefined {
	126	const row = db
	127	.query("SELECT * FROM conversation WHERE id = ?1 AND user_id = ?2")
	128	.get(conversationId, userId) as ConversationRow \| null;
	129	return row === null ? undefined : conversationOf(row);
	130	}
	131
	132	/** The person's conversations, newest activity first; `archived` picks the put-away ones instead. */
	133	export function listConversations(db: Database, userId: string, opts: { readonly archived?: boolean } = {}): Conversation[] {
	134	const rows = db
	135	.query(
	136	`SELECT * FROM conversation WHERE user_id = ?1 AND archived_at IS ${opts.archived === true ? "NOT" : ""} NULL ORDER BY updated_at DESC, rowid DESC LIMIT 200`,
	137	)
	138	.all(userId) as ConversationRow[];
	139	return rows.map(conversationOf);
	140	}
	141
	142	/** Give a conversation a title (1 to `TITLE_MAX` characters, no line breaks); an empty one clears it. */
	143	export function renameConversation(
	144	db: Database,
	145	userId: string,
	146	conversationId: string,
	147	title: string,
	148	): Result<Conversation, "not_found" \| "bad_title"> {
	149	const clean = title.trim();
	150	if (clean.length > TITLE_MAX \|\| /[\u0000-\u001f\u007f]/.test(clean)) return err("bad_title");
	151	const changed = db.query("UPDATE conversation SET title = ?3 WHERE id = ?1 AND user_id = ?2").run(conversationId, userId, clean).changes;
	152	const found = changed === 0 ? undefined : getConversation(db, userId, conversationId);
	153	return found === undefined ? err("not_found") : ok(found);
	154	}
	155
	156	/** Put a conversation away, or bring it back (`archived` false). It keeps its turns and its URL. */
	157	export function archiveConversation(
	158	db: Database,
	159	userId: string,
	160	conversationId: string,
	161	archived: boolean,
	162	): Result<Conversation, "not_found"> {
	163	const changed = db
	164	.query("UPDATE conversation SET archived_at = ?3 WHERE id = ?1 AND user_id = ?2")
	165	.run(conversationId, userId, archived ? new Date().toISOString() : null).changes;
	166	const found = changed === 0 ? undefined : getConversation(db, userId, conversationId);
	167	return found === undefined ? err("not_found") : ok(found);
	168	}
	169
90	170	const owned = (db: Database, userId: string, conversationId: string): boolean =>
91	171	db
92	172	.query("SELECT 1 FROM conversation WHERE id = ?1 AND user_id = ?2")