debugging this problem

catmando · catmando · commit 47b2ae2d02c5 · 2019-06-23T08:57:02.000-04:00
diff --git a/ruby/hyper-model/lib/active_record_base.rb b/ruby/hyper-model/lib/active_record_base.rb
@@ -291,6 +291,7 @@ def do_not_synchronize?
       after_commit :synchromesh_after_destroy, on: [:destroy]
 
       def synchromesh_after_create
+        puts "synchromesh_after_create: #{do_not_synchronize?} channels: #{Hyperstack::Connection.active}" if Hyperstack::Connection.show_diagnostics
         return if do_not_synchronize?
         ReactiveRecord::Broadcast.after_commit :create, self
       end
diff --git a/ruby/hyper-model/lib/reactive_record/broadcast.rb b/ruby/hyper-model/lib/reactive_record/broadcast.rb
@@ -6,6 +6,8 @@ def self.after_commit(operation, model)
       # before the first broadcast.
       @public_columns_hash ||= ActiveRecord::Base.public_columns_hash
       Hyperstack::InternalPolicy.regulate_broadcast(model) do |data|
+        puts "Broadcast aftercommit hook: #{data}" if Hyperstack::Connection.show_diagnostics
+
         if !Hyperstack.on_server? && Hyperstack::Connection.root_path
           send_to_server(operation, data) rescue nil # fails if server no longer running so ignore
         else
diff --git a/ruby/hyper-model/spec/batch7/poly_assoc_spec.rb b/ruby/hyper-model/spec/batch7/poly_assoc_spec.rb
@@ -301,7 +301,9 @@ class Testing123 < HyperComponent
     end
 
     it 'creates due to a broadcast client side' do
-      wait_for_ajax # so pusher can initialize
+      Hyperstack::Connection.show_diagnostics = true
+      # wait_for_ajax # so pusher can initialize
+      # sleep 1
       @uzer1.groups << @group1
       compare_to_server @group1, 'uzers.collect(&:id)', [@uzer1.id], false
     end
diff --git a/ruby/hyper-operation/lib/hyper-operation/transport/connection.rb b/ruby/hyper-operation/lib/hyper-operation/transport/connection.rb
@@ -100,6 +100,7 @@ def transport
 
     class << self
       attr_accessor :transport
+      attr_accessor :show_diagnostics
 
       def active
         # if table doesn't exist then we are either calling from within
@@ -114,8 +115,9 @@ def active
       end
 
       def open(channel, session = nil, root_path = nil)
+        puts "open(#{channel}, #{session}, #{root_path})" if show_diagnostics
         self.root_path = root_path
-        find_or_create_by(channel: channel, session: session)
+        find_or_create_by(channel: channel, session: session).tap { |c| puts " - open returning #{c}" if show_diagnostics}
       end
 
       def send_to_channel(channel, data)
@@ -133,6 +135,7 @@ def read(session, root_path)
       end
 
       def connect_to_transport(channel, session, root_path)
+        puts "connect_to_transport(#{channel}, #{session}, #{root_path})" if show_diagnostics
         self.root_path = root_path
         if (connection = find_by(channel: channel, session: session))
           messages = connection.messages.pluck(:data)
