summaryrefslogtreecommitdiff
path: root/app/assets/javascripts/monitoring/stores/monitoring_store.js
blob: 737c964f12ed0ea4cb5688d030e55c9632372f06 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
import _ from 'underscore';

class MonitoringStore {
  constructor() {
    this.groups = [];
    this.deploymentData = [];
  }

  // eslint-disable-next-line class-methods-use-this
  createArrayRows(metrics = []) {
    const currentMetrics = metrics;
    const availableMetrics = [];
    let metricsRow = [];
    let index = 1;
    Object.keys(currentMetrics).forEach((key) => {
      const metricValues = currentMetrics[key].queries[0].result[0].values;
      if (metricValues != null) {
        const literalMetrics = metricValues.map(metric => ({
          time: new Date(metric[0] * 1000),
          value: metric[1],
        }));
        currentMetrics[key].queries[0].result[0].values = literalMetrics;
        metricsRow.push(currentMetrics[key]);
        if (index % 2 === 0) {
          availableMetrics.push(metricsRow);
          metricsRow = [];
        }
        index = index += 1;
      }
    });
    if (metricsRow.length > 0) {
      availableMetrics.push(metricsRow);
    }
    return availableMetrics;
  }

  storeMetrics(groups = []) {
    this.groups = groups.map((group) => {
      const currentGroup = group;
      currentGroup.metrics = _.chain(group.metrics).sortBy('weight').sortBy('title').value();
      currentGroup.metrics = this.createArrayRows(currentGroup.metrics);
      return currentGroup;
    });
  }

  storeDeploymentData(deploymentData = []) {
    this.deploymentData = deploymentData;
  }

  getMetricsCount() {
    let metricsCount = 0;
    this.groups.forEach((group) => {
      group.metrics.forEach((metric) => {
        metricsCount = metricsCount += metric.length;
      });
    });
    return metricsCount;
  }
}

export default MonitoringStore;