import base64
import json
import time
from typing import Any, Dict, List, Optional

from langchain_core.language_models import BaseLLM
from loguru import logger

from ...config import llm_config
from ...constants import USER_AGENT
from ...security.safe_requests import safe_get
from ...utilities.json_utils import extract_json, get_llm_response_text
from ..search_engine_base import BaseSearchEngine


_VALID_SEARCH_TYPES = frozenset({"repositories", "code", "issues", "users"})


class GitHubSearchEngine(BaseSearchEngine):
    """
    GitHub search engine implementation.
    Provides search across GitHub repositories, code, issues, and users.
    """

    is_public = True
    is_code = True
    is_lexical = True
    needs_llm_relevance_filter = True

    def __init__(
        self,
        max_results: int = 15,
        api_key: Optional[str] = None,
        search_type: str = "repositories",
        include_readme: bool = True,
        include_issues: bool = False,
        llm: Optional[BaseLLM] = None,
        max_filtered_results: Optional[int] = None,
        settings_snapshot: Optional[Dict[str, Any]] = None,
    ):
        """
        Initialize the GitHub search engine.

        Args:
            max_results: Maximum number of search results
            api_key: GitHub API token (can also be set via LDR_SEARCH_ENGINE_WEB_GITHUB_API_KEY env var or in UI settings)
            search_type: Type of GitHub search ("repositories", "code", "issues", "users")
            include_readme: Whether to include README content for repositories
            include_issues: Whether to include recent issues for repositories
            llm: Language model for relevance filtering
            max_filtered_results: Maximum number of results to keep after filtering
        """
        # Initialize the BaseSearchEngine with LLM, max_filtered_results, and max_results
        super().__init__(
            llm=llm,
            max_filtered_results=max_filtered_results,
            max_results=max_results,
            settings_snapshot=settings_snapshot,
        )
        self.api_key = api_key
        if search_type not in _VALID_SEARCH_TYPES:
            raise ValueError(
                f"Invalid GitHub search_type: {search_type!r}. "
                f"Must be one of {_VALID_SEARCH_TYPES}"
            )
        self.search_type = search_type
        self.include_readme = include_readme
        self.include_issues = include_issues

        self._owns_llm = False

        # API endpoints
        self.api_base = "https://api.github.com"
        self.search_endpoint = f"{self.api_base}/search/{search_type}"

        # Set up API headers
        self.headers = {
            "Accept": "application/vnd.github.v3+json",
            "User-Agent": USER_AGENT,
        }

        # Add authentication if API key provided
        if self.api_key:
            self.headers["Authorization"] = f"token {self.api_key}"
            logger.info("Using authenticated GitHub API requests")
        else:
            logger.warning(
                "No GitHub API key provided. Rate limits will be restricted."
            )

    def close(self) -> None:
        """Close the lazily-loaded LLM client if this engine created it."""
        from ...utilities.resource_utils import safe_close

        if self._owns_llm:
            safe_close(self.llm, "GitHub LLM")
        super().close()

    def _handle_rate_limits(self, response):
        """Handle GitHub API rate limits by logging warnings and sleeping if necessary"""
        remaining = int(response.headers.get("X-RateLimit-Remaining", 60))
        reset_time = int(response.headers.get("X-RateLimit-Reset", 0))

        if remaining < 5:
            current_time = time.time()
            wait_time = max(reset_time - current_time, 0)
            logger.warning(
                f"GitHub API rate limit almost reached. {remaining} requests remaining."
            )

            if wait_time > 0 and remaining == 0:
                logger.warning(
                    f"GitHub API rate limit exceeded. Waiting {wait_time:.0f} seconds."
                )
                time.sleep(min(wait_time, 60))  # Wait at most 60 seconds

    def _optimize_github_query(self, query: str) -> str:
        """
        Optimize the GitHub search query using LLM to improve search results.

        Args:
            query: Original search query

        Returns:
            Optimized GitHub search query
        """
        # Get LLM from config if not already set
        if not self.llm:
            try:
                self.llm = llm_config.get_llm()
                self._owns_llm = True
                if not self.llm:
                    logger.warning("No LLM available for query optimization")
                    return query
            except Exception as e:
                safe_msg = self._scrub_error(e)
                logger.warning(f"Error getting LLM from config: {safe_msg}")
                return query

        prompt = f"""Transform this GitHub search query into an optimized version for the GitHub search API. Follow these steps:
                        1. Strip question words (e.g., 'what', 'are', 'is'), stop words (e.g., 'and', 'as', 'of', 'on'), and redundant terms (e.g., 'repositories', 'repos', 'github') since they're implied by the search context.
                        2. Keep only domain-specific keywords and avoid using "-related" terms.
                        3. Add GitHub-specific filters with dynamic thresholds based on query context:
                           - For stars: Use higher threshold (e.g., 'stars:>1000') for mainstream topics, lower (e.g., 'stars:>50') for specialized topics
                           - For language: Detect programming language from query or omit if unclear
                           - For search scope: Use 'in:name,description,readme' for general queries, 'in:file' for code-specific queries
                        4. For date ranges, adapt based on query context:
                           - For emerging: Use 'created:>2024-01-01'
                           - For mature: Use 'pushed:>2023-01-01'
                           - For historical research: Use 'created:2020-01-01..2024-01-01'
                        5. For excluding results, adapt based on query:
                           - Exclude irrelevant languages based on context
                           - Use 'NOT' to exclude competing terms
                        6. Ensure the output is a concise, space-separated string with no punctuation or extra text beyond keywords and filters.


                        Original query: "{query}"

                        Return ONLY the optimized query, ready for GitHub's search API. Do not include explanations or additional text."""

        try:
            response = self.llm.invoke(prompt)

            # Handle different response formats (string or object with content attribute)
            if hasattr(response, "content"):
                optimized_query = str(response.content).strip()
            else:
                # Handle string responses
                optimized_query = str(response).strip()

            # Validate the optimized query
            if optimized_query and len(optimized_query) > 0:
                logger.info(
                    f"LLM optimized query from '{query}' to '{optimized_query}'"
                )
                return optimized_query
            logger.warning("LLM returned empty query, using original")
            return query

        except Exception as e:
            safe_msg = self._scrub_error(e)
            logger.warning(f"Error optimizing query with LLM: {safe_msg}")
            return query

    def _search_github(self, query: str) -> List[Dict[str, Any]]:
        """
        Perform a GitHub search based on the configured search type.

        Args:
            query: The search query

        Returns:
            List of GitHub search result items
        """
        results = []

        try:
            # Optimize GitHub query using LLM
            github_query = self._optimize_github_query(query)

            logger.info(f"Final GitHub query: {github_query}")

            # Construct search parameters
            params = {
                "q": github_query,
                "per_page": min(
                    self.max_results, 100
                ),  # GitHub API max is 100 per page
                "page": 1,
            }

            # Add sort parameters based on search type
            if self.search_type == "repositories":
                params["sort"] = "stars"
                params["order"] = "desc"
            elif self.search_type == "code":
                params["sort"] = "indexed"
                params["order"] = "desc"
            elif self.search_type == "issues":
                params["sort"] = "updated"
                params["order"] = "desc"
            elif self.search_type == "users":
                params["sort"] = "followers"
                params["order"] = "desc"

            # Apply rate limiting before request
            self._last_wait_time = self.rate_tracker.apply_rate_limit(
                self.engine_type
            )

            # Execute the API request
            response = safe_get(
                self.search_endpoint, headers=self.headers, params=params
            )

            # Check for rate limiting
            self._handle_rate_limits(response)

            # Handle response with detailed logging
            if response.status_code == 200:
                data = response.json()
                total_count = data.get("total_count", 0)
                results = data.get("items", [])
                logger.info(
                    f"GitHub search returned {len(results)} results (total available: {total_count})"
                )

                # Log the rate limit information
                rate_limit_remaining = response.headers.get(
                    "X-RateLimit-Remaining", "unknown"
                )
                logger.info(
                    f"GitHub API rate limit: {rate_limit_remaining} requests remaining"
                )

                # If no results, try to provide more guidance
                if not results:
                    logger.warning(
                        "No results found. Consider these search tips:"
                    )
                    logger.warning("1. Use shorter, more specific queries")
                    logger.warning(
                        "2. For repositories, try adding 'stars:>100' or 'language:python'"
                    )
                    logger.warning(
                        "3. For contribution opportunities, search for 'good-first-issue' or 'help-wanted'"
                    )
            else:
                logger.error(
                    f"GitHub API error: {response.status_code} - {response.text}"
                )

        except Exception as e:
            safe_msg = self._scrub_error(e)
            logger.warning(f"Error searching GitHub: {safe_msg}")

        return results

    def _get_readme_content(self, repo_full_name: str) -> str:
        """
        Get README content for a repository.

        Args:
            repo_full_name: Full name of the repository (owner/repo)

        Returns:
            Decoded README content or empty string if not found
        """
        try:
            # Get README
            # Apply rate limiting before request
            self._last_wait_time = self.rate_tracker.apply_rate_limit(
                self.engine_type
            )

            response = safe_get(
                f"{self.api_base}/repos/{repo_full_name}/readme",
                headers=self.headers,
            )

            # Check for rate limiting
            self._handle_rate_limits(response)

            if response.status_code == 200:
                data = response.json()
                content: str = data.get("content", "")
                encoding = data.get("encoding", "")

                if encoding == "base64" and content:
                    return base64.b64decode(content).decode(
                        "utf-8", errors="replace"
                    )
                return content
            logger.warning(
                f"Could not get README for {repo_full_name}: {response.status_code}"
            )
            return ""

        except Exception as e:
            safe_msg = self._scrub_error(e)
            logger.warning(
                f"Error getting README for {repo_full_name}: {safe_msg}"
            )
            return ""

    def _get_recent_issues(
        self, repo_full_name: str, limit: int = 5
    ) -> List[Dict[str, Any]]:
        """
        Get recent issues for a repository.

        Args:
            repo_full_name: Full name of the repository (owner/repo)
            limit: Maximum number of issues to return

        Returns:
            List of recent issues
        """
        issues = []

        try:
            # Get recent issues
            # Apply rate limiting before request
            self._last_wait_time = self.rate_tracker.apply_rate_limit(
                self.engine_type
            )

            response = safe_get(
                f"{self.api_base}/repos/{repo_full_name}/issues",
                headers=self.headers,
                params={
                    "state": "all",
                    "per_page": limit,
                    "sort": "updated",
                    "direction": "desc",
                },
            )

            # Check for rate limiting
            self._handle_rate_limits(response)

            if response.status_code == 200:
                issues = response.json()
                logger.info(
                    f"Got {len(issues)} recent issues for {repo_full_name}"
                )
            else:
                logger.warning(
                    f"Could not get issues for {repo_full_name}: {response.status_code}"
                )

        except Exception as e:
            safe_msg = self._scrub_error(e)
            logger.warning(
                f"Error getting issues for {repo_full_name}: {safe_msg}"
            )

        return issues

    def _get_file_content(self, file_url: str) -> str:
        """
        Get content of a file from GitHub.

        Args:
            file_url: API URL for the file

        Returns:
            Decoded file content or empty string if not found
        """
        try:
            # Apply rate limiting before request
            self._last_wait_time = self.rate_tracker.apply_rate_limit(
                self.engine_type
            )

            # Get file content
            response = safe_get(file_url, headers=self.headers)

            # Check for rate limiting
            self._handle_rate_limits(response)

            if response.status_code == 200:
                data = response.json()
                content2: str = data.get("content", "")
                encoding = data.get("encoding", "")

                if encoding == "base64" and content2:
                    return base64.b64decode(content2).decode(
                        "utf-8", errors="replace"
                    )
                return content2
            logger.warning(
                f"Could not get file content: {response.status_code}"
            )
            return ""

        except Exception as e:
            safe_msg = self._scrub_error(e)
            logger.warning(f"Error getting file content: {safe_msg}")
            return ""

    def _format_repository_preview(
        self, repo: Dict[str, Any]
    ) -> Dict[str, Any]:
        """Format repository search result as preview"""
        return {
            "id": str(repo.get("id", "")),
            "title": repo.get("full_name", ""),
            "link": repo.get("html_url", ""),
            "snippet": repo.get("description", "No description provided"),
            "stars": repo.get("stargazers_count", 0),
            "forks": repo.get("forks_count", 0),
            "language": repo.get("language", ""),
            "updated_at": repo.get("updated_at", ""),
            "created_at": repo.get("created_at", ""),
            "topics": repo.get("topics", []),
            "owner": repo.get("owner", {}).get("login", ""),
            "is_fork": repo.get("fork", False),
            "search_type": "repository",
            "repo_full_name": repo.get("full_name", ""),
        }

    def _format_code_preview(self, code: Dict[str, Any]) -> Dict[str, Any]:
        """Format code search result as preview"""
        repo = code.get("repository", {})
        return {
            "id": f"code_{code.get('sha', '')}",
            "title": f"{code.get('name', '')} in {repo.get('full_name', '')}",
            "link": code.get("html_url", ""),
            "snippet": f"Match in {code.get('path', '')}",
            "path": code.get("path", ""),
            "repo_name": repo.get("full_name", ""),
            "repo_url": repo.get("html_url", ""),
            "search_type": "code",
            "file_url": code.get("url", ""),
        }

    def _format_issue_preview(self, issue: Dict[str, Any]) -> Dict[str, Any]:
        """Format issue search result as preview"""
        repo = (
            issue.get("repository", {})
            if "repository" in issue
            else {"full_name": ""}
        )
        return {
            "id": f"issue_{issue.get('number', '')}",
            "title": issue.get("title", ""),
            "link": issue.get("html_url", ""),
            "snippet": (
                issue.get("body", "")[:200] + "..."
                if len(issue.get("body", "")) > 200
                else issue.get("body", "")
            ),
            "state": issue.get("state", ""),
            "created_at": issue.get("created_at", ""),
            "updated_at": issue.get("updated_at", ""),
            "user": issue.get("user", {}).get("login", ""),
            "comments": issue.get("comments", 0),
            "search_type": "issue",
            "repo_name": repo.get("full_name", ""),
        }

    def _format_user_preview(self, user: Dict[str, Any]) -> Dict[str, Any]:
        """Format user search result as preview"""
        return {
            "id": f"user_{user.get('id', '')}",
            "title": user.get("login", ""),
            "link": user.get("html_url", ""),
            "snippet": user.get("bio", "No bio provided"),
            "name": user.get("name", ""),
            "followers": user.get("followers", 0),
            "public_repos": user.get("public_repos", 0),
            "location": user.get("location", ""),
            "search_type": "user",
            "user_login": user.get("login", ""),
        }

    def _get_previews(self, query: str) -> List[Dict[str, Any]]:
        """
        Get preview information for GitHub search results.

        Args:
            query: The search query

        Returns:
            List of preview dictionaries
        """
        logger.info(f"Getting GitHub previews for query: {query}")

        # For contribution-focused queries, automatically adjust search type and add filters
        if any(
            term in query.lower()
            for term in [
                "contribute",
                "contributing",
                "contribution",
                "beginner",
                "newcomer",
            ]
        ):
            # Use repositories search with help-wanted or good-first-issue labels
            original_search_type = self.search_type
            self.search_type = "repositories"
            self.search_endpoint = f"{self.api_base}/search/repositories"

            # Create a specialized query for finding beginner-friendly projects
            specialized_query = "good-first-issues:>5 is:public archived:false"

            # Extract language preferences if present
            languages = []
            for lang in [
                "python",
                "javascript",
                "java",
                "rust",
                "go",
                "typescript",
                "c#",
                "c++",
                "ruby",
            ]:
                if lang in query.lower():
                    languages.append(lang)

            if languages:
                specialized_query += f" language:{' language:'.join(languages)}"

            # Extract keywords
            keywords = [
                word
                for word in query.split()
                if len(word) > 3
                and word.lower()
                not in [
                    "recommend",
                    "recommended",
                    "github",
                    "repositories",
                    "looking",
                    "developers",
                    "contribute",
                    "contributing",
                    "beginner",
                    "newcomer",
                ]
            ]

            if keywords:
                specialized_query += " " + " ".join(
                    keywords[:5]
                )  # Add up to 5 keywords

            logger.info(
                f"Using specialized contribution query: {specialized_query}"
            )

            # Perform GitHub search with specialized query
            results = self._search_github(specialized_query)

            # Restore original search type
            self.search_type = original_search_type
            self.search_endpoint = f"{self.api_base}/search/{self.search_type}"
        else:
            # Perform standard GitHub search
            results = self._search_github(query)

        if not results:
            logger.warning(f"No GitHub results found for query: {query}")
            return []

        # Format results as previews
        previews = []
        for result in results:
            # Format based on search type
            if self.search_type == "repositories":
                preview = self._format_repository_preview(result)
            elif self.search_type == "code":
                preview = self._format_code_preview(result)
            elif self.search_type == "issues":
                preview = self._format_issue_preview(result)
            elif self.search_type == "users":
                preview = self._format_user_preview(result)
            else:
                logger.warning(f"Unknown search type: {self.search_type}")
                continue

            previews.append(preview)

        logger.info(f"Formatted {len(previews)} GitHub preview results")
        return previews

    def _get_full_content(
        self, relevant_items: List[Dict[str, Any]]
    ) -> List[Dict[str, Any]]:
        """
        Get full content for the relevant GitHub search results.

        Args:
            relevant_items: List of relevant preview dictionaries

        Returns:
            List of result dictionaries with full content
        """
        logger.info(
            f"Getting full content for {len(relevant_items)} GitHub results"
        )

        results = []
        for item in relevant_items:
            result = item.copy()
            search_type = item.get("search_type", "")

            # Add content based on search type
            if search_type == "repository" and self.include_readme:
                repo_full_name = item.get("repo_full_name", "")
                if repo_full_name:
                    # Get README content
                    readme_content = self._get_readme_content(repo_full_name)
                    result["full_content"] = readme_content
                    result["content_type"] = "readme"

                    # Get recent issues if requested
                    if self.include_issues:
                        issues = self._get_recent_issues(repo_full_name)
                        result["recent_issues"] = issues

            elif search_type == "code":
                file_url = item.get("file_url", "")
                if file_url:
                    # Get file content
                    file_content = self._get_file_content(file_url)
                    result["full_content"] = file_content
                    result["content_type"] = "file"

            elif search_type == "issue":
                # For issues, the snippet usually contains a summary already
                # We'll just keep it as is
                result["full_content"] = item.get("snippet", "")
                result["content_type"] = "issue"

            elif search_type == "user":
                # For users, construct a profile summary
                profile_summary = f"GitHub user: {item.get('title', '')}\n"

                if item.get("name"):
                    profile_summary += f"Name: {item.get('name')}\n"

                if item.get("location"):
                    profile_summary += f"Location: {item.get('location')}\n"

                profile_summary += f"Followers: {item.get('followers', 0)}\n"
                profile_summary += (
                    f"Public repositories: {item.get('public_repos', 0)}\n"
                )

                if (
                    item.get("snippet")
                    and item.get("snippet") != "No bio provided"
                ):
                    profile_summary += f"\nBio: {item.get('snippet')}\n"

                result["full_content"] = profile_summary
                result["content_type"] = "user_profile"

            results.append(result)

        return results

    def search_repository(
        self, repo_owner: str, repo_name: str
    ) -> Dict[str, Any]:
        """
        Get detailed information about a specific repository.

        Args:
            repo_owner: Owner of the repository
            repo_name: Name of the repository

        Returns:
            Dictionary with repository information
        """
        repo_full_name = f"{repo_owner}/{repo_name}"
        logger.info(f"Getting details for repository: {repo_full_name}")

        try:
            # Get repository details
            # Apply rate limiting before request
            self._last_wait_time = self.rate_tracker.apply_rate_limit(
                self.engine_type
            )

            response = safe_get(
                f"{self.api_base}/repos/{repo_full_name}", headers=self.headers
            )

            # Check for rate limiting
            self._handle_rate_limits(response)

            if response.status_code == 200:
                repo = response.json()

                # Format as repository preview
                result = self._format_repository_preview(repo)

                # Add README content if requested
                if self.include_readme:
                    readme_content = self._get_readme_content(repo_full_name)
                    result["full_content"] = readme_content
                    result["content_type"] = "readme"

                # Add recent issues if requested
                if self.include_issues:
                    issues = self._get_recent_issues(repo_full_name)
                    result["recent_issues"] = issues

                return result
            logger.error(
                f"Error getting repository details: {response.status_code} - {response.text}"
            )
            return {}

        except Exception as e:
            safe_msg = self._scrub_error(e)
            logger.warning(f"Error getting repository details: {safe_msg}")
            return {}

    def search_code(
        self,
        query: str,
        language: Optional[str] = None,
        user: Optional[str] = None,
    ) -> List[Dict[str, Any]]:
        """
        Search for code with more specific parameters.

        Args:
            query: Code search query
            language: Filter by programming language
            user: Filter by GitHub username/organization

        Returns:
            List of code search results
        """
        # Build advanced query
        advanced_query = query

        if language:
            advanced_query += f" language:{language}"

        if user:
            advanced_query += f" user:{user}"

        # Save current search type
        original_search_type = self.search_type

        try:
            # Set search type to code
            self.search_type = "code"
            self.search_endpoint = f"{self.api_base}/search/code"

            # Perform search
            results = self._search_github(advanced_query)

            # Format results
            previews = [self._format_code_preview(result) for result in results]

            return self._get_full_content(previews)

        finally:
            # Restore original search type
            self.search_type = original_search_type
            self.search_endpoint = f"{self.api_base}/search/{self.search_type}"

    def search_issues(
        self, query: str, state: str = "open", sort: str = "updated"
    ) -> List[Dict[str, Any]]:
        """
        Search for issues with more specific parameters.

        Args:
            query: Issue search query
            state: Filter by issue state ("open", "closed", "all")
            sort: Sort order ("updated", "created", "comments")

        Returns:
            List of issue search results
        """
        # Build advanced query
        advanced_query = query + f" state:{state}"

        # Save current search type
        original_search_type = self.search_type

        try:
            # Set search type to issues
            self.search_type = "issues"
            self.search_endpoint = f"{self.api_base}/search/issues"

            # Set sort parameter
            params = {
                "q": advanced_query,
                "per_page": min(self.max_results, 100),
                "page": 1,
                "sort": sort,
                "order": "desc",
            }

            # Perform search
            response = safe_get(
                self.search_endpoint, headers=self.headers, params=params
            )

            # Check for rate limiting
            self._handle_rate_limits(response)

            if response.status_code == 200:
                data = response.json()
                results = data.get("items", [])

                # Format results
                return [
                    self._format_issue_preview(result) for result in results
                ]

                # For issues, we don't need to get full content
            logger.error(
                f"GitHub API error: {response.status_code} - {response.text}"
            )
            return []

        finally:
            # Restore original search type
            self.search_type = original_search_type
            self.search_endpoint = f"{self.api_base}/search/{self.search_type}"

    def set_search_type(self, search_type: str):
        """
        Set the search type for subsequent searches.

        Args:
            search_type: Type of GitHub search ("repositories", "code", "issues", "users")
        """
        if search_type not in _VALID_SEARCH_TYPES:
            raise ValueError(
                f"Invalid GitHub search_type: {search_type!r}. "
                f"Must be one of {_VALID_SEARCH_TYPES}"
            )
        self.search_type = search_type
        self.search_endpoint = f"{self.api_base}/search/{search_type}"
        logger.info(f"Set GitHub search type to: {search_type}")

    @staticmethod
    def _valid_unique_indices(ranked_indices, upper_bound):
        """Yield valid indices once, preserving first-seen (ranked) order.

        Rejects non-integers, booleans, negative and out-of-range indices,
        and deduplicates so a malformed LLM response cannot select the wrong
        preview (e.g. ``-1`` -> last preview) or list the same preview twice.
        """
        seen = set()
        for idx in ranked_indices:
            if not isinstance(idx, int) or isinstance(idx, bool):
                continue
            if idx in seen:
                continue
            if 0 <= idx < upper_bound:
                seen.add(idx)
                yield idx

    def _filter_for_relevance(
        self, previews: List[Dict[str, Any]], query: str
    ) -> List[Dict[str, Any]]:
        """
        Filter GitHub search results for relevance using LLM.

        Args:
            previews: List of preview dictionaries
            query: Original search query

        Returns:
            List of relevant preview dictionaries
        """
        if not self.llm or not previews:
            return previews

        # Create a specialized prompt for GitHub results
        prompt = f"""Analyze these GitHub search results and rank them by relevance to the query.
Consider:
1. Repository stars and activity (higher is better)
2. Match between query intent and repository description
3. Repository language and topics
4. Last update time (more recent is better)
5. Whether it's a fork (original repositories are preferred)

Query: "{query}"

Results:
{json.dumps(previews, indent=2)}

Return ONLY a JSON array of indices in order of relevance (most relevant first).
Example: [0, 2, 1, 3]
Do not include any other text or explanation."""

        try:
            response = self.llm.invoke(prompt)
            response_text = get_llm_response_text(response)

            ranked_indices = extract_json(response_text, expected_type=list)

            if ranked_indices is not None:
                # Return the results in ranked order, validated and
                # deduplicated so each preview appears at most once.
                ranked_results = [
                    previews[idx]
                    for idx in self._valid_unique_indices(
                        ranked_indices, len(previews)
                    )
                ]

                # Limit to max_filtered_results if specified
                if (
                    self.max_filtered_results
                    and len(ranked_results) > self.max_filtered_results
                ):
                    logger.info(
                        f"Limiting filtered results to top {self.max_filtered_results}"
                    )
                    return ranked_results[: self.max_filtered_results]

                return ranked_results
            logger.info(
                "Could not find JSON array in response, returning no previews"
            )
            return []

        except Exception as e:
            safe_msg = self._scrub_error(e)
            logger.warning(f"Error filtering GitHub results: {safe_msg}")
            return []
