Изменения вебсокета
This commit is contained in:
parent
f37a576936
commit
e00aec63c1
1 changed files with 3 additions and 0 deletions
|
@ -1,3 +1,5 @@
|
||||||
|
import logging
|
||||||
|
|
||||||
import websockets
|
import websockets
|
||||||
from fastapi import WebSocket, WebSocketDisconnect, Depends
|
from fastapi import WebSocket, WebSocketDisconnect, Depends
|
||||||
|
|
||||||
|
@ -42,6 +44,7 @@ class ConnectionManager:
|
||||||
raise IncorrectDataException
|
raise IncorrectDataException
|
||||||
|
|
||||||
async def send(self, uow: UnitOfWork, user_id: int, chat_id: int, message: dict) -> dict:
|
async def send(self, uow: UnitOfWork, user_id: int, chat_id: int, message: dict) -> dict:
|
||||||
|
logging.critical(message)
|
||||||
message = SSendMessage.model_validate(message)
|
message = SSendMessage.model_validate(message)
|
||||||
|
|
||||||
new_message = await self.add_message_to_database(uow=uow, user_id=user_id, chat_id=chat_id, message=message)
|
new_message = await self.add_message_to_database(uow=uow, user_id=user_id, chat_id=chat_id, message=message)
|
||||||
|
|
Loading…
Add table
Reference in a new issue