160 lines
5 KiB
JavaScript
160 lines
5 KiB
JavaScript
|
import mutations from '~/monitoring/stores/mutations';
|
||
|
import * as types from '~/monitoring/stores/mutation_types';
|
||
|
import state from '~/monitoring/stores/state';
|
||
|
import { metricsGroupsAPIResponse, deploymentData, metricsDashboardResponse } from '../mock_data';
|
||
|
|
||
|
describe('Monitoring mutations', () => {
|
||
|
let stateCopy;
|
||
|
|
||
|
beforeEach(() => {
|
||
|
stateCopy = state();
|
||
|
});
|
||
|
|
||
|
describe(types.RECEIVE_METRICS_DATA_SUCCESS, () => {
|
||
|
let groups;
|
||
|
|
||
|
beforeEach(() => {
|
||
|
stateCopy.groups = [];
|
||
|
groups = metricsGroupsAPIResponse.data;
|
||
|
});
|
||
|
|
||
|
it('normalizes values', () => {
|
||
|
mutations[types.RECEIVE_METRICS_DATA_SUCCESS](stateCopy, groups);
|
||
|
|
||
|
const expectedTimestamp = '2017-05-25T08:22:34.925Z';
|
||
|
const expectedValue = 0.0010794445585559514;
|
||
|
const [timestamp, value] = stateCopy.groups[0].metrics[0].queries[0].result[0].values[0];
|
||
|
|
||
|
expect(timestamp).toEqual(expectedTimestamp);
|
||
|
expect(value).toEqual(expectedValue);
|
||
|
});
|
||
|
|
||
|
it('contains two groups that contains, one of which has two queries sorted by priority', () => {
|
||
|
mutations[types.RECEIVE_METRICS_DATA_SUCCESS](stateCopy, groups);
|
||
|
|
||
|
expect(stateCopy.groups).toBeDefined();
|
||
|
expect(stateCopy.groups.length).toEqual(2);
|
||
|
expect(stateCopy.groups[0].metrics.length).toEqual(2);
|
||
|
});
|
||
|
|
||
|
it('assigns queries a metric id', () => {
|
||
|
mutations[types.RECEIVE_METRICS_DATA_SUCCESS](stateCopy, groups);
|
||
|
|
||
|
expect(stateCopy.groups[1].metrics[0].queries[0].metricId).toEqual('100');
|
||
|
});
|
||
|
|
||
|
it('removes the data if all the values from a query are not defined', () => {
|
||
|
mutations[types.RECEIVE_METRICS_DATA_SUCCESS](stateCopy, groups);
|
||
|
|
||
|
expect(stateCopy.groups[1].metrics[0].queries[0].result.length).toEqual(0);
|
||
|
});
|
||
|
|
||
|
it('assigns metric id of null if metric has no id', () => {
|
||
|
stateCopy.groups = [];
|
||
|
const noId = groups.map(group => ({
|
||
|
...group,
|
||
|
...{
|
||
|
metrics: group.metrics.map(metric => {
|
||
|
const { id, ...metricWithoutId } = metric;
|
||
|
|
||
|
return metricWithoutId;
|
||
|
}),
|
||
|
},
|
||
|
}));
|
||
|
|
||
|
mutations[types.RECEIVE_METRICS_DATA_SUCCESS](stateCopy, noId);
|
||
|
|
||
|
stateCopy.groups.forEach(group => {
|
||
|
group.metrics.forEach(metric => {
|
||
|
expect(metric.queries.every(query => query.metricId === null)).toBe(true);
|
||
|
});
|
||
|
});
|
||
|
});
|
||
|
|
||
|
describe('dashboard endpoint enabled', () => {
|
||
|
const dashboardGroups = metricsDashboardResponse.dashboard.panel_groups;
|
||
|
|
||
|
beforeEach(() => {
|
||
|
stateCopy.useDashboardEndpoint = true;
|
||
|
});
|
||
|
|
||
|
it('aliases group panels to metrics for backwards compatibility', () => {
|
||
|
mutations[types.RECEIVE_METRICS_DATA_SUCCESS](stateCopy, dashboardGroups);
|
||
|
|
||
|
expect(stateCopy.groups[0].metrics[0]).toBeDefined();
|
||
|
});
|
||
|
|
||
|
it('aliases panel metrics to queries for backwards compatibility', () => {
|
||
|
mutations[types.RECEIVE_METRICS_DATA_SUCCESS](stateCopy, dashboardGroups);
|
||
|
|
||
|
expect(stateCopy.groups[0].metrics[0].queries).toBeDefined();
|
||
|
});
|
||
|
});
|
||
|
});
|
||
|
|
||
|
describe(types.RECEIVE_DEPLOYMENTS_DATA_SUCCESS, () => {
|
||
|
it('stores the deployment data', () => {
|
||
|
stateCopy.deploymentData = [];
|
||
|
mutations[types.RECEIVE_DEPLOYMENTS_DATA_SUCCESS](stateCopy, deploymentData);
|
||
|
|
||
|
expect(stateCopy.deploymentData).toBeDefined();
|
||
|
expect(stateCopy.deploymentData.length).toEqual(3);
|
||
|
expect(typeof stateCopy.deploymentData[0]).toEqual('object');
|
||
|
});
|
||
|
});
|
||
|
|
||
|
describe('SET_ENDPOINTS', () => {
|
||
|
it('should set all the endpoints', () => {
|
||
|
mutations[types.SET_ENDPOINTS](stateCopy, {
|
||
|
metricsEndpoint: 'additional_metrics.json',
|
||
|
environmentsEndpoint: 'environments.json',
|
||
|
deploymentsEndpoint: 'deployments.json',
|
||
|
dashboardEndpoint: 'dashboard.json',
|
||
|
});
|
||
|
|
||
|
expect(stateCopy.metricsEndpoint).toEqual('additional_metrics.json');
|
||
|
expect(stateCopy.environmentsEndpoint).toEqual('environments.json');
|
||
|
expect(stateCopy.deploymentsEndpoint).toEqual('deployments.json');
|
||
|
expect(stateCopy.dashboardEndpoint).toEqual('dashboard.json');
|
||
|
});
|
||
|
});
|
||
|
|
||
|
describe('SET_QUERY_RESULT', () => {
|
||
|
const metricId = 12;
|
||
|
const result = [{ values: [[0, 1], [1, 1], [1, 3]] }];
|
||
|
|
||
|
beforeEach(() => {
|
||
|
stateCopy.useDashboardEndpoint = true;
|
||
|
const dashboardGroups = metricsDashboardResponse.dashboard.panel_groups;
|
||
|
mutations[types.RECEIVE_METRICS_DATA_SUCCESS](stateCopy, dashboardGroups);
|
||
|
});
|
||
|
|
||
|
it('clears empty state', () => {
|
||
|
mutations[types.SET_QUERY_RESULT](stateCopy, {
|
||
|
metricId,
|
||
|
result,
|
||
|
});
|
||
|
|
||
|
expect(stateCopy.showEmptyState).toBe(false);
|
||
|
});
|
||
|
|
||
|
it('sets metricsWithData value', () => {
|
||
|
mutations[types.SET_QUERY_RESULT](stateCopy, {
|
||
|
metricId,
|
||
|
result,
|
||
|
});
|
||
|
|
||
|
expect(stateCopy.metricsWithData).toEqual([12]);
|
||
|
});
|
||
|
|
||
|
it('does not store empty results', () => {
|
||
|
mutations[types.SET_QUERY_RESULT](stateCopy, {
|
||
|
metricId,
|
||
|
result: [],
|
||
|
});
|
||
|
|
||
|
expect(stateCopy.metricsWithData).toEqual([]);
|
||
|
});
|
||
|
});
|
||
|
});
|