More work on restoring features after moving to plugin model for datasources, #1276 #1472

src/app/plugins/datasource/influxdb/influxSeries.js

@@ -0,0 +1,107 @@
+define([
+  'lodash',
+],
+function (_) {
+  'use strict';
+
+  function InfluxSeries(options) {
+    this.seriesList = options.seriesList;
+    this.alias = options.alias;
+    this.annotation = options.annotation;
+  }
+
+  var p = InfluxSeries.prototype;
+
+  p.getTimeSeries = function() {
+    var output = [];
+    var self = this;
+
+    console.log(self.seriesList);
+    if (!self.seriesList || !self.seriesList.results || !self.seriesList.results[0]) {
+      return output;
+    }
+
+    this.seriesList = self.seriesList.results[0].series;
+
+    _.each(self.seriesList, function(series) {
+      var datapoints = [];
+      for (var i = 0; i < series.values.length; i++) {
+        datapoints[i] = [series.values[i][1], new Date(series.values[i][0]).getTime()];
+      }
+
+      var seriesName = series.name;
+      var tags = _.map(series.tags, function(value, key) {
+        return key + ': ' + value;
+      });
+
+      if (tags.length > 0) {
+        seriesName = seriesName + ' {' + tags.join(', ') + '}';
+      }
+
+      output.push({ target: seriesName, datapoints: datapoints });
+    });
+
+    return output;
+  };
+
+  p.getAnnotations = function () {
+    var list = [];
+    var self = this;
+
+    _.each(this.seriesList, function (series) {
+      var titleCol = null;
+      var timeCol = null;
+      var tagsCol = null;
+      var textCol = null;
+
+      _.each(series.columns, function(column, index) {
+        if (column === 'time') { timeCol = index; return; }
+        if (column === 'sequence_number') { return; }
+        if (!titleCol) { titleCol = index; }
+        if (column === self.annotation.titleColumn) { titleCol = index; return; }
+        if (column === self.annotation.tagsColumn) { tagsCol = index; return; }
+        if (column === self.annotation.textColumn) { textCol = index; return; }
+      });
+
+      _.each(series.points, function (point) {
+        var data = {
+          annotation: self.annotation,
+          time: point[timeCol],
+          title: point[titleCol],
+          tags: point[tagsCol],
+          text: point[textCol]
+        };
+
+        if (tagsCol) {
+          data.tags = point[tagsCol];
+        }
+
+        list.push(data);
+      });
+    });
+
+    return list;
+  };
+
+  p.createNameForSeries = function(seriesName, groupByColValue) {
+    var regex = /\$(\w+)/g;
+    var segments = seriesName.split('.');
+
+    return this.alias.replace(regex, function(match, group) {
+      if (group === 's') {
+        return seriesName;
+      }
+      else if (group === 'g') {
+        return groupByColValue;
+      }
+      var index = parseInt(group);
+      if (_.isNumber(index) && index < segments.length) {
+        return segments[index];
+      }
+      return match;
+    });
+
+  };
+
+  return InfluxSeries;
+});