energylink/public/app/plugins/datasource/stackdriver/query_aggregation_ctrl.ts

import angular from 'angular';
import _ from 'lodash';
import * as options from './constants';
import * as options from './constants';
import kbn from 'app/core/utils/kbn';

export class StackdriverAggregation {
  constructor() {
    return {
      templateUrl: 'public/app/plugins/datasource/stackdriver/partials/query.aggregation.html',
      controller: 'StackdriverAggregationCtrl',
      restrict: 'E',
      scope: {
        target: '=',
        alignmentPeriod: '<',
        refresh: '&',
      },
    };
  }
}

export class StackdriverAggregationCtrl {
  constructor(private $scope) {
    $scope.aggOptions = options.aggOptions;
    this.setAggOptions();
    this.setAlignOptions();
    $scope.alignmentPeriods = options.alignmentPeriods;
    $scope.onAlignmentChange = this.onAlignmentChange.bind(this);
    $scope.onAggregationChange = this.onAggregationChange.bind(this);
    $scope.formatAlignmentText = this.formatAlignmentText.bind(this);
    $scope.$on('metricTypeChanged', this.setAlignOptions.bind(this));
  }

  onAlignmentChange(newVal: string) {
    if (newVal === 'ALIGN_NONE') {
      this.$scope.target.aggregation.crossSeriesReducer = 'REDUCE_NONE';
    }
    this.$scope.refresh();
  }

  onAggregationChange(newVal: string) {
    if (newVal !== 'REDUCE_NONE' && this.$scope.target.aggregation.perSeriesAligner === 'ALIGN_NONE') {
      const newAlignmentOption = options.alignOptions.find(
        o =>
          o.value !== 'ALIGN_NONE' &&
          o.valueTypes.indexOf(this.$scope.target.valueType) !== -1 &&
          o.metricKinds.indexOf(this.$scope.target.metricKind) !== -1
      );
      this.$scope.target.aggregation.perSeriesAligner = newAlignmentOption ? newAlignmentOption.value : '';
    }
    this.$scope.refresh();
  }

  setAlignOptions() {
    this.$scope.alignOptions = !this.$scope.target.valueType
      ? []
      : options.alignOptions.filter(i => {
          return (
            i.valueTypes.indexOf(this.$scope.target.valueType) !== -1 &&
            i.metricKinds.indexOf(this.$scope.target.metricKind) !== -1
          );
        });
    if (!this.$scope.alignOptions.find(o => o.value === this.$scope.target.aggregation.perSeriesAligner)) {
      const newValue = this.$scope.alignOptions.find(o => o.value !== 'ALIGN_NONE');
      this.$scope.target.aggregation.perSeriesAligner = newValue ? newValue.value : '';
    }
  }

  setAggOptions() {
    this.$scope.aggOptions = !this.$scope.target.metricKind
      ? []
      : options.aggOptions.filter(i => {
          return (
            i.valueTypes.indexOf(this.$scope.target.valueType) !== -1 &&
            i.metricKinds.indexOf(this.$scope.target.metricKind) !== -1
          );
        });

    if (!this.$scope.aggOptions.find(o => o.value === this.$scope.target.aggregation.crossSeriesReducer)) {
      const newValue = this.$scope.aggOptions.find(o => o.value !== 'REDUCE_NONE');
      this.$scope.target.aggregation.crossSeriesReducer = newValue ? newValue.value : '';
    }
  }

  formatAlignmentText() {
    const selectedAlignment = this.$scope.alignOptions.find(
      ap => ap.value === this.$scope.target.aggregation.perSeriesAligner
    );
    return `${kbn.secondsToHms(this.$scope.alignmentPeriod)} interval (${selectedAlignment.text})`;
  }
}

angular.module('grafana.controllers').directive('stackdriverAggregation', StackdriverAggregation);
angular.module('grafana.controllers').controller('StackdriverAggregationCtrl', StackdriverAggregationCtrl);