mirror of
https://github.com/grafana/grafana.git
synced 2025-02-25 18:55:37 -06:00
Azure Monitor: Fix behavior for nested template variables (#60697)
This commit is contained in:
Andres Martinez Gotor
GitHub
parent
c34aa05548
commit
eb757ee15e
@ -1,31 +0,0 @@
|
||||
.min-width-10 {
|
||||
min-width: 10rem;
|
||||
}
|
||||
|
||||
.min-width-12 {
|
||||
min-width: 12rem;
|
||||
}
|
||||
|
||||
.min-width-20 {
|
||||
min-width: 20rem;
|
||||
}
|
||||
|
||||
.gf-form-select-wrapper select.gf-form-input {
|
||||
height: 2.64rem;
|
||||
}
|
||||
|
||||
.gf-form-select-wrapper--caret-indent.gf-form-select-wrapper::after {
|
||||
right: 0.775rem;
|
||||
}
|
||||
|
||||
.service-dropdown {
|
||||
width: 12rem;
|
||||
}
|
||||
|
||||
.aggregation-dropdown-wrapper {
|
||||
max-width: 29.1rem;
|
||||
}
|
||||
|
||||
.timegrainunit-dropdown-wrapper {
|
||||
width: 8rem;
|
||||
}
|
||||
@ -1,6 +1,6 @@
|
||||
import { from } from 'rxjs';
|
||||
import { from, lastValueFrom } from 'rxjs';
|
||||
|
||||
import { DataQueryRequest, DataQueryResponseData, toDataFrame } from '@grafana/data';
|
||||
import { DataQueryRequest, toDataFrame } from '@grafana/data';
|
||||
|
||||
import createMockDatasource from './__mocks__/datasource';
|
||||
import { invalidSubscriptionError } from './__mocks__/errors';
|
||||
@ -15,9 +15,10 @@ jest.mock('@grafana/runtime', () => ({
|
||||
},
|
||||
}),
|
||||
}));
|
||||
|
||||
describe('VariableSupport', () => {
|
||||
describe('querying for grafana template variable fns', () => {
|
||||
it('can fetch subscriptions', (done) => {
|
||||
it('can fetch subscriptions', async () => {
|
||||
const fakeSubscriptions = ['subscriptionId'];
|
||||
const variableSupport = new VariableSupport(
|
||||
createMockDatasource({
|
||||
@ -36,43 +37,11 @@ describe('VariableSupport', () => {
|
||||
} as AzureMonitorQuery,
|
||||
],
|
||||
} as DataQueryRequest<AzureMonitorQuery>;
|
||||
const observables = variableSupport.query(mockRequest);
|
||||
observables.subscribe((result: DataQueryResponseData) => {
|
||||
const result = await lastValueFrom(variableSupport.query(mockRequest));
|
||||
expect(result.data[0].source).toEqual(fakeSubscriptions);
|
||||
done();
|
||||
});
|
||||
});
|
||||
|
||||
it('can fetch resourceGroups with a default subscriptionId', (done) => {
|
||||
const expectedResults = ['test'];
|
||||
const variableSupport = new VariableSupport(
|
||||
createMockDatasource({
|
||||
azureLogAnalyticsDatasource: {
|
||||
defaultSubscriptionId: 'defaultSubscriptionId',
|
||||
},
|
||||
getResourceGroups: jest.fn().mockResolvedValueOnce(expectedResults),
|
||||
})
|
||||
);
|
||||
const mockRequest = {
|
||||
targets: [
|
||||
{
|
||||
refId: 'A',
|
||||
queryType: AzureQueryType.GrafanaTemplateVariableFn,
|
||||
grafanaTemplateVariableFn: {
|
||||
kind: 'ResourceGroupsQuery',
|
||||
rawQuery: 'ResourceGroups()',
|
||||
},
|
||||
} as AzureMonitorQuery,
|
||||
],
|
||||
} as DataQueryRequest<AzureMonitorQuery>;
|
||||
const observables = variableSupport.query(mockRequest);
|
||||
observables.subscribe((result: DataQueryResponseData) => {
|
||||
expect(result.data[0].source).toEqual(expectedResults);
|
||||
done();
|
||||
});
|
||||
});
|
||||
|
||||
it('can fetch resourceGroups with a subscriptionId arg', (done) => {
|
||||
it('can fetch resourceGroups with a subscriptionId arg', async () => {
|
||||
const expectedResults = ['test'];
|
||||
const variableSupport = new VariableSupport(
|
||||
createMockDatasource({
|
||||
@ -87,55 +56,20 @@ describe('VariableSupport', () => {
|
||||
grafanaTemplateVariableFn: {
|
||||
kind: 'ResourceGroupsQuery',
|
||||
rawQuery: 'ResourceGroups(sub)',
|
||||
subscription: 'sub',
|
||||
},
|
||||
} as AzureMonitorQuery,
|
||||
],
|
||||
} as DataQueryRequest<AzureMonitorQuery>;
|
||||
const observables = variableSupport.query(mockRequest);
|
||||
observables.subscribe((result: DataQueryResponseData) => {
|
||||
const result = await lastValueFrom(variableSupport.query(mockRequest));
|
||||
expect(result.data[0].source).toEqual(expectedResults);
|
||||
done();
|
||||
});
|
||||
});
|
||||
|
||||
it('can fetch metricNamespaces with a default subscriptionId', (done) => {
|
||||
it('can fetch metricNamespaces with a subscriptionId', async () => {
|
||||
const expectedResults = ['test'];
|
||||
const variableSupport = new VariableSupport(
|
||||
createMockDatasource({
|
||||
azureLogAnalyticsDatasource: {
|
||||
defaultSubscriptionId: 'defaultSubscriptionId',
|
||||
},
|
||||
azureMonitorDatasource: {
|
||||
getMetricNamespaces: jest.fn().mockResolvedValue(expectedResults),
|
||||
},
|
||||
})
|
||||
);
|
||||
const mockRequest = {
|
||||
targets: [
|
||||
{
|
||||
refId: 'A',
|
||||
queryType: AzureQueryType.GrafanaTemplateVariableFn,
|
||||
grafanaTemplateVariableFn: {
|
||||
kind: 'MetricNamespaceQuery',
|
||||
rawQuery: 'Namespaces(resourceGroup)',
|
||||
},
|
||||
} as AzureMonitorQuery,
|
||||
],
|
||||
} as DataQueryRequest<AzureMonitorQuery>;
|
||||
const observables = variableSupport.query(mockRequest);
|
||||
observables.subscribe((result: DataQueryResponseData) => {
|
||||
expect(result.data[0].source).toEqual(expectedResults);
|
||||
done();
|
||||
});
|
||||
});
|
||||
|
||||
it('can fetch metricNamespaces with a subscriptionId', (done) => {
|
||||
const expectedResults = ['test'];
|
||||
const variableSupport = new VariableSupport(
|
||||
createMockDatasource({
|
||||
azureMonitorDatasource: {
|
||||
getMetricNamespaces: jest.fn().mockResolvedValue(expectedResults),
|
||||
},
|
||||
})
|
||||
);
|
||||
const mockRequest = {
|
||||
@ -146,47 +80,17 @@ describe('VariableSupport', () => {
|
||||
grafanaTemplateVariableFn: {
|
||||
kind: 'MetricNamespaceQuery',
|
||||
rawQuery: 'Namespaces(resourceGroup, subscriptionId)',
|
||||
subscription: 'subscriptionId',
|
||||
resourceGroup: 'resourceGroup',
|
||||
},
|
||||
} as AzureMonitorQuery,
|
||||
],
|
||||
} as DataQueryRequest<AzureMonitorQuery>;
|
||||
const observables = variableSupport.query(mockRequest);
|
||||
observables.subscribe((result: DataQueryResponseData) => {
|
||||
const result = await lastValueFrom(variableSupport.query(mockRequest));
|
||||
expect(result.data[0].source).toEqual(expectedResults);
|
||||
done();
|
||||
});
|
||||
});
|
||||
|
||||
it('can fetch resourceNames with a default subscriptionId', (done) => {
|
||||
const expectedResults = ['test'];
|
||||
const variableSupport = new VariableSupport(
|
||||
createMockDatasource({
|
||||
azureLogAnalyticsDatasource: {
|
||||
defaultSubscriptionId: 'defaultSubscriptionId',
|
||||
},
|
||||
getResourceNames: jest.fn().mockResolvedValueOnce(expectedResults),
|
||||
})
|
||||
);
|
||||
const mockRequest = {
|
||||
targets: [
|
||||
{
|
||||
refId: 'A',
|
||||
queryType: AzureQueryType.GrafanaTemplateVariableFn,
|
||||
grafanaTemplateVariableFn: {
|
||||
kind: 'ResourceNamesQuery',
|
||||
rawQuery: 'ResourceNames(resourceGroup, metricNamespace)',
|
||||
},
|
||||
} as AzureMonitorQuery,
|
||||
],
|
||||
} as DataQueryRequest<AzureMonitorQuery>;
|
||||
const observables = variableSupport.query(mockRequest);
|
||||
observables.subscribe((result: DataQueryResponseData) => {
|
||||
expect(result.data[0].source).toEqual(expectedResults);
|
||||
done();
|
||||
});
|
||||
});
|
||||
|
||||
it('can fetch resourceNames with a subscriptionId', (done) => {
|
||||
it('can fetch resourceNames with a subscriptionId', async () => {
|
||||
const expectedResults = ['test'];
|
||||
const variableSupport = new VariableSupport(
|
||||
createMockDatasource({
|
||||
@ -201,55 +105,22 @@ describe('VariableSupport', () => {
|
||||
grafanaTemplateVariableFn: {
|
||||
kind: 'ResourceNamesQuery',
|
||||
rawQuery: 'ResourceNames(subscriptionId, resourceGroup, metricNamespace)',
|
||||
subscription: 'subscriptionId',
|
||||
resourceGroup: 'resourceGroup',
|
||||
metricNamespace: 'metricNamespace',
|
||||
},
|
||||
} as AzureMonitorQuery,
|
||||
],
|
||||
} as DataQueryRequest<AzureMonitorQuery>;
|
||||
const observables = variableSupport.query(mockRequest);
|
||||
observables.subscribe((result: DataQueryResponseData) => {
|
||||
const result = await lastValueFrom(variableSupport.query(mockRequest));
|
||||
expect(result.data[0].source).toEqual(expectedResults);
|
||||
done();
|
||||
});
|
||||
});
|
||||
|
||||
it('can fetch a metricNamespace with a default subscriptionId', (done) => {
|
||||
it('can fetch a metricNamespace with a subscriptionId', async () => {
|
||||
const expectedResults = ['test'];
|
||||
const variableSupport = new VariableSupport(
|
||||
createMockDatasource({
|
||||
azureLogAnalyticsDatasource: {
|
||||
defaultSubscriptionId: 'defaultSubscriptionId',
|
||||
},
|
||||
azureMonitorDatasource: {
|
||||
getMetricNamespaces: jest.fn().mockResolvedValueOnce(expectedResults),
|
||||
},
|
||||
})
|
||||
);
|
||||
const mockRequest = {
|
||||
targets: [
|
||||
{
|
||||
refId: 'A',
|
||||
queryType: AzureQueryType.GrafanaTemplateVariableFn,
|
||||
grafanaTemplateVariableFn: {
|
||||
kind: 'MetricNamespaceQuery',
|
||||
rawQuery: 'metricNamespace(resourceGroup, metricNamespace, resourceName)',
|
||||
},
|
||||
} as AzureMonitorQuery,
|
||||
],
|
||||
} as DataQueryRequest<AzureMonitorQuery>;
|
||||
const observables = variableSupport.query(mockRequest);
|
||||
observables.subscribe((result: DataQueryResponseData) => {
|
||||
expect(result.data[0].source).toEqual(expectedResults);
|
||||
done();
|
||||
});
|
||||
});
|
||||
|
||||
it('can fetch a metricNamespace with a subscriptionId', (done) => {
|
||||
const expectedResults = ['test'];
|
||||
const variableSupport = new VariableSupport(
|
||||
createMockDatasource({
|
||||
azureMonitorDatasource: {
|
||||
getMetricNamespaces: jest.fn().mockResolvedValueOnce(expectedResults),
|
||||
},
|
||||
})
|
||||
);
|
||||
const mockRequest = {
|
||||
@ -260,55 +131,23 @@ describe('VariableSupport', () => {
|
||||
grafanaTemplateVariableFn: {
|
||||
kind: 'MetricNamespaceQuery',
|
||||
rawQuery: 'metricNamespace(subscriptionId, resourceGroup, metricNamespace, resourceName)',
|
||||
subscription: 'subscriptionId',
|
||||
resourceGroup: 'resourceGroup',
|
||||
metricNamespace: 'metricNamespace',
|
||||
resourceName: 'resourceName',
|
||||
},
|
||||
} as AzureMonitorQuery,
|
||||
],
|
||||
} as DataQueryRequest<AzureMonitorQuery>;
|
||||
const observables = variableSupport.query(mockRequest);
|
||||
observables.subscribe((result: DataQueryResponseData) => {
|
||||
const result = await lastValueFrom(variableSupport.query(mockRequest));
|
||||
expect(result.data[0].source).toEqual(expectedResults);
|
||||
done();
|
||||
});
|
||||
});
|
||||
|
||||
it('can fetch metricNames with a default subscriptionId', (done) => {
|
||||
it('can fetch metricNames with a subscriptionId', async () => {
|
||||
const expectedResults = ['test'];
|
||||
const variableSupport = new VariableSupport(
|
||||
createMockDatasource({
|
||||
azureLogAnalyticsDatasource: {
|
||||
defaultSubscriptionId: 'defaultSubscriptionId',
|
||||
},
|
||||
azureMonitorDatasource: {
|
||||
getMetricNames: jest.fn().mockResolvedValueOnce(expectedResults),
|
||||
},
|
||||
})
|
||||
);
|
||||
const mockRequest = {
|
||||
targets: [
|
||||
{
|
||||
refId: 'A',
|
||||
queryType: AzureQueryType.GrafanaTemplateVariableFn,
|
||||
grafanaTemplateVariableFn: {
|
||||
kind: 'MetricNamesQuery',
|
||||
rawQuery: 'metricNames(resourceGroup, metricNamespace, resourceName, metricNamespace)',
|
||||
},
|
||||
} as AzureMonitorQuery,
|
||||
],
|
||||
} as DataQueryRequest<AzureMonitorQuery>;
|
||||
const observables = variableSupport.query(mockRequest);
|
||||
observables.subscribe((result: DataQueryResponseData) => {
|
||||
expect(result.data[0].source).toEqual(expectedResults);
|
||||
done();
|
||||
});
|
||||
});
|
||||
|
||||
it('can fetch metricNames with a subscriptionId', (done) => {
|
||||
const expectedResults = ['test'];
|
||||
const variableSupport = new VariableSupport(
|
||||
createMockDatasource({
|
||||
azureMonitorDatasource: {
|
||||
getMetricNames: jest.fn().mockResolvedValueOnce(expectedResults),
|
||||
},
|
||||
})
|
||||
);
|
||||
const mockRequest = {
|
||||
@ -319,52 +158,23 @@ describe('VariableSupport', () => {
|
||||
grafanaTemplateVariableFn: {
|
||||
kind: 'MetricNamesQuery',
|
||||
rawQuery: 'metricNames(subscription, resourceGroup, metricNamespace, resourceName, metricNamespace)',
|
||||
subscription: 'subscriptionId',
|
||||
resourceGroup: 'resourceGroup',
|
||||
metricNamespace: 'metricNamespace',
|
||||
resourceName: 'resourceName',
|
||||
},
|
||||
} as AzureMonitorQuery,
|
||||
],
|
||||
} as DataQueryRequest<AzureMonitorQuery>;
|
||||
const observables = variableSupport.query(mockRequest);
|
||||
observables.subscribe((result: DataQueryResponseData) => {
|
||||
const result = await lastValueFrom(variableSupport.query(mockRequest));
|
||||
expect(result.data[0].source).toEqual(expectedResults);
|
||||
done();
|
||||
});
|
||||
});
|
||||
|
||||
it('can fetch workspaces with a default subscriptionId', (done) => {
|
||||
it('can fetch workspaces with a subscriptionId', async () => {
|
||||
const expectedResults = ['test'];
|
||||
const variableSupport = new VariableSupport(
|
||||
createMockDatasource({
|
||||
azureLogAnalyticsDatasource: {
|
||||
defaultSubscriptionId: 'defaultSubscriptionId',
|
||||
getWorkspaces: jest.fn().mockResolvedValueOnce(expectedResults),
|
||||
},
|
||||
})
|
||||
);
|
||||
const mockRequest = {
|
||||
targets: [
|
||||
{
|
||||
refId: 'A',
|
||||
queryType: AzureQueryType.GrafanaTemplateVariableFn,
|
||||
grafanaTemplateVariableFn: {
|
||||
kind: 'WorkspacesQuery',
|
||||
rawQuery: 'workspaces()',
|
||||
},
|
||||
} as AzureMonitorQuery,
|
||||
],
|
||||
} as DataQueryRequest<AzureMonitorQuery>;
|
||||
const observables = variableSupport.query(mockRequest);
|
||||
observables.subscribe((result: DataQueryResponseData) => {
|
||||
expect(result.data[0].source).toEqual(expectedResults);
|
||||
done();
|
||||
});
|
||||
});
|
||||
it('can fetch workspaces with a subscriptionId', (done) => {
|
||||
const expectedResults = ['test'];
|
||||
const variableSupport = new VariableSupport(
|
||||
createMockDatasource({
|
||||
azureLogAnalyticsDatasource: {
|
||||
getWorkspaces: jest.fn().mockResolvedValueOnce(expectedResults),
|
||||
},
|
||||
getAzureLogAnalyticsWorkspaces: jest.fn().mockResolvedValueOnce(expectedResults),
|
||||
})
|
||||
);
|
||||
const mockRequest = {
|
||||
@ -375,24 +185,41 @@ describe('VariableSupport', () => {
|
||||
grafanaTemplateVariableFn: {
|
||||
kind: 'WorkspacesQuery',
|
||||
rawQuery: 'workspaces(subscriptionId)',
|
||||
subscription: 'subscriptionId',
|
||||
},
|
||||
} as AzureMonitorQuery,
|
||||
],
|
||||
} as DataQueryRequest<AzureMonitorQuery>;
|
||||
const observables = variableSupport.query(mockRequest);
|
||||
observables.subscribe((result: DataQueryResponseData) => {
|
||||
const result = await lastValueFrom(variableSupport.query(mockRequest));
|
||||
expect(result.data[0].source).toEqual(expectedResults);
|
||||
done();
|
||||
});
|
||||
});
|
||||
|
||||
it('can handle legacy string queries', (done) => {
|
||||
it('can handle legacy string queries with a default subscription', async () => {
|
||||
const expectedResults = ['test'];
|
||||
const variableSupport = new VariableSupport(
|
||||
createMockDatasource({
|
||||
azureMonitorDatasource: {
|
||||
defaultSubscriptionId: 'defaultSubscriptionId',
|
||||
},
|
||||
getMetricNamespaces: jest.fn((sub: string, rg: string) => {
|
||||
if (sub === 'defaultSubscriptionId' && rg === 'resourceGroup') {
|
||||
return Promise.resolve(expectedResults);
|
||||
}
|
||||
return Promise.resolve([`getmetricNamespaces unexpected input: ${sub}, ${rg}`]);
|
||||
}),
|
||||
})
|
||||
);
|
||||
const mockRequest = {
|
||||
targets: ['Namespaces(resourceGroup)' as unknown as AzureMonitorQuery],
|
||||
} as DataQueryRequest<AzureMonitorQuery>;
|
||||
const result = await lastValueFrom(variableSupport.query(mockRequest));
|
||||
expect(result.data[0].source).toEqual(expectedResults);
|
||||
});
|
||||
|
||||
it('can handle legacy string queries', async () => {
|
||||
const expectedResults = ['test'];
|
||||
const variableSupport = new VariableSupport(
|
||||
createMockDatasource({
|
||||
getMetricNamespaces: jest.fn((sub: string, rg: string) => {
|
||||
if (sub === 'subscriptionId' && rg === 'resourceGroup') {
|
||||
return Promise.resolve(expectedResults);
|
||||
@ -404,13 +231,11 @@ describe('VariableSupport', () => {
|
||||
const mockRequest = {
|
||||
targets: ['Namespaces(subscriptionId, resourceGroup)' as unknown as AzureMonitorQuery],
|
||||
} as DataQueryRequest<AzureMonitorQuery>;
|
||||
const observables = variableSupport.query(mockRequest);
|
||||
observables.subscribe((result: DataQueryResponseData) => {
|
||||
const result = await lastValueFrom(variableSupport.query(mockRequest));
|
||||
expect(result.data[0].source).toEqual(expectedResults);
|
||||
done();
|
||||
});
|
||||
});
|
||||
it('returns an empty array for unknown queries', (done) => {
|
||||
|
||||
it('returns an empty array for unknown queries', async () => {
|
||||
const variableSupport = new VariableSupport(createMockDatasource());
|
||||
const mockRequest = {
|
||||
targets: [
|
||||
@ -422,22 +247,14 @@ describe('VariableSupport', () => {
|
||||
} as AzureMonitorQuery,
|
||||
],
|
||||
} as DataQueryRequest<AzureMonitorQuery>;
|
||||
const observables = variableSupport.query(mockRequest);
|
||||
observables.subscribe((result: DataQueryResponseData) => {
|
||||
const result = await lastValueFrom(variableSupport.query(mockRequest));
|
||||
expect(result.data).toEqual([]);
|
||||
done();
|
||||
});
|
||||
});
|
||||
|
||||
it('should return None when there is no data', (done) => {
|
||||
it('should return None when there is no data', async () => {
|
||||
const variableSupport = new VariableSupport(
|
||||
createMockDatasource({
|
||||
azureLogAnalyticsDatasource: {
|
||||
defaultSubscriptionId: 'defaultSubscriptionId',
|
||||
},
|
||||
azureMonitorDatasource: {
|
||||
getMetricNames: jest.fn().mockResolvedValueOnce([]),
|
||||
},
|
||||
})
|
||||
);
|
||||
const mockRequest = {
|
||||
@ -448,19 +265,20 @@ describe('VariableSupport', () => {
|
||||
grafanaTemplateVariableFn: {
|
||||
kind: 'MetricNamesQuery',
|
||||
rawQuery: 'metricNames(resourceGroup, metricNamespace, resourceName, metricNamespace)',
|
||||
subscription: 'subscriptionId',
|
||||
resourceGroup: 'resourceGroup',
|
||||
metricNamespace: 'metricNamespace',
|
||||
resourceName: 'resourceName',
|
||||
},
|
||||
} as AzureMonitorQuery,
|
||||
],
|
||||
} as DataQueryRequest<AzureMonitorQuery>;
|
||||
const observables = variableSupport.query(mockRequest);
|
||||
observables.subscribe((result: DataQueryResponseData) => {
|
||||
expect(result.data.length).toBe(0);
|
||||
done();
|
||||
});
|
||||
const result = await lastValueFrom(variableSupport.query(mockRequest));
|
||||
expect(result.data).toEqual([]);
|
||||
});
|
||||
});
|
||||
|
||||
it('passes on the query to the main datasource for all non-grafana template variable fns', (done) => {
|
||||
it('passes on the query to the main datasource for all non-grafana template variable fns', async () => {
|
||||
const expectedResults = ['test'];
|
||||
const variableSupport = new VariableSupport(
|
||||
createMockDatasource({
|
||||
@ -482,14 +300,11 @@ describe('VariableSupport', () => {
|
||||
} as AzureMonitorQuery,
|
||||
],
|
||||
} as DataQueryRequest<AzureMonitorQuery>;
|
||||
const observables = variableSupport.query(mockRequest);
|
||||
observables.subscribe((result: DataQueryResponseData) => {
|
||||
const result = await lastValueFrom(variableSupport.query(mockRequest));
|
||||
expect(result.data[0].source).toEqual(expectedResults);
|
||||
done();
|
||||
});
|
||||
});
|
||||
|
||||
it('passes on the query error for a log query', (done) => {
|
||||
it('passes on the query error for a log query', async () => {
|
||||
const variableSupport = new VariableSupport(
|
||||
createMockDatasource({
|
||||
query: () =>
|
||||
@ -513,21 +328,15 @@ describe('VariableSupport', () => {
|
||||
} as AzureMonitorQuery,
|
||||
],
|
||||
} as DataQueryRequest<AzureMonitorQuery>;
|
||||
const observables = variableSupport.query(mockRequest);
|
||||
observables.subscribe((result: DataQueryResponseData) => {
|
||||
const result = await lastValueFrom(variableSupport.query(mockRequest));
|
||||
expect(result.data).toEqual([]);
|
||||
expect(result.error.message).toEqual('boom');
|
||||
done();
|
||||
});
|
||||
expect(result.error?.message).toEqual('boom');
|
||||
});
|
||||
|
||||
it('should handle http error', (done) => {
|
||||
it('should handle http error', async () => {
|
||||
const error = invalidSubscriptionError();
|
||||
const variableSupport = new VariableSupport(
|
||||
createMockDatasource({
|
||||
azureLogAnalyticsDatasource: {
|
||||
defaultSubscriptionId: 'defaultSubscriptionId',
|
||||
},
|
||||
getResourceGroups: jest.fn().mockRejectedValue(error),
|
||||
})
|
||||
);
|
||||
@ -539,19 +348,17 @@ describe('VariableSupport', () => {
|
||||
grafanaTemplateVariableFn: {
|
||||
kind: 'ResourceGroupsQuery',
|
||||
rawQuery: 'ResourceGroups()',
|
||||
subscription: 'subscriptionId',
|
||||
},
|
||||
} as AzureMonitorQuery,
|
||||
],
|
||||
} as DataQueryRequest<AzureMonitorQuery>;
|
||||
const observables = variableSupport.query(mockRequest);
|
||||
observables.subscribe((result: DataQueryResponseData) => {
|
||||
const result = await lastValueFrom(variableSupport.query(mockRequest));
|
||||
expect(result.error?.message).toBe(error.data.error.message);
|
||||
done();
|
||||
});
|
||||
});
|
||||
|
||||
describe('predefined functions', () => {
|
||||
it('can fetch subscriptions', (done) => {
|
||||
it('can fetch subscriptions', async () => {
|
||||
const fakeSubscriptions = ['subscriptionId'];
|
||||
const variableSupport = new VariableSupport(
|
||||
createMockDatasource({
|
||||
@ -566,14 +373,11 @@ describe('VariableSupport', () => {
|
||||
} as AzureMonitorQuery,
|
||||
],
|
||||
} as DataQueryRequest<AzureMonitorQuery>;
|
||||
const observables = variableSupport.query(mockRequest);
|
||||
observables.subscribe((result: DataQueryResponseData) => {
|
||||
const result = await lastValueFrom(variableSupport.query(mockRequest));
|
||||
expect(result.data[0].source).toEqual(fakeSubscriptions);
|
||||
done();
|
||||
});
|
||||
});
|
||||
|
||||
it('can fetch resourceGroups', (done) => {
|
||||
it('can fetch resourceGroups', async () => {
|
||||
const expectedResults = ['test'];
|
||||
const variableSupport = new VariableSupport(
|
||||
createMockDatasource({
|
||||
@ -589,14 +393,26 @@ describe('VariableSupport', () => {
|
||||
} as AzureMonitorQuery,
|
||||
],
|
||||
} as DataQueryRequest<AzureMonitorQuery>;
|
||||
const observables = variableSupport.query(mockRequest);
|
||||
observables.subscribe((result: DataQueryResponseData) => {
|
||||
const result = await lastValueFrom(variableSupport.query(mockRequest));
|
||||
expect(result.data[0].source).toEqual(expectedResults);
|
||||
done();
|
||||
});
|
||||
});
|
||||
|
||||
it('can fetch namespaces', (done) => {
|
||||
it('returns no data if calling resourceGroups but the subscription is a template variable with no value', async () => {
|
||||
const variableSupport = new VariableSupport(createMockDatasource());
|
||||
const mockRequest = {
|
||||
targets: [
|
||||
{
|
||||
refId: 'A',
|
||||
queryType: AzureQueryType.ResourceGroupsQuery,
|
||||
subscription: '$sub',
|
||||
} as AzureMonitorQuery,
|
||||
],
|
||||
} as DataQueryRequest<AzureMonitorQuery>;
|
||||
const result = await lastValueFrom(variableSupport.query(mockRequest));
|
||||
expect(result.data).toEqual([]);
|
||||
});
|
||||
|
||||
it('can fetch namespaces', async () => {
|
||||
const expectedResults = ['test'];
|
||||
const variableSupport = new VariableSupport(
|
||||
createMockDatasource({
|
||||
@ -612,14 +428,26 @@ describe('VariableSupport', () => {
|
||||
} as AzureMonitorQuery,
|
||||
],
|
||||
} as DataQueryRequest<AzureMonitorQuery>;
|
||||
const observables = variableSupport.query(mockRequest);
|
||||
observables.subscribe((result: DataQueryResponseData) => {
|
||||
const result = await lastValueFrom(variableSupport.query(mockRequest));
|
||||
expect(result.data[0].source).toEqual(expectedResults);
|
||||
done();
|
||||
});
|
||||
});
|
||||
|
||||
it('can fetch resource names', (done) => {
|
||||
it('returns no data if calling namespaces but the subscription is a template variable with no value', async () => {
|
||||
const variableSupport = new VariableSupport(createMockDatasource());
|
||||
const mockRequest = {
|
||||
targets: [
|
||||
{
|
||||
refId: 'A',
|
||||
queryType: AzureQueryType.NamespacesQuery,
|
||||
subscription: '$sub',
|
||||
} as AzureMonitorQuery,
|
||||
],
|
||||
} as DataQueryRequest<AzureMonitorQuery>;
|
||||
const result = await lastValueFrom(variableSupport.query(mockRequest));
|
||||
expect(result.data).toEqual([]);
|
||||
});
|
||||
|
||||
it('can fetch resource names', async () => {
|
||||
const expectedResults = ['test'];
|
||||
const variableSupport = new VariableSupport(
|
||||
createMockDatasource({
|
||||
@ -635,14 +463,26 @@ describe('VariableSupport', () => {
|
||||
} as AzureMonitorQuery,
|
||||
],
|
||||
} as DataQueryRequest<AzureMonitorQuery>;
|
||||
const observables = variableSupport.query(mockRequest);
|
||||
observables.subscribe((result: DataQueryResponseData) => {
|
||||
const result = await lastValueFrom(variableSupport.query(mockRequest));
|
||||
expect(result.data[0].source).toEqual(expectedResults);
|
||||
done();
|
||||
});
|
||||
});
|
||||
|
||||
it('can fetch metric names', (done) => {
|
||||
it('returns no data if calling resourceNames but the subscription is a template variable with no value', async () => {
|
||||
const variableSupport = new VariableSupport(createMockDatasource());
|
||||
const mockRequest = {
|
||||
targets: [
|
||||
{
|
||||
refId: 'A',
|
||||
queryType: AzureQueryType.ResourceNamesQuery,
|
||||
subscription: '$sub',
|
||||
} as AzureMonitorQuery,
|
||||
],
|
||||
} as DataQueryRequest<AzureMonitorQuery>;
|
||||
const result = await lastValueFrom(variableSupport.query(mockRequest));
|
||||
expect(result.data).toEqual([]);
|
||||
});
|
||||
|
||||
it('can fetch metric names', async () => {
|
||||
const expectedResults = ['test'];
|
||||
const variableSupport = new VariableSupport(
|
||||
createMockDatasource({
|
||||
@ -661,14 +501,29 @@ describe('VariableSupport', () => {
|
||||
} as AzureMonitorQuery,
|
||||
],
|
||||
} as DataQueryRequest<AzureMonitorQuery>;
|
||||
const observables = variableSupport.query(mockRequest);
|
||||
observables.subscribe((result: DataQueryResponseData) => {
|
||||
const result = await lastValueFrom(variableSupport.query(mockRequest));
|
||||
expect(result.data[0].source).toEqual(expectedResults);
|
||||
done();
|
||||
});
|
||||
});
|
||||
|
||||
it('can fetch workspaces', (done) => {
|
||||
it('returns no data if calling metric names but the subscription is a template variable with no value', async () => {
|
||||
const variableSupport = new VariableSupport(createMockDatasource());
|
||||
const mockRequest = {
|
||||
targets: [
|
||||
{
|
||||
refId: 'A',
|
||||
queryType: AzureQueryType.ResourceNamesQuery,
|
||||
subscription: '$sub',
|
||||
resourceGroup: 'rg',
|
||||
namespace: 'ns',
|
||||
resource: 'rn',
|
||||
} as AzureMonitorQuery,
|
||||
],
|
||||
} as DataQueryRequest<AzureMonitorQuery>;
|
||||
const result = await lastValueFrom(variableSupport.query(mockRequest));
|
||||
expect(result.data).toEqual([]);
|
||||
});
|
||||
|
||||
it('can fetch workspaces', async () => {
|
||||
const expectedResults = ['test'];
|
||||
const variableSupport = new VariableSupport(
|
||||
createMockDatasource({
|
||||
@ -684,11 +539,8 @@ describe('VariableSupport', () => {
|
||||
} as AzureMonitorQuery,
|
||||
],
|
||||
} as DataQueryRequest<AzureMonitorQuery>;
|
||||
const observables = variableSupport.query(mockRequest);
|
||||
observables.subscribe((result: DataQueryResponseData) => {
|
||||
const result = await lastValueFrom(variableSupport.query(mockRequest));
|
||||
expect(result.data[0].source).toEqual(expectedResults);
|
||||
done();
|
||||
});
|
||||
});
|
||||
});
|
||||
});
|
||||
|
||||
@ -17,14 +17,21 @@ import { GrafanaTemplateVariableQuery } from './types/templateVariables';
|
||||
import messageFromError from './utils/messageFromError';
|
||||
|
||||
export class VariableSupport extends CustomVariableSupport<DataSource, AzureMonitorQuery> {
|
||||
templateSrv = getTemplateSrv();
|
||||
|
||||
constructor(private readonly datasource: DataSource) {
|
||||
super();
|
||||
this.datasource = datasource;
|
||||
this.query = this.query.bind(this);
|
||||
this.templateSrv = getTemplateSrv();
|
||||
}
|
||||
|
||||
editor = VariableEditor;
|
||||
|
||||
hasValue(...values: string[]) {
|
||||
return values.every((v) => !!this.templateSrv.replace(v));
|
||||
}
|
||||
|
||||
query(request: DataQueryRequest<AzureMonitorQuery>): Observable<DataQueryResponse> {
|
||||
const promisedResults = async () => {
|
||||
const queryObj = await migrateQuery(request.targets[0], { datasource: this.datasource });
|
||||
@ -37,21 +44,23 @@ export class VariableSupport extends CustomVariableSupport<DataSource, AzureMoni
|
||||
data: res?.length ? [toDataFrame(res)] : [],
|
||||
};
|
||||
case AzureQueryType.ResourceGroupsQuery:
|
||||
if (queryObj.subscription) {
|
||||
if (queryObj.subscription && this.hasValue(queryObj.subscription)) {
|
||||
const rgs = await this.datasource.getResourceGroups(queryObj.subscription);
|
||||
return {
|
||||
data: rgs?.length ? [toDataFrame(rgs)] : [],
|
||||
};
|
||||
}
|
||||
return { data: [] };
|
||||
case AzureQueryType.NamespacesQuery:
|
||||
if (queryObj.subscription) {
|
||||
if (queryObj.subscription && this.hasValue(queryObj.subscription)) {
|
||||
const rgs = await this.datasource.getMetricNamespaces(queryObj.subscription, queryObj.resourceGroup);
|
||||
return {
|
||||
data: rgs?.length ? [toDataFrame(rgs)] : [],
|
||||
};
|
||||
}
|
||||
return { data: [] };
|
||||
case AzureQueryType.ResourceNamesQuery:
|
||||
if (queryObj.subscription) {
|
||||
if (queryObj.subscription && this.hasValue(queryObj.subscription)) {
|
||||
const rgs = await this.datasource.getResourceNames(
|
||||
queryObj.subscription,
|
||||
queryObj.resourceGroup,
|
||||
@ -61,8 +70,15 @@ export class VariableSupport extends CustomVariableSupport<DataSource, AzureMoni
|
||||
data: rgs?.length ? [toDataFrame(rgs)] : [],
|
||||
};
|
||||
}
|
||||
return { data: [] };
|
||||
case AzureQueryType.MetricNamesQuery:
|
||||
if (queryObj.subscription && queryObj.resourceGroup && queryObj.namespace && queryObj.resource) {
|
||||
if (
|
||||
queryObj.subscription &&
|
||||
queryObj.resourceGroup &&
|
||||
queryObj.namespace &&
|
||||
queryObj.resource &&
|
||||
this.hasValue(queryObj.subscription, queryObj.resourceGroup, queryObj.namespace, queryObj.resource)
|
||||
) {
|
||||
const rgs = await this.datasource.getMetricNames(
|
||||
queryObj.subscription,
|
||||
queryObj.resourceGroup,
|
||||
@ -73,13 +89,15 @@ export class VariableSupport extends CustomVariableSupport<DataSource, AzureMoni
|
||||
data: rgs?.length ? [toDataFrame(rgs)] : [],
|
||||
};
|
||||
}
|
||||
return { data: [] };
|
||||
case AzureQueryType.WorkspacesQuery:
|
||||
if (queryObj.subscription) {
|
||||
if (queryObj.subscription && this.hasValue(queryObj.subscription)) {
|
||||
const rgs = await this.datasource.getAzureLogAnalyticsWorkspaces(queryObj.subscription);
|
||||
return {
|
||||
data: rgs?.length ? [toDataFrame(rgs)] : [],
|
||||
};
|
||||
}
|
||||
return { data: [] };
|
||||
case AzureQueryType.GrafanaTemplateVariableFn:
|
||||
if (queryObj.grafanaTemplateVariableFn) {
|
||||
const templateVariablesResults = await this.callGrafanaTemplateVariableFn(
|
||||
@ -89,6 +107,7 @@ export class VariableSupport extends CustomVariableSupport<DataSource, AzureMoni
|
||||
data: templateVariablesResults?.length ? [toDataFrame(templateVariablesResults)] : [],
|
||||
};
|
||||
}
|
||||
return { data: [] };
|
||||
default:
|
||||
request.targets[0] = queryObj;
|
||||
const queryResp = await lastValueFrom(this.datasource.query(request));
|
||||
|
||||
Loading…
Reference in New Issue
Block a user