Google Agent

class GoogleAgent(BaseBrowserAgent):
    """Searches Google for person information via browser-use."""
    
    agent_name = "google"
    
    def __init__(self, settings: Settings, *, inbox_pool=None):
        super().__init__(settings, inbox_pool=inbox_pool)

# RESEARCH: Checked googlesearch-python (1k stars), SerpAPI (paid), Google Custom Search API
# DECISION: Browser Use for Google — avoids API key costs, can extract rich snippets
# ALT: SerpAPI if we need scale (paid, $50/mo)

async def _run_task(self, request: ResearchRequest) -> AgentResult:
    if not self.configured:
        return AgentResult(
            agent_name=self.agent_name,
            status=AgentStatus.FAILED,
            error="Browser Use not configured (BROWSER_USE_API_KEY or OPENAI_API_KEY missing)",
        )
    
    query = self._build_search_query(request)
    logger.info("google agent searching: {}", query)
    
    try:
        task = (
            f"Go to https://www.google.com/search?q={query.replace(' ', '+')} "
            f"and use the extract tool to pull from the FIRST page only:\n"
            f"- Social media profile links (LinkedIn, Twitter/X, Instagram, GitHub)\n"
            f"- Company affiliations and job titles\n"
            f"- News articles and notable mentions\n"
            f"- Personal website or blog\n"
            f"Do NOT scroll. Do NOT click into results. "
            f"After extracting, immediately call done with the result."
        )
        
        agent = self._create_browser_agent(task, max_steps=3)
        result = await agent.run()
        final_result = result.final_result() if result else None
        
        if final_result:
            profiles: list[SocialProfile] = []
            output_str = str(final_result)
            
            # Extract any social profile URLs mentioned
            platform_indicators = {
                "linkedin.com": "linkedin",
                "twitter.com": "twitter",
                "x.com": "twitter",
                "instagram.com": "instagram",
                "github.com": "github",
                "facebook.com": "facebook",
            }
            
            for indicator, platform in platform_indicators.items():
                if indicator in output_str.lower():
                    profiles.append(
                        SocialProfile(
                            platform=platform,
                            url=f"https://{indicator}",
                            display_name=request.person_name,
                        )
                    )
            
            return AgentResult(
                agent_name=self.agent_name,
                status=AgentStatus.SUCCESS,
                profiles=profiles,
                snippets=[output_str],
                urls_found=[p.url for p in profiles],
            )
        
        return AgentResult(
            agent_name=self.agent_name,
            status=AgentStatus.SUCCESS,
            snippets=["No Google results found"],
        )
    
    except Exception as exc:
        logger.error("google agent error: {}", str(exc))
        return AgentResult(
            agent_name=self.agent_name,
            status=AgentStatus.FAILED,
            error=f"Google agent error: {exc}",
        )

def _build_search_query(self, request: ResearchRequest) -> str:
    """Build a search query string from the request."""
    parts = [request.person_name]
    if request.company:
        parts.append(request.company)
    return " ".join(parts)

agent = self._create_browser_agent(task, max_steps=3)
# Only 3 steps: navigate, extract, done
# No scrolling, no clicking into results
# Just surface-level extraction from Google's SERP