ITQC/pydase
24
0
Fork 0
mirror of https://github.com/tiqi-group/pydase.git synced 2025-06-06 13:30:41 +02:00
Code Issues Packages Projects Releases Wiki Activity

updates SocketIOHandler

Browse Source
This commit is contained in:
Mose Müller 2023-11-27 16:01:36 +01:00
parent 3970d5a17b
commit a769f4eb3b
1 changed files with 10 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/pydase/utils/logging.py
View File

@ -37,9 +37,15 @@ class DefaultFormatter(uvicorn.logging.ColourizedFormatter):
class SocketIOHandler(logging.Handler): class SocketIOHandler(logging.Handler):
def __init__(self, sio: socketio.AsyncServer, level: int = 40) -> None: """
super().__init__(level) Custom logging handler that emits ERROR and EXCEPTION log records to a Socket.IO
self.sio = sio server, allowing for real-time logging in applications that use Socket.IO for
communication.
"""
def __init__(self, sio: socketio.AsyncServer) -> None:
super().__init__(logging.ERROR)
self._sio = sio
def format(self, record: logging.LogRecord) -> str: def format(self, record: logging.LogRecord) -> str:
return f"{record.name}:{record.funcName}:{record.lineno} - {record.message}" return f"{record.name}:{record.funcName}:{record.lineno} - {record.message}"
@ -49,7 +55,7 @@ class SocketIOHandler(logging.Handler):
loop = asyncio.get_event_loop() loop = asyncio.get_event_loop()
loop.create_task( loop.create_task(
self.sio.emit( # type: ignore[reportUnknownMemberType] self._sio.emit( # type: ignore[reportUnknownMemberType]
"log", "log",
{ {
"levelname": record.levelname, "levelname": record.levelname,