All InMemoryEventStore have the same configuration.

Author: dysk

notifications/lib/notifications/slack_notifier.rb

@@ -50,22 +50,15 @@ def maybe_notify_remaining_players(event)
     end
 
     def notify_about_timer_reset(event)
-      puts "=== NOTIFY_ABOUT_TIMER_RESET DEBUG ==="
       game = ReadModel::GameReadModel.find_by(id: event.data[:game_id])
-      puts "Game found: #{!!game}"
-      puts "Game slack_token present: #{game&.slack_token&.present?}"
       return unless game && game.slack_token
       player_id = game.registered_slots&.dig(event.data[:slot])
-      puts "Player ID from registered_slots: #{player_id}"
       player = Player.find_by(id: player_id) if player_id
-      puts "Player found: #{!!player}"
-      puts "About to call CustomSlackClient.post_message"
       CustomSlackClient.post_message(
         channel: game.slack_channel,
         text: game.build_slack_timer_reset_message(event.data, player),
         token: game.slack_token
       )
-      puts "CustomSlackClient.post_message called successfully"
     end
 
     attr_reader :logger, :event_store

notifications/spec/notifications/slack_notifier_spec.rb

@@ -184,16 +184,6 @@ def given(*domain_events)
       )
 
       timer_reset_event = Game::TimerReset.new(data: {slot: 1, game_id: game_id})
-
-      # Debug: Check if event_store has subscribers
-      puts "=== EVENT STORE DEBUG ==="
-      puts "Event store class: #{event_store.class}"
-      puts "Event store repository: #{event_store.instance_variable_get(:@repository).class}"
-      puts "Event store same as Rails: #{event_store.object_id == Rails.configuration.event_store.object_id}"
-      puts "InMemoryEventStore included: #{self.class.included_modules.include?(InMemoryEventStore)}"
-      puts "Method source: #{method(:event_store).source_location}"
-      puts "=========================="
-
       event_store.publish(timer_reset_event, stream_name: game_id)
       expect(stub).to have_been_requested
     end

notifications/spec/spec_helper.rb

@@ -15,22 +15,14 @@ def event_store
       RailsEventStore::Client
         .new(repository: RailsEventStore::InMemoryRepository.new)
         .tap do |client|
-          puts "=== SUBSCRIBING TO InMemoryEventStore ==="
           client.subscribe(
-            ->(event) {
-              puts "SlackNotifier subscriber called for #{event.class}"
-              Notifications::SlackNotifier.new(logger: Rails.logger, event_store: client).call(event)
-            },
+            ->(event) { Notifications::SlackNotifier.new(logger: Rails.logger, event_store: client).call(event) },
             to:  [Game::NewTurnStarted, Game::PlayerDisconnected, Game::TimerReset]
           )
           client.subscribe(
-            ->(event) {
-              puts "GameReadModelUpdater subscriber called for #{event.class}"
-              ReadModel::GameReadModelUpdater.new(logger: Rails.logger).call(event)
-            },
+            ->(event) { ReadModel::GameReadModelUpdater.new(logger: Rails.logger).call(event) },
             to: [Game::PlayerRegistered]
           )
-          puts "=== SUBSCRIPTIONS COMPLETE ==="
         end
   end
 end

stats/spec/spec_helper.rb

@@ -20,7 +20,11 @@ def event_store
         )
         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]
+        )
+        client.subscribe(
+          ->(event) { ReadModel::GameReadModelUpdater.new(logger: Rails.logger).call(event) },
+          to: [Game::PlayerRegistered]
         )
       end
   end