Collect all `.txt` mega-files from `directory` that meet `sessions_min`. Returns a sorted vec of `(path, session_count)` pairs. Files exceeding the s

Handle the `compress` sub-command — compresses drawers into AAAK dialect format.

Called by `run_compress_row` to print the dry-run preview for one drawer. Decodes the AAAK text and shows entities, topics, quote, emotions, and flag

Handle the `dedup` sub-command — finds and removes near-duplicate drawers.

Handle the `diary-ingest` sub-command — ingests diary markdown files into the palace.

Called by `run_discover_entities` to add prose-detected entity candidates. Scans up to 10 prose/code files in `directory`, runs `detect_entities` wit

Handle the `export` sub-command — exports palace drawers to markdown files.

Handle the `mcp` sub-command — opens the palace and starts the MCP server.

Mine the just-initialised project directory using pre-scanned files. Called by the `init` arm when the user confirms mining. Opens the palace, acquir

Print entity registry summary: people, projects, ambiguous names, wiki cache count.

Print KG entity and triple counts when either is non-zero.

Print per-room drawer counts, grouping rooms under their wing header.

Read one newline-delimited line from stdin, enforcing a hard byte limit. Prevents OOM by never buffering more than `limit` bytes from a client-contro

Drain bytes from the reader until the next newline or EOF. Called after detecting an overlong line to resync the stream.

Clear and rebuild the inverted word index via the palace library. Delegates the transaction and index work to `palace::repair::rebuild_index`, which

Handle the `repair` sub-command — prompts for confirmation then rebuilds the index. `skip_confirm` maps to the `-y` / `--yes` CLI flag; when false th

Read one line from `reader` and return `true` iff the user typed "y" (case-insensitive). Extracted so tests can inject a `Cursor` instead of real std

Handle the `search` sub-command — opens the palace and runs the search.

Handle the `split` sub-command — expands `~` then delegates to the splitter.

Handle the `sweep` sub-command — expands `~` then delegates to the sweeper.

Drive `cli::sync::run` over the resolved palace and print the report.

Handle the `wakeup` sub-command — opens the palace and runs wake-up.

Write `mempalace.yaml` to `directory` and print the next-step instructions. Called by [`run`] after the user confirms.

Process one slug directory and insert a `ProjectInfo` into `projects` if it has sessions. Called by [`scan_claude_projects`] to keep that function wi

Return a flat list of all conversation files under `directory`. Delegates the actual traversal to `walk_convos`.

Resolve the user's git identity from the first repo's local config, falling back to global. Called by [`scan`] to keep that function within the 70-li

Decide whether this repo should be considered "mine" (the current user is a key contributor). Called by [`scan_process_repo`] to keep that function w

Process one git repo: collect manifests, count authors, and update `projects` and `all_commits`. Called by [`scan`] to keep that function within the

Score person-related signals: verb patterns, dialogue markers, pronouns, direct address. `pronoun_re` is the compiled locale pronoun regex built from

Fetch `(source_file, content)` pairs from `compressed` for the given paths. Helper for [`search_closet_boost`]. Skips rows with empty content.

Parse neighbor expansion rows into `SearchResult` values with zero relevance score. The `source_path` argument is the path from the anchor drawer use

First-pass query: select top `n_candidates` drawers by raw TF sum.

Extend `words` with tokens derived from known person names found in `query`. Loads the entity registry on every call; the file is small so the overhe

Parse candidate rows (columns: id, content, wing, room, `source_file`, `chunk_index`, `filed_at`).

Convert a `(score, Candidate)` pair to a `SearchResult`.

Rebuild `ambiguous_flags` from the current `people` map. A name is ambiguous when its lowercase form appears in `COMMON_ENGLISH_WORDS`. Called at the

Insert one canonical `PersonEntry` from onboarding data. Called for each non-empty person in [`EntityRegistry::seed`].

Sanitize a Slack speaker ID for safe embedding in transcript text. Replaces bracket characters and control characters (U+0000..U+001F) with `_` to pr

Snap a byte offset to the nearest char boundary (backward).

Snap a byte offset to the nearest char boundary (forward).

Group `lines` into segments by splitting on conversation-turn markers.

Scan `directory` for `.txt` files, honouring or ignoring `.gitignore` rules. Depth is fixed at 1 — sub-directories are never traversed — matching the

Return the agreed-upon `source_mtime` for all drawers from `source_file`, or `None` when the file has never been mined or its mtime cannot be trusted.

Apply the prune: delete drawers by id, then closets by `source_file`. Counts deleted closets via a pre-DELETE COUNT so the report reflects what actua

Perform the inner deletes inside the open transaction. Splitting this off keeps `sync_delete` focused on transaction lifecycle.

Build a `?,?,?,...,?` placeholder string of length `count`. Used by [`sync_delete_inner`] to construct an `IN (...)` clause that binds each id as a s

Fetch every drawer's `(id, source_file, room, ingest_mode)`, optionally scoped to one wing.

Substitute `{name}` placeholders in `text` with the provided values. Placeholders not present in `vars` are left as-is; no error is raised for unreso

Open an in-memory test palace database and return the database + connection pair.

Write the drawer row and log the WAL event on confirmed insert. Returns the MCP response JSON.

Total drawer count for the same `(wing, room)` filter as `tool_list_drawers_query`. Excludes diary entries to match the listing query exactly — witho

Run the parameterized drawer list query for the given wing/room filter combination. Excludes diary entries — they use UUID IDs (not the `drawer_` pre

Check whether `new_id` already belongs to a different drawer, rejecting updates that would silently duplicate an existing entry. Returns `Some(error_

Compute the deterministic SHA256-based drawer ID from wing, room, and content. Mirrors the ID computation in `tool_add_drawer` so that IDs stay consi

Execute the transactional reindex: update the drawers row to its new ID, wing, room, and content, then rebuild the `drawer_words` full-text index. Wr

Parse and validate all input args for `tool_update_drawer`. Returns `Ok(UpdateDrawerArgs)` on success. Returns `Err(Value)` on validation failure **

Normalize a topic name for case-insensitive overlap detection.

Called by `traverse` to keep that function within the 70-line limit. For one BFS frontier node at `room_current`/`depth`, find all unvisited rooms th

Try to parse a `ChatGPT` conversations.json mapping tree into transcript text. Traverses the node tree from root through `children` links, extracting

Extract and join non-empty text blocks from a Gemini CLI message entry's `content` array of `{"text": "..."}` objects.

Find the root node ID in a `ChatGPT` mapping — the node with `parent=null` and no message body. Falls back to the first null-parent node with a messag

Walk the linear path of the message tree from `root`, collecting (role, text) pairs. Returns `None` if any node lookup fails (malformed export). Alwa

Returns `$XDG_DATA_HOME` if set to an absolute path, otherwise `$HOME/.local/share`. A relative or empty `$XDG_DATA_HOME` is treated as unset, per XD