HOALedgerIQ_Website/agents/cast-iron-scout/scanner.py

#!/usr/bin/env python3
"""
Cast Iron Scout - Main Scanner Engine
Continuously scans for cast iron deals and alerts when good deals found
"""
import json
import subprocess
import sys
from datetime import datetime
from pathlib import Path
from sources.ebay_scanner import search_ebay_cast_iron
from sources.craigslist_scanner import search_craigslist_cast_iron
from sources.facebook_scanner import search_facebook_marketplaceCast_iron
from valuation import is_good_deal, calculate_fmv

SCRIPT_DIR = Path(__file__).parent
STATE_FILE = SCRIPT_DIR / "state" / "seen_items.json"
CONFIG_FILE = SCRIPT_DIR / "config.json"
LOG_FILE = SCRIPT_DIR / "logs" / f"scanner-{datetime.now().strftime('%Y%m%d')}.log"

def load_config():
    """Load configuration"""
    if CONFIG_FILE.exists():
        return json.loads(CONFIG_FILE.read_text())
    return {}

def load_state():
    """Load previously seen items to avoid duplicates"""
    if STATE_FILE.exists():
        return json.loads(STATE_FILE.read_text())
    return {"seen_links": [], "last_scan": None}

def save_state(state):
    """Save state to file"""
    state['last_scan'] = datetime.now().isoformat()
    STATE_FILE.write_text(json.dumps(state, indent=2))

def log(message):
    """Log message"""
    ts = datetime.now().strftime('%Y-%m-%d %H:%M:%S')
    log_line = f"[{ts}] {message}"
    print(log_line)
    with open(LOG_FILE, 'a') as f:
        f.write(log_line + '\n')

def send_telegram_alert(item, fmv, discount):
    """Send Telegram alert for a good deal"""
    config = load_config()
    target = config.get('telegram_target', 'telegram:8269921691')
    
    message = f"""🔥 *CAST IRON DEAL ALERT!*

*Item:* {item['title']}
*Price:* ${item['price']:.2f}
*FMV:* ${fmv:.2f}
*Discount:* {discount:.0f}% below FMV! 💰

*Source:* {item['source']}
*Found:* {item['found_at']}

🔗 {item['link']}

_Action: Buy now / Bid / Ignore_"""
    
    try:
        subprocess.run([
            'openclaw', 'message', 'send',
            '--channel', 'telegram',
            '--target', target,
            '--message', message
        ], capture_output=True, timeout=30)
        log(f"✅ Alert sent for: {item['title'][:50]}")
    except Exception as e:
        log(f"❌ Failed to send alert: {e}")

def scan_all_sources():
    """Scan all sources for cast iron items"""
    log("🔍 Starting cast iron scan...")
    
    # Load config and state
    config = load_config()
    state = load_state()
    seen_links = set(state.get('seen_links', []))
    
    all_items = []
    
    # Scan eBay
    try:
        ebay_items = search_ebay_cast_iron()
        log(f"Found {len(ebay_items)} items on eBay")
        all_items.extend(ebay_items)
    except Exception as e:
        log(f"eBay scan error: {e}")
    
    # Scan Craigslist
    try:
        cl_items = search_craigslist_cast_iron()
        log(f"Found {len(cl_items)} items on Craigslist")
        all_items.extend(cl_items)
    except Exception as e:
        log(f"Craigslist scan error: {e}")
    
    # Scan Facebook Marketplace (placeholder for now)
    try:
        fb_items = search_facebook_marketplaceCast_iron(config)
        log(f"Found {len(fb_items)} items on Facebook Marketplace")
        all_items.extend(fb_items)
    except Exception as e:
        log(f"Facebook scan error: {e}")
    
    deals_found = 0
    min_discount = config.get('min_discount_percent', 50)
    
    for item in all_items:
        # Skip if already seen
        if item['link'] in seen_links:
            continue
        
        # Check if it's a good deal
        is_deal, discount, fmv = is_good_deal(item['price'], item['title'], min_discount)
        
        if is_deal:
            log(f"🎯 DEAL FOUND: {item['title'][:50]} - ${item['price']} ({discount:.0f}% off)")
            send_telegram_alert(item, fmv, discount)
            deals_found += 1
        
        # Mark as seen
        seen_links.add(item['link'])
    
    # Keep only last 1000 seen items to prevent state file from growing forever
    if len(seen_links) > 1000:
        seen_links = set(list(seen_links)[-1000:])
    
    state['seen_links'] = list(seen_links)
    save_state(state)
    
    log(f"Scan complete. Deals found: {deals_found}, Total items processed: {len(all_items)}")
    return deals_found

if __name__ == "__main__":
    deals = scan_all_sources()
    sys.exit(0)