Skip to content

Commit 3013e2c

Browse files
authored
[Feature] Write Failed tests to influxdb (alexjustesen#2200)
1 parent 9a75dfa commit 3013e2c

File tree

2 files changed

+10
-2
lines changed

2 files changed

+10
-2
lines changed

app/Actions/Influxdb/v2/BuildPointData.php

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,8 @@ public function handle(Result $result): Point
4848
->addField('upload_latency_avg', Number::castToType(Arr::get($result->data, 'upload.latency.iqm'), 'float'))
4949
->addField('upload_latency_high', Number::castToType(Arr::get($result->data, 'upload.latency.high'), 'float'))
5050
->addField('upload_latency_low', Number::castToType(Arr::get($result->data, 'upload.latency.low'), 'float'))
51-
->addField('packet_loss', Number::castToType(Arr::get($result->data, 'packetLoss'), 'float'));
51+
->addField('packet_loss', Number::castToType(Arr::get($result->data, 'packetLoss'), 'float'))
52+
->addField('log_message', Arr::get($result->data, 'message'));
5253

5354
return $point;
5455
}

app/Listeners/SpeedtestEventSubscriber.php

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,14 @@ class SpeedtestEventSubscriber
1313
/**
1414
* Handle speedtest failed events.
1515
*/
16-
public function handleSpeedtestFailed(SpeedtestFailed $event): void {}
16+
public function handleSpeedtestFailed(SpeedtestFailed $event): void
17+
{
18+
$settings = app(DataIntegrationSettings::class);
19+
20+
if ($settings->influxdb_v2_enabled) {
21+
WriteResult::dispatch($event->result);
22+
}
23+
}
1724

1825
/**
1926
* Handle speedtest completed events.

0 commit comments

Comments
 (0)