summaryrefslogtreecommitdiffstats
path: root/crates/core/tedge_mapper/src/sm_c8y_mapper/mapper.rs
diff options
context:
space:
mode:
authorinitard <solo@softwareag.com>2022-02-14 13:41:32 +0000
committerinitard <solo@softwareag.com>2022-02-15 11:57:40 +0000
commitb9d05bea8213809e2683d2d83a0d4629391430a8 (patch)
tree202052ea7ba84f1c2efd464807825fd9109899e3 /crates/core/tedge_mapper/src/sm_c8y_mapper/mapper.rs
parentff40d4e958fefb289cb76e8f1cc168cb61fb0f81 (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.rs5
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?;