feat: appbar pickers, multi-agent personas, threads, library, profile
Adds a substantial chrome layer atop the bare template: Appbar - Font-size picker (root font-size scale): S/M/L/XL - Surface picker: tints --background/--card/--popover/--sidebar/--muted/ --secondary/--accent across light + dark - Background picker: 11 atmospheric gradients (Pearl, Linen, Mist, Dawn, Seafoam, Aurora, Sunset, Meadow, Midnight, Blush, Noir) + None - Vivid foreground tokens for stronger text contrast; fixed dark-mode blue-on-blue user bubble (deeper --primary, near-white --primary-fg) Assistant route - Multi-agent personas (~/lib/agents.ts): Atlas, Forge, Inkwell, Pilot, Cursor — each with name/role/sub-prompt; per-thread persona; agent picker with avatar tint + handoff submenu - Conversation threads (~/lib/threads.ts): new/switch/rename/delete, auto-titling from first user message, per-thread pinned indices - Compact summarization with snapshot-based Restore that preserves pinned messages verbatim - Edit & retry the last user message, Regenerate, Continue, Show system prompt, Copy / Export Markdown, Save to Library, Compare across agents (parallel completions in a side-by-side modal) - Per-message Pin / Read aloud (Web Speech) / Edit - Voice input via Web Speech Recognition - Two-column Actions popover (UI Control + Conversation / Share / Multi-agent / Clear sections) - Status bar: connection dot + LOCAL/API/MOCK chip + host chip + context progress bar - Compactly named threads picker; New conversation - DropdownMenuItem onSelect → onClick (base-ui Menu fires onClick) Library - ~/lib/library.ts store, /library route with search + detail panel (Copy / Download / Delete) Profile - /profile route + ~/lib/profile.ts (name/email/title/bio/signature/ avatar dataURL/default agent), AppShell uses live profile for the appbar avatar; account menu now navigates to /profile Settings - Sub-sidenav (LLM / Agents / Appearance / Account / About) - Editable system prompt with reset-to-default - Agents CRUD panel - Reorganized layout UI Control - Static action catalog in the system prompt so the assistant can drive controls on routes that aren't currently mounted - Always returns to /assistant after a UI Control sequence (model- side rule + deterministic safety net) - Cursor uses click-nav over direct navigate so the virtual cursor is visibly involved - New ids tagged across the app (sidebar, settings, profile, library, assistant tools, agent handoff, thread management) Hydration - root.tsx: suppressHydrationWarning on html/body since the pre-mount script sets dark/data-bg/data-surface/data-font-scale before React Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>
This commit is contained in:
jules
217
app/lib/threads.ts
Normal file
217
app/lib/threads.ts
Normal file
@@ -0,0 +1,217 @@
|
||||
// Conversation threads — multiple named chats, each with its own history,
|
||||
// active agent, and pinned message indices. Persisted in localStorage.
|
||||
|
||||
import { useEffect, useSyncExternalStore } from "react"
|
||||
|
||||
export type ThreadMessage = { role: "user" | "assistant"; content: string }
|
||||
|
||||
export type Thread = {
|
||||
id: string
|
||||
title: string
|
||||
agentId: string
|
||||
messages: ThreadMessage[]
|
||||
pinned: number[] // indices into messages[]
|
||||
createdAt: number
|
||||
updatedAt: number
|
||||
}
|
||||
|
||||
const THREADS_KEY = "crema.assistant.threads"
|
||||
const ACTIVE_KEY = "crema.assistant.activeThreadId"
|
||||
const SNAPSHOT_KEY_PREFIX = "crema.assistant.thread.snapshot."
|
||||
const CHANGE_EVENT = "crema:threads-change"
|
||||
const MAX_BYTES = 800_000
|
||||
|
||||
export function newThreadId(): string {
|
||||
return `t-${Date.now().toString(36)}-${Math.random().toString(36).slice(2, 6)}`
|
||||
}
|
||||
|
||||
function isThread(v: unknown): v is Thread {
|
||||
if (!v || typeof v !== "object") return false
|
||||
const t = v as Thread
|
||||
return (
|
||||
typeof t.id === "string" &&
|
||||
typeof t.title === "string" &&
|
||||
typeof t.agentId === "string" &&
|
||||
Array.isArray(t.messages) &&
|
||||
Array.isArray(t.pinned) &&
|
||||
typeof t.createdAt === "number" &&
|
||||
typeof t.updatedAt === "number"
|
||||
)
|
||||
}
|
||||
|
||||
function readFromStorage(): Thread[] {
|
||||
if (typeof window === "undefined") return []
|
||||
try {
|
||||
const raw = localStorage.getItem(THREADS_KEY)
|
||||
if (!raw) return []
|
||||
const parsed = JSON.parse(raw)
|
||||
if (!Array.isArray(parsed)) return []
|
||||
return parsed.filter(isThread)
|
||||
} catch {
|
||||
return []
|
||||
}
|
||||
}
|
||||
|
||||
function writeToStorage(threads: Thread[]) {
|
||||
if (typeof window === "undefined") return
|
||||
let serialized = JSON.stringify(threads)
|
||||
// Trim oldest threads if quota gets tight.
|
||||
let trimmed = threads
|
||||
while (serialized.length > MAX_BYTES && trimmed.length > 1) {
|
||||
trimmed = trimmed.slice(0, -1)
|
||||
serialized = JSON.stringify(trimmed)
|
||||
}
|
||||
try {
|
||||
localStorage.setItem(THREADS_KEY, serialized)
|
||||
window.dispatchEvent(new CustomEvent(CHANGE_EVENT))
|
||||
} catch {
|
||||
/* quota — bail */
|
||||
}
|
||||
}
|
||||
|
||||
export function loadThreads(): Thread[] {
|
||||
return readFromStorage()
|
||||
}
|
||||
|
||||
export function saveThreads(threads: Thread[]) {
|
||||
writeToStorage(threads)
|
||||
}
|
||||
|
||||
export function loadActiveThreadId(): string | null {
|
||||
if (typeof window === "undefined") return null
|
||||
return localStorage.getItem(ACTIVE_KEY)
|
||||
}
|
||||
|
||||
export function saveActiveThreadId(id: string | null) {
|
||||
if (typeof window === "undefined") return
|
||||
if (id) localStorage.setItem(ACTIVE_KEY, id)
|
||||
else localStorage.removeItem(ACTIVE_KEY)
|
||||
window.dispatchEvent(new CustomEvent(CHANGE_EVENT))
|
||||
}
|
||||
|
||||
let cached: Thread[] | null = null
|
||||
|
||||
function subscribe(cb: () => void): () => void {
|
||||
const onChange = () => {
|
||||
cached = null
|
||||
cb()
|
||||
}
|
||||
window.addEventListener(CHANGE_EVENT, onChange)
|
||||
window.addEventListener("storage", (e) => {
|
||||
if (e.key === THREADS_KEY || e.key === ACTIVE_KEY) onChange()
|
||||
})
|
||||
return () => {
|
||||
window.removeEventListener(CHANGE_EVENT, onChange)
|
||||
}
|
||||
}
|
||||
|
||||
function getSnapshot(): Thread[] {
|
||||
if (!cached) cached = readFromStorage()
|
||||
return cached
|
||||
}
|
||||
function getServerSnapshot(): Thread[] {
|
||||
return []
|
||||
}
|
||||
|
||||
export function useThreads(): Thread[] {
|
||||
const value = useSyncExternalStore(subscribe, getSnapshot, getServerSnapshot)
|
||||
useEffect(() => {
|
||||
cached = null
|
||||
}, [])
|
||||
return value
|
||||
}
|
||||
|
||||
export function ensureThread(
|
||||
threads: Thread[],
|
||||
fallbackAgentId: string,
|
||||
): { threads: Thread[]; activeId: string } {
|
||||
const stored = loadActiveThreadId()
|
||||
if (stored && threads.some((t) => t.id === stored))
|
||||
return { threads, activeId: stored }
|
||||
if (threads.length > 0) {
|
||||
saveActiveThreadId(threads[0].id)
|
||||
return { threads, activeId: threads[0].id }
|
||||
}
|
||||
const id = newThreadId()
|
||||
const now = Date.now()
|
||||
const fresh: Thread = {
|
||||
id,
|
||||
title: "New conversation",
|
||||
agentId: fallbackAgentId,
|
||||
messages: [],
|
||||
pinned: [],
|
||||
createdAt: now,
|
||||
updatedAt: now,
|
||||
}
|
||||
saveActiveThreadId(id)
|
||||
saveThreads([fresh, ...threads])
|
||||
return { threads: [fresh, ...threads], activeId: id }
|
||||
}
|
||||
|
||||
export function updateThread(id: string, patch: Partial<Thread>) {
|
||||
const threads = readFromStorage()
|
||||
const next = threads.map((t) =>
|
||||
t.id === id ? { ...t, ...patch, updatedAt: Date.now() } : t,
|
||||
)
|
||||
writeToStorage(next)
|
||||
}
|
||||
|
||||
export function createThread(agentId: string, title = "New conversation"): Thread {
|
||||
const threads = readFromStorage()
|
||||
const id = newThreadId()
|
||||
const now = Date.now()
|
||||
const fresh: Thread = {
|
||||
id,
|
||||
title,
|
||||
agentId,
|
||||
messages: [],
|
||||
pinned: [],
|
||||
createdAt: now,
|
||||
updatedAt: now,
|
||||
}
|
||||
writeToStorage([fresh, ...threads])
|
||||
saveActiveThreadId(id)
|
||||
return fresh
|
||||
}
|
||||
|
||||
export function deleteThread(id: string) {
|
||||
const threads = readFromStorage()
|
||||
const next = threads.filter((t) => t.id !== id)
|
||||
writeToStorage(next)
|
||||
if (loadActiveThreadId() === id) {
|
||||
saveActiveThreadId(next[0]?.id ?? null)
|
||||
}
|
||||
}
|
||||
|
||||
export function snapshotThread(id: string) {
|
||||
const threads = readFromStorage()
|
||||
const t = threads.find((x) => x.id === id)
|
||||
if (!t) return
|
||||
try {
|
||||
localStorage.setItem(SNAPSHOT_KEY_PREFIX + id, JSON.stringify(t))
|
||||
} catch {
|
||||
/* quota */
|
||||
}
|
||||
}
|
||||
|
||||
export function loadThreadSnapshot(id: string): Thread | null {
|
||||
if (typeof window === "undefined") return null
|
||||
try {
|
||||
const raw = localStorage.getItem(SNAPSHOT_KEY_PREFIX + id)
|
||||
if (!raw) return null
|
||||
const parsed = JSON.parse(raw)
|
||||
return isThread(parsed) ? parsed : null
|
||||
} catch {
|
||||
return null
|
||||
}
|
||||
}
|
||||
|
||||
export function clearThreadSnapshot(id: string) {
|
||||
if (typeof window === "undefined") return
|
||||
localStorage.removeItem(SNAPSHOT_KEY_PREFIX + id)
|
||||
}
|
||||
|
||||
export function deriveTitleFromFirstMessage(text: string): string {
|
||||
const trimmed = text.trim().split(/\s+/).slice(0, 8).join(" ")
|
||||
return trimmed.length > 60 ? trimmed.slice(0, 57) + "…" : trimmed || "New conversation"
|
||||
}
|
||||
Reference in New Issue
Block a user