| 12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182 |
- define([
- 'angular',
- 'lodash',
- './editorCtrl'
- ], function (angular, _) {
- 'use strict';
- var module = angular.module('grafana.services');
- module.service('annotationsSrv', function(datasourceSrv, $q, alertSrv, $rootScope) {
- var promiseCached;
- var list = [];
- var self = this;
- this.init = function() {
- $rootScope.onAppEvent('refresh', this.clearCache, $rootScope);
- $rootScope.onAppEvent('setup-dashboard', this.clearCache, $rootScope);
- };
- this.clearCache = function() {
- promiseCached = null;
- list = [];
- };
- this.getAnnotations = function(rangeUnparsed, dashboard) {
- if (dashboard.annotations.list.length === 0) {
- return $q.when(null);
- }
- if (promiseCached) {
- return promiseCached;
- }
- self.dashboard = dashboard;
- var annotations = _.where(dashboard.annotations.list, {enable: true});
- var promises = _.map(annotations, function(annotation) {
- return datasourceSrv.get(annotation.datasource).then(function(datasource) {
- return datasource.annotationQuery(annotation, rangeUnparsed)
- .then(self.receiveAnnotationResults)
- .then(null, errorHandler);
- }, this);
- });
- promiseCached = $q.all(promises)
- .then(function() {
- return list;
- });
- return promiseCached;
- };
- this.receiveAnnotationResults = function(results) {
- for (var i = 0; i < results.length; i++) {
- self.addAnnotation(results[i]);
- }
- };
- this.addAnnotation = function(options) {
- list.push({
- annotation: options.annotation,
- min: options.time,
- max: options.time,
- eventType: options.annotation.name,
- title: options.title,
- tags: options.tags,
- text: options.text,
- score: 1
- });
- };
- function errorHandler(err) {
- console.log('Annotation error: ', err);
- var message = err.message || "Annotation query failed";
- alertSrv.set('Annotations error', message,'error');
- }
- // Now init
- this.init();
- });
- });
|