Change anomaly id to predictor id everywhere (#65)

* Change anomaly id to predictor id everywhere

* some fiex

README.md

@@ -95,6 +95,9 @@ docker run -d --name hastic-server -p 80:8000 -e HASTIC_API_KEY=<your_grafana_ap
 
 ### Changelog
 
+### [0.2.0-alpha] - Not released yet
+`Please note: hastic-panels of older versions are not supported`
+
 ### [0.1.4-alpha] - 2018-06-29
 #### Changed
 - Informative error messages instead of "Internal error" [#40](https://github.com/hastic/hastic-server/issues/33)

REST.md

@@ -3,7 +3,7 @@
 ## /anomalies
 
 ### Get anomalies
-`GET /anomalies?id=<anomaly_id>[&name=<anomaly_name>]`
+`GET /anomalies?id=<predictor_id>[&name=<anomaly_name>]`
 
 NOTE: `name` param is deprecated, use `id` instead
 
@@ -24,7 +24,7 @@ status field can be one of:
 - `failed`
 
 ### Get anomaly status
-`GET /anomalies/status?id=<anomaly_id>[&name=<anomaly_name>]`
+`GET /anomalies/status?id=<predictor_id>[&name=<anomaly_name>]`
 
 NOTE: `name` param is deprecated, use `id` instead
 
@@ -102,7 +102,7 @@ Return data format:
 
 ```
 {
-  "anomaly_id": "<anomaly_id>"
+  "predictor_id": "<predictor_id>"
 }
 ```
 
@@ -113,7 +113,7 @@ Data format:
 
 ```
 {
-  "id": "<anomaly_id>",
+  "id": "<predictor_id>",
   "name": "<anomaly_name>" // deprecated, use id instead
 }
 ```
@@ -127,7 +127,7 @@ Success
 ## /segments
 
 ### Get segments
-`GET /segments?anomaly_id=<anomaly_id>[&last_segment=<id>][&from=<time_from>][&to=<time_to>]`
+`GET /segments?predictor_id=<predictor_id>[&last_segment=<id>][&from=<time_from>][&to=<time_to>]`
 
 Return data format:
 
@@ -153,7 +153,7 @@ Data format:
 
 ```
 {
-  "anomaly_id": "<anomaly_id>",
+  "predictor_id": "<predictor_id>",
   "name": "<anomaly_name>", // deprecated, use id instead
   "added_segments": [
     {
@@ -178,7 +178,7 @@ Return data format:
 
 ### Check if alert is enabled for anomaly
 
-`GET /alerts?anomaly_id=<anomaly_id>`
+`GET /alerts?predictor_id=<predictor_id>`
 
 Return data format:
 
@@ -196,7 +196,7 @@ Data format:
 
 ```
 {
-  "anomaly_id": "<anomaly_id>",
+  "predictor_id": "<predictor_id>",
   "enable": true
 }
 ```

analytics/pattern_detection_model.py

@@ -24,8 +24,8 @@ def segments_box(segments):
 
 class PatternDetectionModel:
 
-    def __init__(self, anomaly_id, pattern):
-        self.anomaly_id = anomaly_id
+    def __init__(self, predictor_id, pattern):
+        self.predictor_id = predictor_id
         self.pattern = pattern
 
         self.__load_anomaly_config()
@@ -101,16 +101,16 @@ class PatternDetectionModel:
             return StepDetector(pattern)
 
     def __load_anomaly_config(self):
-        with open(os.path.join(config.ANOMALIES_FOLDER, self.anomaly_id + ".json"), 'r') as config_file:
+        with open(os.path.join(config.ANOMALIES_FOLDER, self.predictor_id + ".json"), 'r') as config_file:
             self.anomaly_config = json.load(config_file)
 
     def __save_model(self):
-        logger.info("Save model '%s'" % self.anomaly_id)
-        model_filename = os.path.join(config.MODELS_FOLDER, self.anomaly_id + ".m")
+        logger.info("Save model '%s'" % self.predictor_id)
+        model_filename = os.path.join(config.MODELS_FOLDER, self.predictor_id + ".m")
         self.model.save(model_filename)
 
     def __load_model(self, pattern):
-        logger.info("Load model '%s'" % self.anomaly_id)
+        logger.info("Load model '%s'" % self.predictor_id)
         model_filename = os.path.join(config.MODELS_FOLDER, self.pattern + ".m")
         if os.path.exists(model_filename):
             self.model = self.__create_model(pattern)

analytics/server.py

@@ -28,7 +28,7 @@ def handleTask(text):
 
         socket.send_string(json.dumps({
             'task': task['type'],
-            'anomaly_id': task['anomaly_id'],
+            'predictor_id': task['predictor_id'],
             '__task_id': task['__task_id'],
             'status': "in progress"
         }))

analytics/worker.py

@@ -41,15 +41,15 @@ class Worker(object):
     def do_task(self, task):
         try:
             type = task['type']
-            anomaly_id = task['anomaly_id']
+            predictor_id = task['predictor_id']
             if type == "predict":
                 last_prediction_time = task['last_prediction_time']
                 pattern = task['pattern']
-                result = self.do_predict(anomaly_id, last_prediction_time, pattern)
+                result = self.do_predict(predictor_id, last_prediction_time, pattern)
             elif type == "learn":
                 segments = task['segments']
                 pattern = task['pattern']
-                result = self.do_learn(anomaly_id, segments, pattern)
+                result = self.do_learn(predictor_id, segments, pattern)
             else:
                 result = {
                     'status': "failed",
@@ -62,48 +62,48 @@ class Worker(object):
             result = {
                 'task': type,
                 'status': "failed",
-                'anomaly_id': anomaly_id,
+                'predictor_id': predictor_id,
                 'error': str(e)
             }
         return result
 
-    def do_learn(self, anomaly_id, segments, pattern):
-        model = self.get_model(anomaly_id, pattern)
+    def do_learn(self, predictor_id, segments, pattern):
+        model = self.get_model(predictor_id, pattern)
         model.synchronize_data()
         last_prediction_time = model.learn(segments)
         # TODO: we should not do predict before labeling in all models, not just in drops
         if pattern == 'drops' and len(segments) == 0:
             result = {
                 'status': 'success',
-                'anomaly_id': anomaly_id,
+                'predictor_id': predictor_id,
                 'segments': [],
                 'last_prediction_time': last_prediction_time
             }
         else:
-            result = self.do_predict(anomaly_id, last_prediction_time, pattern)
+            result = self.do_predict(predictor_id, last_prediction_time, pattern)
             
         result['task'] = 'learn'
         return result
 
-    def do_predict(self, anomaly_id, last_prediction_time, pattern):
-        model = self.get_model(anomaly_id, pattern)
+    def do_predict(self, predictor_id, last_prediction_time, pattern):
+        model = self.get_model(predictor_id, pattern)
         model.synchronize_data()
         segments, last_prediction_time = model.predict(last_prediction_time)
         return {
             'task': "predict",
             'status': "success",
-            'anomaly_id': anomaly_id,
+            'predictor_id': predictor_id,
             'segments': segments,
             'last_prediction_time': last_prediction_time
         }
 
-    def get_model(self, anomaly_id, pattern):
-        if anomaly_id not in self.models_cache:
+    def get_model(self, predictor_id, pattern):
+        if predictor_id not in self.models_cache:
             if pattern.find('general') != -1:
-                model = AnomalyModel(anomaly_id)
+                model = AnomalyModel(predictor_id)
             else:
-                model = PatternDetectionModel(anomaly_id, pattern)
-            self.models_cache[anomaly_id] = model
-        return self.models_cache[anomaly_id]
+                model = PatternDetectionModel(predictor_id, pattern)
+            self.models_cache[predictor_id] = model
+        return self.models_cache[predictor_id]
 
 

server/src/routes/alerts.ts

@@ -1,4 +1,4 @@
-import { AnomalyId, getAnomalyIdByName, loadAnomalyById } from '../services/anomalyType';
+import { PredictorId, getPredictorIdByName, loadAnomalyById } from '../services/anomalyType';
 import { getAlertsAnomalies, saveAlertsAnomalies } from '../services/alerts';
 
 import * as Router from 'koa-router';
@@ -6,14 +6,14 @@ import * as Router from 'koa-router';
 
 function getAlert(ctx: Router.IRouterContext) {
   
-  let anomalyId: AnomalyId = ctx.request.query.anomaly_id.toLowerCase();
-  let anomaly = loadAnomalyById(anomalyId)
+  let predictorId: PredictorId = ctx.request.query.predictor_id.toLowerCase();
+  let anomaly = loadAnomalyById(predictorId)
   if(anomaly == null) {
-    anomalyId = getAnomalyIdByName(anomalyId);
+    predictorId = getPredictorIdByName(predictorId);
   }
 
   let alertsAnomalies = getAlertsAnomalies();
-  let pos = alertsAnomalies.indexOf(anomalyId);
+  let pos = alertsAnomalies.indexOf(predictorId);
 
   let enable: boolean = (pos !== -1);
   ctx.response.body = { enable };
@@ -22,18 +22,18 @@ function getAlert(ctx: Router.IRouterContext) {
 
 function changeAlert(ctx: Router.IRouterContext) {
 
-  let anomalyId: AnomalyId = ctx.request.body.anomaly_id.toLowerCase();
+  let predictorId: PredictorId = ctx.request.body.predictor_id.toLowerCase();
   let enable: boolean = ctx.request.body.enable;
 
-  let anomaly = loadAnomalyById(anomalyId)
+  let anomaly = loadAnomalyById(predictorId)
   if(anomaly == null) {
-    anomalyId = getAnomalyIdByName(anomalyId);
+    predictorId = getPredictorIdByName(predictorId);
   }
 
   let alertsAnomalies = getAlertsAnomalies();
-  let pos: number = alertsAnomalies.indexOf(anomalyId);
+  let pos: number = alertsAnomalies.indexOf(predictorId);
   if(enable && pos == -1) {
-    alertsAnomalies.push(anomalyId);
+    alertsAnomalies.push(predictorId);
     saveAlertsAnomalies(alertsAnomalies);
   } else if(!enable && pos > -1) {
     alertsAnomalies.splice(pos, 1);

server/src/routes/anomalies.ts

@@ -5,7 +5,7 @@ import {
   Metric,
   Anomaly,
   saveAnomaly,
-  insertAnomaly, removeAnomaly, loadAnomalyByName, loadAnomalyById, getAnomalyIdByName
+  insertAnomaly, removeAnomaly, loadAnomalyByName, loadAnomalyById, getPredictorIdByName
 } from '../services/anomalyType';
 import { runLearning } from '../services/analytics'
 import { saveTargets } from '../services/metrics';
@@ -84,8 +84,8 @@ async function createAnomaly(ctx: Router.IRouterContext) {
       last_prediction_time: 0,
       next_id: 0
     };
-    let anomalyId = insertAnomaly(anomaly);
-    if(anomalyId === null) {
+    let predictorId = insertAnomaly(anomaly);
+    if(predictorId === null) {
       ctx.response.status = 403;
       ctx.response.body = {
         code: 403,
@@ -93,9 +93,9 @@ async function createAnomaly(ctx: Router.IRouterContext) {
       };
     }
 
-    ctx.response.body = { anomaly_id: anomalyId };
+    ctx.response.body = { predictor_id: predictorId };
 
-    runLearning(anomalyId);
+    runLearning(predictorId);
   } catch(e) {
     ctx.response.status = 500;
     ctx.response.body = {

server/src/routes/segments.ts

@@ -7,7 +7,7 @@ import {
 } from '../services/segments';
 
 import {
-  Anomaly, AnomalyId, getAnomalyIdByName, loadAnomalyById
+  Anomaly, PredictorId, getPredictorIdByName, loadAnomalyById
 } from '../services/anomalyType';
 
 import { runLearning } from '../services/analytics';
@@ -15,17 +15,17 @@ import { runLearning } from '../services/analytics';
 
 async function sendSegments(ctx: Router.IRouterContext) {
 
-  let anomalyId: AnomalyId = ctx.request.query.anomaly_id.toLowerCase();
-  let anomaly:Anomaly = loadAnomalyById(anomalyId);
+  let predictorId: PredictorId = ctx.request.query.predictor_id.toLowerCase();
+  let anomaly:Anomaly = loadAnomalyById(predictorId);
   if(anomaly === null) {
-    anomalyId = getAnomalyIdByName(anomalyId);
+    predictorId = getPredictorIdByName(predictorId);
   }
 
   let lastSegmentId = ctx.request.query.last_segment;
   let timeFrom = ctx.request.query.from;
   let timeTo = ctx.request.query.to;
 
-  let segments = getLabeledSegments(anomalyId);
+  let segments = getLabeledSegments(predictorId);
 
   // Id filtering
   if(lastSegmentId !== undefined) {
@@ -49,19 +49,19 @@ async function updateSegments(ctx: Router.IRouterContext) {
   try {
     let segmentsUpdate = ctx.request.body;
 
-    let anomalyId = segmentsUpdate.anomaly_id;
+    let predictorId = segmentsUpdate.predictor_id;
     let anomalyName = segmentsUpdate.name.toLowerCase();
 
-    if(anomalyId === undefined) {
-      anomalyId = getAnomalyIdByName(anomalyName);
+    if(predictorId === undefined) {
+      predictorId = getPredictorIdByName(anomalyName);
     }
 
-    let addedIds = insertSegments(anomalyId, segmentsUpdate.added_segments, true);
-    removeSegments(anomalyId, segmentsUpdate.removed_segments);
+    let addedIds = insertSegments(predictorId, segmentsUpdate.added_segments, true);
+    removeSegments(predictorId, segmentsUpdate.removed_segments);
 
     ctx.response.body = { added_ids: addedIds };
 
-    runLearning(anomalyId);
+    runLearning(predictorId);
   } catch(e) {
     ctx.response.status = 500;
     ctx.response.body = {

server/src/services/alerts.ts

@@ -1,5 +1,5 @@
 import { getJsonDataSync, writeJsonDataSync } from './json';
-import { AnomalyId } from './anomalyType';
+import { PredictorId } from './anomalyType';
 import { runPredict } from './analytics';
 import { sendNotification } from './notification';
 import { getLabeledSegments } from './segments';
@@ -13,22 +13,22 @@ import * as fs from 'fs';
 
 const ALERTS_DB_PATH = path.join(ANOMALIES_PATH, `alerts_anomalies.json`);
 
-function getAlertsAnomalies(): AnomalyId[] {
+function getAlertsAnomalies(): PredictorId[] {
   if(!fs.existsSync(ALERTS_DB_PATH)) {
     saveAlertsAnomalies([]);
   }
   return getJsonDataSync(ALERTS_DB_PATH);
 }
 
-function saveAlertsAnomalies(anomalies: AnomalyId[]) {
+function saveAlertsAnomalies(anomalies: PredictorId[]) {
   return writeJsonDataSync(ALERTS_DB_PATH, anomalies);
 }
 
-function processAlerts(anomalyId) {
-  let segments = getLabeledSegments(anomalyId);
+function processAlerts(predictorId) {
+  let segments = getLabeledSegments(predictorId);
 
   const currentTime = new Date().getTime();
-  const activeAlert = activeAlerts.has(anomalyId);
+  const activeAlert = activeAlerts.has(predictorId);
   let newActiveAlert = false;
 
   if(segments.length > 0) {
@@ -39,20 +39,20 @@ function processAlerts(anomalyId) {
   }
 
   if(!activeAlert && newActiveAlert) {
-    activeAlerts.add(anomalyId);
-    sendNotification(anomalyId, true);
+    activeAlerts.add(predictorId);
+    sendNotification(predictorId, true);
   } else if(activeAlert && !newActiveAlert) {
-    activeAlerts.delete(anomalyId);
-    sendNotification(anomalyId, false);
+    activeAlerts.delete(predictorId);
+    sendNotification(predictorId, false);
   }
 }
 
 async function alertsTick() {
   let alertsAnomalies = getAlertsAnomalies();
-  for (let anomalyId of alertsAnomalies) {
+  for (let predictorId of alertsAnomalies) {
     try {
-      await runPredict(anomalyId);
-      processAlerts(anomalyId);
+      await runPredict(predictorId);
+      processAlerts(predictorId);
     } catch (e) {
       console.error(e);
     }

server/src/services/analytics.ts

@@ -1,6 +1,6 @@
 import {
   Anomaly,
-  AnomalyId, getAnomalyTypeInfo,
+  PredictorId, getAnomalyTypeInfo,
   loadAnomalyById,
   setAnomalyPredictionTime,
   setAnomalyStatus
@@ -28,7 +28,7 @@ function onResponse(response: any) {
 }
 
 async function runTask(task): Promise<any> {
-  let anomaly: Anomaly = loadAnomalyById(task.anomaly_id);
+  let anomaly: Anomaly = loadAnomalyById(task.predictor_id);
   task.metric = {
     datasource: anomaly.metric.datasource,
     targets: anomaly.metric.targets.map(t => getTarget(t))
@@ -42,14 +42,14 @@ async function runTask(task): Promise<any> {
   })
 }
 
-export async function runLearning(anomalyId:AnomalyId) {
-  let segments = getLabeledSegments(anomalyId);
-  setAnomalyStatus(anomalyId, 'learning');
-  let anomaly:Anomaly  = loadAnomalyById(anomalyId);
+export async function runLearning(predictorId:PredictorId) {
+  let segments = getLabeledSegments(predictorId);
+  setAnomalyStatus(predictorId, 'learning');
+  let anomaly:Anomaly  = loadAnomalyById(predictorId);
   let pattern = anomaly.pattern;
   let task = {
     type: 'learn',
-    anomaly_id: anomalyId,
+    predictor_id: predictorId,
     pattern,
     segments: segments
   };
@@ -57,20 +57,20 @@ export async function runLearning(anomalyId:AnomalyId) {
   let result = await runTask(task);
 
   if (result.status === 'success') {
-    setAnomalyStatus(anomalyId, 'ready');
-    insertSegments(anomalyId, result.segments, false);
-    setAnomalyPredictionTime(anomalyId, result.last_prediction_time);
+    setAnomalyStatus(predictorId, 'ready');
+    insertSegments(predictorId, result.segments, false);
+    setAnomalyPredictionTime(predictorId, result.last_prediction_time);
   } else {
-    setAnomalyStatus(anomalyId, 'failed', result.error);
+    setAnomalyStatus(predictorId, 'failed', result.error);
   }
 }
 
-export async function runPredict(anomalyId:AnomalyId) {
-  let anomaly:Anomaly = loadAnomalyById(anomalyId);
+export async function runPredict(predictorId:PredictorId) {
+  let anomaly:Anomaly = loadAnomalyById(predictorId);
   let pattern = anomaly.pattern;
   let task = {
     type: 'predict',
-    anomaly_id: anomalyId,
+    predictor_id: predictorId,
     pattern,
     last_prediction_time: anomaly.last_prediction_time
   };
@@ -80,18 +80,18 @@ export async function runPredict(anomalyId:AnomalyId) {
     return [];
   }
   // Merging segments
-  let segments = getLabeledSegments(anomalyId);
+  let segments = getLabeledSegments(predictorId);
   if(segments.length > 0 && result.segments.length > 0) {
     let lastOldSegment = segments[segments.length - 1];
     let firstNewSegment = result.segments[0];
 
     if(firstNewSegment.start <= lastOldSegment.finish) {
       result.segments[0].start = lastOldSegment.start;
-      removeSegments(anomalyId, [lastOldSegment.id]);
+      removeSegments(predictorId, [lastOldSegment.id]);
     }
   }
 
-  insertSegments(anomalyId, result.segments, false);
-  setAnomalyPredictionTime(anomalyId, result.last_prediction_time);
+  insertSegments(predictorId, result.segments, false);
+  setAnomalyPredictionTime(predictorId, result.last_prediction_time);
   return result.segments;
 }

server/src/services/anomalyType.ts

@@ -32,7 +32,7 @@ export type Anomaly = {
   next_id: number
 }
 
-export type AnomalyId = string;
+export type PredictorId = string;
 
 let anomaliesNameToIdMap = {};
 
@@ -49,7 +49,7 @@ function saveAnomaliesMap() {
   writeJsonDataSync(filename, anomaliesNameToIdMap);
 }
 
-function getAnomalyIdByName(anomalyName:string) : AnomalyId {
+function getPredictorIdByName(anomalyName:string): PredictorId {
   loadAnomaliesMap();
   anomalyName = anomalyName.toLowerCase();
   if(anomalyName in anomaliesNameToIdMap) {
@@ -58,42 +58,40 @@ function getAnomalyIdByName(anomalyName:string) : AnomalyId {
   return anomalyName;
 }
 
-function insertAnomaly(anomaly: Anomaly) : AnomalyId {
+function insertAnomaly(anomaly: Anomaly): PredictorId {
   const hashString = anomaly.name + (new Date()).toString();
-  const anomalyId:AnomalyId = crypto.createHash('md5').update(hashString).digest('hex');
-  anomaliesNameToIdMap[anomaly.name] = anomalyId;
+  const predictorId:PredictorId = crypto.createHash('md5').update(hashString).digest('hex');
+  anomaliesNameToIdMap[anomaly.name] = predictorId;
   saveAnomaliesMap();
-  // return anomalyId
-  // const anomalyId:AnomalyId = anomaly.name;
-  let filename = path.join(ANOMALIES_PATH, `${anomalyId}.json`);
+  let filename = path.join(ANOMALIES_PATH, `${predictorId}.json`);
   if(fs.existsSync(filename)) {
     return null;
   }
-  saveAnomaly(anomalyId, anomaly);
-  return anomalyId;
+  saveAnomaly(predictorId, anomaly);
+  return predictorId;
 }
 
-function removeAnomaly(anomalyId:AnomalyId) {
-  let filename = path.join(ANOMALIES_PATH, `${anomalyId}.json`);
+function removeAnomaly(predictorId: PredictorId) {
+  let filename = path.join(ANOMALIES_PATH, `${predictorId}.json`);
   fs.unlinkSync(filename);
 }
 
-function saveAnomaly(anomalyId: AnomalyId, anomaly: Anomaly) {
-  let filename = path.join(ANOMALIES_PATH, `${anomalyId}.json`);
+function saveAnomaly(predictorId: PredictorId, anomaly: Anomaly) {
+  let filename = path.join(ANOMALIES_PATH, `${predictorId}.json`);
   return writeJsonDataSync(filename, anomaly);
 }
 
-function loadAnomalyById(anomalyId: AnomalyId) : Anomaly {
-  let filename = path.join(ANOMALIES_PATH, `${anomalyId}.json`);
+function loadAnomalyById(predictorId: PredictorId): Anomaly {
+  let filename = path.join(ANOMALIES_PATH, `${predictorId}.json`);
   if(!fs.existsSync(filename)) {
     return null;
   }
   return getJsonDataSync(filename);
 }
 
-function loadAnomalyByName(anomalyName: string) : Anomaly {
-  let anomalyId = getAnomalyIdByName(anomalyName);
-  return loadAnomalyById(anomalyId);
+function loadAnomalyByName(anomalyName: string): Anomaly {
+  let predictorId = getPredictorIdByName(anomalyName);
+  return loadAnomalyById(predictorId);
 }
 
 function saveAnomalyTypeInfo(info) {
@@ -113,24 +111,24 @@ function getAnomalyTypeInfo(name) {
   return getJsonDataSync(path.join(ANOMALIES_PATH, `${name}.json`));
 }
 
-function setAnomalyStatus(anomalyId:AnomalyId, status:string, error?:string) {
-  let info = loadAnomalyById(anomalyId);
+function setAnomalyStatus(predictorId: PredictorId, status: string, error?: string) {
+  let info = loadAnomalyById(predictorId);
   info.status = status;
   if(error !== undefined) {
     info.error = error;
   } else {
     info.error = '';
   }
-  saveAnomaly(anomalyId, info);
+  saveAnomaly(predictorId, info);
 }
 
-function setAnomalyPredictionTime(anomalyId:AnomalyId, lastPredictionTime:number) {
-  let info = loadAnomalyById(anomalyId);
+function setAnomalyPredictionTime(predictorId: PredictorId, lastPredictionTime: number) {
+  let info = loadAnomalyById(predictorId);
   info.last_prediction_time = lastPredictionTime;
-  saveAnomaly(anomalyId, info);
+  saveAnomaly(predictorId, info);
 }
 
 export {
   saveAnomaly, loadAnomalyById, loadAnomalyByName, insertAnomaly, removeAnomaly, saveAnomalyTypeInfo,
-  getAnomalyTypeInfo, getAnomalyIdByName, setAnomalyStatus, setAnomalyPredictionTime
+  getAnomalyTypeInfo, getPredictorIdByName, setAnomalyStatus, setAnomalyPredictionTime
 }

server/src/services/data.ts

@@ -12,7 +12,7 @@ function maybeCreate(path: string): void {
 }
 
 export function checkDataFolders(): void {
-  var folders = [
+  [
     config.DATA_PATH,
     config.DATASETS_PATH,
     config.ANOMALIES_PATH,

server/src/services/notification.ts

@@ -1,8 +1,8 @@
 import axios from 'axios';
 import { loadAnomalyById } from './anomalyType';
 
-export async function sendNotification(anomalyId, active) {
-  let anomalyName = loadAnomalyById(anomalyId).name;
+export async function sendNotification(predictorId, active) {
+  let anomalyName = loadAnomalyById(predictorId).name;
   console.log('Notification ' + anomalyName);
 
   let notification = {

server/src/services/segments.ts

@@ -2,12 +2,12 @@ import * as path from 'path';
 import * as fs from 'fs';
 import { getJsonDataSync, writeJsonDataSync }  from './json';
 import { SEGMENTS_PATH } from '../config';
-import { AnomalyId, loadAnomalyById, saveAnomaly } from './anomalyType';
+import { PredictorId, loadAnomalyById, saveAnomaly } from './anomalyType';
 
 import * as _ from 'lodash';
 
-function getLabeledSegments(anomalyId: AnomalyId) {
-  let filename = path.join(SEGMENTS_PATH, `${anomalyId}_labeled.json`);
+function getLabeledSegments(predictorId: PredictorId) {
+  let filename = path.join(SEGMENTS_PATH, `${predictorId}_labeled.json`);
 
   if(!fs.existsSync(filename)) {
     return [];
@@ -22,8 +22,8 @@ function getLabeledSegments(anomalyId: AnomalyId) {
   }
 }
 
-function getPredictedSegments(anomalyId: AnomalyId) {
-  let filename = path.join(SEGMENTS_PATH, `${anomalyId}_segments.json`);
+function getPredictedSegments(predictorId: PredictorId) {
+  let filename = path.join(SEGMENTS_PATH, `${predictorId}_segments.json`);
 
   let jsonData;
   try {
@@ -35,8 +35,8 @@ function getPredictedSegments(anomalyId: AnomalyId) {
   return jsonData;
 }
 
-function saveSegments(anomalyId: AnomalyId, segments) {
-  let filename = path.join(SEGMENTS_PATH, `${anomalyId}_labeled.json`);
+function saveSegments(predictorId: PredictorId, segments) {
+  let filename = path.join(SEGMENTS_PATH, `${predictorId}_labeled.json`);
 
   try {
     return writeJsonDataSync(filename, _.uniqBy(segments, 'start'));
@@ -46,10 +46,10 @@ function saveSegments(anomalyId: AnomalyId, segments) {
   }
 }
 
-function insertSegments(anomalyId: AnomalyId, addedSegments, labeled:boolean) {
+function insertSegments(predictorId: PredictorId, addedSegments, labeled:boolean) {
   // Set status
-  let info = loadAnomalyById(anomalyId);
-  let segments = getLabeledSegments(anomalyId);
+  let info = loadAnomalyById(predictorId);
+  let segments = getLabeledSegments(predictorId);
 
   let nextId = info.next_id;
   let addedIds = []
@@ -61,17 +61,17 @@ function insertSegments(anomalyId: AnomalyId, addedSegments, labeled:boolean) {
     segments.push(segment);
   }
   info.next_id = nextId;
-  saveSegments(anomalyId, segments);
-  saveAnomaly(anomalyId, info);
+  saveSegments(predictorId, segments);
+  saveAnomaly(predictorId, info);
   return addedIds;
 }
 
-function removeSegments(anomalyId: AnomalyId, removedSegments) {
-  let segments = getLabeledSegments(anomalyId);
+function removeSegments(predictorId: PredictorId, removedSegments) {
+  let segments = getLabeledSegments(predictorId);
   for (let segmentId of removedSegments) {
     segments = segments.filter(el => el.id !== segmentId);
   }
-  saveSegments(anomalyId, segments);
+  saveSegments(predictorId, segments);
 }
 
 export { getLabeledSegments, getPredictedSegments, saveSegments, insertSegments, removeSegments }