Send slack notification on TimerReset.

Author: dysk

app/models/read_model/game_read_model.rb

@@ -20,8 +20,9 @@ def build_slack_new_turn_message(event_data)
 steam://run/8930/q/%2Bconnect%20#{ip_address}"
     end
 
-    def build_slack_timer_reset_message(event_data)
-      "The turn timer for game #{name} has been reset"
+    def build_slack_timer_reset_message(event_data, player = nil)
+      player_name = player&.slack_name || "Unknown player"
+      "The turn timer for game #{name} has been reset by #{player_name}"
     end
 
     def turn

notifications/lib/notifications/slack_notifier.rb

@@ -13,6 +13,8 @@ def call(event)
         new_turn_notification(event)
       when Game::PlayerDisconnected
         maybe_notify_remaining_players(event)
+      when Game::TimerReset
+        notify_about_timer_reset(event)
       end
     rescue => e
       error_message = "Error in Notifications::SlackNotifier: #{e.inspect}"
@@ -47,6 +49,18 @@ def maybe_notify_remaining_players(event)
       end
     end
 
+    def notify_about_timer_reset(event)
+      game = ReadModel::GameReadModel.find_by(id: event.data[:game_id])
+      return unless game && game.slack_token
+      player_id = game.registered_slots&.dig(event.data[:slot])
+      player = Player.find(player_id) if player_id
+      CustomSlackClient.post_message(
+        channel: game.slack_channel,
+        text: game.build_slack_timer_reset_message(event.data, player),
+        token: game.slack_token
+      )
+    end
+
     attr_reader :logger, :event_store
   end
 end

notifications/spec/notifications/slack_notifier_spec.rb

@@ -33,7 +33,8 @@ def game_read_model
         id: game_id,
         slack_token: game_slack_token,
         slack_channel: game_slack_channel,
-        ip_address: game_ip_address
+        ip_address: game_ip_address,
+        name: "Arkency 135"
       )
     end
 
@@ -48,7 +49,7 @@ def given(*domain_events)
         .with(
           body: {
             "channel" => "#arkency58",
-            "text" => "Game  Turn 1 <!channel>\nsteam://run/8930/q/%2Bconnect%2010.4.0.28"
+            "text" => "Game Arkency 135 Turn 1 <!channel>\nsteam://run/8930/q/%2Bconnect%2010.4.0.28"
           },
           headers: {
             "Authorization" => "Bearer xoxb-302139800755-nR1O848GLyVS5ZfNNMpBLm0b",
@@ -153,5 +154,36 @@ def given(*domain_events)
       expect(stub0).to have_been_requested
       expect(stub1).to have_been_requested
     end
+
+    specify("timer reset notification") do
+      player_1 = Player.create!(steam_name: "some_player", slack_name: "slack_user")
+      game = game_read_model
+      game.update!(registered_slots: { 1 => player_1.id })
+
+      stub = stub_request(:post, "https://slack.com/api/chat.postMessage")
+        .with(
+          body: {
+            "channel" => "#arkency58",
+            "text" => "The turn timer for game Arkency 135 has been reset by slack_user"
+          },
+          headers: {
+            "Authorization" => "Bearer xoxb-302139800755-nR1O848GLyVS5ZfNNMpBLm0b",
+            "Accept" => "application/json; charset=utf-8",
+            "Accept-Encoding" => "gzip;q=1.0,deflate;q=0.6,identity;q=0.3",
+            "Content-Type" => "application/json"
+          }
+        )
+        .to_return(status: 200, body: {ok: true}.to_json, headers: {})
+
+      given(
+        Game::GameHosted.new(data: {turn_timer: 24.hours.to_i, game_id: game_id}),
+        Game::PlayerRegistered.new(data: {slot_id: 1, player_id: player_1.id}),
+        Game::PlayerRegistered.new(data: {slot_id: 2, player_id: player_2}),
+        Game::PlayerRegistered.new(data: {slot_id: 3, player_id: player_3}),
+        Game::NewTurnStarted.new(data: {turn: 1}),
+        Game::TimerReset.new(data: {slot: 1, game_id: game_id}),
+      )
+      expect(stub).to have_been_requested
+    end
   end
 end

notifications/spec/spec_helper.rb

@@ -17,7 +17,7 @@ def event_store
         .tap do |client|
           client.subscribe(
             ->(event) { Notifications::SlackNotifier.new(logger: Rails.logger, event_store: client).call(event) },
-            to:  [Game::NewTurnStarted, Game::PlayerDisconnected]
+            to:  [Game::NewTurnStarted, Game::PlayerDisconnected, Game::TimerReset]
           )
         end
   end