Skip to content

Commit f4731aa

Browse files
[Feature] Add Download/Upload bytes/elapsed to InfluxDB (#2256)
Co-authored-by: Alex Justesen <[email protected]>
1 parent 9d365c6 commit f4731aa

File tree

2 files changed

+24
-0
lines changed

2 files changed

+24
-0
lines changed

app/Actions/Influxdb/v2/BuildPointData.php

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -39,6 +39,8 @@ public function handle(Result $result): Point
3939
->addField('ping', Number::castToType($result->ping, 'float'))
4040
->addField('download_bits', ! blank($result->download) ? Number::castToType(Bitrate::bytesToBits($result->download), 'int') : null)
4141
->addField('upload_bits', ! blank($result->upload) ? Number::castToType(Bitrate::bytesToBits($result->upload), 'int') : null)
42+
->addField('download_elapsed', Number::castToType(Arr::get($result->data, 'download.elapsed'), 'float'))
43+
->addField('upload_elapsed', Number::castToType(Arr::get($result->data, 'upload.elapsed'), 'float'))
4244
->addField('download_jitter', Number::castToType(Arr::get($result->data, 'download.latency.jitter'), 'float'))
4345
->addField('upload_jitter', Number::castToType(Arr::get($result->data, 'upload.latency.jitter'), 'float'))
4446
->addField('ping_jitter', Number::castToType(Arr::get($result->data, 'ping.jitter'), 'float'))
@@ -48,6 +50,8 @@ public function handle(Result $result): Point
4850
->addField('upload_latency_avg', Number::castToType(Arr::get($result->data, 'upload.latency.iqm'), 'float'))
4951
->addField('upload_latency_high', Number::castToType(Arr::get($result->data, 'upload.latency.high'), 'float'))
5052
->addField('upload_latency_low', Number::castToType(Arr::get($result->data, 'upload.latency.low'), 'float'))
53+
->addField('downloaded_bytes', Number::castToType($result->data, 'downloaded_bytes', 'int'))
54+
->addField('uploaded_bytes', Number::castToType($result->data, 'uploaded_bytes', 'int'))
5155
->addField('packet_loss', Number::castToType(Arr::get($result->data, 'packetLoss'), 'float'))
5256
->addField('log_message', Arr::get($result->data, 'message'));
5357

app/Models/Traits/ResultDataAttributes.php

Lines changed: 20 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -248,6 +248,26 @@ protected function uploadElapsed(): Attribute
248248
);
249249
}
250250

251+
/**
252+
* Get the result's uploaded bytes.
253+
*/
254+
public function uploadedBytes(): Attribute
255+
{
256+
return Attribute::make(
257+
get: fn () => Arr::get($this->data, 'upload.bytes'),
258+
);
259+
}
260+
261+
/**
262+
* Get the result's downloaded bytes.
263+
*/
264+
public function downloadedBytes(): Attribute
265+
{
266+
return Attribute::make(
267+
get: fn () => Arr::get($this->data, 'download.bytes'),
268+
);
269+
}
270+
251271
/**
252272
* Get the result's server port.
253273
*/

0 commit comments

Comments
 (0)