maproom 0.2.0

Semantic code search powered by embeddings, with SQLite or PostgreSQL/pgvector storage
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44

//! `StoreMigration` impl — applies `migrations_pg/` and exposes applied integer
//! versions (§5.2 / §6.3). Backed by the hand-rolled runner in [`super::migrations`].

use std::collections::HashSet;

use async_trait::async_trait;

use super::PostgresStore;
use crate::db::traits::StoreMigration;

#[async_trait]
impl StoreMigration for PostgresStore {
    async fn migrate(&self) -> anyhow::Result<()> {
        super::migrations::run(self.pool.clone()).await
    }

    async fn get_applied_migrations(&self) -> anyhow::Result<HashSet<i32>> {
        super::migrations::get_applied(&self.pool).await
    }

    async fn verify_schema(&self) -> anyhow::Result<Vec<String>> {
        // R03 / R-VER-3: Postgres checks ONLY the 11 core tables —
        // `context_cache` is SQLite-only by design and must not be flagged
        // here (a single shared 12-table list would mark every healthy PG
        // database as damaged).
        // Review [26]: probe UNQUALIFIED so to_regclass resolves via the
        // connection's search_path — the migrator creates tables unqualified,
        // so a DSN with `options=-csearch_path=maproom` lands them in that
        // schema and a hardcoded 'public.' prefix would flag every table
        // missing on a perfectly healthy database.
        let mut missing = Vec::new();
        for name in crate::db::traits::REQUIRED_TABLES_CORE {
            let exists: Option<bool> =
                sqlx::query_scalar("SELECT to_regclass($1) IS NOT NULL")
                    .bind(name)
                    .fetch_one(&self.pool)
                    .await?;
            if !exists.unwrap_or(false) {
                missing.push(name.to_string());
            }
        }
        Ok(missing)
    }
}