energylink/public/app/plugins/datasource/influxdb/influxSeries.js

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;
});