From 85fe63d426fdf68b2aeec0c8ee13151698358a04 Mon Sep 17 00:00:00 2001
From: Alexey Velikiy <cg@corpglory.com>
Date: Sat, 20 Nov 2021 17:45:29 +0300
Subject: [PATCH] TODOs++

---
 .../src/services/analytic_service/analytic_service.rs  | 10 +---------
 1 file changed, 1 insertion(+), 9 deletions(-)

diff --git a/server/src/services/analytic_service/analytic_service.rs b/server/src/services/analytic_service/analytic_service.rs
index 51c6801..fb86d5d 100644
--- a/server/src/services/analytic_service/analytic_service.rs
+++ b/server/src/services/analytic_service/analytic_service.rs
@@ -120,6 +120,7 @@ impl AnalyticService {
     fn consume_request(&mut self, req: types::RequestType) -> () {
         match req {
             RequestType::RunLearning => {
+                // TODO: if detection_runner then add it to learning_waiters
                 if self.learning_handler.is_some() {
                     self.learning_handler.as_ref().unwrap().abort();
                     self.learning_handler = None;
@@ -208,14 +209,6 @@ impl AnalyticService {
                     let task = self.learning_waiters.pop().unwrap();
                     self.run_learning_waiter(task);
                 }
-
-                // TODO: fix this
-                // if self.endpoint.is_some() {
-                //     self.run_detection_runner(DetectionRunnerConfig {
-                //         endpoint: self.endpoint.as_ref().unwrap().clone(),
-                //         from: Utc::now().timestamp() as u64,
-                //     });
-                // }
             }
             ResponseType::LearningFinishedEmpty => {
                 // TODO: drop all learning_waiters with empty results
@@ -275,7 +268,6 @@ impl AnalyticService {
         if self.alerting.is_some() {
             self.run_detection_runner();
         }
-        
 
         while let Some(message) = self.rx.recv().await {
             match message {