energylink/public/app/plugins/datasource/influxdb/response_parser.ts

///<reference path="../../../headers/common.d.ts" />

import _ from 'lodash';

export default class ResponseParser {

  parse(query, results) {
    if (!results || results.results.length === 0) { return []; }

    var influxResults = results.results[0];
    if (!influxResults.series) {
      return [];
    }

    var influxdb11format = query.toLowerCase().indexOf('show tag values') >= 0;

    var res = {};
    _.each(influxResults.series, serie => {
      _.each(serie.values, value => {
        if (_.isArray(value)) {
          if (influxdb11format) {
            addUnique(res, value[1] || value[0]);
          } else {
            addUnique(res, value[0]);
          }
        } else {
          addUnique(res, value);
        }
      });
    });

    return _.map(res, value => {
      return { text: value};
    });
  }
}

function addUnique(arr, value) {
  arr[value] = value;
}