gsm-core 0.4.13

Core types and platform abstractions for the Greentic messaging runtime.
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
95
96
97
98
99
100
101

//! Minimal Wasmtime host setup using Greentic host bindings.

#[cfg(feature = "component-host")]
mod demo {
    use anyhow::Result;
    use greentic_interfaces_host::host_import::v0_6;
    use greentic_interfaces_host::host_import::v0_6::{http, iface_types, state, types};
    use gsm_core::add_host_imports;
    use wasmtime::component::Linker;
    use wasmtime::{Config, Engine};

    pub struct DemoHost;

    impl v0_6::HostImports for DemoHost {
        fn secrets_get(
            &mut self,
            _key: String,
            _ctx: Option<types::TenantCtx>,
        ) -> wasmtime::Result<Result<String, types::IfaceError>> {
            Ok(Err(unavailable("secrets_get")))
        }

        fn telemetry_emit(
            &mut self,
            _span_json: String,
            _ctx: Option<types::TenantCtx>,
        ) -> wasmtime::Result<()> {
            Ok(())
        }

        fn http_fetch(
            &mut self,
            _req: http::HttpRequest,
            _ctx: Option<types::TenantCtx>,
        ) -> wasmtime::Result<Result<http::HttpResponse, types::IfaceError>> {
            Ok(Err(unavailable("http_fetch")))
        }

        fn mcp_exec(
            &mut self,
            _component: String,
            _action: String,
            _args_json: String,
            _ctx: Option<types::TenantCtx>,
        ) -> wasmtime::Result<Result<String, types::IfaceError>> {
            Ok(Err(unavailable("mcp_exec")))
        }

        fn state_get(
            &mut self,
            _key: iface_types::StateKey,
            _ctx: Option<types::TenantCtx>,
        ) -> wasmtime::Result<Result<String, types::IfaceError>> {
            Ok(Err(unavailable("state_get")))
        }

        fn state_set(
            &mut self,
            _key: iface_types::StateKey,
            _value_json: String,
            _ctx: Option<types::TenantCtx>,
        ) -> wasmtime::Result<Result<state::OpAck, types::IfaceError>> {
            Ok(Err(unavailable("state_set")))
        }

        fn session_update(
            &mut self,
            _cursor: iface_types::SessionCursor,
            _ctx: Option<types::TenantCtx>,
        ) -> wasmtime::Result<Result<String, types::IfaceError>> {
            Ok(Err(unavailable("session_update")))
        }
    }

    fn unavailable(_op: &str) -> types::IfaceError {
        types::IfaceError::Unavailable
    }

    pub fn run() -> Result<()> {
        // Enable the component model; this example focuses on wiring the host imports.
        let mut config = Config::new();
        config.wasm_component_model(true);
        let engine = Engine::new(&config)?;

        let mut linker: Linker<DemoHost> = Linker::new(&engine);
        add_host_imports(&mut linker)?;

        // Component loading and instantiation would follow here.
        Ok(())
    }
}

#[cfg(feature = "component-host")]
fn main() -> anyhow::Result<()> {
    demo::run()
}

#[cfg(not(feature = "component-host"))]
fn main() {
    eprintln!("Enable `component-host` feature to run this example.");
}