Fix version conflict

get_tools_working.py

@@ -22,13 +22,13 @@ import requests
 import sys
 import xml.etree.ElementTree as ET
 from botocore.config import Config as BotocoreConfig
+from datetime import date
 
 from strands import Agent, tool
 from strands.models import BedrockModel
 from strands_tools import workflow
 from strands_tools import rss
 from strands_tools import http_request
-from brave import Brave
 
 from sendgrid import SendGridAPIClient
 from sendgrid.helpers.mail import Mail
@@ -38,7 +38,7 @@ os.environ.setdefault("BYPASS_TOOL_CONSENT", "true")
 
 @tool
 def brave_search(query: str, count: int = 10) -> str:
-    """Search the web using Brave Search API for news and information"""
+    """Search the web using Brave Search API for news and information via direct HTTP requests"""
     
     print(f"🔍 Searching Brave for: '{query}' (count: {count})")
     
@@ -48,42 +48,85 @@ def brave_search(query: str, count: int = 10) -> str:
         raise ValueError("BRAVE_API_KEY environment variable is not set")
     
     try:
-        # Initialize Brave search client
-        brave_client = Brave(api_key=brave_api_key)
+        # Brave Search API endpoint
+        api_url = "https://api.search.brave.com/res/v1/web/search"
         
-        # Perform web search
-        search_results = brave_client.search(q=query, count=count)
+        # Set up headers with API key
+        headers = {
+            "Accept": "application/json",
+            "Accept-Encoding": "gzip",
+            "X-Subscription-Token": brave_api_key
+        }
         
-        # Format results for the agent
+        # Set up query parameters
+        params = {
+            "q": query,
+            "count": min(count, 20),  # API maximum is 20
+            "offset": 0,
+            "safesearch": "moderate",
+            "freshness": "",
+            "text_decorations": True,
+            "spellcheck": True,
+            "result_filter": "web,news"  # Include both web and news results
+        }
+        
+        # Make the HTTP request
+        print(f"📡 Making request to Brave Search API...")
+        response = requests.get(api_url, headers=headers, params=params, timeout=30)
+        
+        # Check if request was successful
+        if response.status_code != 200:
+            error_msg = f"Brave Search API returned status {response.status_code}: {response.text}"
+            print(f"❌ {error_msg}")
+            return error_msg
+            
+        # Parse JSON response
+        search_data = response.json()
         formatted_results = []
         
-        if hasattr(search_results, 'web') and search_results.web:
-            for idx, result in enumerate(search_results.web.results[:count], 1):
+        # Process web results
+        if "web" in search_data and "results" in search_data["web"]:
+            web_results = search_data["web"]["results"]
+            for idx, result in enumerate(web_results[:count], 1):
                 formatted_result = f"""
 Result {idx}:
-Title: {result.title}
-URL: {result.url}
-Description: {result.description}
+Title: {result.get('title', 'N/A')}
+URL: {result.get('url', 'N/A')}
+Description: {result.get('description', 'N/A')}
 ---"""
                 formatted_results.append(formatted_result)
         
-        # Also include news results if available
-        if hasattr(search_results, 'news') and search_results.news:
-            formatted_results.append("\n🗞️ NEWS RESULTS:")
-            for idx, news in enumerate(search_results.news.results[:count], 1):
-                formatted_result = f"""
+        # Process news results if available
+        if "news" in search_data and "results" in search_data["news"]:
+            news_results = search_data["news"]["results"]
+            if news_results:
+                formatted_results.append("\n🗞️ NEWS RESULTS:")
+                for idx, news in enumerate(news_results[:count], 1):
+                    formatted_result = f"""
 News {idx}:
-Title: {news.title}
-URL: {news.url}
-Description: {news.description}
-Age: {getattr(news, 'age', 'N/A')}
+Title: {news.get('title', 'N/A')}
+URL: {news.get('url', 'N/A')}
+Description: {news.get('description', 'N/A')}
+Age: {news.get('age', 'N/A')}
 ---"""
-                formatted_results.append(formatted_result)
+                    formatted_results.append(formatted_result)
         
         final_result = "\n".join(formatted_results) if formatted_results else "No results found"
-        print(f"✅ Found {len(formatted_results)} results from Brave Search")
+        print(f"✅ Found {len(formatted_results)} results from Brave Search API")
         return final_result
         
+    except requests.exceptions.Timeout:
+        error_msg = "Request to Brave Search API timed out"
+        print(f"❌ {error_msg}")
+        return error_msg
+    except requests.exceptions.RequestException as e:
+        error_msg = f"Network error with Brave Search API: {str(e)}"
+        print(f"❌ {error_msg}")
+        return error_msg
+    except json.JSONDecodeError as e:
+        error_msg = f"Failed to parse Brave Search API response: {str(e)}"
+        print(f"❌ {error_msg}")
+        return error_msg
     except Exception as e:
         error_msg = f"Error performing Brave search: {str(e)}"
         print(f"❌ {error_msg}")
@@ -156,7 +199,7 @@ def get_leadgen_agent(user_email: str):
     
     
     # Generic system instructions for Docker environment with LinkedIn profile search and outreach
-    autonomous_system_prompt = """
+    autonomous_system_prompt = f"""
 CRITICAL: You are running in a Docker container environment and MUST operate completely autonomously without ANY user input or interaction. 
 
 ENVIRONMENT CONTEXT:
@@ -201,21 +244,21 @@ AVAILABLE TOOLS AND BEST PRACTICES:
    - Examples:
    ```
    # Fetch a web page
-   http_request({
+   http_request({{
        "method": "GET",
        "url": "https://example.com/page",
        "convert_to_markdown": True
-   })
+   }})
    
    # API call with authentication
-   http_request({
+   http_request({{
        "method": "POST",
        "url": "https://api.example.com/endpoint",
-       "headers": {"Content-Type": "application/json"},
-       "body": json.dumps({"key": "value"}),
+       "headers": {{"Content-Type": "application/json"}},
+       "body": json.dumps({{"key": "value"}}),
        "auth_type": "Bearer",
        "auth_token": "your_token"
-   })
+   }})
    ```
 
 3. RSS TOOL (rss) - Use for news feeds and RSS content management
@@ -223,11 +266,11 @@ AVAILABLE TOOLS AND BEST PRACTICES:
    - Examples:
    ```
    # Fetch without subscribing
-   rss({
+   rss({{
        "action": "fetch",
        "url": "https://example.com/feed",
        "max_entries": 3
-   })
+   }})
    ```
 
 4. EMAIL TOOL (send_email) - Use for sending reports and notifications
@@ -321,6 +364,8 @@ IMPORTANT: For each lead found, you MUST:
 - Reference recent company news or developments
 - Always send a final email report with all leads, LinkedIn URLs, and outreach messages
 
+IMPORTANT : When you need to use a date , month or year be aware today is {str(date.today())}
+
 Remember: You are in a server environment - operate completely independently without any user interaction. Focus on finding LinkedIn profiles and crafting personalized outreach messages for recruitment leads.
 """
     

requirements.txt

@@ -1,7 +1,9 @@
+# Force tenacity version first to resolve conflicts
+tenacity==9.1.2
 huggingface_hub==0.25.2
 gradio
 strands-agents
-strands-agents-tools
+strands-agents-tools[workflow, rss, http_request]
 botocore
 pandas
 requests
@@ -9,8 +11,4 @@ sendgrid
 uvicorn
 fastapi
 bedrock_agentcore
-playwright
 nest_asyncio
-brave-search
-httpx
-tenacity