fix: tedge connect creating mapper directory owned by root

preventing tedge flows to start.

Signed-off-by: Didier Wenzek <didier.wenzek@free.fr>

Author: didier-wenzek

crates/core/tedge_mapper/src/c8y/mapper.rs

@@ -42,6 +42,7 @@ use tedge_timer_ext::TimerActor;
 use tedge_uploader_ext::UploaderActor;
 use tedge_utils::file::change_mode;
 use tedge_utils::file::change_user_and_group;
+use tedge_utils::file::create_directory_with_user_group;
 use tedge_watch_ext::WatchActorBuilder;
 use tracing::warn;
 use yansi::Paint;
@@ -336,9 +337,15 @@ pub async fn bridge_rules(
     tedge_config: &TEdgeConfig,
     cloud_profile: Option<&ProfileName>,
 ) -> anyhow::Result<BridgeConfig> {
-    let bridge_config_dir = tedge_config
-        .mapper_config_dir::<C8yMapperSpecificConfig>(cloud_profile)
-        .join("bridge");
+    let mapper_config_dir =
+        tedge_config.mapper_config_dir::<C8yMapperSpecificConfig>(cloud_profile);
+    if let Err(err) =
+        create_directory_with_user_group(mapper_config_dir.clone(), "tedge", "tedge", 0o755).await
+    {
+        warn!("failed to set file ownership for '{mapper_config_dir}': {err}");
+    }
+
+    let bridge_config_dir = mapper_config_dir.join("bridge");
 
     // Persist the built-in bridge configuration templates
     persist_bridge_config_file(

crates/extensions/c8y_mapper_ext/src/flows.rs

@@ -5,13 +5,20 @@ use tedge_flows::FlowRegistryExt;
 use tedge_flows::UpdateFlowRegistryError;
 use tedge_mqtt_ext::TopicFilter;
 use tedge_utils::file::create_directory_with_defaults;
+use tracing::error;
 
 impl C8yMapperBuilder {
     pub async fn flow_registry(
         &self,
         flows_dir: impl AsRef<Utf8Path>,
     ) -> Result<ConnectedFlowRegistry, UpdateFlowRegistryError> {
-        create_directory_with_defaults(flows_dir.as_ref()).await?;
+        if let Err(err) = create_directory_with_defaults(flows_dir.as_ref()).await {
+            error!(
+                "failed to create flow directory '{}': {err}",
+                flows_dir.as_ref()
+            );
+            return Err(err)?;
+        };
         let mut flows = ConnectedFlowRegistry::new(flows_dir);
 
         let mapper_topic_id = self.config.service_topic_id.clone();