forked from alexjustesen/speedtest-tracker
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathCheckForInternetConnectionJob.php
More file actions
66 lines (53 loc) · 1.48 KB
/
CheckForInternetConnectionJob.php
File metadata and controls
66 lines (53 loc) · 1.48 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
<?php
namespace App\Jobs;
use App\Actions\PingHostname;
use App\Enums\ResultStatus;
use App\Events\SpeedtestChecking;
use App\Events\SpeedtestFailed;
use App\Models\Result;
use Illuminate\Bus\Batchable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Queue\Queueable;
use Illuminate\Queue\Middleware\SkipIfBatchCancelled;
class CheckForInternetConnectionJob implements ShouldQueue
{
use Batchable, Queueable;
/**
* Create a new job instance.
*/
public function __construct(
public Result $result,
) {}
/**
* Get the middleware the job should pass through.
*/
public function middleware(): array
{
return [
new SkipIfBatchCancelled,
];
}
/**
* Execute the job.
*/
public function handle(): void
{
$this->result->update([
'status' => ResultStatus::Checking,
]);
SpeedtestChecking::dispatch($this->result);
$ping = PingHostname::run();
if ($ping->isSuccess()) {
return;
}
$message = sprintf('Failed to connected to hostname "%s". Error received "%s".', $ping->getHost(), $ping->error()?->value);
$this->result->update([
'data->type' => 'log',
'data->level' => 'error',
'data->message' => $message,
'status' => ResultStatus::Failed,
]);
SpeedtestFailed::dispatch($this->result);
$this->batch()->cancel();
}
}