Update planner_agent_centralized.py

planner_agent_centralized.py

@@ -2,22 +2,33 @@ import os
 from datetime import datetime, timedelta
 from typing import Dict, Any, List
 from urllib.parse import urlencode
+import re
 
 from tavily import TavilyClient
 
 
 GENERIC_KEYWORDS = [
     "best", "top", "guide", "things", "visit", "attractions",
-    "all you must know", "the 10 best", "the best"
+    "all you must know", "the 10 best", "the best", "how to", "tips"
 ]
 BLOCKED_SOURCES = [
-    "reddit", "quora", "tripadvisor", "yelp", "forum", "forums", "community"
+    "reddit", "quora", "tripadvisor", "yelp", "forum", "forums", "community",
+    "wikipedia.org", "wikivoyage.org", "blog", "list of"
 ]
+ARTICLE_PATTERNS = [r"^list of ", r"^how to ", r"^why ", r"^what "]
+
+PROPER_NOUN_RE = re.compile(r"\b([A-Z][a-z]+(?:\s+[A-Z][a-z]+)*)\b")
 
 
 def is_generic_title(title: str) -> bool:
     t = title.lower()
-    return any(k in t for k in GENERIC_KEYWORDS) or any(s in t for s in BLOCKED_SOURCES) or t.startswith("r/")
+    if any(k in t for k in GENERIC_KEYWORDS):
+        return True
+    if any(s in t for s in BLOCKED_SOURCES):
+        return True
+    if any(re.match(p, t) for p in ARTICLE_PATTERNS):
+        return True
+    return t.startswith("r/")
 
 
 def normalize_title(title: str) -> str:
@@ -28,6 +39,18 @@ def normalize_title(title: str) -> str:
     return cleaned if cleaned else title
 
 
+def actionize(name: str, fallback_category: str | None = None) -> str:
+    # Convert generic/statement titles into imperative activity suggestions
+    n = name.strip().rstrip(".,! ")
+    # If contains a proper noun (probable place), keep it as is
+    if PROPER_NOUN_RE.search(n):
+        return n
+    # If looks like a topic, make it actionable
+    if fallback_category:
+        return f"Explore {fallback_category.lower()} – {n}" if len(n) < 40 else f"Explore {fallback_category.lower()} in the area"
+    return f"Explore: {n}" if len(n) < 40 else "Explore local highlights"
+
+
 class PlannerAgentCentralized:
     def __init__(self, tavily_api_key: str | None = None):
         api_key = tavily_api_key or os.environ.get("TAVILY_API_KEY")
@@ -40,6 +63,7 @@ class PlannerAgentCentralized:
         departure_date = request.get("departure_date", "")
         return_date = request.get("return_date", "")
         preferences = request.get("preferences", [])
+        pref_hint = preferences[0] if preferences else None
         total_budget = float(request.get("budget", 0) or 0)
         hotel_budget = float(request.get("hotel_budget", 0) or 0)
         activity_budget = float(request.get("activity_budget", 0) or 0)
@@ -49,7 +73,7 @@ class PlannerAgentCentralized:
             activity_budget = round(total_budget * 0.4, 2)
 
         hotel_names, hotel_reason = self._search_hotel_names(destination)
-        poi_items, poi_reason = self._search_pois(destination, preferences)
+        poi_items, poi_reason = self._search_pois(destination, preferences, pref_hint)
 
         if not poi_items:
             poi_items = self._default_activities(destination)
@@ -97,7 +121,7 @@ class PlannerAgentCentralized:
         except Exception as e:
             return [], f"Hotel search failed: {e}"
 
-    def _search_pois(self, destination: str, preferences: List[str]) -> tuple[List[Dict[str, Any]], str]:
+    def _search_pois(self, destination: str, preferences: List[str], pref_hint: str | None) -> tuple[List[Dict[str, Any]], str]:
         pref_part = (", ".join(preferences)) if preferences else "attractions"
         query = f"{pref_part} in {destination}"
         try:
@@ -111,6 +135,8 @@ class PlannerAgentCentralized:
                 if is_generic_title(raw):
                     continue
                 name = normalize_title(raw)
+                # Make action-friendly
+                name = actionize(name, pref_hint)
                 if name and not any(x.get("name") == name for x in items):
                     items.append({"name": name, "url": url})
             reason = f"Collected {len(items)} itinerary items via Tavily for {pref_part}."
@@ -120,11 +146,11 @@ class PlannerAgentCentralized:
 
     def _default_activities(self, destination: str) -> List[Dict[str, Any]]:
         return [
-            {"name": f"City walking tour of {destination}"},
-            {"name": f"Local market & food tasting in {destination}"},
-            {"name": f"Museum or cultural site in {destination}"},
-            {"name": f"Scenic viewpoint / park in {destination}"},
-            {"name": f"Evening dining in {destination} city center"}
+            {"name": f"Morning walking tour of {destination}"},
+            {"name": f"Lunch at a local market in {destination}"},
+            {"name": f"Afternoon museum visit in {destination}"},
+            {"name": f"Sunset viewpoint in {destination}"},
+            {"name": f"Dinner in {destination} city center"}
         ]
 
     def _build_daily_schedule(self, start_date: datetime, num_days: int, items: List[Dict[str, Any]]) -> List[Dict[str, Any]]: