diff --git a/server/src/services/analytic_service/analytic_service.rs b/server/src/services/analytic_service/analytic_service.rs index 94fc5e6..94824da 100644 --- a/server/src/services/analytic_service/analytic_service.rs +++ b/server/src/services/analytic_service/analytic_service.rs @@ -137,7 +137,7 @@ impl AnalyticService { }; let tx = self.tx.clone(); let au = self.analytic_unit.as_ref().unwrap().clone(); - let dr = DetectionRunner::new(self.metric_service.clone(), tx, drcfg, au); + let dr = DetectionRunner::new(tx,self.metric_service.clone(), drcfg, au); self.detection_runner = Some(dr); self.detection_runner.as_mut().unwrap().run(from); diff --git a/server/src/services/analytic_service/detection_runner.rs b/server/src/services/analytic_service/detection_runner.rs index f5362dc..50eb7b3 100644 --- a/server/src/services/analytic_service/detection_runner.rs +++ b/server/src/services/analytic_service/detection_runner.rs @@ -9,8 +9,8 @@ use tokio::time::{sleep, Duration}; pub struct DetectionRunner { - metric_service: MetricService, tx: mpsc::Sender, + metric_service: MetricService, config: DetectionRunnerConfig, analytic_unit: AnalyticUnitRF, running_handler: Option>, @@ -18,8 +18,8 @@ pub struct DetectionRunner { impl DetectionRunner { pub fn new( - metric_service: MetricService, tx: mpsc::Sender, + metric_service: MetricService, config: DetectionRunnerConfig, analytic_unit: AnalyticUnitRF, ) -> DetectionRunner {