Debug ES configuration.

Author: dysk

notifications/spec/notifications/slack_notifier_spec.rb

@@ -184,6 +184,14 @@ 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 has subscribers: #{event_store.respond_to?(:subscribers) ? event_store.subscribers.any? : 'unknown'}"
+      puts "=========================="
+
       event_store.publish(timer_reset_event, stream_name: game_id)
       expect(stub).to have_been_requested
     end

notifications/spec/spec_helper.rb

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