1234567891011121314151617181920212223242526272829303132 |
- import { from, Observable, of } from 'rxjs';
- import { catchError } from 'rxjs/operators';
- import { AnnotationEvent, DataSourceApi } from '@grafana/data';
- import { shouldUseLegacyRunner } from 'app/features/annotations/standardAnnotationSupport';
- import { AnnotationQueryRunner, AnnotationQueryRunnerOptions } from './types';
- import { handleAnnotationQueryRunnerError } from './utils';
- export class LegacyAnnotationQueryRunner implements AnnotationQueryRunner {
- canRun(datasource?: DataSourceApi): boolean {
- if (!datasource) {
- return false;
- }
- if (shouldUseLegacyRunner(datasource)) {
- return true;
- }
- return Boolean(datasource.annotationQuery && !datasource.annotations);
- }
- run({ annotation, datasource, dashboard, range }: AnnotationQueryRunnerOptions): Observable<AnnotationEvent[]> {
- if (!this.canRun(datasource)) {
- return of([]);
- }
- return from(datasource!.annotationQuery!({ range, rangeRaw: range.raw, annotation, dashboard })).pipe(
- catchError(handleAnnotationQueryRunnerError)
- );
- }
- }
|