Tlapbot/tlapbot/db.py

216 lines
6.2 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
from tlapbot.redeems import milestone_complete
2022-06-08 14:22:58 +02:00
2024-02-10 13:38:26 +01:00
2022-06-08 14:22:58 +02:00
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])
return False
return True
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
if insert_counters(db):
return True
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])
return False
return True
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])
return False
if insert_counters(db):
return True
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])
return False
2023-03-15 13:37:21 +01:00
# 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])
return False
return True
2023-03-15 13:37:21 +01:00
def reset_milestone(milestone):
2024-02-10 13:38:26 +01:00
if milestone not in current_app.config['REDEEMS']:
print(f"Failed resetting milestone, {milestone} not in redeems file.")
return False
try:
2023-07-03 12:18:29 +02:00
db = get_db()
db.execute(
"DELETE FROM milestones WHERE name = ?",
(milestone,)
)
db.execute(
2023-07-03 12:18:29 +02:00
"INSERT INTO milestones(name, progress, goal, complete) VALUES(?, ?, ?, FALSE)",
(milestone, 0, current_app.config['REDEEMS'][milestone]['goal'])
)
db.commit()
return True
2023-07-03 12:18:29 +02:00
except sqlite3.Error as e:
current_app.logger.error(f"Error occured adding a milestone: {e.args[0]}")
return False
2023-03-15 13:37:21 +01:00
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."""
if init_db():
click.echo('Initialized the database.')
2022-06-08 14:22:58 +02:00
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."""
if 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.)"""
if 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."""
if refresh_counters() and clear_redeem_queue():
click.echo('Counters refreshed and queue cleared.')
2023-01-13 11:04:01 +01:00
2023-03-15 13:37:21 +01:00
@click.command('refresh-milestones')
@with_appcontext
def refresh_milestones_command():
2024-02-10 13:38:26 +01:00
"""Initialize all milestones from the redeems file,
2023-03-15 13:37:21 +01:00
delete milestones not in redeem file."""
if refresh_milestones():
click.echo('Refreshed milestones.')
2023-03-15 13:37:21 +01:00
@click.command('reset-milestone')
@click.argument('milestone')
def reset_milestone_command(milestone):
"""Resets a completed milestone back to zero."""
2023-07-03 12:18:29 +02:00
if milestone_complete(get_db(), milestone):
if reset_milestone(milestone):
click.echo(f"Reset milestone {milestone}.")
else:
click.echo(f"Could not reset milestone {milestone}, milestone not completed.")
click.echo("(You can hard-reset-milestone if you really want to reset it.)")
@click.command('hard-reset-milestone')
@click.argument('milestone')
def hard_reset_milestone_command(milestone):
"""Resets any milestone back to zero."""
if reset_milestone(milestone):
click.echo(f"Hard reset milestone {milestone}.")
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)