mirror of
https://github.com/flibusta-apps/users_settings_server.git
synced 2025-12-06 14:45:38 +01:00
Fix update user activity
This commit is contained in:
@@ -1,5 +1,6 @@
|
|||||||
from datetime import datetime
|
from datetime import datetime
|
||||||
|
|
||||||
|
from asyncpg.exceptions import UniqueViolationError
|
||||||
from fastapi import APIRouter, Depends, HTTPException, Request, status
|
from fastapi import APIRouter, Depends, HTTPException, Request, status
|
||||||
from fastapi_pagination import Page, Params
|
from fastapi_pagination import Page, Params
|
||||||
from fastapi_pagination.ext.ormar import paginate
|
from fastapi_pagination.ext.ormar import paginate
|
||||||
@@ -59,7 +60,10 @@ async def update_activity(user_id: int) -> None:
|
|||||||
activity = await UserActivity.objects.get_or_none(user__user_id=user_id)
|
activity = await UserActivity.objects.get_or_none(user__user_id=user_id)
|
||||||
|
|
||||||
if activity is None:
|
if activity is None:
|
||||||
await UserActivity.objects.create(user=user.id, updated=datetime.now())
|
try:
|
||||||
|
await UserActivity.objects.create(user=user.id, updated=datetime.now())
|
||||||
|
except UniqueViolationError:
|
||||||
|
pass
|
||||||
return
|
return
|
||||||
|
|
||||||
activity.updated = datetime.now()
|
activity.updated = datetime.now()
|
||||||
|
|||||||
Reference in New Issue
Block a user