greentic-start-dev 1.1.27190108346

Greentic lifecycle runner for start/restart/stop orchestration
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
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94

use std::path::{Path, PathBuf};

#[derive(Clone, Copy, Debug, Eq, PartialEq)]
pub enum ExtensionPackClass {
    CorePlatform,
    OptionalExtension,
}

#[derive(Clone, Debug, Eq, PartialEq)]
pub struct ExtensionPackRole {
    pub class: ExtensionPackClass,
    pub reason: &'static str,
}

pub fn classify_extension_pack_path(bundle_root: &Path, pack_path: &Path) -> ExtensionPackRole {
    let relative = pack_path
        .strip_prefix(bundle_root)
        .unwrap_or(pack_path)
        .to_path_buf();
    classify_relative_path(&relative)
}

pub fn classify_extension_pack_id(pack_id: &str) -> ExtensionPackRole {
    let normalized = pack_id.trim().to_ascii_lowercase();
    if normalized.contains("telemetry")
        || normalized.contains("oauth")
        || normalized.contains("messaging")
        || normalized.contains("state")
        || normalized.contains("events")
        || normalized.contains("secrets")
    {
        return ExtensionPackRole {
            class: ExtensionPackClass::CorePlatform,
            reason: "domain-runtime",
        };
    }
    if normalized.contains("hook")
        || normalized.contains("contract")
        || normalized.contains("capabilit")
        || normalized.contains("subscription")
        || normalized.contains("extension")
    {
        return ExtensionPackRole {
            class: ExtensionPackClass::OptionalExtension,
            reason: "feature-extension",
        };
    }
    ExtensionPackRole {
        class: ExtensionPackClass::OptionalExtension,
        reason: "default-optional",
    }
}

fn classify_relative_path(path: &PathBuf) -> ExtensionPackRole {
    let value = path.to_string_lossy().to_ascii_lowercase();
    if value.starts_with("providers/")
        || value.starts_with("messaging/")
        || value.starts_with("events/")
        || value.starts_with("oauth/")
        || value.starts_with("secrets/")
        || value.starts_with("telemetry/")
        || value.starts_with("state/")
    {
        return ExtensionPackRole {
            class: ExtensionPackClass::CorePlatform,
            reason: "bundle-platform-dir",
        };
    }
    ExtensionPackRole {
        class: ExtensionPackClass::OptionalExtension,
        reason: "bundle-extension-dir",
    }
}

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

    #[test]
    fn platform_dirs_are_classified_as_core() {
        let bundle = Path::new("/tmp/bundle");
        let role = classify_extension_pack_path(
            bundle,
            Path::new("/tmp/bundle/providers/messaging/a.gtpack"),
        );
        assert_eq!(role.class, ExtensionPackClass::CorePlatform);
    }

    #[test]
    fn hook_like_ids_are_optional() {
        let role = classify_extension_pack_id("contracts-and-hooks");
        assert_eq!(role.class, ExtensionPackClass::OptionalExtension);
    }
}