Merge pull request #179 from denis1011101/fix/chat-close-notice-and-media-errors

fix: чат прощается, а лимиты вложений говорят по-русски

Author: denis1011101

.github/workflows/ci.yml

@@ -41,8 +41,17 @@ jobs:
           ruby-version: .ruby-version
           bundler-cache: true
 
+      # Аудит ходит в реестр npm по сети, и тот регулярно отвечает 503 или рвёт
+      # соединение — проверка падала на PR, где JS никто не трогал. Уязвимость
+      # так же уронит шаг, просто не с первой попытки.
       - name: Scan for security vulnerabilities in JavaScript dependencies
-        run: bin/importmap audit
+        run: |
+          for attempt in 1 2 3; do
+            bin/importmap audit && exit 0
+            echo "importmap audit failed (attempt $attempt of 3), retrying in 15s"
+            sleep 15
+          done
+          exit 1
 
   lint:
     runs-on: ubuntu-latest

app/jobs/cleanup_past_one_off_games_job.rb

@@ -7,12 +7,17 @@ class CleanupPastOneOffGamesJob < ApplicationJob
   # then destroy the one-off game record.
   def perform
     Game.where(recurring: false).where("date < ?", Date.current).find_each do |game|
+      # Чат уходит вместе с игрой, а текст письма ссылается на её город и дату —
+      # поэтому готовим его до удаления, а шлём только если удаление удалось.
+      notices = Telegram::Chat::Closure.prepare(game, :chat_closed_finished)
+
       if game.participations.exists?
         game.participations.delete_all
         Rails.logger.info "Cleared participations for past one-off Game##{game.id} (date=#{game.date})"
       end
 
       if game.destroy
+        Telegram::Chat::Closure.deliver(game, notices)
         Rails.logger.info "Destroyed past one-off Game##{game.id} (date=#{game.date})"
       else
         Rails.logger.warn "Failed to destroy past one-off Game##{game.id}: #{game.errors.full_messages.join(', ')}"

app/jobs/reset_participations_job.rb

@@ -7,16 +7,21 @@ def perform
       next unless nd
 
       if game.should_reset_participations?(Date.current)
+        # Снимок до сброса: кому чат закроется, видно только по разнице составов —
+        # часть людей вернётся в состав из предзаписи и никуда не выбывает.
+        chat_members = game.chat_members.to_a
+
         if game.prebooking_enabled?
           apply_prebookings_for_occurrence!(game, nd)
           game.mark_participations_reset!(nd)
           Rails.logger.info "Reset participations from prebookings for Game##{game.id} for occurrence #{nd}"
         else
-          close_chat_sessions(game)
           game.participations.delete_all
           game.mark_participations_reset!(nd)
           Rails.logger.info "Reset participations for Game##{game.id} for occurrence #{nd}"
         end
+
+        close_chat_for_dropped(game, chat_members)
       end
     end
   end
@@ -25,10 +30,13 @@ def perform
 
   # delete_all идёт мимо колбэков Participation, поэтому режим чата у выбывших
   # гасим здесь — иначе они продолжат писать в состав, из которого их убрали.
-  def close_chat_sessions(game)
-    game.participations.includes(:user).find_each do |participation|
-      Telegram::Chat::Session.stop_for(participation.user, game)
-    end
+  # Сброс идёт ночью, и без письма человек заметил бы это, только когда его
+  # сообщение уже никому не ушло.
+  def close_chat_for_dropped(game, previous_members)
+    game.participations.reset
+    remaining = game.team_member_ids
+    dropped = previous_members.reject { |user| remaining.include?(user.id) }
+    Telegram::Chat::Closure.notify(game, :chat_closed_reset, dropped)
   rescue StandardError => e
     Rails.logger.warn("[ResetParticipationsJob] chat cleanup failed for Game##{game.id}: #{e.class}: #{e.message}")
   end

app/services/telegram/chat/closure.rb

@@ -0,0 +1,56 @@
+module Telegram
+  module Chat
+    # Чат закрывается не действием человека, а расписанием: в ночь на субботу
+    # состав сбрасывают, а прошедшую разовую игру удаляют совсем. Без письма
+    # человек узнал бы об этом, только когда его сообщение перестало доходить
+    # до команды, — а оно просто не уходит, молча.
+    module Closure
+      Notice = Struct.new(:user, :text)
+
+      class << self
+        # Текст собираем до того, как игру снесут: после удаления ни состава, ни
+        # ярлыка с городом и датой уже не собрать.
+        def prepare(game, reason, users = nil)
+          return [] if game.nil?
+
+          (users || game.chat_members).to_a.filter_map do |user|
+            next if user.nil? || user.telegram_chat_id.blank?
+
+            locale = Telegram::I18n.locale_for(user)
+            Notice.new(user, Telegram::I18n.t(
+              reason, locale: locale, game: Message.game_label(game, locale: locale)
+            ))
+          end
+        end
+
+        # Указатель гасим здесь же: иначе человек останется в чате, которого уже
+        # нет, и следующее его сообщение уйдёт в никуда. Двумя проходами и с
+        # оговоркой на каждого: сброс состава и удаление игры уже случились,
+        # второго захода по этим людям не будет — так что одна упавшая отправка
+        # не должна ни оставить остальных в мёртвом чате, ни съесть их письма.
+        def deliver(game, notices)
+          notices.each { |notice| guard(notice) { Session.stop_for(notice.user, game) } }
+          notices.count do |notice|
+            guard(notice) do
+              SendTelegramNotificationJob.perform_later(notice.user.telegram_chat_id.to_s, notice.text)
+            end
+          end
+        end
+
+        def notify(game, reason, users = nil)
+          deliver(game, prepare(game, reason, users))
+        end
+
+        private
+
+        def guard(notice)
+          yield
+          true
+        rescue StandardError => e
+          Rails.logger.warn("[Chat::Closure] failed for User##{notice.user.id}: #{e.class}: #{e.message}")
+          false
+        end
+      end
+    end
+  end
+end

config/locales/en.yml

@@ -28,6 +28,21 @@
 #       enabled: "ON"
 
 en:
+  activerecord:
+    attributes:
+      game_medium:
+        file: "File"
+    errors:
+      models:
+        game_medium:
+          attributes:
+            file:
+              blank: "is missing"
+              invalid_type: "must be JPEG, PNG, WebP, MP4 or MOV"
+              too_large: "is too big: up to 5 MB for photos and 25 MB for video"
+            base:
+              too_many_videos: "A game can hold only one video"
+              too_many_images: "A game can hold at most six photos"
   errors:
     messages:
       pending_exists: "already has a pending suggestion for this court"

config/locales/es.yml

@@ -1,4 +1,19 @@
 es:
+  activerecord:
+    attributes:
+      game_medium:
+        file: "Archivo"
+    errors:
+      models:
+        game_medium:
+          attributes:
+            file:
+              blank: "falta"
+              invalid_type: "debe ser JPEG, PNG, WebP, MP4 o MOV"
+              too_large: "es demasiado grande: hasta 5 MB para fotos y 25 MB para vídeo"
+            base:
+              too_many_videos: "Un partido admite un solo vídeo"
+              too_many_images: "Un partido admite como máximo seis fotos"
   errors:
     messages:
       pending_exists: "ya tiene una propuesta pendiente para esta pista"

config/locales/ru.yml

@@ -1,4 +1,19 @@
 ru:
+  activerecord:
+    attributes:
+      game_medium:
+        file: "Файл"
+    errors:
+      models:
+        game_medium:
+          attributes:
+            file:
+              blank: "не выбран"
+              invalid_type: "должен быть JPEG, PNG, WebP, MP4 или MOV"
+              too_large: "слишком большой: фото — до 5 МБ, видео — до 25 МБ"
+            base:
+              too_many_videos: "К игре можно приложить только одно видео"
+              too_many_images: "К игре можно приложить не больше шести фото"
   errors:
     messages:
       pending_exists: "уже имеет предложение для этого корта на проверке"

config/locales/telegram.yml

@@ -77,11 +77,13 @@ ru:
     invite_skipped_self: 'Пропущены (это вы): %{users}'
     game_or_user_not_found: Игра или пользователь не найдены
     joined_game: Вы присоединились к игре
-    chat_started: "Теперь вы пишете в чат игры %{game}. Сообщения увидят участники, подключённые к Telegram (%{count})."
+    chat_started: "Теперь вы пишете в чат игры %{game}. Кроме вас, сообщения увидят участники, подключённые к Telegram (%{count})."
     chat_lifetime: "Чат живёт столько же, сколько состав: до субботы, 4:00."
     chat_switch_btn: "Сменить игру"
     chat_exit_btn: "Выйти из чата"
-    chat_stopped: "Вышли из чата. Сообщения боту снова видите только вы."
+    chat_stopped: "Вышли из чата. Сообщения боту снова видите только вы. Вернуться — командой /chat."
+    chat_closed_reset: "Чат игры %{game} закрыт: состав сброшен до следующей игры. Запишитесь снова — и чат откроется."
+    chat_closed_finished: "Игра %{game} прошла — её чат закрыт."
     chat_pick_prompt: "В какую игру писать?"
     chat_none: "Нет игр, в чат которых можно писать."
     chat_not_available: "Чат этой игры недоступен: игра прошла или вас нет в составе."
@@ -685,11 +687,13 @@ en:
     invite_skipped_self: 'Skipped self: %{users}'
     game_or_user_not_found: Game or user not found
     joined_game: You joined the game
-    chat_started: "You are now writing to game %{game}. Players connected to Telegram will see your messages (%{count})."
+    chat_started: "You are now writing to game %{game}. Besides you, players connected to Telegram will see your messages (%{count})."
     chat_lifetime: "The chat lives as long as the squad does: until Saturday, 4:00."
     chat_switch_btn: "Switch game"
     chat_exit_btn: "Leave chat"
-    chat_stopped: "Left the chat. Messages to the bot are private again."
+    chat_stopped: "Left the chat. Messages to the bot are private again. Send /chat to come back."
+    chat_closed_reset: "The chat for game %{game} is closed: the squad has been reset for the next game. Join again and the chat will reopen."
+    chat_closed_finished: "Game %{game} is over — its chat is closed."
     chat_pick_prompt: "Which game do you want to write to?"
     chat_none: "No games with an open chat."
     chat_not_available: "This game's chat is unavailable: the game is over or you are not in the squad."
@@ -1250,11 +1254,13 @@ es:
     invite_skipped_self: 'Omitidos (eres tú): %{users}'
     game_or_user_not_found: Partido o usuario no encontrado
     joined_game: Te has unido al partido
-    chat_started: "Ahora escribes al partido %{game}. Lo verán los jugadores conectados a Telegram (%{count})."
+    chat_started: "Ahora escribes al partido %{game}. Además de ti, lo verán los jugadores conectados a Telegram (%{count})."
     chat_lifetime: "El chat vive lo mismo que la alineación: hasta el sábado a las 4:00."
     chat_switch_btn: "Cambiar de partido"
     chat_exit_btn: "Salir del chat"
-    chat_stopped: "Has salido del chat. Tus mensajes al bot vuelven a ser privados."
+    chat_stopped: "Has salido del chat. Tus mensajes al bot vuelven a ser privados. Escribe /chat para volver."
+    chat_closed_reset: "El chat del partido %{game} está cerrado: la alineación se ha reiniciado hasta el próximo partido. Apúntate de nuevo y el chat volverá a abrirse."
+    chat_closed_finished: "El partido %{game} ha terminado: su chat está cerrado."
     chat_pick_prompt: "¿A qué partido quieres escribir?"
     chat_none: "No hay partidos con chat abierto."
     chat_not_available: "El chat de este partido no está disponible: ya terminó o no estás en la alineación."

test/jobs/cleanup_past_one_off_games_job_test.rb

@@ -1,6 +1,8 @@
 require "test_helper"
 
 class CleanupPastOneOffGamesJobTest < ActiveJob::TestCase
+  include StubHelper
+
   def setup
     @user  = users(:one)
     @court = courts(:one)
@@ -77,4 +79,23 @@ def setup
     assert_nil Game.find_by(id: game.id)
     assert_equal 0, Participation.where(game_id: game.id).count
   end
+
+  # Разовая игра исчезает вместе с чатом, и текст письма ссылается на её город и
+  # дату — значит, собрать его надо до удаления записи.
+  test "tells the squad that the chat died with the game" do
+    player = User.create!(email: "oneoff-chat@example.com", telegram_chat_id: 910_200_001, telegram_locale: "ru")
+    game = Game.create!(user: @user, court: @court, date: Date.yesterday, recurring: false)
+    game.participations.create!(user: player, status: "approved", approved_at: Time.current)
+
+    sent = []
+    stub_singleton(SendTelegramNotificationJob, :perform_later, ->(chat_id, text) { sent << [ chat_id, text ] }) do
+      CleanupPastOneOffGamesJob.perform_now
+    end
+
+    assert_nil Game.find_by(id: game.id)
+    notice = sent.find { |chat_id, _| chat_id == player.telegram_chat_id.to_s }
+    assert notice, "участнику удалённой игры должно уйти письмо о закрытии чата"
+    assert_match "чат", notice.last
+    assert_no_match(/translation missing/i, notice.last)
+  end
 end

test/jobs/reset_participations_job_test.rb

@@ -1,6 +1,10 @@
 require "test_helper"
+require "support/cache_helper"
 
 class ResetParticipationsJobTest < ActiveJob::TestCase
+  include StubHelper
+  include CacheHelper
+
   setup do
     @owner = users(:one)
     @player = User.create!(email: "reset-player@example.com", notification_channel: "email", locale: "en")
@@ -44,4 +48,47 @@ class ResetParticipationsJobTest < ActiveJob::TestCase
     assert_empty game.participations.reload
     assert_equal game.next_date, game.reload.last_participations_reset_at
   end
+
+  # Сброс идёт ночью и уносит с собой чат. Без письма человек узнал бы об этом
+  # только по тому, что его сообщение никому не дошло, — а оно уходит молча.
+  test "tells the players it drops that their chat is gone" do
+    player = User.create!(email: "reset-chat@example.com", telegram_chat_id: 910_100_001, telegram_locale: "ru")
+    game = Game.create!(
+      court: courts(:one), user: @owner, date: Date.current - 14.days, time: "18:00", recurring: true
+    )
+    game.participations.create!(user: player, status: "approved", approved_at: Time.current)
+
+    sent = []
+    with_memory_cache do
+      Telegram::Chat::Session.start(player.telegram_chat_id.to_s, game)
+
+      stub_singleton(SendTelegramNotificationJob, :perform_later, ->(chat_id, text) { sent << [ chat_id, text ] }) do
+        ResetParticipationsJob.perform_now
+      end
+
+      # Указатель гасим тут же: писать этому составу человек больше не вправе.
+      assert_nil Telegram::Chat::Session.active_game(player.telegram_chat_id.to_s, player)
+    end
+
+    assert_equal [ player.telegram_chat_id.to_s ], sent.map(&:first)
+    assert_match "закрыт", sent.first.last
+    assert_no_match(/translation missing/i, sent.first.last)
+  end
+
+  # Организатор из состава не выпадает — ему закрывать нечего.
+  test "leaves the organiser alone" do
+    @owner.update_column(:telegram_chat_id, 910_100_002)
+    game = Game.create!(
+      court: courts(:one), user: @owner, date: Date.current - 14.days, time: "18:00", recurring: true
+    )
+
+    sent = []
+    with_memory_cache do
+      stub_singleton(SendTelegramNotificationJob, :perform_later, ->(chat_id, text) { sent << [ chat_id, text ] }) do
+        ResetParticipationsJob.perform_now
+      end
+    end
+
+    assert_not_includes sent.map(&:first), @owner.telegram_chat_id.to_s
+  end
 end