Tlapbot/tlapbot/db.py

166 lines
4.5 KiB
Python
Raw Normal View History

2022-06-08 14:22:58 +02:00
import sqlite3
import click
from flask import current_app, g
from flask.cli import with_appcontext
def get_db():
if 'db' not in g:
g.db = sqlite3.connect(
current_app.config['DATABASE'],
detect_types=sqlite3.PARSE_DECLTYPES
)
g.db.row_factory = sqlite3.Row
return g.db
def close_db(e=None):
db = g.pop('db', None)
if db is not None:
db.close()
2022-10-17 18:47:30 +02:00
def insert_counters(db):
for redeem, redeem_info in current_app.config['REDEEMS'].items():
if redeem_info["type"] == "counter":
try:
db.execute(
2022-10-13 13:29:38 +02:00
"INSERT INTO counters(name, count) VALUES(?, 0)",
(redeem,)
)
db.commit()
except sqlite3.Error as e:
2022-10-13 13:29:38 +02:00
print("Failed inserting counters to db:", e.args[0])
2022-10-17 18:47:30 +02:00
2022-06-08 14:22:58 +02:00
def init_db():
db = get_db()
with current_app.open_resource('schema.sql') as f:
db.executescript(f.read().decode('utf8'))
2022-10-17 18:47:30 +02:00
insert_counters(db)
2022-06-08 14:22:58 +02:00
def clear_redeem_queue():
db = get_db()
try:
cursor = db.execute(
"DELETE FROM redeem_queue"
)
cursor.execute(
"""UPDATE counters SET count = 0"""
)
db.commit()
except sqlite3.Error as e:
print("Error occured deleting redeem queue:", e.args[0])
def refresh_counters():
db = get_db()
try:
db.execute("DELETE FROM counters")
db.commit()
except sqlite3.Error as e:
print("Error occured deleting old counters:", e.args[0])
2023-03-27 14:19:26 +02:00
insert_counters(db)
2023-03-15 13:37:21 +01:00
def refresh_milestones():
db = get_db()
# delete old milestones
try:
cursor = db.execute("SELECT name FROM milestones")
milestones = cursor.fetchall()
2023-03-15 13:37:21 +01:00
to_delete = []
for milestone in milestones:
milestone = milestone[0]
2023-03-15 14:19:38 +01:00
if milestone not in current_app.config['REDEEMS'].keys():
to_delete.append(milestone)
elif current_app.config['REDEEMS'][milestone]['type'] != "milestone":
to_delete.append(milestone)
for milestone in to_delete:
2023-03-15 14:19:38 +01:00
cursor.execute("DELETE FROM milestones WHERE name = ?", (milestone,))
2023-03-15 13:37:21 +01:00
db.commit()
except sqlite3.Error as e:
2023-03-15 13:37:21 +01:00
print("Failed deleting old milestones from db:", e.args[0])
# add new milestones
try:
for redeem, redeem_info in current_app.config['REDEEMS'].items():
if redeem_info["type"] == "milestone":
cursor = db.execute(
"SELECT goal FROM milestones WHERE name = ?",
(redeem,)
)
result = cursor.fetchone()
if result is None:
cursor.execute(
2023-03-20 13:23:20 +01:00
"INSERT INTO milestones(name, progress, goal, complete) VALUES(?, 0, ?, FALSE)",
(redeem, redeem_info['goal'])
)
# update existing milestone to new goal
elif result != redeem_info["goal"]:
cursor.execute(
"UPDATE milestones SET goal = ? WHERE name = ?",
(redeem_info["goal"], redeem)
)
db.commit()
except sqlite3.Error as e:
2023-03-15 13:37:21 +01:00
print("Failed inserting milestones to db:", e.args[0])
2022-06-08 14:22:58 +02:00
@click.command('init-db')
@with_appcontext
def init_db_command():
"""Clear the existing data and create new tables."""
init_db()
click.echo('Initialized the database.')
2022-10-17 18:47:30 +02:00
@click.command('clear-queue')
@with_appcontext
def clear_queue_command():
"""Remove all redeems from the redeem queue."""
clear_redeem_queue()
click.echo('Cleared redeem queue.')
@click.command('refresh-counters')
@with_appcontext
def refresh_counters_command():
2023-01-09 15:21:20 +01:00
"""Refresh counters from current config file.
(Remove old ones, add new ones.)"""
refresh_counters()
click.echo('Counters refreshed.')
2023-01-13 11:04:01 +01:00
@click.command('clear-refresh')
@with_appcontext
def refresh_and_clear_command():
"""Refresh counters and clear queue."""
refresh_counters()
clear_redeem_queue()
click.echo('Counters refreshed and queue cleared.')
2023-03-15 13:37:21 +01:00
@click.command('refresh-milestones')
@with_appcontext
def refresh_milestones_command():
"""Initialize all milestones from the redeems file,
delete milestones not in redeem file."""
refresh_milestones()
click.echo('Refreshed milestones.')
2022-06-08 14:22:58 +02:00
def init_app(app):
app.teardown_appcontext(close_db)
2022-10-17 18:47:30 +02:00
app.cli.add_command(init_db_command)