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)