Compare commits
1 Commits
dd7a99e8b7
...
9db739e56d
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
9db739e56d |
@@ -376,10 +376,18 @@ class SqlCalendarService:
|
|||||||
async def adopt_entries_for_user(
|
async def adopt_entries_for_user(
|
||||||
self, session: AsyncSession, user_id: int, session_id: str,
|
self, session: AsyncSession, user_id: int, session_id: str,
|
||||||
) -> None:
|
) -> None:
|
||||||
"""Adopt anonymous calendar entries for a logged-in user."""
|
"""Adopt anonymous calendar entries for a logged-in user.
|
||||||
|
|
||||||
|
Only deletes stale *pending* entries for the user — confirmed/ordered
|
||||||
|
entries must be preserved.
|
||||||
|
"""
|
||||||
await session.execute(
|
await session.execute(
|
||||||
update(CalendarEntry)
|
update(CalendarEntry)
|
||||||
.where(CalendarEntry.deleted_at.is_(None), CalendarEntry.user_id == user_id)
|
.where(
|
||||||
|
CalendarEntry.deleted_at.is_(None),
|
||||||
|
CalendarEntry.user_id == user_id,
|
||||||
|
CalendarEntry.state == "pending",
|
||||||
|
)
|
||||||
.values(deleted_at=func.now())
|
.values(deleted_at=func.now())
|
||||||
)
|
)
|
||||||
cal_result = await session.execute(
|
cal_result = await session.execute(
|
||||||
|
|||||||
Reference in New Issue
Block a user