Method get_memory

core/src/memory/store.rs:101–118

Get a single memory by ID.

(&self, memory_id: &MemoryId)

    /// Get a single memory by ID.
    pub async fn get_memory(&self, memory_id: &MemoryId) -> GraphBitResult<Option<Memory>> {
        let id = memory_id.to_string();
        let conn_arc = Arc::clone(&self.conn);

        tokio::task::spawn_blocking(move || -> GraphBitResult<Option<Memory>> {
            let conn = conn_arc.blocking_lock();
            let mut stmt =
                conn.prepare("SELECT id, content, user_id, agent_id, run_id, hash, metadata, created_at, updated_at FROM memories WHERE id = ?1")?;
            let mut rows = stmt.query(rusqlite::params![id])?;
            if let Some(row) = rows.next()? {
                Ok(Some(row_to_memory(row)?))
            } else {
                Ok(None)
            }
        })
        .await
        .map_err(|e| GraphBitError::memory(format!("Join error: {e}")))?
    }

    /// Get all memories matching the given scope.
    pub async fn get_all_memories(&self, scope: &MemoryScope) -> GraphBitResult<Vec<Memory>> {