| 1234567891011 |
- 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)
|
