Struct Database 

pub struct Database { /* private fields */ }

Master transactional store for a single brain (.brain/db.sqlite).

The connection is crate-visible for ranked-query helpers; external consumers use typed methods only.

Implementations

impl Database

pub fn search_ranked( &self, query: &str, opts: &QueryOptions, ) -> Result<Vec<RankedHit>>

Ranked search combining FTS5 BM25 with tag, alias, title, and id boosts.

Steps:

1. Prepare the query (tokenize, drop stopwords, OR multi-token MATCH)
2. Collect BM25-ordered candidates (oversample by 2 × limit)
3. Apply additive boosts for title/id/tag/alias token hits + multi-token coverage
4. Apply multiplicative type priors from QueryOptions::type_boosts
5. Augment with pure tag/alias exact matches FTS may have missed
6. Sort by score, dedupe by id, truncate to limit

Errors

Returns crate::BrainError::FtsQuery for empty input after tokenization.

pub fn get_tags_for(&self, node_id: &str) -> Result<Vec<String>>

Tags attached to a node (empty if none).

pub fn list_pending_links(&self) -> Result<Vec<PendingLink>>

List unresolved WikiLink / symbol targets.

pub fn count_nodes_by_type(&self) -> Result<Vec<(String, usize)>>

Count nodes grouped by node_type.

impl Database

pub fn open<P: AsRef<Path>>(path: P) -> Result<Self>

Open or create a database at path, apply pragmas, and run migrations.

pub fn open_in_memory() -> Result<Self>

Open an in-memory database (tests).

pub fn with_transaction<T, F>(&self, f: F) -> Result<T>

where F: FnOnce(&Connection) -> Result<T>,

Run f inside a single transaction (unchecked; suitable for &self).

pub fn insert_node(&self, node: &Node) -> Result<()>

Insert or update a node. Preserves created_at on conflict when the existing row is older (caller should pass original created_at when known).

pub fn get_content_hash(&self, node_id: &str) -> Result<Option<String>>

Fetch content_hash for a node if present.

pub fn insert_edge(&self, edge: &Edge) -> Result<()>

Insert or update a weighted edge. Both endpoints must exist.

pub fn insert_pending_link( &self, source_id: &str, raw_target: &str, relation_type: &str, created_at: i64, ) -> Result<()>

Record an unresolved WikiLink for later resolution / reporting.

pub fn clear_pending_links_for(&self, source_id: &str) -> Result<()>

Clear all pending links originating from source_id (before re-resolve).

pub fn clear_all_auto_edges(&self) -> Result<()>

Delete all soft auto-edges (relation_type like auto_%).

pub fn clear_auto_edges_involving(&self, node_id: &str) -> Result<()>

Delete soft auto-edges where node_id is source or target.

pub fn insert_symbol_anchor(&self, anchor: &SymbolAnchor) -> Result<()>

Insert or update a code symbol anchor row (AST metadata).

pub fn replace_node_tags(&self, node_id: &str, tags: &[String]) -> Result<()>

Replace the full tag set for a node.

pub fn replace_node_aliases( &self, node_id: &str, aliases: &[String], ) -> Result<()>

Replace aliases for a node.

pub fn index_fts( &self, node_id: &str, title: &str, content: &str, tags: &str, ) -> Result<()>

Idempotent FTS upsert: delete existing rows for node_id, then insert once.

pub fn get_fts_content(&self, node_id: &str) -> Result<Option<String>>

Fetch indexed FTS body/content for a node (for context excerpts).

pub fn search_fts(&self, query: &str) -> Result<Vec<Node>>

Search nodes using FTS5 BM25 ranking with a safely escaped query.

pub fn list_node_ids_by_type(&self, node_type: &str) -> Result<Vec<String>>

List node ids with the given node_type string (e.g. "adr").

pub fn get_node(&self, id: &str) -> Result<Option<Node>>

Fetch a single node by id, if present.

pub fn count_nodes(&self) -> Result<usize>

Number of rows in nodes.

pub fn count_edges(&self) -> Result<usize>

Number of rows in edges.

pub fn count_fts_rows(&self) -> Result<usize>

Number of rows in the FTS5 node_fts table (should equal indexed notes).

pub fn count_pending_links(&self) -> Result<usize>

Number of unresolved WikiLink / symbol refs in pending_links.

pub fn count_symbol_anchors(&self) -> Result<usize>

Number of AST symbol anchor rows.

pub fn get_all_node_ids(&self) -> Result<Vec<String>>

All node IDs in stable ascending order (CSR index order).

pub fn get_all_edges(&self) -> Result<Vec<Edge>>

Full edge records (relation_type preserved).

pub fn get_csr_edges(&self) -> Result<Vec<(String, String, f32)>>

Lightweight edge triples for CSR compile: (source, target, weight).

pub fn get_all_nodes(&self) -> Result<Vec<Node>>

All nodes ordered by id ascending (export / CSR compile order).

pub fn link_resolution_maps( &self, ) -> Result<(HashSet<String>, HashMap<String, String>, HashMap<String, String>)>

Build resolution maps: ids, alias→id, lowercase title→id.

pub fn resolve_pending_links(&self) -> Result<(usize, usize)>

Attempt to resolve all pending links; returns (resolved, still_pending).