from functools import wraps
from typing import TYPE_CHECKING

import sentry_sdk
from sentry_sdk.consts import SPANDATA
from sentry_sdk.integrations import DidNotEnable
from sentry_sdk.scope import should_send_default_pii
from sentry_sdk.traces import StreamedSpan
from sentry_sdk.utils import has_data_collection_enabled

from ..spans import execute_tool_span, update_execute_tool_span

if TYPE_CHECKING:
    from typing import Any, Awaitable, Callable

try:
    import agents
    from agents import FunctionTool
except ImportError:
    raise DidNotEnable("OpenAI Agents not installed")


async def _get_all_tools(
    original_get_all_tools: "Callable[..., Awaitable[list[agents.Tool]]]",
    agent: "agents.Agent",
    context_wrapper: "agents.RunContextWrapper",
) -> "list[agents.Tool]":
    """
    Responsible for creating and managing `gen_ai.execute_tool` spans.
    """
    # Get the original tools
    tools = await original_get_all_tools(agent, context_wrapper)

    wrapped_tools: "list[agents.Tool]" = []
    for tool in tools:
        # Wrap only the function tools (for now)
        if not isinstance(tool, FunctionTool):
            wrapped_tools.append(tool)
            continue

        # Create a new FunctionTool with our wrapped invoke method
        original_on_invoke = tool.on_invoke_tool

        def create_wrapped_invoke(
            current_tool: "FunctionTool", current_on_invoke: "Callable[..., Any]"
        ) -> "Callable[..., Any]":
            @wraps(current_on_invoke)
            async def sentry_wrapped_on_invoke_tool(
                *args: "Any", **kwargs: "Any"
            ) -> "Any":
                with execute_tool_span(current_tool, *args, **kwargs) as span:
                    # We can not capture exceptions in tool execution here because
                    # `_on_invoke_tool` is swallowing the exception here:
                    # https://github.com/openai/openai-agents-python/blob/main/src/agents/tool.py#L409-L422
                    # And because function_tool is a decorator with `default_tool_error_function` set as a default parameter
                    # I was unable to monkey patch it because those are evaluated at module import time
                    # and the SDK is too late to patch it. I was also unable to patch `_on_invoke_tool_impl`
                    # because it is nested inside this import time code. As if they made it hard to patch on purpose...
                    result = await current_on_invoke(*args, **kwargs)
                    update_execute_tool_span(span, agent, current_tool, result)

                    client = sentry_sdk.get_client()
                    if has_data_collection_enabled(client.options):
                        if not client.options["data_collection"]["gen_ai"]["inputs"]:
                            return result
                    elif not should_send_default_pii():
                        return result

                    if isinstance(span, StreamedSpan):
                        span.set_attribute(SPANDATA.GEN_AI_TOOL_INPUT, args[1])
                    else:
                        span.set_data(SPANDATA.GEN_AI_TOOL_INPUT, args[1])

                return result

            return sentry_wrapped_on_invoke_tool

        tool.on_invoke_tool = create_wrapped_invoke(tool, original_on_invoke)
        wrapped_tools.append(tool)

    return wrapped_tools