feat(job) Run log in a queueable job

Author: mbpcoder

README.md

@@ -17,6 +17,10 @@ composer require thecoder/laravel-monolog-telegram
 # Usage
 Open config/logging.php and change the file
 
+### Run log in a Queue
+
+If a queue name is set, the job will run in the specified queue; otherwise, it will run synchronously.
+
 ```php
 
 use TheCoder\MonologTelegram\Attributes\EmergencyAttribute;
@@ -47,6 +51,7 @@ use TheCoder\MonologTelegram\Attributes\LowPriorityAttribute;
                 'topic_id' => env('LOG_TELEGRAM_TOPIC_ID',null),
                 'bot_api' => env('LOG_TELEGRAM_BOT_API', 'https://api.telegram.org/bot'),
                 'proxy' => env('LOG_TELEGRAM_BOT_PROXY', null),
+                'queue' => env('LOG_TELEGRAM_QUEUE', null),
                 'topics_level' => [
                     EmergencyAttribute::class => env('LOG_TELEGRAM_EMERGENCY_ATTRIBUTE_TOPIC_ID', null),
                     CriticalAttribute::class => env('LOG_TELEGRAM_CRITICAL_ATTRIBUTE_TOPIC_ID', null),

src/SendJob.php

@@ -0,0 +1,55 @@
+<?php
+
+namespace TheCoder\MonologTelegram;
+
+use GuzzleHttp\Client;
+use Illuminate\Bus\Queueable;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Foundation\Bus\Dispatchable;
+use Illuminate\Queue\InteractsWithQueue;
+use Illuminate\Queue\SerializesModels;
+
+
+class SendJob implements ShouldQueue
+{
+    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
+
+    public function __construct(
+        private string      $url,
+        private string      $message,
+        private string      $chatId,
+        private string|null $topicId = null,
+        private string|null $proxy = null,
+    )
+    {
+    }
+
+    public function handle(): void
+    {
+        $httpClientOption = [];
+        $httpClientOption['verify'] = false;
+
+        if (!is_null($this->proxy)) {
+            $httpClientOption['proxy'] = $this->proxy;
+        }
+
+        $params = [
+            'text' => $this->message,
+            'chat_id' => $this->chatId,
+            'parse_mode' => 'html',
+            'disable_web_page_preview' => true,
+        ];
+
+        $requestOptions = [
+            'form_params' => $this->topicId !== null ? $params + ['message_thread_id' => $this->topicId] : $params
+        ];
+
+        $httpClient = new Client($httpClientOption);
+
+        try {
+            $response = $httpClient->post($this->url, $requestOptions);
+        } catch (\Throwable $exception) {
+            $this->fail($exception);
+        }
+    }
+}

src/TelegramBotHandler.php

@@ -56,6 +56,8 @@ class TelegramBotHandler extends AbstractProcessingHandler
      */
     protected $topicId;
 
+    protected $queue = null;
+
     protected $topicsLevel;
 
     /**
@@ -68,6 +70,7 @@ public function __construct(
         string  $token,
         string  $chat_id,
         ?string $topic_id = null,
+        ?string $queue = null,
         $topics_level = [],
                 $level = Logger::DEBUG,
         bool    $bubble = true,
@@ -81,6 +84,7 @@ public function __construct(
         $this->botApi = $bot_api;
         $this->chatId = $chat_id;
         $this->topicId = $topic_id;
+        $this->queue = $queue;
         $this->topicsLevel = $topics_level;
         $this->level = $level;
         $this->bubble = $bubble;
@@ -116,47 +120,24 @@ private function truncateTextToTelegramLimit(string $textMessage): string
      * @param null $token
      * @param null $chatId
      * @param null $topicId
-     * @param array $option
      * @throws GuzzleException
      */
-    protected function send(string $message, $token = null, $chatId = null, $topicId = null, array $option = []): void
+    protected function send(string $message, $token = null, $chatId = null, $topicId = null): void
     {
-        try {
-
-            $token = $token ?? $this->token;
-            $chatId = $chatId ?? $this->chatId;
-            $topicId = $topicId ?? $this->topicId;
-
-            if (!isset($option['verify'])) {
-                $option['verify'] = false;
-            }
-
-            if (!is_null($this->proxy)) {
-                $option['proxy'] = $this->proxy;
-            }
-
-            $httpClient = new Client($option);
-
-            $url = !str_contains($this->botApi, 'https://api.telegram.org')
-                ? $this->botApi
-                : $this->botApi . $token . '/SendMessage';
-
-            $message = $this->truncateTextToTelegramLimit($message);
+        $token = $token ?? $this->token;
+        $chatId = $chatId ?? $this->chatId;
+        $topicId = $topicId ?? $this->topicId;
 
-            $params = [
-                'text' => $message,
-                'chat_id' => $chatId,
-                'parse_mode' => 'html',
-                'disable_web_page_preview' => true,
-            ];
+        $url = !str_contains($this->botApi, 'https://api.telegram.org')
+            ? $this->botApi
+            : $this->botApi . $token . '/SendMessage';
 
-            $options = [
-                'form_params' => $topicId !== null ? $params + ['message_thread_id' => $topicId] : $params
-            ];
+        $message = $this->truncateTextToTelegramLimit($message);
 
-            $response = $httpClient->post($url, $options);
-        } catch (\Exception $e) {
-            $a = 1;
+        if ($this->queue === null) {
+            dispatch_sync(new SendJob($url, $message, $chatId, $topicId, $this->proxy));
+        } else {
+            dispatch(new SendJob($url, $message, $chatId, $topicId, $this->proxy))->onQueue($this->queue);
         }
     }