energylink/public/app/plugins/datasource/influxdb/specs/response_parser_specs.ts

import _ from 'lodash';
import {describe, beforeEach, it, sinon, expect} from 'test/lib/common';
import ResponseParser from '../response_parser';

describe("influxdb response parser", () => {
  this.parser = new ResponseParser();
  describe("SHOW TAG response", () => {
    var query = 'SHOW TAG KEYS FROM "cpu"';
    describe("response from 0.10.0", () => {
      var response = {
        "results": [
          {
            "series": [
              {
                "name": "cpu",
                "columns": ["tagKey"],
                "values": [ ["datacenter"], ["hostname"], ["source"] ]
              }
            ]
          }
        ]
      };

      var result = this.parser.parse(query, response);

      it("expects three results", () => {
        expect(_.size(result)).to.be(3);
      });
    });

    describe("response from 0.11.0", () => {
      var response = {
        "results": [
          {
            "series": [
              {
                "name": "cpu",
                "columns": ["tagKey"],
                "values": [ ["datacenter"], ["hostname"], ["source"] ]
              }
            ]
          }
        ]
      };

      var result = this.parser.parse(query, response);

      it("expects three results", () => {
        expect(_.size(result)).to.be(3);
      });
    });
  });

  describe("SHOW TAG VALUES response", () => {
    var query = 'SHOW TAG VALUES FROM "cpu" WITH KEY = "hostname"';

    describe("response from 0.10.0", () => {
      var response = {
        "results": [
          {
            "series": [
              {
                "name": "hostnameTagValues",
                "columns": ["hostname"],
                "values": [ ["server1"], ["server2"] ]
              }
            ]
          }
        ]
      };

      var result = this.parser.parse(query, response);

      it("should get two responses", () => {
        expect(_.size(result)).to.be(2);
        expect(result[0].text).to.be("server1");
        expect(result[1].text).to.be("server2");
      });
    });

    describe("response from 0.11.0", () => {
      var response = {
        "results": [
           {
             "series": [
               {
                 "name": "cpu",
                 "columns": [ "key", "value"],
                 "values": [ [ "source", "site" ], [ "source", "api" ] ]
               }
             ]
           }
        ]
      };

      var result = this.parser.parse(query, response);

      it("should get two responses", () => {
        expect(_.size(result)).to.be(2);
        expect(result[0].text).to.be('site');
        expect(result[1].text).to.be('api');
      });
    });




  });

  describe("SHOW FIELD response", () => {
    var query = 'SHOW FIELD KEYS FROM "cpu"';
    describe("response from 0.10.0", () => {
      var response = {
        "results": [
          {
            "series": [
              {
                "name": "measurements",
                "columns": ["name"],
                "values": [
                  ["cpu"], ["derivative"], ["logins.count"], ["logs"], ["payment.ended"], ["payment.started"]
                ]
              }
            ]
          }
        ]
      };

      var result = this.parser.parse(query, response);
      it("should get two responses", () => {
        expect(_.size(result)).to.be(6);
      });
    });

    describe("response from 0.11.0", () => {
      var response = {
        "results": [
          {
            "series": [
              {
                "name": "cpu",
                "columns": ["fieldKey"],
                "values": [ [ "value"] ]
              }
            ]
          }
        ]
      };

      var result = this.parser.parse(query, response);

      it("should get two responses", () => {
        expect(_.size(result)).to.be(1);
      });
    });
  });
});