From 1f0f7fcff49df5959ac9db8567649af80fb14cb0 Mon Sep 17 00:00:00 2001
From: Alexey Velikiy <cg@corpglory.com>
Date: Thu, 11 Nov 2021 02:22:58 +0300
Subject: [PATCH] anomaly segments

---
 client/src/components/Graph.vue               |  2 +-
 client/src/services/analytics.service.ts      |  1 -
 .../analytic_unit/anomaly_analytic_unit.rs    | 83 +++++++++++++------
 3 files changed, 57 insertions(+), 29 deletions(-)

diff --git a/client/src/components/Graph.vue b/client/src/components/Graph.vue
index 56c23e6..e2999a0 100644
--- a/client/src/components/Graph.vue
+++ b/client/src/components/Graph.vue
@@ -108,7 +108,7 @@ async function resolveDataAnomaly(range: TimeRange): Promise<{
           datapoints: hsr.map(([t, v, [l, u]]) => [t, v]),
           color: 'red'
         },
-        { 
+        {
           target: "HSR_Upper_bound",
           datapoints: hsr.map(([t, v, [u, l]]) => [t, u]),
           color: 'red'
diff --git a/client/src/services/analytics.service.ts b/client/src/services/analytics.service.ts
index c671140..a3b5844 100644
--- a/client/src/services/analytics.service.ts
+++ b/client/src/services/analytics.service.ts
@@ -66,7 +66,6 @@ export async function getHSRAnomaly(from: number, to: number): Promise<[number,
   const res = await axios.get(uri);
 
   const values = res["data"]["ConfidenceTimeSerie"];
-  console.log(values);
   
   return values as [number, number, [number, number]][];
 }
diff --git a/server/src/services/analytic_service/analytic_unit/anomaly_analytic_unit.rs b/server/src/services/analytic_service/analytic_unit/anomaly_analytic_unit.rs
index cde8421..93ae17a 100644
--- a/server/src/services/analytic_service/analytic_unit/anomaly_analytic_unit.rs
+++ b/server/src/services/analytic_service/analytic_unit/anomaly_analytic_unit.rs
@@ -3,6 +3,7 @@ use crate::services::{analytic_service::types::{self, HSR}, metric_service::Metr
 use super::types::{AnalyticUnit, AnalyticUnitConfig, AnomalyConfig, LearningResult};
 
 use async_trait::async_trait;
+use subbeat::metric::MetricResult;
 
 // TODO: move to config
 const DETECTION_STEP: u64 = 10;
@@ -15,6 +16,30 @@ impl AnomalyAnalyticUnit {
     pub fn new(config: AnomalyConfig) -> AnomalyAnalyticUnit {
         AnomalyAnalyticUnit { config }
     }
+
+    fn get_hsr_from_metric_result(&self, mr: &MetricResult) -> anyhow::Result<HSR> {
+        if mr.data.keys().len() == 0 {
+            return Ok(HSR::ConfidenceTimeSerie(Vec::new()));
+        }
+
+        let k = mr.data.keys().nth(0).unwrap();
+        let ts = mr.data[k].clone();
+
+        if ts.len() == 0 {
+            return Ok(HSR::ConfidenceTimeSerie(Vec::new()));
+        }
+
+        let mut sts = Vec::new();
+        sts.push((ts[0].0, ts[0].1, ((ts[0].1 + self.config.confidence, ts[0].1 - self.config.confidence))));
+
+        for t in 1..ts.len() {
+            let alpha = self.config.alpha;
+            let stv = alpha * ts[t].1 + (1.0 - alpha) * sts[t - 1].1;
+            sts.push((ts[t].0, stv, (stv + self.config.confidence, stv - self.config.confidence)));
+        }
+
+        Ok(HSR::ConfidenceTimeSerie(sts))
+    }
 }
 
 #[async_trait]
@@ -42,18 +67,43 @@ impl AnalyticUnit for AnomalyAnalyticUnit {
         }
 
         let k = mr.data.keys().nth(0).unwrap();
-        let ts = &mr.data[k];
+        let ts = mr.data[k].clone();
 
         if ts.len() == 0 {
             return Ok(Vec::new());
         }
 
-        let ct = ts[0];
+        let mut result = Vec::new();
+
+        if let HSR::ConfidenceTimeSerie(hsr) = self.get_hsr_from_metric_result(&mr)? {
+
+            let mut from = None;
+
+            for ((t, _, (u, l)), (t1, rv)) in hsr.iter().zip(ts) {
+                if *t != t1 {
+                    return Err(anyhow::format_err!("incompatible hsr/ts"))
+                }
+                if rv > *u || rv < *l {
+                    if from.is_none() {
+                        from = Some(*t);
+                    }
+                } else {
+                    if from.is_some() {
+                        result.push((from.unwrap(), *t));
+                        from = None;
+                    }
+                }
+            }
 
-        // TODO: implement
-        // TODO: decide what to do it from is Some() in the end
+            return Ok(result);
 
-        Ok(Default::default())
+        } else {
+            return Err(anyhow::format_err!("bad hsr"));
+        }
+
+        
+
+        
     }
 
     // TODO: use hsr for learning and detections
@@ -64,27 +114,6 @@ impl AnalyticUnit for AnomalyAnalyticUnit {
         to: u64,
     ) -> anyhow::Result<HSR> {
         let mr = ms.query(from, to, DETECTION_STEP).await.unwrap();
-
-        if mr.data.keys().len() == 0 {
-            return Ok(HSR::TimeSerie(Vec::new()));
-        }
-
-        let k = mr.data.keys().nth(0).unwrap();
-        let ts = mr.data[k].clone();
-
-        if ts.len() == 0 {
-            return Ok(HSR::TimeSerie(Vec::new()));
-        }
-
-        let mut sts = Vec::new();
-        sts.push((ts[0].0, ts[0].1, ((ts[0].1 + self.config.confidence, ts[0].1 - self.config.confidence))));
-
-        for t in 1..ts.len() {
-            let alpha = self.config.alpha;
-            let stv = alpha * ts[t].1 + (1.0 - alpha) * sts[t - 1].1;
-            sts.push((ts[t].0, stv, (stv + self.config.confidence, stv - self.config.confidence)));
-        }
-
-        Ok(HSR::ConfidenceTimeSerie(sts))
+        return self.get_hsr_from_metric_result(&mr);
     }
 }