Update controllers/fetch_microsoft_mails.py

controllers/fetch_microsoft_mails.py

@@ -76,32 +76,32 @@ async def get_messages(code: str,websocket:WebSocket,brand_name: Optional[str] =
             
         return None
 
-    while True:
+    # while True:
         # outlook_url = f"https://graph.microsoft.com/v1.0/me/messages?$filter=subject eq '{g_query}'"
-        outlook_url = f"https://graph.microsoft.com/v1.0/me/messages"
-        outlook_response = requests.get(outlook_url, headers={"Authorization": f"Bearer {access_token}"})
-        outlook_data = outlook_response.json()
-        print(len(outlook_data))
-        print(outlook_data)
+    outlook_url = f"https://graph.microsoft.com/v1.0/me/messages"
+    outlook_response = requests.get(outlook_url, headers={"Authorization": f"Bearer {access_token}"})
+    outlook_data = outlook_response.json()
+    # print(len(outlook_data))
+    # print(outlook_data)
         
-        if "value" in outlook_data:
-            with ThreadPoolExecutor(max_workers=15) as executor:
+    if "value" in outlook_data:
+        with ThreadPoolExecutor(max_workers=15) as executor:
                 
                            
                 
-                futures=[executor.submit(fetch_message_wrapper, message_data) for message_data in
-                           outlook_data["value"]]
-                for future in futures:
-                    message = future.result()
-                    if message:
-                        messages.append(message)
-            for message_data in messages:
-                await process_message(message_data,websocket,10000)
-
-        if "@odata.nextLink" in outlook_data:
-            outlook_url = outlook_data["@odata.nextLink"]
-        else:
-            break
+            futures=[executor.submit(fetch_message_wrapper, message_data) for message_data in
+                        outlook_data["value"]]
+            for future in futures:
+                message = future.result()
+                if message:
+                    messages.append(message)
+        for message_data in messages:
+            await process_message(message_data,websocket,10000)
+
+    if "@odata.nextLink" in outlook_data:
+        outlook_url = outlook_data["@odata.nextLink"]
+    else:
+        break
     print("printing messages")
     print(messages)
     return messages