From 48be0b2b610bcd775ec597e4e1ace5c7f32dd3c5 Mon Sep 17 00:00:00 2001
From: jock <findsource@proton.me>
Date: Mon, 9 Jun 2025 16:53:01 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E6=97=A5=E5=BF=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 watcher.py | 17 ++++++++++++-----
 1 file changed, 12 insertions(+), 5 deletions(-)

diff --git a/watcher.py b/watcher.py
index 1b8fda7..36e3edc 100644
--- a/watcher.py
+++ b/watcher.py
@@ -2,9 +2,10 @@ import asyncio
 from pathlib import Path
 
 import websockets
-from watchdog.events import FileSystemEventHandler
+from watchdog.events import FileSystemEventHandler, FileSystemEvent
 from watchdog.observers import Observer
 from websockets.asyncio.server import serve, ServerConnection
+from logger import logger
 
 
 # Credentials.json 文件位置
@@ -53,8 +54,13 @@ class CredentialsFileHandler(FileSystemEventHandler):
         self.filename = filename
         self.loop = eventloop
         self.notification_queue = notification_queue
+        logger.debug(f"开始监控文件: {filename}")
+
+    def on_any_event(self, event: FileSystemEvent) -> None:
+        logger.debug(f"on_any_event: {event}")
 
     def on_modified(self, event):
+        logger.debug(f"on_modified: {event}")
         if event.src_path == self.filename:
             try:
                 with open(self.filename, 'r') as file:
@@ -67,11 +73,16 @@ class CredentialsFileHandler(FileSystemEventHandler):
 # 启动 websocket 服务
 async def main(notification_queue):
     asyncio.create_task(notify_clients(notification_queue))
+
+    logger.info(f"开始启动 websocket 服务")
     async with serve(connect_handler, "localhost") as server:
         for socket in server.sockets:
             port = socket.getsockname()[1]
+            logger.info(f"websocket 端口: {port}")
             print(f"WebSocket 监听地址: ws://localhost:{port}")
             print("\n所有服务已启动完毕! \n\n请配置网站的 Credentials 设置以抓取阅读量等数据")
+
+        logger.info(f"websocket 服务启动完毕")
         await server.serve_forever()
 
 
@@ -95,7 +106,3 @@ def start():
         observer.join()
         loop.close()
 
-
-# Program entry point
-if __name__ == "__main__":
-    start()