feat(recall): add corpus browser page

Distilled entries need a corpus-wide inspection surface so extraction coverage and output quality can be assessed beyond one transcript. Expose read-only manager coverage and exact review-state filtering while keeping the first page bounded and management actions out of this slice.

Author: wesm

cmd/agentsview/main.go

@@ -23,6 +23,7 @@ import (
 	"go.kenn.io/agentsview/internal/config"
 	"go.kenn.io/agentsview/internal/db"
 	"go.kenn.io/agentsview/internal/parser"
+	"go.kenn.io/agentsview/internal/recall/extract"
 	"go.kenn.io/agentsview/internal/remotesync"
 	"go.kenn.io/agentsview/internal/secrets"
 	"go.kenn.io/agentsview/internal/server"
@@ -481,6 +482,10 @@ func runServe(cfg config.Config, opts serveOptions) {
 		// no sync activity follows. Notify never blocks.
 		srvOpts = append(srvOpts,
 			server.WithSessionMutationNotifier(extractSched.Notify))
+		if manager, ok := extractSched.mgr.(*extract.Manager); ok {
+			srvOpts = append(srvOpts,
+				server.WithRecallExtractionStatusProvider(manager))
+		}
 	}
 	if engine != nil {
 		srvOpts = append(srvOpts, server.WithLocalSyncRunner(

frontend/messages/en.json

@@ -19,6 +19,7 @@
   "nav_more_navigation": "More navigation",
   "nav_more": "More",
   "nav_trends": "Trends",
+  "nav_recall": "Recall",
   "nav_pinned": "Pinned",
   "nav_insights": "Insights",
   "nav_trash": "Trash",
@@ -1151,6 +1152,30 @@
   "session_recall_provenance_revoked": "Provenance revoked",
   "session_recall_evidence_range": "Messages {start}–{end}",
   "session_recall_jump_evidence": "Jump to transcript messages {start}–{end}",
+  "recall_page_title": "Recall",
+  "recall_page_subtitle": "Browse distilled entries and extraction coverage.",
+  "recall_page_search_placeholder": "Search Recall entries…",
+  "recall_page_clear_search": "Clear Recall search",
+  "recall_page_type_filter": "Entry type",
+  "recall_page_all_types": "All types",
+  "recall_page_generation_filter": "Extraction generation",
+  "recall_page_all_generations": "All generations",
+  "recall_page_review_filter": "Review state",
+  "recall_page_all_review_states": "All review states",
+  "recall_page_loading": "Loading Recall entries…",
+  "recall_page_empty": "No Recall entries match these filters.",
+  "recall_page_error": "Could not load Recall entries.",
+  "recall_page_entries_shown": "Entries shown: {countLabel}",
+  "recall_page_extraction_title": "Extraction status",
+  "recall_page_extraction_unconfigured": "Recall extraction is not configured.",
+  "recall_page_extraction_error": "Could not load extraction status.",
+  "recall_page_status_done": "{countLabel} done",
+  "recall_page_status_failed": "{countLabel} failed",
+  "recall_page_status_eligible": "{countLabel} eligible",
+  "recall_page_status_pending": "{countLabel} pending",
+  "recall_page_status_partial": "{countLabel} partial",
+  "recall_page_status_units": "Units {doneLabel}/{totalLabel}",
+  "recall_page_status_entries": "{countLabel} entries",
   "session_vitals_title": "Analysis",
   "session_vitals_subtitle": "Session vital signs",
   "session_vitals_close": "Close session analysis",

frontend/messages/fr.json

@@ -19,6 +19,7 @@
   "nav_more_navigation": "Plus de navigation",
   "nav_more": "Plus",
   "nav_trends": "Tendances",
+  "nav_recall": "Rappel",
   "nav_pinned": "Épinglés",
   "nav_insights": "Analyses",
   "nav_trash": "Corbeille",
@@ -1151,6 +1152,30 @@
   "session_recall_provenance_revoked": "Provenance révoquée",
   "session_recall_evidence_range": "Messages {start}–{end}",
   "session_recall_jump_evidence": "Aller aux messages {start}–{end} de la transcription",
+  "recall_page_title": "Rappel",
+  "recall_page_subtitle": "Parcourir les entrées distillées et la couverture d’extraction.",
+  "recall_page_search_placeholder": "Rechercher dans le rappel…",
+  "recall_page_clear_search": "Effacer la recherche de rappel",
+  "recall_page_type_filter": "Type d’entrée",
+  "recall_page_all_types": "Tous les types",
+  "recall_page_generation_filter": "Génération d’extraction",
+  "recall_page_all_generations": "Toutes les générations",
+  "recall_page_review_filter": "État de révision",
+  "recall_page_all_review_states": "Tous les états de révision",
+  "recall_page_loading": "Chargement des entrées de rappel…",
+  "recall_page_empty": "Aucune entrée de rappel ne correspond à ces filtres.",
+  "recall_page_error": "Impossible de charger les entrées de rappel.",
+  "recall_page_entries_shown": "Entrées affichées : {countLabel}",
+  "recall_page_extraction_title": "État de l’extraction",
+  "recall_page_extraction_unconfigured": "L’extraction du rappel n’est pas configurée.",
+  "recall_page_extraction_error": "Impossible de charger l’état de l’extraction.",
+  "recall_page_status_done": "{countLabel} terminées",
+  "recall_page_status_failed": "{countLabel} échouées",
+  "recall_page_status_eligible": "{countLabel} éligibles",
+  "recall_page_status_pending": "{countLabel} en attente",
+  "recall_page_status_partial": "{countLabel} partielles",
+  "recall_page_status_units": "Unités {doneLabel}/{totalLabel}",
+  "recall_page_status_entries": "{countLabel} entrées",
   "session_vitals_title": "Analyse",
   "session_vitals_subtitle": "Signes vitaux de la session",
   "session_vitals_close": "Fermer l'analyse de la session",

frontend/messages/ko.json

@@ -19,6 +19,7 @@
   "nav_more_navigation": "추가 내비게이션",
   "nav_more": "더 보기",
   "nav_trends": "트렌드",
+  "nav_recall": "리콜",
   "nav_pinned": "고정됨",
   "nav_insights": "인사이트",
   "nav_trash": "휴지통",
@@ -1121,6 +1122,30 @@
   "session_recall_provenance_revoked": "출처가 취소됨",
   "session_recall_evidence_range": "메시지 {start}–{end}",
   "session_recall_jump_evidence": "대화 기록 메시지 {start}–{end}(으)로 이동",
+  "recall_page_title": "리콜",
+  "recall_page_subtitle": "추출된 항목과 추출 범위를 살펴봅니다.",
+  "recall_page_search_placeholder": "리콜 항목 검색…",
+  "recall_page_clear_search": "리콜 검색 지우기",
+  "recall_page_type_filter": "항목 유형",
+  "recall_page_all_types": "모든 유형",
+  "recall_page_generation_filter": "추출 세대",
+  "recall_page_all_generations": "모든 세대",
+  "recall_page_review_filter": "검토 상태",
+  "recall_page_all_review_states": "모든 검토 상태",
+  "recall_page_loading": "리콜 항목을 불러오는 중…",
+  "recall_page_empty": "이 필터와 일치하는 리콜 항목이 없습니다.",
+  "recall_page_error": "리콜 항목을 불러올 수 없습니다.",
+  "recall_page_entries_shown": "표시된 항목: {countLabel}",
+  "recall_page_extraction_title": "추출 상태",
+  "recall_page_extraction_unconfigured": "리콜 추출이 구성되지 않았습니다.",
+  "recall_page_extraction_error": "추출 상태를 불러올 수 없습니다.",
+  "recall_page_status_done": "완료 {countLabel}",
+  "recall_page_status_failed": "실패 {countLabel}",
+  "recall_page_status_eligible": "대상 {countLabel}",
+  "recall_page_status_pending": "대기 {countLabel}",
+  "recall_page_status_partial": "부분 완료 {countLabel}",
+  "recall_page_status_units": "단위 {doneLabel}/{totalLabel}",
+  "recall_page_status_entries": "항목 {countLabel}",
   "session_vitals_title": "분석",
   "session_vitals_subtitle": "세션 바이탈 사인",
   "session_vitals_close": "세션 분석 닫기",

frontend/messages/zh-CN.json

@@ -19,6 +19,7 @@
   "nav_more_navigation": "更多导航",
   "nav_more": "更多",
   "nav_trends": "趋势",
+  "nav_recall": "召回",
   "nav_pinned": "已固定",
   "nav_insights": "洞察",
   "nav_trash": "回收站",
@@ -1119,6 +1120,30 @@
   "session_recall_provenance_revoked": "来源已撤销",
   "session_recall_evidence_range": "消息 {start}–{end}",
   "session_recall_jump_evidence": "跳转到转录消息 {start}–{end}",
+  "recall_page_title": "召回",
+  "recall_page_subtitle": "浏览提炼条目和提取覆盖情况。",
+  "recall_page_search_placeholder": "搜索召回条目…",
+  "recall_page_clear_search": "清除召回搜索",
+  "recall_page_type_filter": "条目类型",
+  "recall_page_all_types": "所有类型",
+  "recall_page_generation_filter": "提取代次",
+  "recall_page_all_generations": "所有代次",
+  "recall_page_review_filter": "审核状态",
+  "recall_page_all_review_states": "所有审核状态",
+  "recall_page_loading": "正在加载召回条目…",
+  "recall_page_empty": "没有符合这些筛选条件的召回条目。",
+  "recall_page_error": "无法加载召回条目。",
+  "recall_page_entries_shown": "显示条目：{countLabel}",
+  "recall_page_extraction_title": "提取状态",
+  "recall_page_extraction_unconfigured": "尚未配置召回提取。",
+  "recall_page_extraction_error": "无法加载提取状态。",
+  "recall_page_status_done": "已完成 {countLabel}",
+  "recall_page_status_failed": "失败 {countLabel}",
+  "recall_page_status_eligible": "符合条件 {countLabel}",
+  "recall_page_status_pending": "待处理 {countLabel}",
+  "recall_page_status_partial": "部分完成 {countLabel}",
+  "recall_page_status_units": "单元 {doneLabel}/{totalLabel}",
+  "recall_page_status_entries": "条目 {countLabel}",
   "session_vitals_title": "分析",
   "session_vitals_subtitle": "会话指标",
   "session_vitals_close": "关闭会话分析",

frontend/messages/zh-TW.json

@@ -19,6 +19,7 @@
   "nav_more_navigation": "更多導航",
   "nav_more": "更多",
   "nav_trends": "趨勢",
+  "nav_recall": "召回",
   "nav_pinned": "已固定",
   "nav_insights": "洞察",
   "nav_trash": "回收站",
@@ -1119,6 +1120,30 @@
   "session_recall_provenance_revoked": "來源已撤銷",
   "session_recall_evidence_range": "訊息 {start}–{end}",
   "session_recall_jump_evidence": "跳至逐字稿訊息 {start}–{end}",
+  "recall_page_title": "召回",
+  "recall_page_subtitle": "瀏覽提煉項目和擷取涵蓋情況。",
+  "recall_page_search_placeholder": "搜尋召回項目…",
+  "recall_page_clear_search": "清除召回搜尋",
+  "recall_page_type_filter": "項目類型",
+  "recall_page_all_types": "所有類型",
+  "recall_page_generation_filter": "擷取代次",
+  "recall_page_all_generations": "所有代次",
+  "recall_page_review_filter": "審核狀態",
+  "recall_page_all_review_states": "所有審核狀態",
+  "recall_page_loading": "正在載入召回項目…",
+  "recall_page_empty": "沒有符合這些篩選條件的召回項目。",
+  "recall_page_error": "無法載入召回項目。",
+  "recall_page_entries_shown": "顯示項目：{countLabel}",
+  "recall_page_extraction_title": "擷取狀態",
+  "recall_page_extraction_unconfigured": "尚未設定召回擷取。",
+  "recall_page_extraction_error": "無法載入擷取狀態。",
+  "recall_page_status_done": "已完成 {countLabel}",
+  "recall_page_status_failed": "失敗 {countLabel}",
+  "recall_page_status_eligible": "符合條件 {countLabel}",
+  "recall_page_status_pending": "待處理 {countLabel}",
+  "recall_page_status_partial": "部分完成 {countLabel}",
+  "recall_page_status_units": "單元 {doneLabel}/{totalLabel}",
+  "recall_page_status_entries": "項目 {countLabel}",
   "session_vitals_title": "分析",
   "session_vitals_subtitle": "會話指標",
   "session_vitals_close": "關閉會話分析",

frontend/src/App.svelte

@@ -60,6 +60,7 @@
   import UsagePage from "./lib/components/usage/UsagePage.svelte";
   import ActivityPage from "./lib/components/activity/ActivityPage.svelte";
   import TrendsPage from "./lib/components/trends/TrendsPage.svelte";
+  import RecallPage from "./lib/components/recall/RecallPage.svelte";
   import InsightsPage from "./lib/components/insights/InsightsPage.svelte";
   import PinnedPage from "./lib/components/pinned/PinnedPage.svelte";
   import TrashPage from "./lib/components/trash/TrashPage.svelte";
@@ -666,6 +667,10 @@
   <div class="page-scroll">
     <TrendsPage />
   </div>
+{:else if router.route === "recall"}
+  <div class="page-scroll">
+    <RecallPage />
+  </div>
 {:else if router.route === "insights"}
   <div class="page-scroll">
     <InsightsPage />

frontend/src/lib/api/recall.test.ts

@@ -0,0 +1,44 @@
+import {
+  afterEach,
+  describe,
+  expect,
+  it,
+  vi,
+} from "vite-plus/test";
+import { fetchRecallEntries } from "./recall.js";
+
+afterEach(() => {
+  vi.unstubAllGlobals();
+});
+
+describe("fetchRecallEntries", () => {
+  it("sends every corpus-browser filter to the Recall API", async () => {
+    const fetchMock = vi.fn().mockResolvedValue(new Response(
+      JSON.stringify({ entries: [], trusted_only: false }),
+      { status: 200, headers: { "Content-Type": "application/json" } },
+    ));
+    vi.stubGlobal("fetch", fetchMock);
+
+    await fetchRecallEntries({
+      query: "bounded pass",
+      project: "project-a",
+      type: "decision",
+      sourceRunId: "generation-a",
+      reviewState: "human_reviewed",
+      limit: 75,
+    });
+
+    expect(fetchMock).toHaveBeenCalledOnce();
+    const url = new URL(String(fetchMock.mock.calls[0]?.[0]),
+      window.location.origin);
+    expect(url.pathname).toBe("/api/v1/recall/entries");
+    expect(Object.fromEntries(url.searchParams)).toEqual({
+      limit: "75",
+      q: "bounded pass",
+      project: "project-a",
+      type: "decision",
+      source_run_id: "generation-a",
+      review_state: "human_reviewed",
+    });
+  });
+});

frontend/src/lib/api/recall.ts

@@ -1,6 +1,8 @@
 import type {
   RecallEntriesResponse,
   RecallEntry,
+  RecallEntryFilters,
+  RecallExtractionStatus,
 } from "./types/recall.js";
 import {
   ApiError,
@@ -10,6 +12,53 @@ import {
 } from "./runtime.js";
 
 const SESSION_RECALL_LIMIT = 500;
+const RECALL_PAGE_LIMIT = 200;
+
+export async function fetchRecallEntries(
+  filters: RecallEntryFilters = {},
+  signal?: AbortSignal,
+): Promise<RecallEntry[]> {
+  const query = new URLSearchParams({
+    limit: String(filters.limit ?? RECALL_PAGE_LIMIT),
+  });
+  if (filters.query) query.set("q", filters.query);
+  if (filters.project) query.set("project", filters.project);
+  if (filters.type) query.set("type", filters.type);
+  if (filters.sourceRunId) {
+    query.set("source_run_id", filters.sourceRunId);
+  }
+  if (filters.reviewState) {
+    query.set("review_state", filters.reviewState);
+  }
+  const response = await fetch(
+    `${getBase()}/recall/entries?${query.toString()}`,
+    authHeaders({ signal }),
+  );
+  if (!response.ok) {
+    throw new ApiError(
+      response.status,
+      await responseErrorMessage(response),
+    );
+  }
+  const data = (await response.json()) as RecallEntriesResponse;
+  return data.entries ?? [];
+}
+
+export async function fetchRecallExtractionStatus(
+  signal?: AbortSignal,
+): Promise<RecallExtractionStatus> {
+  const response = await fetch(
+    `${getBase()}/recall/extraction/status`,
+    authHeaders({ signal }),
+  );
+  if (!response.ok) {
+    throw new ApiError(
+      response.status,
+      await responseErrorMessage(response),
+    );
+  }
+  return (await response.json()) as RecallExtractionStatus;
+}
 
 export async function fetchSessionRecall(
   sessionId: string,

frontend/src/lib/api/types/recall.ts

@@ -15,6 +15,13 @@ export interface RecallEntry {
   review_state: string;
   title: string;
   body: string;
+  trigger?: string;
+  confidence?: number;
+  uncertainty?: string;
+  project?: string;
+  cwd?: string;
+  git_branch?: string;
+  agent?: string;
   source_session_id: string;
   source_run_id?: string;
   extractor_method?: string;
@@ -30,3 +37,39 @@ export interface RecallEntriesResponse {
   entries: RecallEntry[];
   trusted_only: boolean;
 }
+
+export interface RecallExtractGeneration {
+  fingerprint: string;
+  state: string;
+  model: string;
+  segmenter: string;
+  created_at: string;
+  updated_at: string;
+}
+
+export interface RecallExtractProgressStats {
+  pending: number;
+  partial: number;
+  done: number;
+  failed: number;
+  units_done: number;
+  units_total: number;
+  entries: number;
+}
+
+export interface RecallExtractionStatus {
+  configured: boolean;
+  fingerprint?: string;
+  generations?: RecallExtractGeneration[];
+  stats?: RecallExtractProgressStats;
+  eligible_backlog?: number;
+}
+
+export interface RecallEntryFilters {
+  query?: string;
+  project?: string;
+  type?: string;
+  sourceRunId?: string;
+  reviewState?: string;
+  limit?: number;
+}