leankg 0.16.7

Lightweight Knowledge Graph for AI-Assisted Development
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

use crate::db::schema::CozoDb;
use crate::mcp::tracker::WriteTracker;
use std::collections::BTreeMap;
use std::sync::Arc;

pub struct TrackingDb {
    inner: CozoDb,
    tracker: Arc<WriteTracker>,
}

impl TrackingDb {
    pub fn new(inner: CozoDb, tracker: Arc<WriteTracker>) -> Self {
        Self { inner, tracker }
    }

    pub fn run_script(
        &self,
        script: &str,
        params: BTreeMap<String, serde_json::Value>,
    ) -> Result<cozo::NamedRows, cozo::Error> {
        if is_write_operation(script) {
            self.tracker.mark_dirty();
        }
        self.inner.run_script(script, params)
    }

    pub fn into_inner(self) -> CozoDb {
        self.inner
    }
}

fn is_write_operation(script: &str) -> bool {
    let script_lower = script.to_lowercase();
    script_lower.contains(":put") || script_lower.contains(":delete")
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn test_is_write_operation_put() {
        assert!(is_write_operation(
            "?[id, name] <- [[$id, $name]] :put code_elements"
        ));
        assert!(is_write_operation(":put code_elements { id, name }"));
    }

    #[test]
    fn test_is_write_operation_delete() {
        assert!(is_write_operation(":delete code_elements where id = $id"));
        assert!(is_write_operation("?[id] := *code_elements[id] :delete"));
    }

    #[test]
    fn test_is_write_operation_query() {
        assert!(!is_write_operation(
            "?[id, name] := *code_elements[id, name]"
        ));
        assert!(!is_write_operation(":schema code_elements"));
    }
}