Utilities/common
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: 'LogRecord' format

Browse Source
This commit is contained in:
break27
2026-04-17 09:45:53 +08:00
parent ad5f0b0010
commit d3502f7a86
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/common/jsonrpc2/server.py
View File

@@ -88,7 +88,11 @@ class History(logging.Handler):
self.records = [] self.records = []
def emit(self, record): def emit(self, record):
self.records.append(vars(record)) keys = set(['name', 'levelno', 'levelname', 'msg', 'exc_text', 'stack_info', 'created'])
values = vars(record)
values['msg'] %= values['args']
result = { key: values[key] for key in keys }
self.records.append(result)
def truncate(self) -> list: def truncate(self) -> list:
copy = self.records.copy() copy = self.records.copy()
@@ -151,13 +155,10 @@ async def handler(request: ws.WebSocketRequest):
if mid is not None: await connection.send_message(str(Response(mid, err or res))) if mid is not None: await connection.send_message(str(Response(mid, err or res)))
async def backend(options: Options): async def backend(options: Options):
import _thread as t
global server global server
listeners = await trio.open_tcp_listeners(port=options.port, host=options.listen) listeners = await trio.open_tcp_listeners(port=options.port, host=options.listen)
server = ws.WebSocketServer(handler, listeners, max_message_size=options.max_message_size) server = ws.WebSocketServer(handler, listeners, max_message_size=options.max_message_size)
await server.run() await server.run()
t.interrupt_main()
def define(method: str, handler: Callable[..., Any]): def define(method: str, handler: Callable[..., Any]):
if method in handlers: raise KeyError() if method in handlers: raise KeyError()