rsclaw 2026.5.1

AI Agent Engine Compatible with OpenClaw
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
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64

use anyhow::Result;

use super::style::*;
use crate::{agent, cli::MemoryCommand, config, sys::detect_memory_tier};

pub async fn cmd_memory(sub: MemoryCommand) -> Result<()> {
    let tier = detect_memory_tier();
    let base = config::loader::base_dir();
    let data_dir = base.join("var/data");
    let model_dir = {
        let zh = base.join("models/bge-small-zh");
        let en = base.join("models/bge-small-en");
        if zh.join("config.json").exists() { zh } else { en }
    };
    let cfg = config::load().ok();
    let search_cfg = cfg.as_ref().and_then(|c| c.raw.memory_search.as_ref());
    match sub {
        MemoryCommand::Status(args) => {
            // Read-only: won't conflict with running gateway.
            let mem =
                agent::memory::MemoryStore::open_readonly(&data_dir, Some(&model_dir), search_cfg)
                    .await?;
            let count = mem.count().await?;
            if args.json {
                println!("{}", serde_json::json!({"documents": count}));
            } else {
                banner(&format!("rsclaw memory v{}", option_env!("RSCLAW_BUILD_VERSION").unwrap_or("dev")));
                kv("documents", &bold(&count.to_string()));
            }
        }
        MemoryCommand::Search(args) => {
            banner(&format!("rsclaw memory search v{}", option_env!("RSCLAW_BUILD_VERSION").unwrap_or("dev")));
            // Read-only: won't conflict with running gateway.
            let mut mem =
                agent::memory::MemoryStore::open_readonly(&data_dir, Some(&model_dir), search_cfg)
                    .await?;
            let results = mem.search(&args.query, None, args.max_results).await?;
            if results.is_empty() {
                warn_msg("no results");
            } else {
                kv("query", &cyan(&args.query));
                kv("results", &bold(&results.len().to_string()));
                println!();
                for doc in &results {
                    println!(
                        "  {} {} {}",
                        dim(&format!("[{}]", doc.id)),
                        dim(&format!("({})", doc.kind)),
                        doc.text
                    );
                }
            }
        }
        MemoryCommand::Index(_args) => {
            // Write operation: needs exclusive access. Gateway must be stopped.
            let mut mem =
                agent::memory::MemoryStore::open(&data_dir, Some(&model_dir), tier, search_cfg)
                    .await?;
            let count = mem.reindex().await?;
            ok(&format!("re-indexed {} document(s)", bold(&count.to_string())));
        }
    }
    Ok(())
}