Files
coolify/app/Jobs/SendMessageToPushoverJob.php
T

56 lines
1.8 KiB
PHP

<?php
namespace App\Jobs;
use App\Models\PushoverNotificationSettings;
use App\Notifications\Dto\PushoverMessage;
use App\Traits\HandlesNotificationResponse;
use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldBeEncrypted;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;
use Illuminate\Support\Facades\Http;
class SendMessageToPushoverJob implements ShouldBeEncrypted, ShouldQueue
{
use Dispatchable, HandlesNotificationResponse, InteractsWithQueue, Queueable, SerializesModels;
/**
* The number of times the job may be attempted.
*
* @var int
*/
public $tries = 5;
public $backoff = 10;
/**
* The maximum number of unhandled exceptions to allow before failing.
*/
public int $maxExceptions = 5;
public function __construct(
public PushoverMessage $message,
public string $token,
public string $user,
public ?PushoverNotificationSettings $settings = null,
) {
$this->onQueue('high');
}
/**
* Execute the job.
*/
public function handle(): void
{
$response = $this->sendNotificationRequest('Pushover', 'https://api.pushover.net/1/messages.json', fn () => Http::post('https://api.pushover.net/1/messages.json', $this->message->toPayload($this->token, $this->user)));
// Pushover marks the invalid field in the error body, for example {"token": "invalid"}.
$isConfigurationError = $response->clientError()
&& ($response->json('token') === 'invalid' || $response->json('user') === 'invalid');
$this->handleNotificationResponse($response, 'Pushover', $isConfigurationError);
}
}