siera_cloudagent_python/cloudagent/
basic_message.rs

1use crate::agent::CloudAgentPython;
2use async_trait::async_trait;
3use serde_json::{json, Value};
4use siera_agent::error::Result;
5use siera_agent::modules::basic_message::{BasicMessageModule, SendBasicMessageOptions};
6
7#[async_trait]
8impl BasicMessageModule for CloudAgentPython {
9    async fn send_message(&self, options: SendBasicMessageOptions) -> Result<()> {
10        let url = self.create_url(&["connections", &options.connection_id, "send-message"])?;
11
12        let body = json!({
13          "content": options.message,
14        });
15
16        self.post::<Value>(url, None, Some(body)).await?;
17
18        Ok(())
19    }
20}