Update app.py

app.py

@@ -117,11 +117,7 @@ forecast_tool = FunctionTool.from_defaults(
 # -----------------------------
 
 def fetch_news_headlines() -> str:
-    """Fetches the latest news from Google News RSS feed.
-    
-    Returns:
-        A string containing the latest news articles from Google News, or an error message if the request fails.
-    """
+    """Fetches the latest news from Google News RSS feed."""
     url = "https://news.google.com/rss"
     
     try:
@@ -131,7 +127,7 @@ def fetch_news_headlines() -> str:
         # Parse the XML content
         root = ET.fromstring(response.content)
         
-        # Format the news articles into a readable string
+        # Format the news articles into a readable string with clickable links
         formatted_news = []
         for i, item in enumerate(root.findall('.//item')):
             if i >= 5:
@@ -139,12 +135,10 @@ def fetch_news_headlines() -> str:
             title = item.find('title').text if item.find('title') is not None else 'N/A'
             link = item.find('link').text if item.find('link') is not None else 'N/A'
             pub_date = item.find('pubDate').text if item.find('pubDate') is not None else 'N/A'
-            description = item.find('description').text if item.find('description') is not None else 'N/A'
             
-            formatted_news.append(f"Title: {title}")
+            # Make the title a clickable link using Markdown syntax
+            formatted_news.append(f"**[{title}]({link})**")
             formatted_news.append(f"Published: {pub_date}")
-            formatted_news.append(f"Link: {link}")
-            formatted_news.append(f"Description: {description}")
             formatted_news.append("---")
         
         return "\n".join(formatted_news) if formatted_news else "No news articles found."
@@ -163,14 +157,7 @@ google_rss_tool = FunctionTool.from_defaults(
 # SERPER API
 # -----------------------------
 def fetch_news_topics(query: str) -> str:
-    """Fetches news articles about a specific topic using the Serper API.
-    
-    Args:
-        query: The topic to search for news about.
-        
-    Returns:
-        A string containing the news articles found, or an error message if the request fails.
-    """
+    """Fetches news articles about a specific topic using the Serper API."""
     url = "https://google.serper.dev/news"
     
     payload = json.dumps({
@@ -188,15 +175,20 @@ def fetch_news_topics(query: str) -> str:
         
         news_data = response.json()
         
-        # Format the news articles into a readable string
+        # Format the news articles with clickable links
         formatted_news = []
         for i, article in enumerate(news_data.get('news', [])):
             if i >= 5:
                 break
-            formatted_news.append(f"Title: {article.get('title', 'N/A')}")
-            formatted_news.append(f"Source: {article.get('source', 'N/A')}")
-            formatted_news.append(f"Link: {article.get('link', 'N/A')}")
-            formatted_news.append(f"Snippet: {article.get('snippet', 'N/A')}")
+            title = article.get('title', 'N/A')
+            link = article.get('link', 'N/A')
+            source = article.get('source', 'N/A')
+            snippet = article.get('snippet', 'N/A')
+            
+            # Make the title a clickable link using Markdown syntax
+            formatted_news.append(f"**[{title}]({link})**")
+            formatted_news.append(f"Source: {source}")
+            formatted_news.append(f"Snippet: {snippet}")
             formatted_news.append("---")
         
         return "\n".join(formatted_news) if formatted_news else "No news articles found."
@@ -318,25 +310,56 @@ async def run_query(query: str):
             # Start the handler
             handler = web_agent.run(query, ctx=ctx)
             
-            # Just stream the text content naturally, with minimal additions
+            # Stream content
             async for event in handler.stream_events():
+                # Add some debugging info to understand event structure
+                # print(f"Event type: {type(event)}")
+                # print(f"Event attrs: {dir(event)}")
+                
                 if isinstance(event, AgentStream):
-                    # This is the text being generated - pass it through directly
+                    # This is the text being generated
                     if hasattr(event, 'delta') and event.delta:
                         yield event.delta
                 
-                # We can optionally add minimal annotations for tool calls and results
-                # But we'll keep it simple to avoid interfering with the agent's natural output
                 elif isinstance(event, ToolCall):
-                    # We could optionally add a subtle marker here
-                    pass  # Or comment this out if you want nothing added
+                    # Handle ToolCall differently - check available attributes
+                    tool_name = "unknown tool"
+                    
+                    # Try different possible attribute locations
+                    if hasattr(event, 'name'):
+                        tool_name = event.name
+                    elif hasattr(event, 'function_name'):
+                        tool_name = event.function_name
+                    elif hasattr(event, 'tool_name'):
+                        tool_name = event.tool_name
+                    
+                    yield f"\n\n🔧 Using tool: {tool_name}...\n"
                 
                 elif isinstance(event, ToolCallResult):
-                    # We could optionally add a subtle marker here
-                    pass  # Or comment this out if you want nothing added
+                    # Handle ToolCallResult - check available attributes
+                    result = "Result not available"
+                    
+                    # Try different possible attribute locations
+                    if hasattr(event, 'result'):
+                        result = event.result
+                    elif hasattr(event, 'output'):
+                        result = event.output
+                    elif hasattr(event, 'data') and hasattr(event.data, 'get'):
+                        result = event.data.get("result", "")
+                    
+                    # Truncate long results for display
+                    if isinstance(result, str) and len(result) > 200:
+                        result_preview = result[:200] + "... (truncated)"
+                    else:
+                        result_preview = str(result)
+                    
+                    yield f"\n📊 Got result from tool\n"
             
     except Exception as e:
         yield f"\n\n❌ Error: {str(e)}\n"
+        # For debugging:
+        import traceback
+        yield f"Traceback: {traceback.format_exc()}"
     finally:
         instrumentor.flush()