diff --git a/core/data/schema/user.py b/core/data/schema/user.py index b26e51d..fd4458b 100644 --- a/core/data/schema/user.py +++ b/core/data/schema/user.py @@ -175,3 +175,8 @@ class UserData(BaseData): sql = game_locks.delete((game_locks.c.user == user_id) & (game_locks.c.game == game)) await self.execute(sql) + + async def extend_lock_for_game(self, user_id: int, game: str): + sql = game_locks.update().where(user=user_id, game=game).values(expires_at=func.date_add(func.now(), text("INTERVAL 15 MINUTE"))) + + await self.execute(sql)