crewai_tool.py

"""CrewAI tool that fetches trading signals via x402 payments."""

import asyncio

from crewai.tools import BaseTool

from x402_agent_kit import SignalFuse


class SignalFuseTool(BaseTool):
    name: str = "signalfuse_signal"
    description: str = (
        "Fetch the latest trading signal for a cryptocurrency symbol. "
        "Pays for the API call with USDC on Base via the x402 protocol."
    )

    wallet_key: str

    def _run(self, symbol: str) -> dict:
        sf = SignalFuse(wallet_key=self.wallet_key)
        return asyncio.run(sf.get_signal(symbol))


# Usage with a CrewAI agent:
#
#   from crewai import Agent
#
#   tool = SignalFuseTool(wallet_key="0xYOUR_KEY")
#   agent = Agent(
#       role="Trader",
#       goal="Find high-conviction trading signals",
#       tools=[tool],
#   )