YouTube Integration

# Handle YouTube Super Chats
def Execute():
    user = args["displayName"]
    amount = float(args["amount"])
    currency = args["currency"]
    formatted = args["formattedAmount"]
    message = args.get("message", "")

    # Log the Super Chat
    CPH.LogInfo(f"Super Chat from {user}: {formatted}")

    # Scale reaction based on amount
    if amount >= 100:
        CPH.RunAction("Massive Super Chat Alert")
        CPH.ObsSetScene("Super Chat Celebration")
    elif amount >= 20:
        CPH.RunAction("Big Super Chat Alert")
    else:
        CPH.RunAction("Super Chat Alert")

    # Thank the supporter
    CPH.SendMessage(f"Thank you {user} for the {formatted} Super Chat!")

    return True

# Handle YouTube member events
def Execute():
    user = args["displayName"]
    event_type = args.get("eventType", "new")
    level = args.get("memberLevel", "Member")
    months = int(args.get("memberMonths", 1))

    if event_type == "new":
        CPH.LogInfo(f"New member: {user} at {level}")
        CPH.RunAction("New Member Alert")
        CPH.SendMessage(f"Welcome {user} to the {level} family!")

    elif event_type == "milestone":
        CPH.LogInfo(f"{user} hit {months} months!")
        if months >= 12:
            CPH.RunAction("Annual Member Alert")
        CPH.SendMessage(f"{user} has been a member for {months} months!")

    elif event_type == "gift":
        recipient = args["recipientName"]
        CPH.LogInfo(f"{user} gifted membership to {recipient}")
        CPH.SendMessage(f"{user} gifted a membership to {recipient}!")

    return True

# Manage YouTube stream settings
def Execute():
    command = args.get("command", "")

    if command == "!title":
        new_title = args.get("input", "")
        if new_title:
            CPH.YouTubeSetStreamTitle(new_title)
            CPH.SendMessage(f"Stream title updated to: {new_title}")
        else:
            current = CPH.YouTubeGetStreamInfo()
            CPH.SendMessage(f"Current title: {current['title']}")

    elif command == "!category":
        category = args.get("input", "")
        if category:
            CPH.YouTubeSetStreamCategory(category)
            CPH.SendMessage(f"Category changed to: {category}")

    elif command == "!stream":
        info = CPH.YouTubeGetStreamInfo()
        if info["isLive"]:
            viewers = info["viewerCount"]
            likes = info["likeCount"]
            CPH.SendMessage(f"Live with {viewers} viewers and {likes} likes!")
        else:
            CPH.SendMessage("Stream is currently offline")

    return True

# Moderate YouTube live chat
def Execute():
    user = args["displayName"]
    user_id = args["userId"]
    message = args["message"].lower()
    is_mod = args.get("isModerator", False)
    is_member = args.get("isMember", False)

    # Skip moderators and members
    if is_mod or is_member:
        return True

    # Check for spam patterns
    spam_patterns = ["buy followers", "free money", "click here"]

    for pattern in spam_patterns:
        if pattern in message:
            CPH.LogInfo(f"Spam detected from {user}")
            CPH.YouTubeDeleteMessage(args["messageId"])
            CPH.YouTubeTimeoutUser(user_id, 300)
            return False

    # Link filter for non-members
    if "http" in message or "www." in message:
        CPH.YouTubeDeleteMessage(args["messageId"])
        CPH.SendMessage(f"@{user} links are only allowed for members.")
        return False

    return True