IntenseWebs/grafana
3
0
Fork 0
mirror of https://github.com/grafana/grafana.git synced 2025-02-25 18:55:37 -06:00
Code Issues Packages Projects Releases Wiki Activity

stackdriver: improve error handling

Browse Source
This commit is contained in:
Erik Sundell 2018-10-11 13:46:51 +02:00
parent 5b04a8b6c2
commit ae8a765190
2 changed files with 44 additions and 30 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

61
public/app/plugins/datasource/stackdriver/datasource.ts
View File

@ -1,11 +1,13 @@
import { stackdriverUnitMappings } from './constants';
import appEvents from 'app/core/app_events';
import _ from 'lodash';
export default class StackdriverDatasource {
id: number;
url: string;
baseUrl: string;
projectName: string;
authenticationType: string;
queryPromise: Promise<any>;
/** @ngInject */
@ -15,6 +17,7 @@ export default class StackdriverDatasource {
this.doRequest = this.doRequest;
this.id = instanceSettings.id;
this.projectName = instanceSettings.jsonData.defaultProject || '';
this.authenticationType = instanceSettings.jsonData.authenticationType || 'jwt';
}
async getTimeSeries(options) {
@ -178,29 +181,36 @@ export default class StackdriverDatasource {
}
async testDatasource() {
let status, message;
const defaultErrorMessage = 'Cannot connect to Stackdriver API';
try {
await this.backendSrv.datasourceRequest({
url: '/api/tsdb/query',
method: 'POST',
data: {
queries: [
{
refId: 'testDatasource',
datasourceId: this.id,
type: 'testDatasource',
},
],
},
});
return {
status: 'success',
message: 'Successfully queried the Stackdriver API.',
title: 'Success',
};
const projectName = await this.getDefaultProject();
const path = `v3/projects/${projectName}/metricDescriptors`;
const response = await this.doRequest(`${this.baseUrl}${path}`);
if (response.status === 200) {
status = 'success';
message = 'Successfully queried the Stackdriver API.';
} else {
status = 'error';
message = response.statusText ? response.statusText : defaultErrorMessage;
}
} catch (error) {
status = 'error';
if (_.isString(error)) {
message = error;
} else {
message = 'Stackdriver: ';
message += error.statusText ? error.statusText + ': ' : '';
if (error.data && error.data.error && error.data.error.code) {
message += error.data.error.code + '. ' + error.data.error.message;
} else {
message = defaultErrorMessage;
}
}
} finally {
return {
status: 'error',
message: this.formatStackdriverError(error),
status,
message,
};
}
}
@ -223,28 +233,27 @@ export default class StackdriverDatasource {
async getDefaultProject() {
try {
if (!this.projectName) {
if (this.authenticationType === 'gce' || !this.projectName) {
const { data } = await this.backendSrv.datasourceRequest({
url: '/api/tsdb/query',
method: 'POST',
data: {
queries: [
{
refId: 'defaultProject',
type: 'defaultProject',
refId: 'ensureDefaultProjectQuery',
type: 'ensureDefaultProjectQuery',
datasourceId: this.id,
},
],
},
});
this.projectName = data.results.defaultProject.meta.defaultProject;
this.projectName = data.results.ensureDefaultProjectQuery.meta.defaultProject;
return this.projectName;
} else {
return this.projectName;
}
} catch (error) {
appEvents.emit('ds-request-error', this.formatStackdriverError(error));
return '';
throw this.formatStackdriverError(error);
}
}

13
public/app/plugins/datasource/stackdriver/query_filter_ctrl.ts
View File

@ -79,11 +79,16 @@ export class StackdriverFilterCtrl {
}
async getCurrentProject() {
return new Promise(async resolve => {
if (!this.target.defaultProject || this.target.defaultProject === 'loading project...') {
this.target.defaultProject = await this.datasource.getDefaultProject();
return new Promise(async (resolve, reject) => {
try {
if (!this.target.defaultProject || this.target.defaultProject === 'loading project...') {
this.target.defaultProject = await this.datasource.getDefaultProject();
}
resolve(this.target.defaultProject);
} catch (error) {
appEvents.emit('ds-request-error', error);
reject();
}
resolve(this.target.defaultProject);
});
}