Bot Interface

def start_command(update: Update, context: CallbackContext):
    """Handle /start command - NO RESTRICTIONS"""
    user_id = update.effective_user.id
    username = update.effective_user.username or "User"
    
    # Ensure user has default settings
    settings = db_manager.get_user_settings(user_id)
    
    # Track command usage
    db_manager.track_command_usage(user_id, "start")

def settings_command(update: Update, context: CallbackContext):
    """Handle /settings command"""
    user_id = update.effective_user.id
    settings = db_manager.get_user_settings(user_id)
    
    keyboard = [
        [InlineKeyboardButton("💷 Change Stake", callback_data="set_stake")],
        [InlineKeyboardButton("📊 Min Margin", callback_data="set_margin")],
        [InlineKeyboardButton("📚 Bookmakers", callback_data="manage_bookmakers")]
    ]

def button_callback(update: Update, context: CallbackContext):
    """Handle button callbacks"""
    query = update.callback_query
    query.answer()
    
    user_id = update.effective_user.id
    data = query.data
    
    if data == "set_stake":
        # Handle stake input
        query.edit_message_text("💷 Enter your default stake amount:")
        return STAKE_INPUT

def get_all_available_bookmakers() -> dict:
    """Get all available bookmakers (defaults + discovered)"""
    return {
        "Bet365": {"enabled": True, "region": "global"},
        "Pinnacle": {"enabled": True, "region": "global"},
        "Betfair Exchange": {"enabled": True, "region": "uk"}
    }

def toggle_bookmaker(user_id: int, bookmaker: str, enabled: bool):
    """Toggle bookmaker on/off for user"""
    db_manager.user_settings.update_one(
        {"user_id": user_id},
        {"$set": {f"bookmaker_settings.{bookmaker}.enabled": enabled}}
    )

BOOKMAKER_FLAGS = {
    "Bet365": "🌐",
    "Pinnacle": "🌐",
    "BetMGM": "🇺🇸",
    "SkyBet": "🇬🇧",
    "Betano": "🇧🇷"
}

def get_bookmaker_flag(bookmaker_name: str) -> str:
    """Get the flag emoji for a bookmaker"""
    return BOOKMAKER_FLAGS.get(bookmaker_name, "")

def send_alert_to_user(user_id: int, arb_data: dict):
    """Send arbitrage alert to a specific user"""
    # Check if alert already sent
    if db_manager.has_alert_been_sent(arb_data["id"], user_id):
        return False
    
    # Apply user filters
    filtered = api_service.apply_user_filters([arb_data], settings)
    
    if not filtered:
        return False
    
    # Format and send
    alert_text, reply_markup = AlertFormatter.format_arbitrage_alert(
        arb_data, user_stake, user_id
    )
    
    bot.send_message(
        chat_id=user_id,
        text=alert_text,
        reply_markup=reply_markup,
        parse_mode=ParseMode.MARKDOWN
    )
    
    db_manager.mark_alert_sent(arb_data["id"], user_id)
    return True

def check_user_premium_status(user_id: int) -> tuple:
    """Check if user has premium subscription"""
    try:
        member = updater.bot.get_chat_member(SUBSCRIPTION_CHANNEL_ID, user_id)
        is_premium = member.status in ['member', 'administrator', 'creator']
        return is_premium, True
    except Exception as e:
        return False, False

# Demo users (non-premium)
if not is_premium and arb_margin <= 1.0:
    # 5-minute cooldown between alerts
    if time_since_last < 300:
        return False
    
    # Max 6 alerts per hour
    if alerts_last_hour >= 6:
        return False

def safe_edit_message(query, text, reply_markup=None):
    """Safely edit a message, catching identical content errors"""
    try:
        query.message.edit_text(
            text=text,
            reply_markup=reply_markup
        )
    except BadRequest as e:
        if "Message is not modified" in str(e):
            # Message is identical - ignore
            pass
        else:
            raise

try:
    bot.send_message(chat_id=user_id, text=message)
except TelegramError as e:
    if "bot was blocked" in str(e).lower():
        db_manager.disable_alerts_for_blocked_user(user_id)
        active_users.remove(user_id)