conproxy 0.2.1

Cache proxy server for heterogeneous RAG/vector search backends with cascade, scope, and MCP
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

use crate::helpers::client::E2eClient;
use crate::helpers::config::ConfigManager;
use crate::helpers::constants::{category_enabled, Suite};
use crate::helpers::report::TestReport;
use crate::run_test;

pub fn run(client: &E2eClient, suite: Suite, config: &ConfigManager, report: &mut TestReport) {
    if !category_enabled("reload") || !suite.is_all() {
        return;
    }

    eprintln!();
    eprintln!("\x1b[1mHot Reload Tests\x1b[0m");
    eprintln!("--------------------------------------------");

    // Reload returns success
    run_test!(report, "reload", "Reload: success response", {
        let (status, body) = client.admin_reload();
        assert_eq!(status, 200);
        assert_eq!(body["success"], true, "Expected success=true: {}", body);
    });

    // Modify config on disk
    config.backup_current();
    config.set_max_entries(9999);

    // Reload picks up new max_entries (verify via /stats cache section)
    run_test!(report, "reload", "Reload: picks up new max_entries", {
        let (status, body) = client.admin_reload();
        assert_eq!(status, 200);
        assert_eq!(body["success"], true);
        let (status, stats) = client.stats();
        assert_eq!(status, 200);
        let max_entries = stats["cache"]["max_entries"].as_u64().unwrap_or(0);
        assert_eq!(
            max_entries, 9999,
            "Expected max_entries=9999 after reload, got {max_entries}"
        );
    });

    // Reload reports reloaded sections
    run_test!(report, "reload", "Reload: reports reloaded sections", {
        let (_, body) = client.admin_reload();
        let reloaded = body["reloaded"].as_array().map(|a| a.len()).unwrap_or(0);
        assert!(reloaded > 0, "Expected reloaded sections > 0");
    });

    // Restore original config
    config.restore_reload_backup();

    // Reload with restored config
    run_test!(report, "reload", "Reload: restored config", {
        let (status, body) = client.admin_reload();
        assert_eq!(status, 200);
        assert_eq!(body["success"], true);
    });

    eprintln!("--------------------------------------------");
}