Method init_schema_sync

core/src/memory/store.rs:37–72

Create the required tables if they do not already exist.

(&self)

    /// Create the required tables if they do not already exist.
    fn init_schema_sync(&self) -> GraphBitResult<()> {
        let conn = self
            .conn
            .try_lock()
            .map_err(|_| GraphBitError::memory("Failed to acquire database lock during init"))?;

        conn.execute_batch(
            "CREATE TABLE IF NOT EXISTS memories (
                id          TEXT PRIMARY KEY,
                content     TEXT NOT NULL,
                user_id     TEXT,
                agent_id    TEXT,
                run_id      TEXT,
                hash        TEXT NOT NULL,
                metadata    TEXT NOT NULL DEFAULT '{}',
                created_at  TEXT NOT NULL,
                updated_at  TEXT NOT NULL
            );
            CREATE TABLE IF NOT EXISTS memory_history (
                id          INTEGER PRIMARY KEY AUTOINCREMENT,
                memory_id   TEXT NOT NULL,
                old_content TEXT NOT NULL DEFAULT '',
                new_content TEXT NOT NULL DEFAULT '',
                action      TEXT NOT NULL,
                timestamp   TEXT NOT NULL,
                FOREIGN KEY (memory_id) REFERENCES memories(id) ON DELETE CASCADE
            );
            CREATE INDEX IF NOT EXISTS idx_memories_user_id  ON memories(user_id);
            CREATE INDEX IF NOT EXISTS idx_memories_agent_id ON memories(agent_id);
            CREATE INDEX IF NOT EXISTS idx_memories_run_id   ON memories(run_id);
            CREATE INDEX IF NOT EXISTS idx_memories_hash     ON memories(hash);
            CREATE INDEX IF NOT EXISTS idx_history_memory_id ON memory_history(memory_id);",
        )?;

        Ok(())
    }

    /// Insert a new memory.
    pub async fn insert_memory(&self, memory: &Memory) -> GraphBitResult<()> {