QueryRow.tsx 5.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163
  1. import React, { PureComponent } from 'react';
  2. import { hot } from 'react-hot-loader';
  3. import { connect } from 'react-redux';
  4. import { RawTimeRange } from '@grafana/ui';
  5. import _ from 'lodash';
  6. import { QueryTransaction, HistoryItem, QueryHint, ExploreItemState, ExploreId } from 'app/types/explore';
  7. import { Emitter } from 'app/core/utils/emitter';
  8. import { DataQuery, StoreState } from 'app/types';
  9. // import DefaultQueryField from './QueryField';
  10. import QueryEditor from './QueryEditor';
  11. import QueryTransactionStatus from './QueryTransactionStatus';
  12. import {
  13. addQueryRow,
  14. changeQuery,
  15. highlightLogsExpression,
  16. modifyQueries,
  17. removeQueryRow,
  18. runQueries,
  19. } from './state/actions';
  20. function getFirstHintFromTransactions(transactions: QueryTransaction[]): QueryHint {
  21. const transaction = transactions.find(qt => qt.hints && qt.hints.length > 0);
  22. if (transaction) {
  23. return transaction.hints[0];
  24. }
  25. return undefined;
  26. }
  27. interface QueryRowProps {
  28. addQueryRow: typeof addQueryRow;
  29. changeQuery: typeof changeQuery;
  30. className?: string;
  31. exploreId: ExploreId;
  32. datasourceInstance: any;
  33. highlightLogsExpression: typeof highlightLogsExpression;
  34. history: HistoryItem[];
  35. index: number;
  36. initialQuery: DataQuery;
  37. modifyQueries: typeof modifyQueries;
  38. queryTransactions: QueryTransaction[];
  39. exploreEvents: Emitter;
  40. range: RawTimeRange;
  41. removeQueryRow: typeof removeQueryRow;
  42. runQueries: typeof runQueries;
  43. }
  44. export class QueryRow extends PureComponent<QueryRowProps> {
  45. onExecuteQuery = () => {
  46. const { exploreId } = this.props;
  47. this.props.runQueries(exploreId);
  48. };
  49. onChangeQuery = (query: DataQuery, override?: boolean) => {
  50. const { datasourceInstance, exploreId, index } = this.props;
  51. this.props.changeQuery(exploreId, query, index, override);
  52. if (query && !override && datasourceInstance.getHighlighterExpression && index === 0) {
  53. // Live preview of log search matches. Only use on first row for now
  54. this.updateLogsHighlights(query);
  55. }
  56. };
  57. onClickAddButton = () => {
  58. const { exploreId, index } = this.props;
  59. this.props.addQueryRow(exploreId, index);
  60. };
  61. onClickClearButton = () => {
  62. this.onChangeQuery(null, true);
  63. };
  64. onClickHintFix = action => {
  65. const { datasourceInstance, exploreId, index } = this.props;
  66. if (datasourceInstance && datasourceInstance.modifyQuery) {
  67. const modifier = (queries: DataQuery, action: any) => datasourceInstance.modifyQuery(queries, action);
  68. this.props.modifyQueries(exploreId, action, index, modifier);
  69. }
  70. };
  71. onClickRemoveButton = () => {
  72. const { exploreId, index } = this.props;
  73. this.props.removeQueryRow(exploreId, index);
  74. };
  75. updateLogsHighlights = _.debounce((value: DataQuery) => {
  76. const { datasourceInstance } = this.props;
  77. if (datasourceInstance.getHighlighterExpression) {
  78. const expressions = [datasourceInstance.getHighlighterExpression(value)];
  79. this.props.highlightLogsExpression(this.props.exploreId, expressions);
  80. }
  81. }, 500);
  82. render() {
  83. const { datasourceInstance, history, index, initialQuery, queryTransactions, exploreEvents, range } = this.props;
  84. const transactions = queryTransactions.filter(t => t.rowIndex === index);
  85. const transactionWithError = transactions.find(t => t.error !== undefined);
  86. const hint = getFirstHintFromTransactions(transactions);
  87. const queryError = transactionWithError ? transactionWithError.error : null;
  88. const QueryField = datasourceInstance.pluginExports.ExploreQueryField;
  89. return (
  90. <div className="query-row">
  91. <div className="query-row-status">
  92. <QueryTransactionStatus transactions={transactions} />
  93. </div>
  94. <div className="query-row-field">
  95. {QueryField ? (
  96. <QueryField
  97. datasource={datasourceInstance}
  98. error={queryError}
  99. hint={hint}
  100. initialQuery={initialQuery}
  101. history={history}
  102. onClickHintFix={this.onClickHintFix}
  103. onPressEnter={this.onExecuteQuery}
  104. onQueryChange={this.onChangeQuery}
  105. />
  106. ) : (
  107. <QueryEditor
  108. datasource={datasourceInstance}
  109. error={queryError}
  110. onQueryChange={this.onChangeQuery}
  111. onExecuteQuery={this.onExecuteQuery}
  112. initialQuery={initialQuery}
  113. exploreEvents={exploreEvents}
  114. range={range}
  115. />
  116. )}
  117. </div>
  118. <div className="query-row-tools">
  119. <button className="btn navbar-button navbar-button--tight" onClick={this.onClickClearButton}>
  120. <i className="fa fa-times" />
  121. </button>
  122. <button className="btn navbar-button navbar-button--tight" onClick={this.onClickAddButton}>
  123. <i className="fa fa-plus" />
  124. </button>
  125. <button className="btn navbar-button navbar-button--tight" onClick={this.onClickRemoveButton}>
  126. <i className="fa fa-minus" />
  127. </button>
  128. </div>
  129. </div>
  130. );
  131. }
  132. }
  133. function mapStateToProps(state: StoreState, { exploreId, index }) {
  134. const explore = state.explore;
  135. const item: ExploreItemState = explore[exploreId];
  136. const { datasourceInstance, history, initialQueries, queryTransactions, range } = item;
  137. const initialQuery = initialQueries[index];
  138. return { datasourceInstance, history, initialQuery, queryTransactions, range };
  139. }
  140. const mapDispatchToProps = {
  141. addQueryRow,
  142. changeQuery,
  143. highlightLogsExpression,
  144. modifyQueries,
  145. removeQueryRow,
  146. runQueries,
  147. };
  148. export default hot(module)(connect(mapStateToProps, mapDispatchToProps)(QueryRow));