Trilltechnician/hack-house
1
1
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

Updated server/server.py

Browse Source
This commit is contained in:
mirai 2022-12-02 08:25:30 +03:00
parent 0547d38d69
commit 09bca5e737
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
server/server.py
View File

@ -17,9 +17,8 @@ users: dict[str, str] = {}
key = Fernet.generate_key() key = Fernet.generate_key()
#@app.route('/talk', methods=["GET", "POST"]) @app.route('/talk', methods=["GET", "POST"])
@app.websocket("/talk") async def talking(request: Request) -> HTTPResponse:
async def talking(request: Request, ws: Websocket) -> HTTPResponse:
new_message = Message( new_message = Message(
message=request.form.get("text") message=request.form.get("text")
) )
@ -31,8 +30,11 @@ async def talking(request: Request, ws: Websocket) -> HTTPResponse:
@app.websocket("/update") @app.websocket("/update")
async def talking(request: Request, ws: Websocket) -> HTTPResponse: async def talking(request: Request, ws: Websocket) -> HTTPResponse:
while True: while True:
string = str({"status": [i.message for i in actual_messages], "users_in_chat": list(users.keys())}) payload = str({
await ws.send(string.encode()) "status": [i.message for i in actual_messages],
"users_in_chat": list(users.keys())
})
await ws.send(payload.encode())
await asyncio.sleep(0.2) await asyncio.sleep(0.2)
# return response.json({ # return response.json({
# "status": [i.message for i in actual_messages], # "status": [i.message for i in actual_messages],