speedtest-tracker/app/Jobs/Influxdb/v2/TestConnectionJob.php

<?php

namespace App\Jobs\Influxdb\v2;

use App\Actions\Influxdb\v2\CreateClient;
use App\Models\User;
use Filament\Notifications\Notification;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Queue\Queueable;
use Illuminate\Support\Facades\Log;
use InfluxDB2\ApiException;
use InfluxDB2\Point;

class TestConnectionJob implements ShouldQueue
{
    use Queueable;

    /**
     * Create a new job instance.
     */
    public function __construct(
        public User $user,
    ) {}

    /**
     * Execute the job.
     */
    public function handle(): void
    {
        $client = CreateClient::run();

        $writeApi = $client->createWriteApi();

        $point = Point::measurement('speedtest')
            ->addTag('service', 'faker')
            ->addField('download', (int) 420)
            ->addField('upload', (int) 69)
            ->addField('ping', (float) 4.321)
            ->time(time());

        try {
            $writeApi->write($point);
        } catch (ApiException $e) {
            Log::error('Failed to write test data to Influxdb.', [
                'error' => $e->getMessage(),
            ]);

            Notification::make()
                ->title(__('settings/data_integration.influxdb_test_failed'))
                ->body(__('settings/data_integration.influxdb_test_failed_body'))
                ->danger()
                ->sendToDatabase($this->user);

            $writeApi->close();

            return;
        }

        $writeApi->close();

        Notification::make()
            ->title(__('settings/data_integration.influxdb_test_success'))
            ->body(__('settings/data_integration.influxdb_test_success_body'))
            ->success()
            ->sendToDatabase($this->user);
    }
}