From 40822fe77afc342cc670c4b62aff4cf80afa2866 Mon Sep 17 00:00:00 2001
From: Soulter <905617992@qq.com>
Date: Sat, 5 Apr 2025 15:43:40 +0800
Subject: [PATCH 1/2] =?UTF-8?q?=E2=9C=A8=20feat:=20=E6=9B=B4=E6=96=B0?=
 =?UTF-8?q?=E6=97=A5=E5=BF=97=E5=8F=91=E5=B8=83=E6=9C=BA=E5=88=B6=EF=BC=8C?=
 =?UTF-8?q?=E6=94=AF=E6=8C=81=E6=97=A5=E5=BF=97=E7=BA=A7=E5=88=AB=E5=92=8C?=
 =?UTF-8?q?=E5=86=85=E5=AE=B9=E7=9A=84=E5=AD=97=E5=85=B8=E6=A0=BC=E5=BC=8F?=
 =?UTF-8?q?=EF=BC=8C=E5=A2=9E=E5=8A=A0=E6=97=A5=E5=BF=97=E7=AD=9B=E9=80=89?=
 =?UTF-8?q?=E5=8A=9F=E8=83=BD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

fixes: #1010
---
 astrbot/core/log.py                           |  11 +-
 astrbot/dashboard/routes/log.py               |   2 +-
 .../components/shared/ConsoleDisplayer.vue    | 100 ++++++++++++++++--
 dashboard/src/stores/common.js                |   4 +-
 dashboard/src/views/ConsolePage.vue           |   2 +-
 5 files changed, 103 insertions(+), 16 deletions(-)

diff --git a/astrbot/core/log.py b/astrbot/core/log.py
index 501f0012e..e1e2cde2e 100644
--- a/astrbot/core/log.py
+++ b/astrbot/core/log.py
@@ -108,11 +108,12 @@ class LogBroker:
         """
         self.subscribers.remove(q)
 
-    def publish(self, log_entry: str):
+    def publish(self, log_entry: dict):
         """发布新日志到所有订阅者, 使用非阻塞方式投递, 避免一个订阅者阻塞整个系统
 
         Args:
-            log_entry (str): 日志消息, 可以是字符串或字典
+            log_entry (dict): 日志消息, 包含日志级别和日志内容.
+                example: {"level": "INFO", "data": "This is a log message.", "time": "2023-10-01 12:00:00"}
         """
         self.log_cache.append(log_entry)
         for q in self.subscribers:
@@ -140,7 +141,11 @@ class LogQueueHandler(logging.Handler):
             record (logging.LogRecord): 日志记录对象, 包含日志信息
         """
         log_entry = self.format(record)
-        self.log_broker.publish(log_entry)
+        self.log_broker.publish({
+            "level": record.levelname,
+            "time": record.asctime,
+            "data": log_entry,
+        })
 
 
 class LogManager:
diff --git a/astrbot/dashboard/routes/log.py b/astrbot/dashboard/routes/log.py
index b1c68722c..6f3940c0a 100644
--- a/astrbot/dashboard/routes/log.py
+++ b/astrbot/dashboard/routes/log.py
@@ -20,7 +20,7 @@ class LogRoute(Route):
                     message = await queue.get()
                     payload = {
                         "type": "log",
-                        "data": message,
+                        **message # see astrbot/core/log.py
                     }
                     yield f"data: {json.dumps(payload, ensure_ascii=False)}\n\n"
             except asyncio.CancelledError:
diff --git a/dashboard/src/components/shared/ConsoleDisplayer.vue b/dashboard/src/components/shared/ConsoleDisplayer.vue
index dfee44ce9..1a2d2e520 100644
--- a/dashboard/src/components/shared/ConsoleDisplayer.vue
+++ b/dashboard/src/components/shared/ConsoleDisplayer.vue
@@ -3,9 +3,20 @@ import { useCommonStore } from '@/stores/common';
 </script>
 
 <template>
-    <div id="term"
-      style="background-color: #1e1e1e; padding: 16px; border-radius: 8px; overflow-y:auto">
+  <div>
+    <!-- 添加筛选级别控件 -->
+    <div class="filter-controls mb-2">
+      <v-chip-group v-model="selectedLevels" column multiple>
+        <v-chip v-for="level in logLevels" :key="level" :color="getLevelColor(level)" filter
+          :text-color="level === 'DEBUG' || level === 'INFO' ? 'black' : 'white'">
+          {{ level }}
+        </v-chip>
+      </v-chip-group>
     </div>
+
+    <div id="term" style="background-color: #1e1e1e; padding: 16px; border-radius: 8px; overflow-y:auto; height: 100%">
+    </div>
+  </div>
 </template>
 
 <script>
@@ -25,7 +36,16 @@ export default {
         'default': 'color: #FFFFFF;'
       },
       logCache: useCommonStore().getLogCache(),
-      historyNum_: -1
+      historyNum_: -1,
+      logLevels: ['DEBUG', 'INFO', 'WARNING', 'ERROR', 'CRITICAL'],
+      selectedLevels: [0, 1, 2, 3, 4], // 默认选中所有级别
+      levelColors: {
+        'DEBUG': 'grey',
+        'INFO': 'blue-lighten-3',
+        'WARNING': 'amber',
+        'ERROR': 'red',
+        'CRITICAL': 'purple'
+      }
     }
   },
   props: {
@@ -37,7 +57,16 @@ export default {
   watch: {
     logCache: {
       handler(val) {
-        this.printLog(val[this.logCache.length - 1])
+        const lastLog = val[this.logCache.length - 1];
+        if (lastLog && this.isLevelSelected(lastLog.level)) {
+          this.printLog(lastLog.data);
+        }
+      },
+      deep: true
+    },
+    selectedLevels: {
+      handler() {
+        this.refreshDisplay();
       },
       deep: true
     }
@@ -50,6 +79,32 @@ export default {
     }
   },
   methods: {
+    getLevelColor(level) {
+      return this.levelColors[level] || 'grey';
+    },
+
+    isLevelSelected(level) {
+      for (let i = 0; i < this.selectedLevels.length; ++i) {
+        let level_ = this.logLevels[this.selectedLevels[i]]
+        console
+        if (level_ === level) {
+          return true;
+        }
+      }
+      return false;
+    },
+
+    refreshDisplay() {
+      // 清空现有的显示
+      const termElement = document.getElementById('term');
+      if (termElement) {
+        termElement.innerHTML = '';
+      }
+
+      // 重新显示符合筛选条件的日志
+      this.init();
+    },
+
     delayInit() {
       if (this.logCache.length === 0) {
         setTimeout(() => {
@@ -64,18 +119,21 @@ export default {
       this.historyNum_ = parseInt(this.historyNum)
       let i = 0
       for (let log of this.logCache) {
+        if (this.isLevelSelected(log.level)) { // 只显示选中级别的日志
           if (this.historyNum_ != -1 && i >= this.logCache.length - this.historyNum_) {
-            this.printLog(log)
+            this.printLog(log.data)
             ++i
           } else if (this.historyNum_ == -1) {
-            this.printLog(log)
+            this.printLog(log.data)
           }
+        }
       }
     },
 
     toggleAutoScroll() {
       this.autoScroll = !this.autoScroll;
     },
+
     printLog(log) {
       // append 一个 span 标签到 term，block 的方式
       let ele = document.getElementById('term')
@@ -88,14 +146,38 @@ export default {
           break
         }
       }
+
       span.style = style + 'display: block; font-size: 12px; font-family: Consolas, monospace; white-space: pre-wrap;'
       span.classList.add('fade-in')
-      span.innerText = log
+      span.innerText = `${log}`;
       ele.appendChild(span)
-      if (this.autoScroll) {
+      if (this.autoScroll ) {
         ele.scrollTop = ele.scrollHeight
       }
     }
   },
 }
-</script>
\ No newline at end of file
+</script>
+
+<style scoped>
+.filter-controls {
+  display: flex;
+  flex-wrap: wrap;
+  gap: 8px;
+  margin-bottom: 8px;
+}
+
+.fade-in {
+  animation: fadeIn 0.3s;
+}
+
+@keyframes fadeIn {
+  from {
+    opacity: 0;
+  }
+
+  to {
+    opacity: 1;
+  }
+}
+</style>
\ No newline at end of file
diff --git a/dashboard/src/stores/common.js b/dashboard/src/stores/common.js
index f983115ca..c4b90b8d2 100644
--- a/dashboard/src/stores/common.js
+++ b/dashboard/src/stores/common.js
@@ -71,8 +71,8 @@ export const useCommonStore = defineStore({
 
               let data_json = JSON.parse(data)
               if (data_json.type === 'log') {
-                let log = data_json.data
-                this.log_cache.push(log);
+                // let log = data_json.data
+                this.log_cache.push(data_json);
                 if (this.log_cache.length > this.log_cache_max_len) {
                   this.log_cache.shift();
                 }
diff --git a/dashboard/src/views/ConsolePage.vue b/dashboard/src/views/ConsolePage.vue
index e638df47c..2ac9b3a73 100644
--- a/dashboard/src/views/ConsolePage.vue
+++ b/dashboard/src/views/ConsolePage.vue
@@ -44,7 +44,7 @@ import axios from 'axios';
         </v-dialog>
       </div>
     </div>
-    <ConsoleDisplayer ref="consoleDisplayer" style="height: calc(100vh - 160px); " />
+    <ConsoleDisplayer ref="consoleDisplayer" style="height: calc(100vh - 220px); " />
   </div>
 </template>
 <script>

From d3a7fef9b030cab8bd59c76cbfb9ebbc074196df Mon Sep 17 00:00:00 2001
From: Soulter <905617992@qq.com>
Date: Sat, 5 Apr 2025 15:46:45 +0800
Subject: [PATCH 2/2] =?UTF-8?q?=F0=9F=90=9B=20=E4=BF=AE=E5=A4=8D:=20?=
 =?UTF-8?q?=E7=A7=BB=E9=99=A4=E5=A4=9A=E4=BD=99=E7=9A=84=20console=20?=
 =?UTF-8?q?=E8=AF=AD=E5=8F=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 dashboard/src/components/shared/ConsoleDisplayer.vue | 1 -
 1 file changed, 1 deletion(-)

diff --git a/dashboard/src/components/shared/ConsoleDisplayer.vue b/dashboard/src/components/shared/ConsoleDisplayer.vue
index 1a2d2e520..e780d6569 100644
--- a/dashboard/src/components/shared/ConsoleDisplayer.vue
+++ b/dashboard/src/components/shared/ConsoleDisplayer.vue
@@ -86,7 +86,6 @@ export default {
     isLevelSelected(level) {
       for (let i = 0; i < this.selectedLevels.length; ++i) {
         let level_ = this.logLevels[this.selectedLevels[i]]
-        console
         if (level_ === level) {
           return true;
         }