Commit 52f30f6f by Patrick O'Carroll Committed by Torkel Ödegaard

migrated file to ts (#10328)

parent e234cf5b
define([
'angular',
'lodash',
'app/core/core_module',
'app/core/config',
'./plugin_loader',
],
function (angular, _, coreModule, config, pluginLoader) {
'use strict';
config = config.default;
coreModule.default.service('datasourceSrv', function($q, $injector, $rootScope, templateSrv) {
var self = this;
this.init = function() {
this.datasources = {};
};
this.get = function(name) {
if (!name) {
return this.get(config.defaultDatasource);
}
import _ from 'lodash';
import coreModule from 'app/core/core_module';
import config from 'app/core/config';
// import pluginLoader from './plugin_loader';
import { importPluginModule } from './plugin_loader';
name = templateSrv.replace(name);
export class DatasourceSrv {
datasources: any;
if (name === 'default') {
return this.get(config.defaultDatasource);
}
constructor(private $q, private $injector, $rootScope, private templateSrv) {
this.init();
}
if (this.datasources[name]) {
return $q.when(this.datasources[name]);
}
init() {
this.datasources = {};
}
return this.loadDatasource(name);
};
get(name) {
if (!name) {
return this.get(config.defaultDatasource);
}
this.loadDatasource = function(name) {
var dsConfig = config.datasources[name];
if (!dsConfig) {
return $q.reject({message: "Datasource named " + name + " was not found"});
}
name = this.templateSrv.replace(name);
if (name === 'default') {
return this.get(config.defaultDatasource);
}
if (this.datasources[name]) {
return this.$q.when(this.datasources[name]);
}
return this.loadDatasource(name);
}
var deferred = $q.defer();
var pluginDef = dsConfig.meta;
loadDatasource(name) {
var dsConfig = config.datasources[name];
if (!dsConfig) {
return this.$q.reject({ message: 'Datasource named ' + name + ' was not found' });
}
pluginLoader.importPluginModule(pluginDef.module).then(function(plugin) {
var deferred = this.$q.defer();
var pluginDef = dsConfig.meta;
importPluginModule(pluginDef.module)
.then(plugin => {
// check if its in cache now
if (self.datasources[name]) {
deferred.resolve(self.datasources[name]);
if (this.datasources[name]) {
deferred.resolve(this.datasources[name]);
return;
}
// plugin module needs to export a constructor function named Datasource
if (!plugin.Datasource) {
throw "Plugin module is missing Datasource constructor";
throw new Error('Plugin module is missing Datasource constructor');
}
var instance = $injector.instantiate(plugin.Datasource, {instanceSettings: dsConfig});
var instance = this.$injector.instantiate(plugin.Datasource, { instanceSettings: dsConfig });
instance.meta = pluginDef;
instance.name = name;
self.datasources[name] = instance;
this.datasources[name] = instance;
deferred.resolve(instance);
}).catch(function(err) {
$rootScope.appEvent('alert-error', [dsConfig.name + ' plugin failed', err.toString()]);
})
.catch(function(err) {
this.$rootScope.appEvent('alert-error', [dsConfig.name + ' plugin failed', err.toString()]);
});
return deferred.promise;
};
return deferred.promise;
}
this.getAll = function() {
return config.datasources;
};
getAll() {
return config.datasources;
}
this.getAnnotationSources = function() {
var sources = [];
getAnnotationSources() {
var sources = [];
this.addDataSourceVariables(sources);
this.addDataSourceVariables(sources);
_.each(config.datasources, function(value) {
if (value.meta && value.meta.annotations) {
sources.push(value);
}
});
_.each(config.datasources, function(value) {
if (value.meta && value.meta.annotations) {
sources.push(value);
}
});
return sources;
};
return sources;
}
this.getMetricSources = function(options) {
var metricSources = [];
getMetricSources(options) {
var metricSources = [];
_.each(config.datasources, function(value, key) {
if (value.meta && value.meta.metrics) {
metricSources.push({value: key, name: key, meta: value.meta});
_.each(config.datasources, function(value, key) {
if (value.meta && value.meta.metrics) {
metricSources.push({ value: key, name: key, meta: value.meta });
if (key === config.defaultDatasource) {
metricSources.push({value: null, name: 'default', meta: value.meta});
}
if (key === config.defaultDatasource) {
metricSources.push({ value: null, name: 'default', meta: value.meta });
}
});
if (!options || !options.skipVariables) {
this.addDataSourceVariables(metricSources);
}
});
metricSources.sort(function(a, b) {
// these two should always be at the bottom
if (a.meta.id === "mixed" || a.meta.id === "grafana") {
return 1;
}
if (b.meta.id === "mixed" || b.meta.id === "grafana") {
return -1;
}
if (a.name.toLowerCase() > b.name.toLowerCase()) {
return 1;
}
if (a.name.toLowerCase() < b.name.toLowerCase()) {
return -1;
}
return 0;
});
return metricSources;
};
if (!options || !options.skipVariables) {
this.addDataSourceVariables(metricSources);
}
this.addDataSourceVariables = function(list) {
// look for data source variables
for (var i = 0; i < templateSrv.variables.length; i++) {
var variable = templateSrv.variables[i];
if (variable.type !== 'datasource') {
continue;
}
metricSources.sort(function(a, b) {
// these two should always be at the bottom
if (a.meta.id === 'mixed' || a.meta.id === 'grafana') {
return 1;
}
if (b.meta.id === 'mixed' || b.meta.id === 'grafana') {
return -1;
}
if (a.name.toLowerCase() > b.name.toLowerCase()) {
return 1;
}
if (a.name.toLowerCase() < b.name.toLowerCase()) {
return -1;
}
return 0;
});
return metricSources;
}
addDataSourceVariables(list) {
// look for data source variables
for (var i = 0; i < this.templateSrv.variables.length; i++) {
var variable = this.templateSrv.variables[i];
if (variable.type !== 'datasource') {
continue;
}
var first = variable.current.value;
if (first === 'default') {
first = config.defaultDatasource;
}
var first = variable.current.value;
if (first === 'default') {
first = config.defaultDatasource;
}
var ds = config.datasources[first];
var ds = config.datasources[first];
if (ds) {
list.push({
name: '$' + variable.name,
value: '$' + variable.name,
meta: ds.meta,
});
}
if (ds) {
list.push({
name: '$' + variable.name,
value: '$' + variable.name,
meta: ds.meta,
});
}
};
}
}
}
this.init();
});
});
coreModule.service('datasourceSrv', DatasourceSrv);
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment