feat: add topics level feature

Author: saMahmoudzadeh

src/Attributes/AbstractTopicLevelAttribute.php

@@ -0,0 +1,11 @@
+<?php
+
+namespace TheCoder\MonologTelegram\Attributes;
+
+abstract class AbstractTopicLevelAttribute implements TopicLogInterface
+{
+    public function getTopicID(array $topicsLevel): string|null
+    {
+        return $topicsLevel[static::class] ?? null;
+    }
+}

src/Attributes/CriticalAttribute.php

@@ -0,0 +1,10 @@
+<?php
+
+namespace TheCoder\MonologTelegram\Attributes;
+
+use Attribute;
+
+#[Attribute]
+final class CriticalAttribute extends AbstractTopicLevelAttribute
+{
+}

src/Attributes/DebugAttribute.php

@@ -0,0 +1,10 @@
+<?php
+
+namespace TheCoder\MonologTelegram\Attributes;
+
+use Attribute;
+
+#[Attribute]
+final class DebugAttribute extends AbstractTopicLevelAttribute
+{
+}

src/Attributes/EmergencyAttribute.php

@@ -0,0 +1,10 @@
+<?php
+
+namespace TheCoder\MonologTelegram\Attributes;
+
+use Attribute;
+
+#[Attribute]
+final class EmergencyAttribute extends AbstractTopicLevelAttribute
+{
+}

src/Attributes/ImportantAttribute.php

@@ -0,0 +1,10 @@
+<?php
+
+namespace TheCoder\MonologTelegram\Attributes;
+
+use Attribute;
+
+#[Attribute]
+final class ImportantAttribute extends AbstractTopicLevelAttribute
+{
+}

src/Attributes/InformationAttribute.php

@@ -0,0 +1,10 @@
+<?php
+
+namespace TheCoder\MonologTelegram\Attributes;
+
+use Attribute;
+
+#[Attribute]
+final class InformationAttribute extends AbstractTopicLevelAttribute
+{
+}

src/Attributes/LowPriorityAttribute.php

@@ -0,0 +1,10 @@
+<?php
+
+namespace TheCoder\MonologTelegram\Attributes;
+
+use Attribute;
+
+#[Attribute]
+final class LowPriorityAttribute extends AbstractTopicLevelAttribute
+{
+}

src/Attributes/TopicLogInterface.php

@@ -0,0 +1,8 @@
+<?php
+
+namespace TheCoder\MonologTelegram\Attributes;
+
+interface TopicLogInterface
+{
+    public function getTopicID(array $topicsLevel): string|null;
+}

src/TelegramBotHandler.php

@@ -3,12 +3,18 @@
 namespace TheCoder\MonologTelegram;
 
 use GuzzleHttp\Client;
+use Illuminate\Routing\Router;
+use Illuminate\Support\Facades\Route;
 use Monolog\Handler\AbstractProcessingHandler;
-use Monolog\Handler\HandlerInterface;
 use Monolog\Logger;
+use ReflectionMethod;
+use TheCoder\MonologTelegram\Attributes\TopicLogInterface;
 
-class TelegramBotHandler extends AbstractProcessingHandler implements HandlerInterface
+class TelegramBotHandler extends AbstractProcessingHandler
 {
+
+    protected Router $router;
+
     /**
      * text parameter in sendMessage method
      * @see https://core.telegram.org/bots/api#sendmessage
@@ -49,39 +55,47 @@ class TelegramBotHandler extends AbstractProcessingHandler implements HandlerInt
      */
     protected $topicId;
 
+    protected $topicsLevel;
+
     /**
      * @param string $token Telegram bot access token provided by BotFather
      * @param string $channel Telegram channel name
      * @inheritDoc
      */
     public function __construct(
-        string $token,
-        string $chat_id,
+        Router  $router,
+        string  $token,
+        string  $chat_id,
         ?string $topic_id = null,
-               $level = Logger::DEBUG,
-        bool   $bubble = true,
-               $bot_api = 'https://api.telegram.org/bot',
-               $proxy = null)
+                $topics_level,
+                $level = Logger::DEBUG,
+        bool    $bubble = true,
+                $bot_api = 'https://api.telegram.org/bot',
+                $proxy = null)
     {
         parent::__construct($level, $bubble);
 
+        $this->router = $router;
         $this->token = $token;
         $this->botApi = $bot_api;
         $this->chatId = $chat_id;
         $this->topicId = $topic_id;
+        $this->topicsLevel = $topics_level;
         $this->level = $level;
         $this->bubble = $bubble;
         $this->proxy = $proxy;
     }
 
     /**
      * @inheritDoc
+     * @throws \ReflectionException
      */
     protected function write($record): void
     {
+        $topicId = $this->getTopicByAttribute();
         $token = $record['context']['token'] ?? null;
         $chatId = $record['context']['chat_id'] ?? null;
-        $topicId = $record['context']['topic_id'] ?? null;
+        $topicId = $topicId ?? $record['context']['topic_id'] ?? null;
 
         $this->send($record['formatted'], $token, $chatId, $topicId);
     }
@@ -141,6 +155,41 @@ protected function send(string $message, $token = null, $chatId = null, $topicId
         }
     }
 
+
+    protected function getTopicByAttribute(): string|null
+    {
+        $route = Route::current();
+        if ($route == null) {
+            return null;
+        }
+
+        $action = $route->getAction();
+
+        if (!isset($action['controller'])) {
+            return null;
+        }
+
+        try {
+
+            [$controller, $method] = explode('@', $action['controller']);
+            $reflectionMethod = new ReflectionMethod($controller, $method);
+
+            $attributes = $reflectionMethod->getAttributes();
+
+            if (empty($attributes)) {
+                return null;
+            }
+
+            /** @var TopicLogInterface $notifyException */
+            $notifyException = $attributes[0]->newInstance();
+
+            return $notifyException->getTopicId($this->topicsLevel);
+
+        } catch (\Throwable) {
+            return null;
+        }
+    }
+
     public function setToken(string $token): static
     {
         $this->token = $token;