tinycortex 0.1.1

Rust core for the TinyCortex memory system
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
65
66
67
68
69
70
71
72
73
74
75
76
77

//! Tests for required-field validation and the path-traversal guard.

use super::*;
use crate::memory::sources::types::SourceKind;
use std::fs;
use tempfile::TempDir;

fn entry(kind: SourceKind) -> MemorySourceEntry {
    MemorySourceEntry {
        id: "src_x".into(),
        kind,
        label: "Label".into(),
        enabled: true,
        toolkit: None,
        connection_id: None,
        path: None,
        glob: None,
        url: None,
        branch: None,
        paths: Vec::new(),
        max_commits: None,
        max_issues: None,
        max_prs: None,
        query: None,
        since_days: None,
        max_items: None,
        selector: None,
        max_tokens_per_sync: None,
        max_cost_per_sync_usd: None,
        sync_depth_days: None,
    }
}

#[test]
fn empty_id_or_label_is_rejected_for_every_kind() {
    let mut e = entry(SourceKind::Conversation);
    e.id = String::new();
    assert!(validate_entry(&e).is_err());

    let mut e = entry(SourceKind::Conversation);
    e.label = String::new();
    assert!(validate_entry(&e).is_err());
}

#[test]
fn empty_string_field_counts_as_missing() {
    let mut e = entry(SourceKind::Folder);
    e.path = Some(String::new());
    assert!(validate_entry(&e).is_err());
}

#[test]
fn composio_requires_both_toolkit_and_connection() {
    let mut e = entry(SourceKind::Composio);
    e.toolkit = Some("gmail".into());
    assert!(validate_entry(&e).is_err());
    e.connection_id = Some("conn".into());
    assert!(validate_entry(&e).is_ok());
}

#[test]
fn ensure_within_base_accepts_contained_file() {
    let tmp = TempDir::new().unwrap();
    fs::write(tmp.path().join("ok.md"), "hi").unwrap();
    let resolved = ensure_within_base(tmp.path(), &tmp.path().join("ok.md")).unwrap();
    assert!(resolved.ends_with("ok.md"));
}

#[test]
fn ensure_within_base_rejects_escape() {
    let tmp = TempDir::new().unwrap();
    fs::write(tmp.path().join("ok.md"), "hi").unwrap();
    // Build a target that escapes the base via `..`.
    let escaping = tmp.path().join("../../etc/hosts");
    let result = ensure_within_base(tmp.path(), &escaping);
    assert!(result.is_err());
}