Add support for TimerReset.

Author: dysk

app/models/pitboss_entry.rb

@@ -30,6 +30,11 @@ def entry_to_domain_event
         Game::PlayerDisconnected.new(data: { slot: value.to_i, game_id: game_name }),
         stream_name: "Game$#{game_name}"
       )
+    when "TimerReset"
+      event_store.publish(
+        Game::TimerReset.new(data: { slot: value.to_i, game_id: game_name }),
+        stream_name: "Game$#{game_name}"
+      )
     end
   end
 end

app/models/read_model/game_read_model.rb

@@ -20,6 +20,10 @@ 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"
+    end
+
     def turn
       current_turn[:number]
     end

config/initializers/rails_event_store.rb

@@ -7,7 +7,7 @@
           .new(logger: Rails.logger, event_store: Rails.configuration.event_store)
           .call(event)
       end,
-      to: [Game::NewTurnStarted, Game::PlayerDisconnected]
+      to: [Game::NewTurnStarted, Game::PlayerDisconnected, Game::TimerReset]
     )
     client.subscribe(
       -> (event) do

game/lib/game.rb

@@ -10,6 +10,7 @@ module Game
   PlayerRegistered = Class.new(DomainEvent)
   PlayerUnregistered = Class.new(DomainEvent)
   PlayerSlotfhulnessIncreased = Class.new(DomainEvent)
+  TimerReset = Class.new(DomainEvent)
 
   HostGame = Struct.new(:game_id, :turn_timer)
   RegisterPlayer = Struct.new(:game_id, :player_id, :slot_id)

game/lib/game/current_turn.rb

@@ -20,6 +20,7 @@ def call(stream_name)
         .when(PlayerEndedTurn, method(:handle_player_ended_turn))
         .when(PlayerEndTurnCancelled, method(:handle_player_end_turn_cancelled))
         .when(PlayerConnected, method(:handle_player_end_turn_cancelled))
+        .when(TimerReset, method(:handle_timer_reset))
         .run(@event_store, count: 10_000)
       Result.new(state[:turn], state[:unfinished_player_ids], state[:ends_at])
     end
@@ -67,5 +68,11 @@ def handle_game_hosted(state, event)
       state[:turn_timer] = event.data.fetch(:turn_timer)
       state
     end
+
+    def handle_timer_reset(state, event)
+      reset_at = event.metadata.fetch(:timestamp)
+      state[:ends_at] = reset_at + state[:turn_timer]
+      state
+    end
   end
 end

game/lib/game/game.rb

@@ -45,5 +45,8 @@ def apply_player_connected(_event)
 
     def apply_player_disconnected(_event)
     end
+
+    def apply_reset_timer(_event)
+    end
   end
 end

game/spec/game/current_turn_spec.rb

@@ -158,12 +158,23 @@ def player_3
         NewTurnStarted.new(data: {turn: 1}),
         PlayerEndedTurn.new(data: {slot: 2}),
         PlayerEndedTurn.new(data: {slot: 2}),
-        PlayerUnregistered.new(data: {slot_id: 3, player_id: player_3})
+        PlayerUnregistered.new(data: {slot: 3, player_id: player_3})
       )
       current_turn = CurrentTurn.new(event_store).call(game_id)
 
       expect(current_turn.turn).to eq(1)
       expect(current_turn.unfinished_player_ids).to eq([player_1])
     end
+
+    specify("timer reset") do
+      given(
+        GameHosted.new(data: {turn_timer: 24.hours.to_i}),
+        NewTurnStarted.new(data: {turn: 1}, metadata: {timestamp: Time.at(0).utc}),
+        TimerReset.new(data: {slot: 1}, metadata: {timestamp: Time.at(24.hours).utc})
+      )
+      current_turn = CurrentTurn.new(event_store).call(game_id)
+
+      expect(current_turn.ends_at).to eq(Time.at(48.hours).utc)
+    end
   end
 end

logs_parser/lib/logs_parser.rb

@@ -29,6 +29,9 @@ def call(line)
         elsif player_disconnected?(line)
           player_number = line.scan(/\d/)[-1]
           return Result.new(game_name, "PlayerDisconnected", player_number, timestamp)
+        elsif timer_reset?(line)
+          player_number = line.scan(/\d/)[-3]
+          return Result.new(game_name, "TimerReset", player_number, timestamp)
         end
       end
     end
@@ -39,7 +42,7 @@ def call(line)
 
     def contains_relevant_data?(line)
       line.match(/DBG: Game Turn/) || line.match(/:NetTurnComplete/) || line.match(/NetTurnUnready/) ||
-        line.match(/NetPlayerReady/) || line.match(/ConnectionClosed Player\(\d\)/)
+        line.match(/NetPlayerReady/) || line.match(/ConnectionClosed Player\(\d\)/) || line.match(/:NetGiftUnit.+UnitID=-1/)
     end
 
     def split_log_line(line)
@@ -67,6 +70,10 @@ def player_connected?(line)
     def player_disconnected?(line)
       line.match(/ConnectionClosed/)
     end
+
+    def timer_reset?(line)
+      line.match(/:NetGiftUnit.+UnitID=-1/)
+    end
   end
 
   class HttpAdapter

logs_parser/spec/service_spec.rb

@@ -79,6 +79,12 @@
     expect(result).to be_nil
   end
 
+  specify "player player connected happy path" do
+    parser = LogsParser::Service.new("arkency_test", 6)
+    result = parser.call("[3540015.559] Net RECV (1) :NetGiftUnit(Player=1, Minor=-1, UnitID=-1)\n")
+    expect_result(result, game_name: "arkency_test", entry_type: "TimerReset", data: "1", timestamp: "3540015.559")
+  end
+
   private
 
   def expect_result(result, game_name:, entry_type:, data:, timestamp:)

spec/domain_events_from_entries_spec.rb

@@ -46,4 +46,10 @@ def event_store
 
     expect(event_store).not_to(have_published(an_event(Game::PlayerDisconnected)))
   end
+
+  specify("TimerReset") do
+    PitbossEntry.create(timestamp: 0, value: 5, entry_type: "TimerReset", game_name: "dummy")
+
+    expect(event_store).to(have_published(an_event(Game::TimerReset).with_data(slot: 5, game_id: "dummy")))
+  end
 end