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

use async_trait::async_trait;
use std::sync::Arc;

use crate::{
    cards::{Card, CardRenderer},
    http::{HttpClient, RawRequest, RawResponse},
    ingress::VerifiedEvent,
    telemetry::TelemetryHandle,
};
use greentic_secrets::spec::SecretsBackend;
use greentic_types::TenantCtx;

#[derive(Clone)]
pub struct PlatformInit {
    pub secrets: Arc<dyn SecretsBackend + Send + Sync>,
    pub telemetry: TelemetryHandle,
    pub http: Arc<dyn HttpClient + Send + Sync>,
    pub card_renderer: Arc<dyn CardRenderer>,
}

#[async_trait]
pub trait PlatformProvider: Send + Sync {
    fn platform_id(&self) -> &'static str;

    async fn health(&self) -> anyhow::Result<()>;

    async fn send_card(&self, ctx: &TenantCtx, to: &str, card: &Card) -> anyhow::Result<()>;

    async fn send_text(&self, ctx: &TenantCtx, to: &str, text: &str) -> anyhow::Result<()> {
        let card = Card::from_text(text);
        self.send_card(ctx, to, &card).await
    }

    async fn verify_webhook(&self, raw: &RawRequest) -> anyhow::Result<VerifiedEvent>;

    async fn raw_call(
        &self,
        _ctx: &TenantCtx,
        _method: &str,
        _path: &str,
        _body: Option<&[u8]>,
    ) -> anyhow::Result<RawResponse> {
        anyhow::bail!("raw_call not supported for {}", self.platform_id())
    }
}