Update controllers/ws_controller.py

controllers/ws_controller.py

@@ -32,15 +32,7 @@ def get_messages(code: str,websocket:WebSocket,brand_name: Optional[str] = None)
         message_id = message_data.get("id")
         if message_id:
             message=fetch_message_data(access_token, message_id)
-            loop = asyncio.new_event_loop()
-            asyncio.set_event_loop(loop)
-            
-            # Run the asynchronous method within the event loop
-            result = loop.run_until_complete(process_message(message,websocket,1000))
-            
-            # Close the event loop
-            loop.close()
-            
+            asyncio.run(process_message(message, websocket, 1000))
             
         return None
 
@@ -55,7 +47,7 @@ def get_messages(code: str,websocket:WebSocket,brand_name: Optional[str] = None)
         print(gmail_data)
         
         if "messages" in gmail_data:
-            with ThreadPoolExecutor(max_workers=5) as executor:
+            with ThreadPoolExecutor(max_workers=15) as executor:
                 for message_data in gmail_data["messages"]:
                            
                     executor.submit(fetch_message_wrapper, message_data , websocket)