// Libraries import React, { PureComponent } from 'react'; import classNames from 'classnames'; import _ from 'lodash'; // Utils & Services import { getDatasourceSrv } from 'app/features/plugins/datasource_srv'; import { AngularComponent, getAngularLoader, getTemplateSrv } from '@grafana/runtime'; import { getTimeSrv } from 'app/features/dashboard/services/TimeSrv'; import { ErrorBoundaryAlert, HorizontalGroup, InfoBox } from '@grafana/ui'; import { DataQuery, DataSourceApi, DataSourceInstanceSettings, EventBusExtended, EventBusSrv, LoadingState, PanelData, PanelEvents, TimeRange, toLegacyResponseData, } from '@grafana/data'; import { QueryEditorRowTitle } from './QueryEditorRowTitle'; import { QueryOperationRow, QueryOperationRowRenderProps, } from 'app/core/components/QueryOperationRow/QueryOperationRow'; import { QueryOperationAction } from 'app/core/components/QueryOperationRow/QueryOperationAction'; import { DashboardModel } from '../../dashboard/state/DashboardModel'; import { selectors } from '@grafana/e2e-selectors'; import { PanelModel } from 'app/features/dashboard/state'; interface Props { data: PanelData; query: DataQuery; queries: DataQuery[]; dsSettings: DataSourceInstanceSettings; id: string; index: number; onAddQuery: (query?: DataQuery) => void; onRemoveQuery: (query: DataQuery) => void; onChange: (query: DataQuery) => void; onRunQuery: () => void; } interface State { loadedDataSourceIdentifier?: string | null; datasource: DataSourceApi | null; hasTextEditMode: boolean; data?: PanelData; isOpen?: boolean; showingHelp: boolean; } export class QueryEditorRow extends PureComponent { element: HTMLElement | null = null; angularScope: AngularQueryComponentScope | null; angularQueryEditor: AngularComponent | null = null; state: State = { datasource: null, hasTextEditMode: false, data: undefined, isOpen: true, showingHelp: false, }; componentDidMount() { this.loadDatasource(); } componentWillUnmount() { if (this.angularQueryEditor) { this.angularQueryEditor.destroy(); } } getAngularQueryComponentScope(): AngularQueryComponentScope { const { query, queries } = this.props; const { datasource } = this.state; const panel = new PanelModel({ targets: queries }); const dashboard = {} as DashboardModel; const me = this; return { datasource: datasource, target: query, panel: panel, dashboard: dashboard, refresh: () => { // Old angular editors modify the query model and just call refresh // Important that this use this.props here so that as this fuction is only created on mount and it's // important not to capture old prop functions in this closure // the "hide" attribute of the quries can be changed from the "outside", // it will be applied to "this.props.query.hide", but not to "query.hide". // so we have to apply it. if (query.hide !== me.props.query.hide) { query.hide = me.props.query.hide; } this.props.onChange(query); this.props.onRunQuery(); }, render: () => () => console.log('legacy render function called, it does nothing'), events: new EventBusSrv(), range: getTimeSrv().timeRange(), }; } getQueryDataSourceIdentifier(): string | null | undefined { const { query, dsSettings } = this.props; return query.datasource ?? dsSettings.name; } async loadDatasource() { const dataSourceSrv = getDatasourceSrv(); let datasource: DataSourceApi; const dataSourceIdentifier = this.getQueryDataSourceIdentifier(); try { datasource = await dataSourceSrv.get(dataSourceIdentifier); } catch (error) { datasource = await dataSourceSrv.get(); } this.setState({ datasource, loadedDataSourceIdentifier: dataSourceIdentifier, hasTextEditMode: _.has(datasource, 'components.QueryCtrl.prototype.toggleEditorMode'), }); } componentDidUpdate(prevProps: Props) { const { datasource, loadedDataSourceIdentifier } = this.state; const { data, query } = this.props; if (data !== prevProps.data) { const dataFilteredByRefId = filterPanelDataToQuery(data, query.refId); this.setState({ data: dataFilteredByRefId }); if (this.angularScope) { this.angularScope.range = getTimeSrv().timeRange(); } if (this.angularQueryEditor && dataFilteredByRefId) { notifyAngularQueryEditorsOfData(this.angularScope!, dataFilteredByRefId, this.angularQueryEditor); } } // check if we need to load another datasource if (datasource && loadedDataSourceIdentifier !== this.getQueryDataSourceIdentifier()) { if (this.angularQueryEditor) { this.angularQueryEditor.destroy(); this.angularQueryEditor = null; } this.loadDatasource(); return; } if (!this.element || this.angularQueryEditor) { return; } this.renderAngularQueryEditor(); } renderAngularQueryEditor = () => { if (!this.element) { return; } if (this.angularQueryEditor) { this.angularQueryEditor.destroy(); this.angularQueryEditor = null; } const loader = getAngularLoader(); const template = ''; const scopeProps = { ctrl: this.getAngularQueryComponentScope() }; this.angularQueryEditor = loader.load(this.element, scopeProps, template); this.angularScope = scopeProps.ctrl; }; onOpen = () => { this.renderAngularQueryEditor(); }; renderPluginEditor = () => { const { query, onChange, queries, onRunQuery } = this.props; const { datasource, data } = this.state; if (datasource?.components?.QueryCtrl) { return
(this.element = element)} />; } if (datasource?.components?.QueryEditor) { const QueryEditor = datasource.components.QueryEditor; return ( ); } return
Data source plugin does not export any Query Editor component
; }; onToggleEditMode = (e: React.MouseEvent, props: QueryOperationRowRenderProps) => { e.stopPropagation(); if (this.angularScope && this.angularScope.toggleEditorMode) { this.angularScope.toggleEditorMode(); this.angularQueryEditor?.digest(); if (!props.isOpen) { props.onOpen(); } } }; onRemoveQuery = () => { this.props.onRemoveQuery(this.props.query); }; onCopyQuery = () => { const copy = _.cloneDeep(this.props.query); this.props.onAddQuery(copy); }; onDisableQuery = () => { const { query } = this.props; this.props.onChange({ ...query, hide: !query.hide }); this.props.onRunQuery(); }; onToggleHelp = () => { this.setState((state) => ({ showingHelp: !state.showingHelp, })); }; onClickExample = (query: DataQuery) => { this.props.onChange({ ...query, refId: this.props.query.refId, }); this.onToggleHelp(); }; renderCollapsedText(): string | null { const { datasource } = this.state; if (datasource?.getQueryDisplayText) { return datasource.getQueryDisplayText(this.props.query); } if (this.angularScope && this.angularScope.getCollapsedText) { return this.angularScope.getCollapsedText(); } return null; } renderActions = (props: QueryOperationRowRenderProps) => { const { query } = this.props; const { hasTextEditMode, datasource } = this.state; const isDisabled = query.hide; const hasEditorHelp = datasource?.components?.QueryEditorHelp; return ( {hasEditorHelp && ( )} {hasTextEditMode && ( { this.onToggleEditMode(e, props); }} /> )} ); }; renderTitle = (props: QueryOperationRowRenderProps) => { const { query, dsSettings, onChange, queries } = this.props; const dataSourceName = dsSettings.meta.mixed ? getTemplateSrv().replace(this.getQueryDataSourceIdentifier() ?? '') : undefined; const isDisabled = query.hide; return ( this.onToggleEditMode(e, props)} onChange={onChange} collapsedText={!props.isOpen ? this.renderCollapsedText() : null} /> ); }; render() { const { query, id, index } = this.props; const { datasource, showingHelp } = this.state; const isDisabled = query.hide; const rowClasses = classNames('query-editor-row', { 'query-editor-row--disabled': isDisabled, 'gf-form-disabled': isDisabled, }); if (!datasource) { return null; } const editor = this.renderPluginEditor(); const DatasourceCheatsheet = datasource.components?.QueryEditorHelp; return (
{showingHelp && DatasourceCheatsheet && ( this.onClickExample(query)} datasource={datasource} /> )} {editor}
); } } function notifyAngularQueryEditorsOfData(scope: AngularQueryComponentScope, data: PanelData, editor: AngularComponent) { if (data.state === LoadingState.Done) { const legacy = data.series.map((v) => toLegacyResponseData(v)); scope.events.emit(PanelEvents.dataReceived, legacy); } else if (data.state === LoadingState.Error) { scope.events.emit(PanelEvents.dataError, data.error); } // Some query controllers listen to data error events and need a digest // for some reason this needs to be done in next tick setTimeout(editor.digest); } export interface AngularQueryComponentScope { target: DataQuery; panel: PanelModel; dashboard: DashboardModel; events: EventBusExtended; refresh: () => void; render: () => void; datasource: DataSourceApi | null; toggleEditorMode?: () => void; getCollapsedText?: () => string; range: TimeRange; } /** * Get a version of the PanelData limited to the query we are looking at */ export function filterPanelDataToQuery(data: PanelData, refId: string): PanelData | undefined { const series = data.series.filter((series) => series.refId === refId); // No matching series if (!series.length) { // If there was an error with no data, pass it to the QueryEditors if (data.error && !data.series.length) { return { ...data, state: LoadingState.Error, }; } return undefined; } // Only say this is an error if the error links to the query let state = LoadingState.Done; const error = data.error && data.error.refId === refId ? data.error : undefined; if (error) { state = LoadingState.Error; } const timeRange = data.timeRange; return { ...data, state, series, error, timeRange, }; }