energylink/public/app/plugins/datasource/elasticsearch/specs/query_def_specs.ts

import { describe, it, expect } from 'test/lib/common';

import * as queryDef from '../query_def';

describe('ElasticQueryDef', function() {
  describe('getPipelineAggOptions', function() {
    describe('with zero targets', function() {
      var response = queryDef.getPipelineAggOptions([]);

      it('should return zero', function() {
        expect(response.length).to.be(0);
      });
    });

    describe('with count and sum targets', function() {
      var targets = {
        metrics: [
          { type: 'count', field: '@value' },
          { type: 'sum', field: '@value' },
        ],
      };

      var response = queryDef.getPipelineAggOptions(targets);

      it('should return zero', function() {
        expect(response.length).to.be(2);
      });
    });

    describe('with count and moving average targets', function() {
      var targets = {
        metrics: [
          { type: 'count', field: '@value' },
          { type: 'moving_avg', field: '@value' },
        ],
      };

      var response = queryDef.getPipelineAggOptions(targets);

      it('should return one', function() {
        expect(response.length).to.be(1);
      });
    });

    describe('with derivatives targets', function() {
      var targets = {
        metrics: [{ type: 'derivative', field: '@value' }],
      };

      var response = queryDef.getPipelineAggOptions(targets);

      it('should return zero', function() {
        expect(response.length).to.be(0);
      });
    });
  });

  describe('isPipelineMetric', function() {
    describe('moving_avg', function() {
      var result = queryDef.isPipelineAgg('moving_avg');

      it('is pipe line metric', function() {
        expect(result).to.be(true);
      });
    });

    describe('count', function() {
      var result = queryDef.isPipelineAgg('count');

      it('is not pipe line metric', function() {
        expect(result).to.be(false);
      });
    });
  });

  describe('pipeline aggs depending on esverison', function() {
    describe('using esversion undefined', function() {
      it('should not get pipeline aggs', function() {
        expect(queryDef.getMetricAggTypes(undefined).length).to.be(9);
      });
    });

    describe('using esversion 1', function() {
      it('should not get pipeline aggs', function() {
        expect(queryDef.getMetricAggTypes(1).length).to.be(9);
      });
    });

    describe('using esversion 2', function() {
      it('should get pipeline aggs', function() {
        expect(queryDef.getMetricAggTypes(2).length).to.be(11);
      });
    });

    describe('using esversion 5', function() {
      it('should get pipeline aggs', function() {
        expect(queryDef.getMetricAggTypes(5).length).to.be(11);
      });
    });
  });
});