from langchain.tools import BaseTool
from pydantic import Field
from solana.keypair import Keypair
from openkitx403_client import OpenKit403Client
import json

class SolanaWalletAuthTool(BaseTool):
    """Tool for authenticating with Solana wallet and fetching data"""
    
    name: str = "solana_wallet_auth"
    description: str = """
    Authenticate with a Solana wallet to access protected APIs.
    Input should be a JSON string with 'url' and 'method' keys.
    Example: {"url": "https://api.example.com/data", "method": "GET"}
    Returns the API response data.
    """
    
    keypair_path: str = Field(default="./keypair.json")
    
    def _run(self, query: str) -> str:
        """Execute the wallet authentication"""
        try:
            # Parse input
            params = json.loads(query)
            url = params.get('url')
            method = params.get('method', 'GET')
            
            # Load keypair
            with open(self.keypair_path, 'r') as f:
                secret_key = json.load(f)
            keypair = Keypair.from_secret_key(bytes(secret_key))
            
            # Create client and authenticate
            client = OpenKit403Client(keypair)
            response = client.authenticate(url, method=method)
            
            # Return response data
            return json.dumps(response.json(), indent=2)
            
        except Exception as e:
            return f"Error: {str(e)}"
    
    async def _arun(self, query: str) -> str:
        """Async version"""
        return self._run(query)

from langchain_openai import ChatOpenAI
from langchain.agents import AgentExecutor, create_openai_functions_agent
from langchain.prompts import ChatPromptTemplate, MessagesPlaceholder

# Initialize LLM
llm = ChatOpenAI(model="gpt-4", temperature=0)

# Create tools
tools = [SolanaWalletAuthTool(keypair_path="./keypair.json")]

# Create prompt
prompt = ChatPromptTemplate.from_messages([
    ("system", """You are a Solana wallet agent assistant. 
    You can authenticate with Solana wallets and interact with protected APIs.
    
    When asked to fetch data from an API:
    1. Use the solana_wallet_auth tool
    2. Provide the URL and HTTP method
    3. Parse and explain the response to the user
    
    Be helpful and explain what you're doing."""),
    ("user", "{input}"),
    MessagesPlaceholder(variable_name="agent_scratchpad"),
])

# Create agent
agent = create_openai_functions_agent(llm, tools, prompt)
agent_executor = AgentExecutor(
    agent=agent, 
    tools=tools, 
    verbose=True,
    max_iterations=3
)

# Run agent
def main():
    print("🤖 Solana AI Agent Started\n")
    
    while True:
        user_input = input("You: ")
        if user_input.lower() in ['exit', 'quit']:
            break
        
        result = agent_executor.invoke({"input": user_input})
        print(f"\nAgent: {result['output']}\n")

if __name__ == "__main__":
    main()