Update tools/WebSearchTool.py

tools/WebSearchTool.py

@@ -6,7 +6,8 @@ class SearxngSearchTool(Tool):
     """
     A metasearch tool that queries multiple search engines (including Google, Bing, etc.) 
     through a free, public Searxng instance. This is a robust, keyless alternative 
-    when specific search APIs are overloaded or require payment/keys.
+    when specific search APIs are overloaded or require payment/keys. It attempts 
+    multiple public instances for high resilience against temporary server outages or blocks.
     """
     name = "searxng_search"
     description = "Use a free, keyless metasearch engine (Searxng) to query the web for general knowledge and current information when other search tools are unavailable."
@@ -16,12 +17,18 @@ class SearxngSearchTool(Tool):
     }
     output_type = "string"
 
-    # Note: Using a popular public instance. This may occasionally fail if the instance is down.
-    DEFAULT_INSTANCE = "https://searx.be/search" 
+    # List of popular, generally reliable public instances. 
+    # The order attempts to prioritize faster or more stable instances first.
+    PUBLIC_INSTANCES = [
+        "https://searx.be/search",  # The original instance
+        "https://searx.prvcy.eu/search",
+        "https://searx.tieko.co/search",
+        "https://searx.baczek.me/search",
+    ]
 
     def forward(self, query: str) -> str:
         """
-        Executes a Searxng search query and formats the top results (up to 3).
+        Executes a Searxng search query, cycling through available instances until one succeeds.
         
         Args:
             query: The search term provided by the agent.
@@ -29,7 +36,6 @@ class SearxngSearchTool(Tool):
         Returns:
             A formatted string of search results, or an error message.
         """
-        print(f"Executing Searxng Search for: '{query}'")
         
         params = {
             "q": query,
@@ -38,32 +44,44 @@ class SearxngSearchTool(Tool):
             "pageno": 1,
         }
 
-        try:
-            # Make the API request
-            response = requests.get(self.DEFAULT_INSTANCE, params=params)
-            response.raise_for_status() 
-            data = response.json()
+        last_error = ""
 
-            # Extract the search results
-            items = data.get('results', [])
+        # Loop through each public instance until a successful connection is made
+        for instance_url in self.PUBLIC_INSTANCES:
+            print(f"Executing Searxng Search for: '{query}' using instance: {instance_url}")
+            try:
+                # Make the API request
+                response = requests.get(instance_url, params=params, timeout=5) # Added timeout
+                response.raise_for_status() 
+                data = response.json()
 
-            if not items:
-                # Return the specific failure message expected by the agent
-                return "XX record info: No results found."
+                # Extract the search results
+                items = data.get('results', [])
 
-            search_results = []
-            # Process the top 3 results
-            for i, item in enumerate(items[:3]):
-                search_results.append(
-                    f"RESULT {i+1}: '{item.get('title', 'N/A')}'\n"
-                    f"CONTENT: {item.get('content', 'No snippet available.')}\n"
-                    f"SOURCE: {item.get('url', 'N/A')}"
-                )
+                if not items:
+                    # If the instance worked but returned no results, continue to the next instance
+                    print(f"Instance {instance_url} returned no results. Trying next instance.")
+                    continue
 
-            # Join the results with a clear separator
-            return "\n\n---SEPARATOR---\n\n".join(search_results)
+                search_results = []
+                # Process the top 3 results
+                for i, item in enumerate(items[:3]):
+                    search_results.append(
+                        f"RESULT {i+1}: '{item.get('title', 'N/A')}'\n"
+                        f"CONTENT: {item.get('content', 'No snippet available.')}\n"
+                        f"SOURCE: {item.get('url', 'N/A')}"
+                    )
 
-        except requests.exceptions.RequestException as e:
-            return f"Error during Searxng API Request. The instance may be temporarily unavailable: {e}"
-        except Exception as e:
-            return f"Error processing Searxng results: {e}"
+                # If successful, return the results immediately
+                return "\n\n---SEPARATOR---\n\n".join(search_results)
+
+            except requests.exceptions.RequestException as e:
+                # Record the error and try the next instance
+                last_error = f"Instance {instance_url} failed: {e}"
+                print(last_error)
+            except Exception as e:
+                last_error = f"Error processing Searxng results for {instance_url}: {e}"
+                print(last_error)
+
+        # If the loop finishes without returning, all instances failed.
+        return f"XX record info: No results found. All Searxng instances failed. Last error: {last_error}"