Method open

atomic-core/src/pristine/txn/pristine.rs:120–229

Open or create a pristine database at the given path This will create all necessary tables if they don't exist.

(path: P)

    ///
    /// This will create all necessary tables if they don't exist.
    pub fn open<P: AsRef<Path>>(path: P) -> PristineResult<Self> {
        // Use 8 GB cache for machines with plenty of RAM.  The default
        // redb cache is 1 GB which causes excessive page eviction when
        // the GRAPH table grows beyond that during large imports.
        let cache_bytes = 8 * 1024 * 1024 * 1024; // 8 GiB
        let db = open_database(path.as_ref(), true, cache_bytes)?;

        // Initialize all tables
        let write_txn = db.begin_write()?;
        {
            // ID mapping tables
            write_txn.open_table(EXTERNAL)?;
            write_txn.open_table(INTERNAL)?;
            write_txn.open_table(NODE_TYPES)?;

            // Graph tables
            write_txn.open_multimap_table(GRAPH)?;
            write_txn.open_multimap_table(INODE_GRAPH)?;

            // View tables
            write_txn.open_table(VIEWS)?;
            write_txn.open_table(VIEW_CHANGES)?;
            write_txn.open_table(REV_VIEW_CHANGES)?;
            write_txn.open_table(CONFLICTS)?;

            // Tree tables
            write_txn.open_table(TREE)?;
            write_txn.open_table(REV_TREE)?;
            write_txn.open_table(INODES)?;
            write_txn.open_table(REV_INODES)?;
            write_txn.open_table(DIRECTORIES)?;

            // File index cache (mtime + size + content hash for fast status detection)
            write_txn.open_table(FILE_INDEX)?;

            // Dependency tables
            write_txn.open_multimap_table(DEPS)?;
            write_txn.open_multimap_table(REV_DEPS)?;
            write_txn.open_multimap_table(CHANGE_DEPS)?;
            write_txn.open_multimap_table(REV_CHANGE_DEPS)?;
            write_txn.open_table(CHANGE_DEPS_INDEXED)?;

            // State tables
            write_txn.open_table(STATES)?;
            write_txn.open_table(MERKLE_CHAIN)?;

            // Tag record tables
            write_txn.open_table(TAG_RECORDS)?;
            write_txn.open_table(TAG_NAME_INDEX)?;

            // Git SHA index (git commit SHA → entity_id)
            write_txn.open_table(GIT_SHA_INDEX)?;

            // Session tables (provenance-derived session data, any agent)
            write_txn.open_table(SESSION_EVENTS)?;
            write_txn.open_table(SESSION_TODOS)?;
            write_txn.open_table(SESSION_PHASES)?;
            write_txn.open_table(SESSION_INTENTS)?;