API Poller

class UnifiedAPIPoller:
    def __init__(self):
        # MongoDB Collections
        self.team_odds_collection
        self.player_odds_collection
        self.exchange_liquidity_collection
        self.arbitrage_bets_collection
        
        # Additional Integrations
        self.overtime_client  # Overtime Markets
        self.betpanda_client  # BetPanda
        self.jackbit_client   # Jackbit
        self.oddschecker_client  # OddsChecker
        
        # Rate Limiting
        self.request_tracker  # Global rate tracker

def get_full_odds_for_events(self, event_ids: List[int]) -> List[Dict]:
    """
    Fetch full odds data for multiple events in batches.
    """
    batch_size = 10
    all_odds_data = []
    
    for i in range(0, len(event_ids), batch_size):
        batch_ids = event_ids[i:i + batch_size]
        
        # Filter V2 IDs (deprecated)
        v3_ids = [id for id in batch_ids if not str(id).startswith('1')]
        
        url = "https://api.odds-api.io/v3/odds/multi"
        params = {
            'apiKey': self.api_key,
            'eventIds': ','.join(str(id) for id in v3_ids),
            'bookmakers': 'Bet365,M88,FB Sports,Betfair Exchange'
        }
        
        response = requests.get(url, params=params, timeout=30)
        all_odds_data.extend(response.json())
    
    return all_odds_data

TEAM_MARKET_NAMES = {
    'ML', 'Moneyline', 'Match Result', '1X2', 'Full Time Result',
    'Totals', 'Goals Over/Under', 'Total Goals',
    'Spread', 'Asian Handicap', 'Handicap',
    'Both Teams to Score', 'BTTS',
    'Corners Totals', 'Total Corners',
    'Total Cards', 'Asian Total Cards',
    'Team Shots Home', 'Team Shots Away',
    'Team Shots On Target Home', 'Team Shots On Target Away',
    'Goalkeeper Saves Home', 'Goalkeeper Saves Away',
    # ... (full list in source)
}

filtered_bookmakers = {}
for bookmaker_name, markets in bookmakers.items():
    team_markets = [m for m in markets if m.get('name') in TEAM_MARKET_NAMES]
    if team_markets:
        filtered_bookmakers[bookmaker_name] = team_markets

if OVERTIME_ENABLED and self.overtime_client:
    # Fetch Overtime markets
    overtime_markets = self.overtime_client.fetch_live_markets()
    
    # Transform to standard format
    transformed = self.overtime_transformer.transform_markets(overtime_markets)
    
    # Match with team_odds via overtime_mappings
    for market in transformed:
        mapping = overtime_mappings_collection.find_one({
            'odds_api_fixture_id': market['fixture_id']
        })
        
        if mapping:
            overtime_fixture_id = mapping['overtime_fixture_id']
            # Update overtime_odds collection

ODDSCHECKER_ENABLED = False  # Default: disabled
ODDSCHECKER_POLL_INTERVAL = 300  # 5 minutes
ODDSCHECKER_HEADLESS = True  # Headless browser

stats = {
    'total_polls': 0,
    'total_fixtures_processed': 0,
    'team_docs_created': 0,
    'team_docs_updated': 0,
    'player_docs_created': 0,
    'player_docs_updated': 0,
    'api_errors': 0,
    'overtime_polls': 0,
    'crypto_polls': 0,
    'oddschecker_polls': 0
}