fixup! Fix hard-coded MQTT topics for flows status and statistics

didier-wenzek · didier-wenzek · commit f0f75b7b6483 · 2026-01-16T10:31:47.000+01:00
diff --git a/crates/extensions/tedge_flows/src/lib.rs b/crates/extensions/tedge_flows/src/lib.rs
@@ -68,7 +68,7 @@ impl FlowsMapperConfig {
     /// Panics if the topic prefix is not a valid MQTT topic name
     pub fn new(topic_prefix: &str) -> Self {
         FlowsMapperConfig {
-            statistics_topic: Topic::new(&format!("{topic_prefix}/statistics")).unwrap(),
+            statistics_topic: Topic::new(&format!("{topic_prefix}/status/metrics")).unwrap(),
             status_topic: Topic::new(&format!("{topic_prefix}/status/flows")).unwrap(),
         }
     }
diff --git a/crates/extensions/tedge_flows/tests/interval.rs b/crates/extensions/tedge_flows/tests/interval.rs
@@ -372,7 +372,6 @@ async fn interval_executes_when_time_exceeds_interval() {
     let count = || {
         captured_messages
             .retain(|msg| !msg.topic.as_ref().contains("status"))
-            .retain(|msg| !msg.topic.as_ref().contains("statistics"))
             .count()
     };
 

Original file line number	Diff line number	Diff line change
`@@ -68,7 +68,7 @@ impl FlowsMapperConfig {`
`68`	`68`	`/// Panics if the topic prefix is not a valid MQTT topic name`
`69`	`69`	`pub fn new(topic_prefix: &str) -> Self {`
`70`	`70`	`FlowsMapperConfig {`
`71`		`- statistics_topic: Topic::new(&format!("{topic_prefix}/statistics")).unwrap(),`
	`71`	`+ statistics_topic: Topic::new(&format!("{topic_prefix}/status/metrics")).unwrap(),`
`72`	`72`	`status_topic: Topic::new(&format!("{topic_prefix}/status/flows")).unwrap(),`
`73`	`73`	`}`
`74`	`74`	`}`