github-mirrors/kibana
1
0
Fork 0
mirror of https://github.com/elastic/kibana.git synced 2025-04-23 17:28:26 -04:00
Code Issues Projects Releases Packages Wiki Activity

[Synthetics] Refactor supress API Key error (#171114)

Browse source
This commit is contained in:
Shahzad 2023-11-22 17:03:35 +01:00 • committed by GitHub
parent 66019dfe05
commit d5fc9b0314
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 39 additions and 40 deletions
Download patch file Download diff file Expand all files Collapse all files

79
x-pack/plugins/synthetics/server/synthetics_service/synthetics_service.ts
View file

@ -423,49 +423,48 @@ export class SyntheticsService {
};
for await (const result of finder.find()) {
if (result.saved_objects.length === 0) {
return;
}
try {
if (!output) {
output = await this.getOutput();
if (result.saved_objects.length > 0) {
try {
if (!output) {
sendErrorTelemetryEvents(service.logger, service.server.telemetry, {
reason: 'API key is not valid.',
message: 'Failed to push configs. API key is not valid.',
type: 'invalidApiKey',
stackVersion: service.server.stackVersion,
});
return;
}
}
const monitors = result.saved_objects.filter(({ error }) => !error);
const formattedConfigs = this.normalizeConfigs(monitors, paramsBySpace);
this.logger.debug(
`${formattedConfigs.length} monitors will be pushed to synthetics service.`
);
formattedConfigs.forEach((monitor) => {
monitor.locations.forEach((location) => {
if (location.isServiceManaged) {
bucketsByLocation[location.id]?.push(monitor);
output = await this.getOutput();
if (!output) {
sendErrorTelemetryEvents(service.logger, service.server.telemetry, {
reason: 'API key is not valid.',
message: 'Failed to push configs. API key is not valid.',
type: 'invalidApiKey',
stackVersion: service.server.stackVersion,
});
return;
}
});
});
}
await syncAllLocations(PER_PAGE);
} catch (e) {
sendErrorTelemetryEvents(service.logger, service.server.telemetry, {
reason: 'Failed to push configs to service',
message: e?.message,
type: 'pushConfigsError',
code: e?.code,
status: e.status,
stackVersion: service.server.stackVersion,
});
this.logger.error(e);
const monitors = result.saved_objects.filter(({ error }) => !error);
const formattedConfigs = this.normalizeConfigs(monitors, paramsBySpace);
this.logger.debug(
`${formattedConfigs.length} monitors will be pushed to synthetics service.`
);
formattedConfigs.forEach((monitor) => {
monitor.locations.forEach((location) => {
if (location.isServiceManaged) {
bucketsByLocation[location.id]?.push(monitor);
}
});
});
await syncAllLocations(PER_PAGE);
} catch (e) {
sendErrorTelemetryEvents(service.logger, service.server.telemetry, {
reason: 'Failed to push configs to service',
message: e?.message,
type: 'pushConfigsError',
code: e?.code,
status: e.status,
stackVersion: service.server.stackVersion,
});
this.logger.error(e);
}
}
}