From d0aeadc5b5502ebba843bcfc87a3f0278fbfcd5b Mon Sep 17 00:00:00 2001
From: "S.H.Mahmoudzadeh" <s.a.mahmoudzadeh@gmail.com>
Date: Thu, 13 Jun 2024 15:09:44 +0330
Subject: [PATCH] feat: add topics level feature

---
 .../AbstractTopicLevelAttribute.php           | 11 +++
 src/Attributes/CriticalAttribute.php          | 10 +++
 src/Attributes/DebugAttribute.php             | 10 +++
 src/Attributes/EmergencyAttribute.php         | 10 +++
 src/Attributes/ImportantAttribute.php         | 10 +++
 src/Attributes/InformationAttribute.php       | 10 +++
 src/Attributes/LowPriorityAttribute.php       | 10 +++
 src/Attributes/TopicLogInterface.php          |  8 +++
 src/TelegramBotHandler.php                    | 67 ++++++++++++++++---
 9 files changed, 137 insertions(+), 9 deletions(-)
 create mode 100644 src/Attributes/AbstractTopicLevelAttribute.php
 create mode 100644 src/Attributes/CriticalAttribute.php
 create mode 100644 src/Attributes/DebugAttribute.php
 create mode 100644 src/Attributes/EmergencyAttribute.php
 create mode 100644 src/Attributes/ImportantAttribute.php
 create mode 100644 src/Attributes/InformationAttribute.php
 create mode 100644 src/Attributes/LowPriorityAttribute.php
 create mode 100644 src/Attributes/TopicLogInterface.php

diff --git a/src/Attributes/AbstractTopicLevelAttribute.php b/src/Attributes/AbstractTopicLevelAttribute.php
new file mode 100644
index 0000000..b04f486
--- /dev/null
+++ b/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;
+    }
+}
diff --git a/src/Attributes/CriticalAttribute.php b/src/Attributes/CriticalAttribute.php
new file mode 100644
index 0000000..1546132
--- /dev/null
+++ b/src/Attributes/CriticalAttribute.php
@@ -0,0 +1,10 @@
+<?php
+
+namespace TheCoder\MonologTelegram\Attributes;
+
+use Attribute;
+
+#[Attribute]
+final class CriticalAttribute extends AbstractTopicLevelAttribute
+{
+}
diff --git a/src/Attributes/DebugAttribute.php b/src/Attributes/DebugAttribute.php
new file mode 100644
index 0000000..1ed643f
--- /dev/null
+++ b/src/Attributes/DebugAttribute.php
@@ -0,0 +1,10 @@
+<?php
+
+namespace TheCoder\MonologTelegram\Attributes;
+
+use Attribute;
+
+#[Attribute]
+final class DebugAttribute extends AbstractTopicLevelAttribute
+{
+}
\ No newline at end of file
diff --git a/src/Attributes/EmergencyAttribute.php b/src/Attributes/EmergencyAttribute.php
new file mode 100644
index 0000000..9d1d867
--- /dev/null
+++ b/src/Attributes/EmergencyAttribute.php
@@ -0,0 +1,10 @@
+<?php
+
+namespace TheCoder\MonologTelegram\Attributes;
+
+use Attribute;
+
+#[Attribute]
+final class EmergencyAttribute extends AbstractTopicLevelAttribute
+{
+}
diff --git a/src/Attributes/ImportantAttribute.php b/src/Attributes/ImportantAttribute.php
new file mode 100644
index 0000000..fc95524
--- /dev/null
+++ b/src/Attributes/ImportantAttribute.php
@@ -0,0 +1,10 @@
+<?php
+
+namespace TheCoder\MonologTelegram\Attributes;
+
+use Attribute;
+
+#[Attribute]
+final class ImportantAttribute extends AbstractTopicLevelAttribute
+{
+}
\ No newline at end of file
diff --git a/src/Attributes/InformationAttribute.php b/src/Attributes/InformationAttribute.php
new file mode 100644
index 0000000..b4c3d67
--- /dev/null
+++ b/src/Attributes/InformationAttribute.php
@@ -0,0 +1,10 @@
+<?php
+
+namespace TheCoder\MonologTelegram\Attributes;
+
+use Attribute;
+
+#[Attribute]
+final class InformationAttribute extends AbstractTopicLevelAttribute
+{
+}
\ No newline at end of file
diff --git a/src/Attributes/LowPriorityAttribute.php b/src/Attributes/LowPriorityAttribute.php
new file mode 100644
index 0000000..4b986d0
--- /dev/null
+++ b/src/Attributes/LowPriorityAttribute.php
@@ -0,0 +1,10 @@
+<?php
+
+namespace TheCoder\MonologTelegram\Attributes;
+
+use Attribute;
+
+#[Attribute]
+final class LowPriorityAttribute extends AbstractTopicLevelAttribute
+{
+}
\ No newline at end of file
diff --git a/src/Attributes/TopicLogInterface.php b/src/Attributes/TopicLogInterface.php
new file mode 100644
index 0000000..4766a53
--- /dev/null
+++ b/src/Attributes/TopicLogInterface.php
@@ -0,0 +1,8 @@
+<?php
+
+namespace TheCoder\MonologTelegram\Attributes;
+
+interface TopicLogInterface
+{
+    public function getTopicID(array $topicsLevel): string|null;
+}
diff --git a/src/TelegramBotHandler.php b/src/TelegramBotHandler.php
index 2374b6a..9d03578 100644
--- a/src/TelegramBotHandler.php
+++ b/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,26 +55,32 @@ 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;
@@ -76,12 +88,14 @@ public function __construct(
 
     /**
      * @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;