Update app.py

app.py

@@ -392,13 +392,21 @@ async def adv_web_search(
     """
     try:
         with WEBS(proxy=proxy) as webs:
-            # 1. Perform the web search
-            extracted_text = str(web_search_and_extract_threading(q=q, region=region,
+            search_results = webs.text(keywords=q, region=region,
                                      safesearch=safesearch,
                                      timelimit=timelimit, backend=backend,
-                                     max_results=max_results))
+                                     max_results=max_results)
+
+            # 2. Extract text from top search result URLs asynchronously
+            extracted_text = ""
+            tasks = [fetch_and_extract(result['href'], 6000, proxy) for result in search_results if 'href' in result]
+            extracted_results = await asyncio.gather(*tasks)
+            for result in extracted_results:
+                if result['text'] and len(extracted_text < max_chars):
+                    extracted_text += f"## Content from: {result['link']}\n\n{result['text']}\n\n"
+
+            extracted_text[:max_chars]
 
-            extracted_text = extracted_text[:max_chars]
 
         # 3. Construct the prompt for the chat model
         ai_prompt = (