Instagram Agent

async def _run_task(self, request: ResearchRequest) -> AgentResult:
    # Try Cloud SDK skill first (faster, more reliable)
    if self._cloud.configured:
        cloud_result = await self._try_cloud_skill(request)
        if (
            cloud_result
            and cloud_result.status == AgentStatus.SUCCESS
            and cloud_result.profiles
        ):
            return cloud_result
    
    # Fallback to Google-scraping via browser-use Agent
    return await self._try_browser_use(request)

async def _try_cloud_skill(self, request: ResearchRequest) -> AgentResult | None:
    """Try the Instagram Profile Posts marketplace skill."""
    query = self._build_search_query(request)
    task = (
        f"Search for Instagram profile of {query} and extract profile info "
        f"including username, bio, followers, following, and post count."
    )
    
    try:
        result = await self._cloud.run_skill(
            "instagram_posts",
            task,
            timeout=60.0,
        )
        
        if not result or not result.get("success"):
            logger.info("instagram cloud skill returned no result, falling back")
            return None
        
        output = result.get("output", "")
        parsed = _parse_instagram_output(output, request.person_name)
        
        return AgentResult(
            agent_name=self.agent_name,
            status=AgentStatus.SUCCESS,
            profiles=[parsed["profile"]],
            snippets=parsed["snippets"],
            urls_found=[parsed["profile"].url] if parsed["profile"].url else [],
        )
    
    except Exception as exc:
        logger.warning("instagram cloud skill error: {}", str(exc))
        return None

async def _try_browser_use(self, request: ResearchRequest) -> AgentResult:
    """Fallback: Google-first scraping via browser-use Agent."""
    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("instagram agent (fallback) searching: {}", query)
    
    try:
        task = (
            "Go to https://www.google.com/search"
            f"?q={query.replace(' ', '+')}+site:instagram.com "
            f"and use the extract tool to get this JSON from the Google results:\n"
            f'{{"username": "", "display_name": "", "bio": "", '
            f'"followers": 0, "following": 0, "post_count": 0, '
            f'"profile_url": ""}}\n'
            f"Extract from Google snippets. Do NOT click into Instagram. Do NOT scroll. "
            f"After extracting, immediately call done with the JSON 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:
            parsed = _parse_instagram_output(str(final_result), request.person_name)
            return AgentResult(
                agent_name=self.agent_name,
                status=AgentStatus.SUCCESS,
                profiles=[parsed["profile"]],
                snippets=parsed["snippets"],
                urls_found=[parsed["profile"].url] if parsed["profile"].url else [],
            )
        
        return AgentResult(
            agent_name=self.agent_name,
            status=AgentStatus.SUCCESS,
            snippets=["No Instagram profile found"],
        )
    
    except Exception as exc:
        logger.error("instagram agent error: {}", str(exc))
        return AgentResult(
            agent_name=self.agent_name,
            status=AgentStatus.FAILED,
            error=f"Instagram agent error: {exc}",
        )