NotBigGhostandClaude Opus 5
8be9a23c0c
Результаты (места и причина победы) теперь пишутся только в завершённую партию. Раньше их можно было проставить идущей: партия оставалась in_progress, висела в «Незавершённых», в статистику не попадала и очков не приносила — победитель есть, а игры как бы не было. Дату и общий комментарий по ходу партии править по-прежнему можно: двойственного состояния они не создают. Форма завершения получила общий черновик (match_finish_drafts): раскладка мест, ничьи, выбывшие, комментарии и причина победы видны всем, кто заполняет партию. Отдельная таблица, а не колонки в matches, намеренно — запись в строку партии дёргает onupdate у updated_at, то есть версию для оптимистичной блокировки, и «Завершить» у второго участника ловил бы STALE_WRITE на каждую чужую правку. Черновик удаляется при завершении и уходит каскадом при удалении партии. Черновик разъезжается отдельным типом SSE-события: он меняется на каждое движение тайла, и полная инвалидация (лидерборд, история, профили) по нему была бы расточительной. Автору правки событие не шлётся. #28 Co-Authored-By: Claude Opus 5 <noreply@anthropic.com> Claude-Session: https://claude.ai/code/session_01BoiJK9ux8peeyjLb8TYjFf
62 lines
3.0 KiB
Python
62 lines
3.0 KiB
Python
"""Публикация SSE-событий «данные изменились» нужным пользователям.
|
|
|
|
Тонкая прослойка над core.events.hub — держит роутеры чистыми. Событие несёт лишь тип и id,
|
|
клиент по нему точечно перезапрашивает данные.
|
|
"""
|
|
from __future__ import annotations
|
|
|
|
from sqlmodel import Session, select
|
|
|
|
from app.core.events import hub
|
|
from app.models import GroupMember, Match
|
|
|
|
|
|
def _group_member_ids(session: Session, group_id: int) -> list[int]:
|
|
return list(
|
|
session.exec(select(GroupMember.user_id).where(GroupMember.group_id == group_id)).all()
|
|
)
|
|
|
|
|
|
def match_changed(session: Session, match: Match) -> None:
|
|
"""Партия изменилась — уведомить всех участников её группы."""
|
|
hub.publish(
|
|
_group_member_ids(session, match.group_id),
|
|
{"type": "match", "match_id": match.id, "group_id": match.group_id},
|
|
)
|
|
|
|
|
|
def match_draft_changed(session: Session, match: Match, actor_id: int) -> None:
|
|
"""Черновик формы завершения изменился — остальным заполняющим из группы.
|
|
|
|
Отдельный тип события: черновик меняется на каждое движение тайла, и гнать по нему
|
|
полную инвалидацию (лидерборд, история, профили) было бы расточительно. Автору
|
|
правки событие не шлём — у него уже актуальное состояние."""
|
|
ids = [uid for uid in _group_member_ids(session, match.group_id) if uid != actor_id]
|
|
hub.publish(ids, {"type": "match_draft", "match_id": match.id, "group_id": match.group_id})
|
|
|
|
|
|
def match_removed(session: Session, match_id: int, group_id: int) -> None:
|
|
"""Партия удалена — уведомить участников группы (обновить списки)."""
|
|
hub.publish(
|
|
_group_member_ids(session, group_id),
|
|
{"type": "match", "match_id": match_id, "group_id": group_id},
|
|
)
|
|
|
|
|
|
def group_changed(session: Session, group_id: int, extra_user_ids: list[int] | None = None) -> None:
|
|
"""Состав/данные группы изменились — участникам (+ доп. адресатам, напр. удалённому)."""
|
|
ids = _group_member_ids(session, group_id)
|
|
if extra_user_ids:
|
|
ids = ids + extra_user_ids
|
|
hub.publish(ids, {"type": "group", "group_id": group_id})
|
|
|
|
|
|
def invitations_changed(user_id: int) -> None:
|
|
"""У пользователя изменился список приглашений."""
|
|
hub.publish([user_id], {"type": "invitations"})
|
|
|
|
|
|
def notifications_changed(user_id: int) -> None:
|
|
"""У пользователя появилось/изменилось уведомление — пусть подтянет список."""
|
|
hub.publish([user_id], {"type": "notifications"})
|