iris-discord-bot/bot/query/user.py

async def create_user(pg, user_id):
	await pg.execute("INSERT INTO \"user\"(user_id) VALUES($1) ON CONFLICT DO NOTHING", user_id)

async def ignore_user(pg, user_id):
	await pg.execute("UPDATE \"user\" SET ignore = TRUE WHERE user_id = $1", user_id)

async def unignore_user(pg, user_id):
	await pg.execute("UPDATE \"user\" SET ignore = FALSE WHERE user_id = $1", user_id)

async def is_ignored(pg, user_id):
	return await pg.fetchval("SELECT ignore FROM \"user\" WHERE user_id = $1", user_id)

async def get_level(pg, user_id):
	return await pg.fetchval("SELECT level FROM \"user\" WHERE user_id = $1", user_id)

async def get_xp(pg, user_id):
	message_array = await pg.fetch("SELECT total_messages FROM channel_user WHERE user_id = $1", user_id)
	print(message_array)
	total_xp = 0
	for messages in message_array:
		print(messages)
		total_xp += messages

	xp_spent = await pg.fetchval("SELECT xp_spent FROM \"user\" WHERE user_id = $1", user_id)
	return xp_spent, total_xp

async def level_up(pg, user_id, xp):
	await pg.execute("UPDATE \"user\" (level, xp_spent) VALUES(+ 1, $2) WHERE user_id = $1", user_id, xp)