77 lines
2.3 KiB
PHP
77 lines
2.3 KiB
PHP
<?php
|
|
|
|
namespace App\Jobs;
|
|
|
|
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;
|
|
use Illuminate\Support\Str;
|
|
|
|
class SendMessageToTelegramJob implements ShouldBeEncrypted, ShouldQueue
|
|
{
|
|
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
|
|
|
|
/**
|
|
* The number of times the job may be attempted.
|
|
*
|
|
* @var int
|
|
*/
|
|
public $tries = 5;
|
|
|
|
/**
|
|
* The maximum number of unhandled exceptions to allow before failing.
|
|
*/
|
|
public int $maxExceptions = 3;
|
|
|
|
public function __construct(
|
|
public string $text,
|
|
public array $buttons,
|
|
public string $token,
|
|
public string $chatId,
|
|
public ?string $topicId = null,
|
|
) {}
|
|
|
|
/**
|
|
* Execute the job.
|
|
*/
|
|
public function handle(): void
|
|
{
|
|
$url = 'https://api.telegram.org/bot'.$this->token.'/sendMessage';
|
|
$inlineButtons = [];
|
|
if (! empty($this->buttons)) {
|
|
foreach ($this->buttons as $button) {
|
|
$buttonUrl = data_get($button, 'url');
|
|
$text = data_get($button, 'text', 'Click here');
|
|
if ($buttonUrl && Str::contains($buttonUrl, 'http://localhost')) {
|
|
$buttonUrl = str_replace('http://localhost', config('app.url'), $buttonUrl);
|
|
}
|
|
$inlineButtons[] = [
|
|
'text' => $text,
|
|
'url' => $buttonUrl,
|
|
];
|
|
}
|
|
}
|
|
$payload = [
|
|
// 'parse_mode' => 'markdown',
|
|
'reply_markup' => json_encode([
|
|
'inline_keyboard' => [
|
|
[...$inlineButtons],
|
|
],
|
|
]),
|
|
'chat_id' => $this->chatId,
|
|
'text' => $this->text,
|
|
];
|
|
if ($this->topicId) {
|
|
$payload['message_thread_id'] = $this->topicId;
|
|
}
|
|
$response = Http::post($url, $payload);
|
|
if ($response->failed()) {
|
|
throw new \Exception('Telegram notification failed with '.$response->status().' status code.'.$response->body());
|
|
}
|
|
}
|
|
}
|