Tlapbot/tlapbot/owncast_webhooks.py

from flask import Flask,request,json,Blueprint
from sqlite3 import Error
from tlapbot.db import get_db
from tlapbot.owncast_helpers import *

bp = Blueprint('owncast_webhooks', __name__)

@bp.route('/owncastWebhook',methods=['POST'])
def owncast_webhook():
    data = request.json
    db = get_db()
    if data["type"] == "USER_JOINED":
        user_id = data["eventData"]["user"]["id"]
        display_name = data["eventData"]["user"]["displayName"]
        # CONSIDER: join points for joining stream
        add_user_to_database(db, user_id, display_name)
    elif data["type"] == "NAME_CHANGE":
        user_id = data["eventData"]["user"]["id"]
        new_name = data["eventData"]["newName"]
        old_names = data["eventData"]["user"]["previousNames"]
        print("Changing name:")
        print(f'from {old_names} to {new_name}')
        change_display_name(db, user_id, new_name)
    elif data["type"] == "CHAT":
        user_id = data["eventData"]["user"]["id"]
        if data["eventData"]["visible"]:
            display_name = data["eventData"]["user"]["displayName"]
            print("New chat message:")
            print(f'from {display_name}:')
            print(f'{data["eventData"]["body"]}')
            if "!help" in data["eventData"]["body"]:
                message = """Tlapbot commands:
                !points to see your points.
                !drink to redeem a pitíčko for 60 points.
                That's it for now."""
                send_chat(message)
            elif "!points" in data["eventData"]["body"]:
                if not user_exists(db, user_id):
                    add_user_to_database(db, user_id, display_name)
                points = read_users_points(db, user_id)
                message = "{}'s points: {}".format(display_name, points)
                send_chat(message)
            elif "!drink" in data["eventData"]["body"]:
                points = read_users_points(db, user_id)
                if points is not None and points > 60:
                    if use_points(db, user_id, 60):
                        add_to_redeem_queue(db, user_id, "drink")
                        send_chat("Pitíčko redeemed for 60 points.")
                    else:
                        send_chat("Pitíčko not redeemed because of an error.")
                else:
                    send_chat("Can't redeem pitíčko, you don't have enough points.")
            elif "!clear" in data["eventData"]["body"]:
                clear_redeem_queue(db)
            elif "!queue" in data["eventData"]["body"]:
                queue = pretty_redeem_queue(db)
                print("timestamp           | redeem | redeemer")
                for row in queue:
                    print(row[0], " ", row[1], "  ", row[2])
            # else: # DEBUG: give points for message
            #     give_points_to_chat(db)
    return data