picodata-pike 3.1.0

Cargo plugin for Picodata plugin 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
63
64

use picotest::*;

// Перед сценарием пытаемся удалить плагин, если он уже есть; ошибки игнорируем
fn best_effort_cleanup(cluster: &Cluster, name: &str, version: &str) {
    let _ = cluster.run_query(format!(r#"ALTER PLUGIN "{name}" {version} DISABLE;"#));
    let _ = cluster.run_query(format!(r#"DROP PLUGIN "{name}" {version} WITH DATA;"#));
}

#[picotest]
fn test_smoke_plugin_lifecycle() {
    let plugin_name = env!("CARGO_PKG_NAME");
    let version = env!("CARGO_PKG_VERSION");

    best_effort_cleanup(cluster, plugin_name, version);

    // 1) CREATE PLUGIN
    cluster.run_query(format!(r#"CREATE PLUGIN "{plugin_name}" {version};"#))
        .unwrap_or_else(|err| panic!("CREATE PLUGIN failed: {err}"));

    // 2) MIGRATE TO
    cluster.run_query(format!(
        r#"ALTER PLUGIN "{plugin_name}" MIGRATE TO {version};"#
    )).unwrap_or_else(|err| panic!("MIGRATE TO failed: {err}"));

    // 3) ENABLE
    cluster.run_query(format!(
        r#"ALTER PLUGIN "{plugin_name}" {version} ENABLE;"#
    )).unwrap_or_else(|err| panic!("ENABLE failed: {err}"));

    let table = cluster
        .run_query("SELECT name, enabled FROM _pico_plugin;")
        .expect("Failed to query _pico_plugin after ENABLE");
    assert!(
        table.contains(plugin_name) && table.contains("true"),
        "Plugin should be enabled. Table:\n{table}"
    );

    // 4) DISABLE
    cluster.run_query(format!(
        r#"ALTER PLUGIN "{plugin_name}" {version} DISABLE;"#
    )).unwrap_or_else(|err| panic!("DISABLE failed: {err}"));

    let table = cluster
        .run_query("SELECT name, enabled FROM _pico_plugin;")
        .expect("Failed to query _pico_plugin after DISABLE");
    assert!(
        table.contains(plugin_name) && table.contains("false"),
        "Plugin should be disabled. Table:\n{table}"
    );

    // 5) DROP WITH DATA
    cluster.run_query(format!(
        r#"DROP PLUGIN "{plugin_name}" {version} WITH DATA;"#
    )).unwrap_or_else(|err| panic!("DROP WITH DATA failed: {err}"));

    // Валидация
    let final_table = cluster
        .run_query("SELECT name FROM _pico_plugin;")
        .expect("Failed to query _pico_plugin after DROP");
    assert!(
        !final_table.contains(plugin_name),
        "Plugin '{plugin_name}' still present after DROP WITH DATA. Table:\n{final_table}"
    );
}