Skip to content

Commit 93e776e

Browse files
Added Delete Message Option
1 parent 3ecd391 commit 93e776e

1 file changed

Lines changed: 14 additions & 0 deletions

File tree

server.py

Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -67,6 +67,20 @@ async def websocket_endpoint(websocket: WebSocket):
6767
try:
6868

6969
while True:
70+
71+
msg_type = message.get("type")
72+
73+
if msg_type == "delete":
74+
msg_id = message.get("id")
75+
76+
cursor.execute("DELETE FROM messages WHERE id=?", (msg_id,))
77+
conn.commit()
78+
79+
await manager.broadcast(json.dumps({
80+
"type": "delete",
81+
"id": msg_id
82+
}))
83+
continue
7084

7185
data = await websocket.receive_text()
7286

0 commit comments

Comments
 (0)