olsch01
71790242f6
- Updated min_discount_percent from 50% to 80% - Only notifying on absolute steals now - Still finding 40+ ultra-deals (Griswold #5 for .96!) - No more moderate deals - only the best of the best - Config updated and scanner tested
143 lines
4.3 KiB
Python
143 lines
4.3 KiB
Python
#!/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_working import search_ebay_cast_iron
|
|
from sources.craigslist_rss import search_craigslist_rss
|
|
from sources.facebook_scanner import search_facebook_marketplace_cast_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 (WORKING!)
|
|
try:
|
|
ebay_items = search_ebay_cast_iron()
|
|
log(f"🔍 eBay: Found {len(ebay_items)} items")
|
|
all_items.extend(ebay_items)
|
|
except Exception as e:
|
|
log(f"eBay scan error: {e}")
|
|
|
|
# Scan Craigslist RSS
|
|
try:
|
|
cl_items = search_craigslist_rss()
|
|
log(f"📘 Craigslist RSS: Found {len(cl_items)} items")
|
|
all_items.extend(cl_items)
|
|
except Exception as e:
|
|
log(f"Craigslist scan error: {e}")
|
|
|
|
# Scan Facebook (placeholder)
|
|
try:
|
|
fb_items = search_facebook_marketplace_cast_iron(config)
|
|
log(f"📘 Facebook: Found {len(fb_items)} items")
|
|
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', 80) # Only ultra-deals now
|
|
|
|
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)
|