Update app.py

app.py

@@ -16,28 +16,28 @@ JOIN = {}
 
 WATCH = {}
 
-async def create_file(websocket, project_name, path):
+async def create_file(websocket, project_name, path, connected):
     file_path = os.path.join(os.getcwd(), 'projects', project_name, path)
     # Create the file
     with open(file_path, 'w'):
             pass
-    await websocket.send(f"file created to {file_path}")
+    websockets.broadcast(connected,f"file created to {file_path}")
 
-async def create_folder(websocket, project_name, path):
+async def create_folder(websocket, project_name, path, connected):
     folder_path = os.path.join(os.getcwd(), 'projects', project_name, path)
     # Create the folder
     os.makedirs(folder_path)
-    await websocket.send(f"folder created to {folder_path}")
+    websockets.broadcast(connected,f"folder created to {folder_path}")
 
-async def wirte_file(websocket, project_name, path, content):
+async def wirte_file(websocket, project_name, path, content, connected):
     try:
         file_path = os.path.join(os.getcwd(), 'projects', project_name, path)
         file_content = content
         with open(file_path, 'w', encoding='utf-8') as file:
             file.write(file_content)
-        await websocket.send(f"Content written to {file_path}")
+        websockets.broadcast(connected,f"Content written to {file_path}")
     except FileNotFoundError as e:
-        await websocket.send(f"Error: {str(e)}")
+        websockets.broadcast(connected,f"Error: {str(e)}")
     
 
 async def execute_command(websocket, project_name, command, connected):
@@ -185,16 +185,16 @@ async def exe(websocket,connected):
                await execute_command(websocket, event["project_name"], event["command"], connected)
             elif "write" in event:
                 
-                await wirte_file(websocket, event["project_name"], event["path"], event["content"])
+                await wirte_file(websocket, event["project_name"], event["path"], event["content"], connected)
             elif "create" in event:
                 
-                await wirte_file(websocket, event["project_name"], event["path"], event["content"]) #Todo
+                await wirte_file(websocket, event["project_name"], event["path"], event["content"], connected) #Todo
             elif "delete" in event:
                 
-                await wirte_file(websocket, event["project_name"], event["path"], event["content"]) #Todo
+                await wirte_file(websocket, event["project_name"], event["path"], event["content"], connected) #Todo
             elif "rename" in event:
                 
-                await wirte_file(websocket, event["project_name"], event["path"], event["content"]) #Todo
+                await wirte_file(websocket, event["project_name"], event["path"], event["content"], connected) #Todo
         
             else:
                 # First player starts a new game.