import queue from flask import Flask, render_template, request, make_response, session from flask_socketio import SocketIO, join_room, leave_room #https://pythonprogramminglanguage.com/python-flask-websocket/ from flask_session import Session import sqlite3 import time import atexit import sys import uuid db_path = 'mate.db' conn = sqlite3.connect(db_path, check_same_thread=False) c = conn.cursor() app = Flask(__name__) key = str(uuid.uuid4().hex) app.config['SESSION_TYPE'] = 'filesystem' app.config['SECRET_KEY'] = key Session(app) socketio = SocketIO(app) status = True users = queue.Queue() finished = None message = None def exit_handler(): conn.close() sys.exit("Program sucsesfully exited") #website @app.route("/") def index(): return 'user and tag list

The creator of this website accepts no liability for any linguistic or technical errors!

' @app.route("/list") def list(): c.execute("SELECT * FROM users") users = c.fetchall() text = "" for i in users: text = text + f'

{i[1]}: {i[2]}

' return '''

''' + text + '' @app.route("/list/user", methods=['GET']) def user_info(): username = request.args.get("user") c.execute("SELECT * FROM users WHERE username = '%s'" % username) user_list = c.fetchall() if user_list != []: user = user_list[0] c.execute(f"SELECT * FROM tags WHERE userid={user[0]}") tags = c.fetchall() text = "" for tag in tags: text = text + f"

{tag[0]}

" return f"""

{user[1]} : {user[2]}

Tags:

{text}

""" else: return "User does not exists" @app.route("/adduser") def new_user(): return render_template("adduser.html") @app.route("/removeuser/confirmation", methods=['GET']) def confirm_remove_user(): user_id = request.args.get("id") return f'Do your realy want to remove the user' @app.route("/removeuser", methods=['GET']) def remove_user(): user_id = request.args.get("id") c.execute(f"SELECT * FROM users WHERE id={user_id}") user_name = c.fetchall()[0][1] c.execute(f"DELETE FROM tags WHERE userid={user_id}") c.execute(f"DELETE FROM users WHERE id={user_id}") conn.commit() return f'

Deleted user {user_name}

return to the tags and user list' @app.route("/adduser/user", methods=['GET']) def adduser(): user = request.args.get("username") c.execute(f"SELECT * FROM users WHERE username='{str(user)}'") if c.fetchall() == []: c.execute("INSERT or IGNORE INTO users (username, balance) VALUES ('%s', 0)" % user) conn.commit() return 'Added user user and tag list

The creator of this website accepts no liability for any linguistic or technical errors!

' else: return 'User already exists user and tag list

The creator of this website accepts no liability for any linguistic or technical errors!

' @app.route("/change", methods=['GET']) def change(): user_id = int(request.args.get("id")) try: change = int(request.args.get("change")) except ValueError: return '

Please enter a number!

tags and user list' c.execute(f"UPDATE users SET balance = balance + {change} WHERE id={user_id}") conn.commit() if change < 0: text = "removed from" change_text = change * -1 elif change > 0: text = "added to" change_text = change elif change == 0: return "

Nothing was done!

" c.execute(f"SELECT * FROM users WHERE id={user_id}") user = c.fetchall()[0][1] return f'

{change_text} was {text} {user}

back to the list' @app.route("/addtag", methods=['GET']) def get_addtag_request(): global users try: user_id = int(request.args.get("id")) except: #except im Normalen Code! return "Wrong user id!" session_id = uuid.uuid4() session[id] = session_id users.put([user_id, "add", session_id]) return render_template("addtag.html", user=user_id) @socketio.on('addtag') def request_addtag(data): global finished global message join_room(session[id]) if len(users.queue) > 0: user = users.queue[len(users.queue) - 1] if user == [data["data"], "add", session[id]]: socketio.emit("wait", "wait", to=session[id]) i = 0 while finished != [data["data"], "add", session[id]]: time.sleep(1) i += 1 if i > 20: socketio.emit("error", "timeout", to=session[id]) notimportant = users.get() break else: finished = None c.execute(f"SELECT * FROM users WHERE id ={user[0]}") username = c.fetchall()[0][1] if message == "Tag already exists": socketio.emit("finished", f"{message}") else: socketio.emit("finished", f"Added {message} to {username}", to=session[id]) else: socketio.emit("busy", "busy", to=session[id]) else: socketio.emit("error", "error", to=session[id]) leave_room(session[id]) @app.route("/removetag", methods=['GET']) def get_removetag_request(): global users try: user_id = int(request.args.get("id")) except: #except im Normalen Code! return "Wrong user id!" session_id = uuid.uuid4() session[id] = session_id users.put([user_id, "remove", session_id]) return render_template("removetag.html", user=user_id) @socketio.on('removetag') def request_removetag(data): global finished global message join_room(session[id]) if len(users.queue) > 0: queue_item = users.queue[len(users.queue) - 1] user = queue_item[0] if queue_item == [data["data"], "remove", session[id]]: socketio.emit("wait", "wait", to=session[id]) i = 0 while finished != [data["data"], "remove", session[id]]: time.sleep(1) i += 1 if i > 20: socketio.emit("error", "timeout", to=session[id]) notimportant = users.get() break else: finished = None c.execute(f"SELECT * FROM users WHERE id ={user}") username = c.fetchall()[0][1] if message == "Tag does not exist": socketio.emit("finished", f"{message}") else: socketio.emit("finished", f"removed {message} from {username}") else: socketio.emit("busy", "busy", to=session[id]) else: socketio.emit("error", "error", to=session[id]) leave_room(session[id]) #api @app.route("/api/tag_id", methods=['GET']) def get_id(): global finished global message tag_id = int(request.args.get("id")) c.execute(f"SELECT * FROM tags WHERE tagid ={tag_id}") tag_list = c.fetchall() if users.qsize() > 0: queue_item = users.get() user = queue_item[0] state = queue_item[1] if state == "add": c.execute(f"SELECT * FROM tags WHERE tagid={tag_id}") if c.fetchall() != []: message = "Tag already exists" else: c.execute(f"INSERT OR IGNORE INTO tags (tagid, userid) VALUES ({tag_id}, {user})") message = tag_id elif state == "remove": c.execute(f"SELECT * FROM tags WHERE (tagid = {tag_id} AND userid = {user})") tags = c.fetchall() if tags != []: c.execute(f"DELETE FROM tags WHERE (tagid = {tag_id} AND userid = {user}) ") message = tag_id else: message = "Tag does not exist" conn.commit() finished = queue_item socketio.emit("update", "update") return make_response("True") elif tag_list != []: tag = tag_list[0] if users.qsize() == 0: c.execute(f"UPDATE users SET balance = balance - 1 WHERE id={tag[1]}") conn.commit() socketio.emit("update", "update") return make_response("True") socketio.emit("update", "update") return make_response("False") def main(): atexit.register(exit_handler) socketio.run(app, host='0.0.0.0', port=5000)