* ui: Extract server stream lifecycle from chatStore into ChatStreamManager
Discovery, attach/replay, resume retry and the remote-running snapshot
formed a cohesive cluster inside chatStore. It now lives in
chat-streams.svelte.ts as ChatStreamManager, owned by chatStore, which
keeps the public entry points as delegates so components are
unchanged. chatStore: 2877 -> 2418 lines.
* ui: Extract user interaction gates from agenticStore into AgenticGates
Tool permission requests, turn-limit continue prompts and queued
steering messages are the state the loop waits on between turns. They
had no coupling to session state, so they now live in
agentic-gates.svelte.ts; agenticStore keeps delegates so components
are unchanged. agenticStore: 1196 -> 1073 lines.
* ui: Compose MCP resources under mcpStore.resources
Resource state was a second import scope next to mcpStore. Consumers
now go through mcpStore.resources, so the MCP surface is one store;
mcp-resources.svelte.ts stays a separate file owned by mcpStore.
* ui: Reorganize stores into domain namespaces
* fix: Update stale doc comments
* ui: Consolidate conv running-state into a chat activity ledger
Running-state was split across chatStore.chatLoadingStates (local
pipes), ChatStreamManager.remoteRunningConvs (backend sessions) and
attachingConvs (attach lifecycle), unioned by hand in
getAllLoadingChats and cross-cleaned by setChatLoading calling
streams.clearRemoteRunning - the 'spinner ghosts until tab toggle'
workaround.
chatActivityStore now owns both sets with one transition per event:
markLocal / localEnded (local pipe end also drops the stale remote
hint, no cross-owner call) / applyRemoteSnapshot (diffed). The
sidebar reads chatStore.activity.loadingConvs through the unchanged
getAllLoadingChats entry point.
Consequences:
- isStreamingActive and its five manual writers are gone; isStreaming()
now reports whether the active conversation has a live streaming
pipe, which is what all four consumers (assistant row, stop action,
context gauge, chat screen) actually check
- isLoading/isReasoning become derived from the per-conv maps plus
the active conversation, dropping the manual resync in
syncLoadingStateForChat and clearUIState
- attachingConvs and the last-attach coordination disappear from
ChatStreamManager
- getAllStreamingChats (no consumers) is removed
* ui: Give store collaborators narrow host interfaces
Collaborators took 'host: typeof <store>', i.e. the store's entire
public surface, which is how chatStore's streamChatCompletion,
createAssistantMessage, getApiOptions and setStreamingActive got
widened to public. Replace with per-collaborator interfaces carrying
only the members each one drives:
- ChatStreamHost (chat/streams) - activity, processing, streaming
states, abort controller, loading/streaming setters
- ChatFlowsHost (chat/flows) - streaming core, message creation,
per-conv state setters
- McpHealthHost (mcp/health) - connection registry + reconnection
- ModelPropsHost / ModelStatusHost (models) - model rows, feed
updates; the managers write modalities/status back onto the host's
rows, so those members stay writable
- ConversationsPreferencesHost (conversations) - the active row and
the conversation list
The store classes now declare 'implements <Host>' so the contract is
visible at the class level, and the 'import type { <store> }' back
references in the collaborators disappear entirely - the host
contract is local to each collaborator file, and collaborators can
no longer reach around their slice. Members stay public (structural
typing), but the collaborator side is now compiler-enforced.
* test: Chat Activity store test
* refactor: Cleanup
* chore: Remove legacy architecture docs
* ui: Memoize findMessageIndex for the streaming hot path
Streaming looks up the same message index on every chunk, a linear
scan of activeMessages each time. Cache the last lookup and reuse it
after validating the id still sits at the same position (O(1)); any
structural change to the array fails validation and falls back to a
full scan.
* ui: Throttle per-chunk stream state writes to localStorage
saveStreamState ran JSON.stringify + a synchronous localStorage.setItem
on every decoded chunk of the stream. The read loop now goes through a
new saveStreamStateThrottled (one write per conversation per 500ms,
latest value held pending); the public saveStreamState keeps its
immediate-write contract for stream start and pre-fetch, and also
resets the throttle window.
A pending offset is force-flushed at resume boundaries (resumeStream
reads the offset back from localStorage), on visibilitychange->hidden
and on pagehide, so a reload always finds a usable offset. The resume
offset only needs to be roughly current since the server retransmits
from a line boundary and the client discards its partial line.
Adds unit tests for the throttled/flush/clear interplay.
* ui: Compute context gauge timing stats in one pass
currentRead/Fresh/Cache/Output were separate deriveds, each running a
full reverse scan of activeMessages for the last assistant timings,
and cumulative ran its own forward scan plus an agentic filter - 4-5
O(n) passes per chunk while streaming. Replace with a single
summarizeAssistantTimings() pass (last assistant timings, last
agentic llm totals and the cumulative sums) feeding a shared derived
snapshot. Semantics unchanged, including the live-stats overrides and
the agentic llm-totals branch.
* agentic : clear session state when a conversation is deleted
Every conversation that ran an agentic flow left an AgenticSession in the
store forever; clearSession was never called. conversationsStore now
notifies deletion listeners and agenticStore drops the matching sessions,
avoiding a circular import back into conversationsStore.
* chat : extract ChatService.normalizeMessagesForApi
The DB->API message normalization (convert + drop empty system messages)
was duplicated in sendMessage, preEncode and the agentic flow. Extract it
into one shared method and call it from all three.
* sse : share record splitting and data extraction
splitSseRecords and extractSseDataPayload centralize the record-boundary
splitting and data: line extraction used by parseSseJsonStream and the
models status feed. chat.service keeps its own line-based parser for
resume support.
* api : delegate apiFetchWithParams to apiFetch
apiFetchWithParams duplicated apiFetch's headers/fetch/error handling
body-for-body; it only differs in URL construction. Build the URL and
delegate.
* chat flows : dedupe title, timings and cleanup handling
- conversationsStore.applyTitleFromContent centralizes the title-from-first-
message logic duplicated in 5 places
- ChatProcessingStore.applyStreamTimings centralizes the onTimings handler
shared by the chat and continue flows
- host.cleanupStreaming centralizes the loading/streaming/processing reset
repeated across the continue flow's exit paths
* conversations : centralize conversation update mirroring
rename, pin, mcp override, reasoning effort and cwd all repeated the same
write-DB-then-mirror-into-list-and-active dance. A single
applyConversationUpdate(id, updates) on the host collapses all five and
removes the forgot-to-mirror-one-field bug class. Drops the redundant
array reassignment in setCwd (deep field assignment is reactive).
* mcp : dedupe tool execution, server parsing and tool indexing
- executeTool delegates to executeToolByName (only diff was argument parsing)
- drop the private #parseServerSettings copy; use parseMcpServerSettings
- cache getServers() keyed on the raw config value (hot path)
- indexServerTools() unifies the three identical toolsIndex rebuild loops
Assisted-by: Claude
* mcp : share cursor pagination and tool indexing
- MCPService.paginate() collapses the identical do-while loops in
listAllResources and listAllResourceTemplates
- promoteHealthCheckToConnection now uses indexServerTools like the other
connect paths
Assisted-by: Claude
* database : share message parent-child bookkeeping
- addChildToParent() dedups the append-to-children update in createMessageBranch
and createSystemMessage
- removeChildFromParent() dedups the remove-from-children cleanup in deleteMessage
and deleteMessageCascading
- bulkAdd the cloned messages when forking a conversation instead of one add
per message
Assisted-by: Claude
* chore: Lint/format
* fix: `pagehide` event from `window`
* refactor: Api Fetch util
* docs : rewrite architecture sections in README
Update the high-level diagram, routes, hooks, stores, services and data
flow tables to match the current UI structure (mcp/settings/search
routes, agentic/tools/mcp stores, MCPService/ToolsService/SandboxService,
/tools API). Fix stale architectural patterns for per-conversation state
and modality validation.
* chore : add ESLint rule for blank lines between accessors
Enforce a blank line between consecutive class accessors. The core
padding-line-between-statements rule does not cover class members, so a
local rule is needed.
* refactor : reorder store members and unify naming
Order store class members as public fields, private fields, constructor,
getters, public methods, then private methods. Normalize private naming
to the `private` keyword (drop `#` and the `_` prefix where there is no
matching public getter). Rename conversationsStore.init() to
initialize() to match the other stores.
* refactor : prefix lookup methods with get in agentic and chat stores
Unify bare-name lookup methods with the get* prefix used across the
other stores (mcp, models, tools, settings). Renames currentTurn,
totalToolCalls, lastError, streamingToolCall, executingToolCallId,
pendingPermissionRequest, pendingContinueRequest,
pendingSteeringMessageContent, pendingSteeringMessageExtras in the
agentic store and pendingMessageContent, pendingMessageExtras in the
chat store. Updates the two consuming components and a doc comment.
* refactor: Clean up comments in stores' and services' code
* chore : add ESLint rule for class member ordering
Enforce structural order (public fields -> private fields -> constructor ->
getters -> setters -> public methods -> private methods) with alphabetical
sorting within each group via perfectionist/sort-classes. Dependency
detection keeps Svelte $derived fields in a valid dependency order instead
of alphabetizing them, since Svelte rejects forward references.
Assisted-by: Claude
* refactor : reorder class members to match new ESLint rule
Apply the sort-classes rule across stores, services, hooks and utils.
Pure reordering - verified no logic changes by comparing sorted line
multisets before/after. All tests and svelte-check pass.
158 lines
5.0 KiB
TypeScript
158 lines
5.0 KiB
TypeScript
import { heicFileToJpegDataURL, isHeicMimeType } from './heic-to-jpeg';
|
|
import { convertPDFToText } from './pdf-processing';
|
|
import { isSvgMimeType, svgBase64UrlToPngDataURL } from './svg-to-png';
|
|
import { isWebpMimeType, webpBase64UrlToPngDataURL } from './webp-to-png';
|
|
import { SETTINGS_KEYS } from '$lib/constants';
|
|
import { FileTypeCategory } from '$lib/enums';
|
|
import { modelsStore } from '$lib/stores/models/index.svelte';
|
|
import { settingsStore } from '$lib/stores/settings/index.svelte';
|
|
import { getFileTypeCategory } from '$lib/utils';
|
|
import { toast } from 'svelte-sonner';
|
|
|
|
/**
|
|
* Read a file as a data URL (base64 encoded)
|
|
* @param file - The file to read
|
|
* @returns Promise resolving to the data URL string
|
|
*/
|
|
function readFileAsDataURL(file: File): Promise<string> {
|
|
return new Promise((resolve, reject) => {
|
|
const reader = new FileReader();
|
|
|
|
reader.onload = () => resolve(reader.result as string);
|
|
reader.onerror = () => reject(reader.error);
|
|
reader.readAsDataURL(file);
|
|
});
|
|
}
|
|
|
|
/**
|
|
* Read a file as UTF-8 text
|
|
* @param file - The file to read
|
|
* @returns Promise resolving to the text content
|
|
*/
|
|
function readFileAsUTF8(file: File): Promise<string> {
|
|
return new Promise((resolve, reject) => {
|
|
const reader = new FileReader();
|
|
|
|
reader.onload = () => resolve(reader.result as string);
|
|
reader.onerror = () => reject(reader.error);
|
|
reader.readAsText(file);
|
|
});
|
|
}
|
|
|
|
/**
|
|
* Process uploaded files into ChatUploadedFile format with previews and content
|
|
*
|
|
* This function processes various file types and generates appropriate previews:
|
|
* - Images: Base64 data URLs with format normalization (SVG/WebP → PNG)
|
|
* - Text files: UTF-8 content extraction
|
|
* - PDFs: Metadata only (processed later in conversion pipeline)
|
|
* - Audio: Base64 data URLs for preview
|
|
*
|
|
* @param files - Array of File objects to process
|
|
* @returns Promise resolving to array of ChatUploadedFile objects
|
|
*/
|
|
export async function processFilesToChatUploaded(
|
|
files: File[],
|
|
activeModelId?: string
|
|
): Promise<ChatUploadedFile[]> {
|
|
const results: ChatUploadedFile[] = [];
|
|
|
|
for (const file of files) {
|
|
const id = Date.now().toString() + Math.random().toString(36).substr(2, 9);
|
|
const base: ChatUploadedFile = {
|
|
file,
|
|
id,
|
|
name: file.name,
|
|
size: file.size,
|
|
type: file.type
|
|
};
|
|
|
|
try {
|
|
if (getFileTypeCategory(file.type) === FileTypeCategory.IMAGE) {
|
|
let preview = await readFileAsDataURL(file);
|
|
|
|
// Normalize SVG and WebP to PNG, and HEIC to compressed JPEG, in previews
|
|
if (isSvgMimeType(file.type)) {
|
|
try {
|
|
preview = await svgBase64UrlToPngDataURL(preview);
|
|
} catch (err) {
|
|
console.error('Failed to convert SVG to PNG:', err);
|
|
}
|
|
} else if (isWebpMimeType(file.type)) {
|
|
try {
|
|
preview = await webpBase64UrlToPngDataURL(preview);
|
|
} catch (err) {
|
|
console.error('Failed to convert WebP to PNG:', err);
|
|
}
|
|
} else if (isHeicMimeType(file.type)) {
|
|
try {
|
|
preview = await heicFileToJpegDataURL(file);
|
|
} catch (err) {
|
|
console.error('Failed to convert HEIC to PNG:', err);
|
|
|
|
continue;
|
|
}
|
|
}
|
|
|
|
results.push({ ...base, preview });
|
|
} else if (getFileTypeCategory(file.type) === FileTypeCategory.PDF) {
|
|
// Extract text content from PDF for preview
|
|
try {
|
|
const textContent = await convertPDFToText(file);
|
|
|
|
results.push({ ...base, textContent });
|
|
} catch (err) {
|
|
console.warn('Failed to extract text from PDF, adding without content:', err);
|
|
results.push(base);
|
|
}
|
|
|
|
// Show suggestion toast if vision model is available but PDF as image is disabled
|
|
const hasVisionSupport = activeModelId
|
|
? modelsStore.props.modelSupportsVision(activeModelId)
|
|
: false;
|
|
const currentConfig = settingsStore.config;
|
|
|
|
if (hasVisionSupport && !currentConfig.pdfAsImage) {
|
|
toast.info(`You can enable parsing PDF as images with vision models.`, {
|
|
action: {
|
|
label: 'Enable PDF as Images',
|
|
onClick: () => {
|
|
settingsStore.updateConfig(SETTINGS_KEYS.PDF_AS_IMAGE, true);
|
|
toast.success('PDF parsing as images enabled!', {
|
|
duration: 3000
|
|
});
|
|
}
|
|
},
|
|
duration: 8000
|
|
});
|
|
}
|
|
} else if (getFileTypeCategory(file.type) === FileTypeCategory.AUDIO) {
|
|
// Generate preview URL for audio files
|
|
const preview = await readFileAsDataURL(file);
|
|
|
|
results.push({ ...base, preview });
|
|
} else if (getFileTypeCategory(file.type) === FileTypeCategory.VIDEO) {
|
|
// Generate preview URL for video files
|
|
const preview = await readFileAsDataURL(file);
|
|
|
|
results.push({ ...base, preview });
|
|
} else {
|
|
// Fallback: treat unknown files as text
|
|
try {
|
|
const textContent = await readFileAsUTF8(file);
|
|
|
|
results.push({ ...base, textContent });
|
|
} catch (err) {
|
|
console.warn('Failed to read file as text, adding without content:', err);
|
|
results.push(base);
|
|
}
|
|
}
|
|
} catch (error) {
|
|
console.error('Error processing file', file.name, error);
|
|
results.push(base);
|
|
}
|
|
}
|
|
|
|
return results;
|
|
}
|