diff options
author | initard <solo@softwareag.com> | 2022-02-14 13:41:32 +0000 |
---|---|---|
committer | initard <solo@softwareag.com> | 2022-02-15 11:57:40 +0000 |
commit | b9d05bea8213809e2683d2d83a0d4629391430a8 (patch) | |
tree | 202052ea7ba84f1c2efd464807825fd9109899e3 /crates/core/tedge_mapper/src/sm_c8y_mapper/mapper.rs | |
parent | ff40d4e958fefb289cb76e8f1cc168cb61fb0f81 (diff) |
fixed session name bug
- renamed jwt token session
- renamed file C8y_LogfileRequest to c8y_LogfileRequest
- added cargo deb asset to create binary in /usr/bin/tedge_logfile_request_plugin
- closing mqtt client connection in plugin
Signed-off-by: initard <solo@softwareag.com>
Diffstat (limited to 'crates/core/tedge_mapper/src/sm_c8y_mapper/mapper.rs')
-rw-r--r-- | crates/core/tedge_mapper/src/sm_c8y_mapper/mapper.rs | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/crates/core/tedge_mapper/src/sm_c8y_mapper/mapper.rs b/crates/core/tedge_mapper/src/sm_c8y_mapper/mapper.rs index 0ade06a2..af41fc21 100644 --- a/crates/core/tedge_mapper/src/sm_c8y_mapper/mapper.rs +++ b/crates/core/tedge_mapper/src/sm_c8y_mapper/mapper.rs @@ -29,6 +29,8 @@ use tedge_config::{ConfigSettingAccessor, MqttPortSetting, TEdgeConfig}; use tracing::{debug, error, info, instrument}; const SM_MAPPER: &str = "SM-C8Y-Mapper"; +const SM_MAPPER_JWT_TOKEN_SESSION_NAME: &str = "SM-C8Y-Mapper-JWT-Token"; + pub struct CumulocitySoftwareManagementMapper {} impl CumulocitySoftwareManagementMapper { @@ -79,7 +81,8 @@ impl TEdgeComponent for CumulocitySoftwareManagementMapper { #[instrument(skip(self, tedge_config), name = "sm-c8y-mapper")] async fn start(&self, tedge_config: TEdgeConfig) -> Result<(), anyhow::Error> { let operations = Operations::try_new("/etc/tedge/operations", "c8y")?; - let http_proxy = JwtAuthHttpProxy::try_new(&tedge_config, SM_MAPPER).await?; + let http_proxy = + JwtAuthHttpProxy::try_new(&tedge_config, SM_MAPPER_JWT_TOKEN_SESSION_NAME).await?; let mut sm_mapper = CumulocitySoftwareManagement::try_new(&tedge_config, http_proxy, operations).await?; |