move whisper logic to subscriptions

anycable · Jul 2, 2024 · 7f2a1d6 · 7f2a1d6
1 parent e1e1f4e
commit 7f2a1d6
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 7 deletions.
diff --git a/lib/anycable/rails/action_cable_ext/channel.rb b/lib/anycable/rails/action_cable_ext/channel.rb
@@ -55,12 +55,6 @@ def stop_all_streams
     connection.anycable_socket.unsubscribe_from_all identifier
   end
 
-  def whisper(payload)
-    return unless whisper_stream
-
-    broadcast_to whisper_stream, payload
-  end
-
   private
 
   def anycabled?

diff --git a/lib/anycable/rails/action_cable_ext/whisper_stream.rb b/lib/anycable/rails/action_cable_ext/whisper_stream.rb
@@ -10,6 +10,9 @@ def execute_command(data)
   end
 
   def whisper(data)
-    find(data).whisper(ActiveSupport::JSON.decode(data["data"]))
+    subscription = find(data)
+    if subscription.whisper_stream
+      connection.anycable_socket.whisper data["identifier"], subscription.whisper_stream
+    end
   end
 end)