diff options
Diffstat (limited to 'crates/core/tedge_mapper/src/c8y/mapper.rs')
| -rw-r--r-- | crates/core/tedge_mapper/src/c8y/mapper.rs | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/crates/core/tedge_mapper/src/c8y/mapper.rs b/crates/core/tedge_mapper/src/c8y/mapper.rs index 315449fe..a5df4d0b 100644 --- a/crates/core/tedge_mapper/src/c8y/mapper.rs +++ b/crates/core/tedge_mapper/src/c8y/mapper.rs @@ -5,7 +5,7 @@ use crate::{ use agent_interface::topic::ResponseTopic; use async_trait::async_trait; -use c8y_api::http_proxy::JwtAuthHttpProxy; +use c8y_api::http_proxy::{C8YHttpProxy, JwtAuthHttpProxy}; use c8y_smartrest::operations::Operations; use mqtt_channel::{Config, TopicFilter}; use tedge_config::{ @@ -16,6 +16,7 @@ use tracing::{info, info_span, Instrument}; use super::topic::C8yTopic; const CUMULOCITY_MAPPER_NAME: &str = "tedge-mapper-c8y"; +const MQTT_MESSAGE_SIZE_THRESHOLD: usize = 16 * 1024; pub struct CumulocityMapper {} @@ -65,10 +66,11 @@ impl CumulocityMapper { #[async_trait] impl TEdgeComponent for CumulocityMapper { async fn start(&self, tedge_config: TEdgeConfig) -> Result<(), anyhow::Error> { - let size_threshold = SizeThreshold(16 * 1024); + let size_threshold = SizeThreshold(MQTT_MESSAGE_SIZE_THRESHOLD); let operations = Operations::try_new("/etc/tedge/operations", "c8y")?; - let http_proxy = JwtAuthHttpProxy::try_new(&tedge_config).await?; + let mut http_proxy = JwtAuthHttpProxy::try_new(&tedge_config).await?; + http_proxy.init().await?; let device_name = tedge_config.query(DeviceIdSetting)?; let device_type = tedge_config.query(DeviceTypeSetting)?; let mqtt_port = tedge_config.query(MqttPortSetting)?.into(); |