Update app.py

app.py

@@ -45,7 +45,12 @@ async def delete_item(websocket, project_name, path, connected):
                     shutil.rmtree(item_path)  # Remove the directory and its contents
                   elif os.path.isfile(item_path):
                       os.remove(item_path)  # Remove the file
-
+                    
+                  event = {
+                "type": "delete-success",
+                "data": item_path,
+            }
+                  websockets.broadcast(connected,json.dumps(event))
                   websockets.broadcast(connected,'success')
               else:
                   print('item not found')
@@ -59,13 +64,23 @@ async def create_file(websocket, project_name, path, connected):
     # Create the file
     with open(file_path, 'w'):
             pass
-    websockets.broadcast(connected,f"file created to {file_path}")
+    event = {
+                "type": "file-created",
+                "data": file_path,
+            }
+    websockets.broadcast(connected,json.dumps(event))
+    
 
 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)
-    websockets.broadcast(connected,f"folder created to {folder_path}")
+    event = {
+                "type": "folder-created",
+                "data": folder_path,
+            }
+    websockets.broadcast(connected,json.dumps(event))
+    
 
 async def wirte_file(websocket, project_name, path, content, connected):
     try:
@@ -73,9 +88,19 @@ async def wirte_file(websocket, project_name, path, content, connected):
         file_content = content
         with open(file_path, 'w', encoding='utf-8') as file:
             file.write(file_content)
-        websockets.broadcast(connected,f"Content written to {file_path}")
+
+        event = {
+                "type": "write-success",
+                "data": file_path,
+            }
+        websockets.broadcast(connected,json.dumps(event))
     except FileNotFoundError as e:
-        websockets.broadcast(connected,f"Error: {str(e)}")
+        event = {
+                "type": "write-error",
+                "data": e,
+            }
+        websockets.broadcast(connected,json.dumps(event))
+        
     
 
 async def execute_command(websocket, project_name, command, connected):
@@ -94,18 +119,25 @@ async def execute_command(websocket, project_name, command, connected):
         async def send_message(message):
             print('sending msg')
             # await websocket.send(f'data: {message}')
-            websockets.broadcast(connected,f'data: {message}' )
+            websockets.broadcast(connected,json.dumps(message) )
 
         async for line in process.stdout:
             print('sending line')
-            print(line.strip())
-            # await process_input_request(line)
-            await send_message(line.strip())
-            print(line.strip())
+            
+            event = {
+                "type": "terminal-data",
+                "data": line.strip(),
+            }
+            await send_message(event)
+            
 
         async for line in process.stderr:
             print(f'error:{line.strip()}')
-            await send_message(f'error:{line.strip()}')
+            event = {
+                "type": "terminal-error",
+                "data": line.strip(),
+            }
+            await send_message(event)
 
         return_code = await process.wait()
         if return_code == 0: