Update app.py

app.py

@@ -141,7 +141,11 @@ async def websocket_endpoint(
                     )
                 ).strip()
 
-                if user == "" or password == "":
+                if (
+                    user == ""
+                    or
+                    password == ""
+                ):
 
                     await ws.send_text(
                         json.dumps({
@@ -225,6 +229,8 @@ async def websocket_endpoint(
                     except:
                         pass
 
+                # Envoi des propriétaires des entreprises
+
                 for path, owner in (
                     entreprises_data.items()
                 ):
@@ -241,7 +247,11 @@ async def websocket_endpoint(
             # POSITION
             # =====================================
 
-            elif msg_type == "player_update":
+            elif (
+                msg_type
+                ==
+                "player_update"
+            ):
 
                 player_positions[
                     session_id
@@ -275,42 +285,15 @@ async def websocket_endpoint(
                     except:
                         pass
 
-            # =====================================
-            # CHAT
-            # =====================================
-
-            elif msg_type == "chat_message":
-
-                broadcast = {
-                    "type":"chat_message",
-                    "username":data.get(
-                        "username",
-                        "Unknown"
-                    ),
-                    "message":data.get(
-                        "message",
-                        ""
-                    )
-                }
-
-                for client in clients.values():
-
-                    try:
-
-                        await client.send_text(
-                            json.dumps(
-                                broadcast
-                            )
-                        )
-
-                    except:
-                        pass
-
             # =====================================
             # MONEY
             # =====================================
 
-            elif msg_type == "save_money":
+            elif (
+                msg_type
+                ==
+                "save_money"
+            ):
 
                 if username:
 
@@ -329,26 +312,58 @@ async def websocket_endpoint(
             # PROGRESS
             # =====================================
 
-            elif msg_type == "save_progress":
+            elif (
+                msg_type
+                ==
+                "save_progress"
+            ):
 
                 if username:
 
-                    players_data[
-                        username
-                    ]["progress"] = int(
+                    progress = int(
                         data.get(
                             "progress",
                             1
                         )
                     )
 
+                    players_data[
+                        username
+                    ]["progress"] = progress
+
                     save_players()
 
+                    broadcast = {
+                        "type":"player_progress",
+                        "id":session_id,
+                        "progress":progress
+                    }
+
+                    for sid, client in clients.items():
+
+                        if sid == session_id:
+                            continue
+
+                        try:
+
+                            await client.send_text(
+                                json.dumps(
+                                    broadcast
+                                )
+                            )
+
+                        except:
+                            pass
+
             # =====================================
-            # SAVE ENTREPRISE
+            # ENTREPRISE
             # =====================================
 
-            elif msg_type == "save_entreprise":
+            elif (
+                msg_type
+                ==
+                "save_entreprise"
+            ):
 
                 path = data.get(
                     "path",
@@ -370,7 +385,11 @@ async def websocket_endpoint(
             # CHANGE OWNER
             # =====================================
 
-            elif msg_type == "set_entreprise_owner":
+            elif (
+                msg_type
+                ==
+                "set_entreprise_owner"
+            ):
 
                 path = data.get(
                     "path",
@@ -413,7 +432,7 @@ async def websocket_endpoint(
 
     finally:
 
-        # Libération des entreprises
+        # Libération entreprises
 
         to_clear = []
 
@@ -467,10 +486,6 @@ async def websocket_endpoint(
             except:
                 pass
 
-# ======================================================
-# RUN
-# ======================================================
-
 if __name__ == "__main__":
 
     port = int(