Изменения вебсокета

chat_test/app/templates/chat.html

@@ -13,7 +13,7 @@
 </div>
 <script>
     async function getLastMessages() {
-        const url = 'http://localhost:8000/chat/last_messages'
+        const url = 'http://localhost:8000/api/chat/get_last_message/2'
         const response = await fetch(url, {
             method: 'GET'
         })
@@ -41,7 +41,9 @@
     document.querySelector("#ws-id").textContent = chat_id;
     let ws = new WebSocket(`ws://localhost:8000/chat/ws/${chat_id}?user_id=1`);
     ws.onmessage = function (event) {
-        appendMessage(event.data)
+        const data = JSON.parse(event.data)
+        appendMessage(data.message);
+        console.log(data)
     };
 
     function sendMessage(event) {

chat_test/app/users/chat/router.py

@@ -15,7 +15,7 @@ router = APIRouter(
 )
 
 
-@router.get('')
+@router.get("")
 async def get_all_chats(user: Users = Depends(get_current_user)):
     return await UserDAO.get_user_allowed_chats(user.id)
 

chat_test/app/users/chat/websocket.py

@@ -26,7 +26,7 @@ class ConnectionManager(WebSocket):
     async def broadcast(self, user_id: int, chat_id: int, message: str):
         await self.add_message_to_database(user_id=user_id, chat_id=chat_id, message=message)
         for websocket in self.active_connections[chat_id]:
-            await websocket.send_text('{"message": ' + message + "}")
+            await websocket.send_json({'message': message})
 
     @staticmethod
     async def add_message_to_database(user_id: int, chat_id: int, message: str):