Yachtr APIyachtr.com ↗

"""
Yachtr Boat Details API Client
Get your API key from: https://parse.bot/settings
"""

import os
import requests
from typing import Optional, Dict, Any, List


class ParseClient:
    """Client for interacting with Parse API scrapers."""
    
    def __init__(self, api_key: Optional[str] = None):
        """
        Initialize the Parse API client.
        
        Args:
            api_key: API key for authentication. If not provided, reads from PARSE_API_KEY env var.
        """
        self.base_url = "https://api.parse.bot"
        self.scraper_id = "aa1e2835-2f90-48a2-b0c0-5a81ce39f795"
        self.api_key = api_key or os.getenv("PARSE_API_KEY")
        
        if not self.api_key:
            raise ValueError("API key must be provided or set in PARSE_API_KEY environment variable")
    
    def _call(self, endpoint: str, method: str = "POST", **params) -> Dict[str, Any]:
        """
        Make a request to the Parse API.
        
        Args:
            endpoint: The endpoint name
            method: HTTP method (GET or POST)
            **params: Parameters to send with the request
            
        Returns:
            Parsed JSON response
            
        Raises:
            requests.RequestException: If the request fails
        """
        url = f"{self.base_url}/scraper/{self.scraper_id}/{endpoint}"
        headers = {
            "X-API-Key": self.api_key,
            "Content-Type": "application/json"
        }
        
        if method.upper() == "GET":
            response = requests.get(url, headers=headers, params=params)
        elif method.upper() == "POST":
            payload = params
            response = requests.post(url, headers=headers, json=payload)
        else:
            raise ValueError(f"Unsupported HTTP method: {method}")
        
        response.raise_for_status()
        return response.json()
    
    def get_boat_details(self, boat_id: str) -> Dict[str, Any]:
        """
        Get comprehensive details of a boat listed on yachtr.com.
        
        Args:
            boat_id: Either a full yachtr.com boat listing URL or the numeric vessel ID
            
        Returns:
            Dictionary containing boat specifications, engine info, images, and broker contact
            
        Example:
            >>> client = ParseClient()
            >>> details = client.get_boat_details("2850869")
            >>> print(details["title"])
        """
        return self._call("get_boat_details", method="GET", boat_id=boat_id)


def format_boat_info(boat: Dict[str, Any]) -> str:
    """Format boat information for display."""
    output = []
    output.append(f"\n{'='*60}")
    output.append(f"BOAT: {boat.get('title', 'N/A')}")
    output.append(f"{'='*60}")
    output.append(f"Name: {boat.get('boat_name', 'N/A')}")
    output.append(f"Location: {boat.get('location', 'N/A')}")
    output.append(f"Price: ${boat.get('price_usd', 'N/A')}")
    output.append(f"\nSPECIFICATIONS:")
    
    specs = boat.get('specifications', {})
    for key, value in specs.items():
        output.append(f"  {key}: {value}")
    
    engines = boat.get('engines', [])
    if engines:
        output.append(f"\nENGINES:")
        for engine in engines:
            output.append(f"  {engine.get('name', 'Unknown')}:")
            output.append(f"    Make: {engine.get('Engine Make', 'N/A')}")
            output.append(f"    Model: {engine.get('Engine Model', 'N/A')}")
            output.append(f"    HP: {engine.get('Power HP', 'N/A')}")
            output.append(f"    Hours: {engine.get('Hours', 'N/A')}")
    
    broker = boat.get('broker', {})
    if broker:
        output.append(f"\nBROKER CONTACT:")
        output.append(f"  Name: {broker.get('name', 'N/A')}")
        output.append(f"  Brokerage: {broker.get('brokerage', 'N/A')}")
        output.append(f"  Email: {broker.get('email', 'N/A')}")
    
    images = boat.get('images', [])
    if images:
        output.append(f"\nIMAGES: {len(images)} available")
        for i, img_url in enumerate(images[:3], 1):
            output.append(f"  {i}. {img_url}")
        if len(images) > 3:
            output.append(f"  ... and {len(images) - 3} more")
    
    description = boat.get('description', '')
    if description:
        desc_preview = description[:200] + "..." if len(description) > 200 else description
        output.append(f"\nDESCRIPTION:")
        output.append(f"  {desc_preview}")
    
    output.append(f"\n{'='*60}\n")
    return "\n".join(output)


if __name__ == "__main__":
    # Initialize the client
    client = ParseClient()
    
    # Example workflow: Retrieve details for multiple boats
    # Using different boat IDs - could come from a search or user input
    boat_ids = [
        "2850869",  # Ted Brewer 44' sailboat example
        # Add more boat IDs as needed
    ]
    
    print("\n🚤 YACHTR BOAT DETAILS RETRIEVAL")
    print("Fetching comprehensive information for listed boats...\n")
    
    # Collection to store retrieved boats
    retrieved_boats = []
    
    for boat_id in boat_ids:
        try:
            print(f"Fetching details for boat ID: {boat_id}...")
            
            # Get boat details from API
            boat_details = client.get_boat_details(boat_id)
            retrieved_boats.append(boat_details)
            
            # Display formatted information
            print(format_boat_info(boat_details))
            
        except requests.RequestException as e:
            print(f"❌ Error retrieving boat {boat_id}: {e}\n")
        except ValueError as e:
            print(f"❌ Invalid data for boat {boat_id}: {e}\n")
    
    # Summary report
    if retrieved_boats:
        print(f"\n📊 SUMMARY")
        print(f"{'='*60}")
        print(f"Total boats retrieved: {len(retrieved_boats)}")
        
        # Calculate average price
        prices = []
        for boat in retrieved_boats:
            try:
                price_str = boat.get('price_usd', '0').replace('$', '').replace(',', '')
                price = float(price_str)
                if price > 0:
                    prices.append(price)
            except (ValueError, TypeError):
                pass
        
        if prices:
            avg_price = sum(prices) / len(prices)
            print(f"Average price: ${avg_price:,.0f}")
            print(f"Price range: ${min(prices):,.0f} - ${max(prices):,.0f}")
        
        # Broker summary
        brokers = set()
        for boat in retrieved_boats:
            broker_name = boat.get('broker', {}).get('brokerage', 'Unknown')
            brokers.add(broker_name)
        
        print(f"Brokerages represented: {len(brokers)}")
        for broker in sorted(brokers):
            print(f"  - {broker}")
        
        print(f"{'='*60}\n")
    else:
        print("No boats were successfully retrieved.")