import {EventsStatsFixture} from 'sentry-fixture/events'; import {OrganizationFixture} from 'sentry-fixture/organization'; import {initializeOrg} from 'sentry-test/initializeOrg'; import {render, screen, waitFor} from 'sentry-test/reactTestingLibrary'; import type {PageFilters} from 'sentry/types/core'; import {MetricsResultsMetaProvider} from 'sentry/utils/performance/contexts/metricsEnhancedPerformanceDataContext'; import {MEPSettingProvider} from 'sentry/utils/performance/contexts/metricsEnhancedSetting'; import {DashboardFilterKeys, DisplayType} from 'sentry/views/dashboards/types'; import {DashboardsMEPContext} from 'sentry/views/dashboards/widgetCard/dashboardsMEPContext'; import type {GenericWidgetQueriesChildrenProps} from 'sentry/views/dashboards/widgetCard/genericWidgetQueries'; import WidgetQueries, { flattenMultiSeriesDataWithGrouping, } from 'sentry/views/dashboards/widgetCard/widgetQueries'; describe('Dashboards > WidgetQueries', function () { const initialData = initializeOrg(); const renderWithProviders = component => render( {component} ); const multipleQueryWidget = { title: 'Errors', interval: '5m', displayType: DisplayType.LINE, queries: [ { conditions: 'event.type:error', fields: ['count()'], aggregates: ['count()'], columns: [], name: 'errors', orderby: '', }, { conditions: 'event.type:default', fields: ['count()'], aggregates: ['count()'], columns: [], name: 'default', orderby: '', }, ], }; const singleQueryWidget = { title: 'Errors', interval: '5m', displayType: DisplayType.LINE, queries: [ { conditions: 'event.type:error', fields: ['count()'], aggregates: ['count()'], columns: [], name: 'errors', orderby: '', }, ], }; const tableWidget = { title: 'SDK', interval: '5m', displayType: DisplayType.TABLE, queries: [ { conditions: 'event.type:error', fields: ['sdk.name'], aggregates: [], columns: ['sdk.name'], name: 'sdk', orderby: '', }, ], }; const selection: PageFilters = { projects: [1], environments: ['prod'], datetime: { period: '14d', start: null, end: null, utc: false, }, }; afterEach(function () { MockApiClient.clearMockResponses(); }); it('can send multiple API requests', async function () { const errorMock = MockApiClient.addMockResponse({ url: '/organizations/org-slug/events-stats/', body: [], match: [MockApiClient.matchQuery({query: 'event.type:error'})], }); const defaultMock = MockApiClient.addMockResponse({ url: '/organizations/org-slug/events-stats/', body: [], match: [MockApiClient.matchQuery({query: 'event.type:default'})], }); renderWithProviders( {() =>
} ); // Child should be rendered and 2 requests should be sent. await screen.findByTestId('child'); expect(errorMock).toHaveBeenCalledTimes(1); expect(defaultMock).toHaveBeenCalledTimes(1); }); it('appends dashboard filters to events series request', async function () { const mock = MockApiClient.addMockResponse({ url: '/organizations/org-slug/events-stats/', body: [], }); renderWithProviders( {() =>
} ); await screen.findByTestId('child'); expect(mock).toHaveBeenCalledWith( '/organizations/org-slug/events-stats/', expect.objectContaining({ query: expect.objectContaining({ query: 'event.type:error release:["abc@1.2.0","abc@1.3.0"] ', }), }) ); }); it('appends dashboard filters to events table request', async function () { const mock = MockApiClient.addMockResponse({ url: '/organizations/org-slug/events/', body: [], }); renderWithProviders( {() =>
} ); await screen.findByTestId('child'); expect(mock).toHaveBeenCalledWith( '/organizations/org-slug/events/', expect.objectContaining({ query: expect.objectContaining({ query: 'event.type:error release:"abc@1.3.0" ', }), }) ); }); it('sets errorMessage when the first request fails', async function () { const okMock = MockApiClient.addMockResponse({ url: '/organizations/org-slug/events-stats/', match: [MockApiClient.matchQuery({query: 'event.type:error'})], body: [], }); const failMock = MockApiClient.addMockResponse({ url: '/organizations/org-slug/events-stats/', statusCode: 400, body: {detail: 'Bad request data'}, match: [MockApiClient.matchQuery({query: 'event.type:default'})], }); let error: string | undefined; renderWithProviders( {({errorMessage}: {errorMessage?: string}) => { error = errorMessage; return
; }} ); // Child should be rendered and 2 requests should be sent. expect(await screen.findByTestId('child')).toBeInTheDocument(); await waitFor(() => { expect(error).toEqual('Bad request data'); }); expect(okMock).toHaveBeenCalledTimes(1); expect(failMock).toHaveBeenCalledTimes(1); }); it('adjusts interval based on date window', async function () { const errorMock = MockApiClient.addMockResponse({ url: '/organizations/org-slug/events-stats/', body: [], }); const widget = {...singleQueryWidget, interval: '1m'}; const longSelection: PageFilters = { projects: [1], environments: ['prod', 'dev'], datetime: { period: '90d', start: null, end: null, utc: false, }, }; renderWithProviders( {() =>
} ); // Child should be rendered and interval bumped up. await screen.findByTestId('child'); expect(errorMock).toHaveBeenCalledTimes(1); expect(errorMock).toHaveBeenCalledWith( '/organizations/org-slug/events-stats/', expect.objectContaining({ query: expect.objectContaining({ interval: '4h', statsPeriod: '90d', environment: ['prod', 'dev'], project: [1], }), }) ); }); it('adjusts interval based on date window 14d', async function () { const errorMock = MockApiClient.addMockResponse({ url: '/organizations/org-slug/events-stats/', body: [], }); const widget = {...singleQueryWidget, interval: '1m'}; renderWithProviders( {() =>
} ); // Child should be rendered and interval bumped up. await screen.findByTestId('child'); expect(errorMock).toHaveBeenCalledTimes(1); expect(errorMock).toHaveBeenCalledWith( '/organizations/org-slug/events-stats/', expect.objectContaining({ query: expect.objectContaining({interval: '30m'}), }) ); }); it('can send table result queries', async function () { const tableMock = MockApiClient.addMockResponse({ url: '/organizations/org-slug/events/', body: { meta: {'sdk.name': 'string'}, data: [{'sdk.name': 'python'}], }, }); let childProps: GenericWidgetQueriesChildrenProps | undefined; renderWithProviders( {props => { childProps = props; return
; }} ); // Child should be rendered and 1 requests should be sent. await screen.findByTestId('child'); expect(tableMock).toHaveBeenCalledTimes(1); expect(tableMock).toHaveBeenCalledWith( '/organizations/org-slug/events/', expect.objectContaining({ query: expect.objectContaining({ query: 'event.type:error', field: ['sdk.name'], statsPeriod: '14d', environment: ['prod'], project: [1], }), }) ); expect(childProps?.timeseriesResults).toBeUndefined(); await waitFor(() => expect(childProps?.tableResults?.[0].data).toHaveLength(1)); expect(childProps?.tableResults?.[0].meta).toBeDefined(); }); it('can send multiple table queries', async function () { const firstQuery = MockApiClient.addMockResponse({ url: '/organizations/org-slug/events/', body: { meta: {'sdk.name': 'string'}, data: [{'sdk.name': 'python'}], }, match: [MockApiClient.matchQuery({query: 'event.type:error'})], }); const secondQuery = MockApiClient.addMockResponse({ url: '/organizations/org-slug/events/', body: { meta: {title: 'string'}, data: [{title: 'ValueError'}], }, match: [MockApiClient.matchQuery({query: 'title:ValueError'})], }); const widget = { title: 'SDK', interval: '5m', displayType: DisplayType.TABLE, queries: [ { conditions: 'event.type:error', fields: ['sdk.name'], aggregates: [], columns: ['sdk.name'], name: 'sdk', orderby: '', }, { conditions: 'title:ValueError', fields: ['title'], aggregates: [], columns: ['sdk.name'], name: 'title', orderby: '', }, ], }; let childProps: GenericWidgetQueriesChildrenProps | undefined; renderWithProviders( {props => { childProps = props; return
; }} ); // Child should be rendered and 2 requests should be sent. await screen.findByTestId('child'); expect(firstQuery).toHaveBeenCalledTimes(1); expect(secondQuery).toHaveBeenCalledTimes(1); await waitFor(() => expect(childProps?.tableResults).toHaveLength(2)); expect(childProps?.tableResults?.[0].data[0]['sdk.name']).toBeDefined(); expect(childProps?.tableResults?.[1].data[0].title).toBeDefined(); }); it('can send big number result queries', async function () { const tableMock = MockApiClient.addMockResponse({ url: '/organizations/org-slug/events/', body: { meta: {'sdk.name': 'string'}, data: [{'sdk.name': 'python'}], }, }); let childProps: GenericWidgetQueriesChildrenProps | undefined; renderWithProviders( {props => { childProps = props; return
; }} ); // Child should be rendered and 1 requests should be sent. await screen.findByTestId('child'); expect(tableMock).toHaveBeenCalledTimes(1); expect(tableMock).toHaveBeenCalledWith( '/organizations/org-slug/events/', expect.objectContaining({ query: expect.objectContaining({ referrer: 'api.dashboards.bignumberwidget', query: 'event.type:error', field: ['sdk.name'], statsPeriod: '14d', environment: ['prod'], project: [1], }), }) ); expect(childProps?.timeseriesResults).toBeUndefined(); await waitFor(() => expect(childProps?.tableResults?.[0]?.data).toHaveLength(1)); expect(childProps?.tableResults?.[0]?.meta).toBeDefined(); }); it('stops loading state once all queries finish even if some fail', async function () { const firstQuery = MockApiClient.addMockResponse({ statusCode: 500, url: '/organizations/org-slug/events/', body: {detail: 'it didnt work'}, match: [MockApiClient.matchQuery({query: 'event.type:error'})], }); const secondQuery = MockApiClient.addMockResponse({ url: '/organizations/org-slug/events/', body: { meta: {title: 'string'}, data: [{title: 'ValueError'}], }, match: [MockApiClient.matchQuery({query: 'title:ValueError'})], }); const widget = { title: 'SDK', interval: '5m', displayType: DisplayType.TABLE, queries: [ { conditions: 'event.type:error', fields: ['sdk.name'], aggregates: [], columns: ['sdk.name'], name: 'sdk', orderby: '', }, { conditions: 'title:ValueError', fields: ['sdk.name'], aggregates: [], columns: ['sdk.name'], name: 'title', orderby: '', }, ], }; let childProps: GenericWidgetQueriesChildrenProps | undefined; renderWithProviders( {props => { childProps = props; return
; }} ); // Child should be rendered and 2 requests should be sent. await screen.findByTestId('child'); expect(firstQuery).toHaveBeenCalledTimes(1); expect(secondQuery).toHaveBeenCalledTimes(1); await waitFor(() => expect(childProps?.loading).toEqual(false)); }); it('sets bar charts to 1d interval', async function () { const errorMock = MockApiClient.addMockResponse({ url: '/organizations/org-slug/events-stats/', body: [], match: [MockApiClient.matchQuery({interval: '1d'})], }); const barWidget = { ...singleQueryWidget, displayType: DisplayType.BAR, // Should be ignored for bars. interval: '5m', }; renderWithProviders( {() =>
} ); // Child should be rendered and 1 requests should be sent. await screen.findByTestId('child'); expect(errorMock).toHaveBeenCalledTimes(1); }); it('returns timeseriesResults in the same order as widgetQuery', async function () { MockApiClient.clearMockResponses(); const defaultMock = MockApiClient.addMockResponse({ url: '/organizations/org-slug/events-stats/', method: 'GET', body: { data: [ [ 1000, [ { count: 100, }, ], ], ], start: 1000, end: 2000, }, match: [MockApiClient.matchQuery({query: 'event.type:default'})], }); const errorMock = MockApiClient.addMockResponse({ url: '/organizations/org-slug/events-stats/', method: 'GET', body: { data: [ [ 1000, [ { count: 200, }, ], ], ], start: 1000, end: 2000, }, match: [MockApiClient.matchQuery({query: 'event.type:error'})], }); const barWidget = { ...multipleQueryWidget, displayType: DisplayType.BAR, // Should be ignored for bars. interval: '5m', }; const child = jest.fn(() =>
); renderWithProviders( {child} ); await screen.findByTestId('child'); expect(defaultMock).toHaveBeenCalledTimes(1); expect(errorMock).toHaveBeenCalledTimes(1); await waitFor(() => expect(child).toHaveBeenLastCalledWith( expect.objectContaining({ timeseriesResults: [ {data: [{name: 1000000, value: 200}], seriesName: 'errors : count()'}, {data: [{name: 1000000, value: 100}], seriesName: 'default : count()'}, ], }) ) ); }); it('calls events-stats with 4h interval when interval buckets would exceed 66', async function () { const eventsStatsMock = MockApiClient.addMockResponse({ url: '/organizations/org-slug/events-stats/', body: [], }); const areaWidget = { ...singleQueryWidget, displayType: DisplayType.AREA, interval: '5m', }; renderWithProviders( {() =>
} ); // Child should be rendered and 1 requests should be sent. await screen.findByTestId('child'); expect(eventsStatsMock).toHaveBeenCalledTimes(1); expect(eventsStatsMock).toHaveBeenCalledWith( '/organizations/org-slug/events-stats/', expect.objectContaining({query: expect.objectContaining({interval: '4h'})}) ); }); it('does not re-query events and sets name in widgets', async function () { const eventsStatsMock = MockApiClient.addMockResponse({ url: '/organizations/org-slug/events-stats/', body: EventsStatsFixture(), }); const lineWidget = { ...singleQueryWidget, displayType: DisplayType.LINE, interval: '5m', }; let childProps; const {rerender} = renderWithProviders( {props => { childProps = props; return
; }} ); expect(eventsStatsMock).toHaveBeenCalledTimes(1); await waitFor(() => expect(childProps.loading).toEqual(false)); // Simulate a re-render with a new query alias rerender( {props => { childProps = props; return
; }} ); // Did not re-query expect(eventsStatsMock).toHaveBeenCalledTimes(1); expect(childProps.timeseriesResults[0].seriesName).toEqual( 'this query alias changed : count()' ); }); describe('multi-series grouped data', () => { const [START, END] = [1647399900, 1647399901]; let mockCountData, mockCountUniqueData, mockRawResultData; beforeEach(() => { mockCountData = { start: START, end: END, data: [ [START, [{'count()': 0}]], [END, [{'count()': 0}]], ], }; mockCountUniqueData = { start: START, end: END, data: [ [START, [{'count_unique()': 0}]], [END, [{'count_unique()': 0}]], ], }; mockRawResultData = { local: { 'count()': mockCountData, 'count_unique()': mockCountUniqueData, order: 0, }, prod: { 'count()': mockCountData, 'count_unique()': mockCountUniqueData, order: 1, }, }; }); it('combines group name and aggregate names in grouped multi series data', () => { const actual = flattenMultiSeriesDataWithGrouping(mockRawResultData, ''); expect(actual).toEqual([ [ 0, expect.objectContaining({ seriesName: 'local : count()', data: expect.anything(), }), ], [ 0, expect.objectContaining({ seriesName: 'local : count_unique()', data: expect.anything(), }), ], [ 1, expect.objectContaining({ seriesName: 'prod : count()', data: expect.anything(), }), ], [ 1, expect.objectContaining({ seriesName: 'prod : count_unique()', data: expect.anything(), }), ], ]); }); it('prefixes with a query alias when provided', () => { const actual = flattenMultiSeriesDataWithGrouping(mockRawResultData, 'Query 1'); expect(actual).toEqual([ [ 0, expect.objectContaining({ seriesName: 'Query 1 > local : count()', data: expect.anything(), }), ], [ 0, expect.objectContaining({ seriesName: 'Query 1 > local : count_unique()', data: expect.anything(), }), ], [ 1, expect.objectContaining({ seriesName: 'Query 1 > prod : count()', data: expect.anything(), }), ], [ 1, expect.objectContaining({ seriesName: 'Query 1 > prod : count_unique()', data: expect.anything(), }), ], ]); }); }); it('charts send metricsEnhanced requests', async function () { const {organization} = initialData; const mock = MockApiClient.addMockResponse({ url: '/organizations/org-slug/events-stats/', body: { data: [ [ 1000, [ { count: 100, }, ], ], ], isMetricsData: false, start: 1000, end: 2000, }, }); const setIsMetricsMock = jest.fn(); const children = jest.fn(() =>
); renderWithProviders( {children} ); expect(mock).toHaveBeenCalledWith( '/organizations/org-slug/events-stats/', expect.objectContaining({ query: expect.objectContaining({dataset: 'metricsEnhanced'}), }) ); await waitFor(() => { expect(setIsMetricsMock).toHaveBeenCalledWith(false); }); }); it('tables send metricsEnhanced requests', async function () { const {organization} = initialData; const mock = MockApiClient.addMockResponse({ url: '/organizations/org-slug/events/', body: { meta: {title: 'string', isMetricsData: true}, data: [{title: 'ValueError'}], }, }); const setIsMetricsMock = jest.fn(); const children = jest.fn(() =>
); renderWithProviders( {children} ); expect(mock).toHaveBeenCalledWith( '/organizations/org-slug/events/', expect.objectContaining({ query: expect.objectContaining({dataset: 'metricsEnhanced'}), }) ); await waitFor(() => { expect(setIsMetricsMock).toHaveBeenCalledWith(true); }); }); it('does not inject equation aliases for top N requests', async function () { const testData = initializeOrg({ organization: { ...OrganizationFixture(), }, }); const eventsStatsMock = MockApiClient.addMockResponse({ url: '/organizations/org-slug/events-stats/', body: [], }); const areaWidget = { title: 'Errors', displayType: DisplayType.AREA, interval: '5m', queries: [ { conditions: 'event.type:error', fields: [], aggregates: ['count()', 'equation|count() * 2'], columns: ['project'], orderby: 'equation[0]', name: '', }, ], }; renderWithProviders( {() =>
} ); // Child should be rendered and 1 requests should be sent. await screen.findByTestId('child'); expect(eventsStatsMock).toHaveBeenCalledTimes(1); expect(eventsStatsMock).toHaveBeenCalledWith( '/organizations/org-slug/events-stats/', expect.objectContaining({ query: expect.objectContaining({ field: ['project', 'count()', 'equation|count() * 2'], orderby: 'equation[0]', }), }) ); }); });