Monitor Crypto News for Trading Signals

import requests
import os

API_KEY = os.environ['SUPACRAWLER_API_KEY']
headers = {
    "Authorization": f"Bearer {API_KEY}",
    "Content-Type": "application/json"
}

# Define crypto news sources
sources = [
    {
        "name": "CoinDesk",
        "url": "https://www.coindesk.com/",
        "selector": "a.card-title"
    },
    {
        "name": "CoinTelegraph", 
        "url": "https://cointelegraph.com/",
        "selector": ".post-card__title a"
    },
    {
        "name": "Decrypt",
        "url": "https://decrypt.co/",
        "selector": "h3 > a"
    }
]

# Create watch jobs for each source
for source in sources:
    response = requests.post(
        "https://api.supacrawler.com/api/v1/watch",
        headers=headers,
        json={
            "url": source["url"],
            "frequency": "hourly",
            "selector": source["selector"],
            "notify_email": "[email protected]",
            "notification_preference": "changes_only"
        }
    )
    
    result = response.json()
    if result.get("success"):
        print(f"{source['name']} monitor created: {result['watch_id']}")
    else:
        print(f"Failed to create {source['name']} monitor: {result.get('error')}")

import re
from typing import List, Dict

# Define market-moving keywords
BULLISH_KEYWORDS = [
    'adoption', 'partnership', 'etf approval', 'institutional', 
    'bullish', 'surge', 'rally', 'breakout'
]

BEARISH_KEYWORDS = [
    'regulation', 'ban', 'hack', 'bearish', 'crash', 
    'sell-off', 'sec action', 'investigation'
]

COIN_TICKERS = ['BTC', 'ETH', 'SOL', 'ADA', 'MATIC']

def analyze_headline(headline: str) -> Dict:
    """Analyze headline for trading relevance and sentiment."""
    headline_lower = headline.lower()
    
    # Check for coin mentions
    mentioned_coins = [ticker for ticker in COIN_TICKERS 
                      if ticker.lower() in headline_lower]
    
    # Sentiment analysis
    bullish_score = sum(1 for keyword in BULLISH_KEYWORDS 
                       if keyword in headline_lower)
    bearish_score = sum(1 for keyword in BEARISH_KEYWORDS 
                       if keyword in headline_lower)
    
    return {
        'headline': headline,
        'coins_mentioned': mentioned_coins,
        'sentiment': 'bullish' if bullish_score > bearish_score 
                    else 'bearish' if bearish_score > 0 else 'neutral',
        'relevance_score': bullish_score + bearish_score + len(mentioned_coins),
        'priority': 'high' if (bullish_score + bearish_score) >= 2 else 'normal'
    }

# Example webhook handler
def process_watch_notification(payload):
    """Process incoming watch notification."""
    changes = payload.get('changes', [])
    
    for change in changes:
        if change['type'] == 'added':
            analysis = analyze_headline(change['content'])
            
            if analysis['relevance_score'] >= 2:
                send_priority_alert(analysis)