使用 Hotwire Rails 广播到用户的 Turbo 流

Question

我想在 Rails 中使用 Hotwire 流式传输模型更新。在文档中，他们提到使用模型创建流，但我想为每个用户创建一个动态流，以便用户对模型所做的更改仅流向该用户。

我有一个 VideoCall 模型，它通过一个连接表拥有并属于许多用户，所以模型看起来像这样，我有这样的广播

class VideoCall < ApplicationRecord
  has_and_belongs_to_many :users

  broadcasts_to ->(video_call) {
    video_call.users.map{|u| "video_calls:user_#{u.id}"}
  }, inserts_by: :prepend

  # more code here
end

在我想要获取已添加模型更新的 ERB 模板上

<%= turbo_stream_from "video_calls:user_#{current_user.id}" %>

如果我在 users_video_calls 表中有一个用户，则此方法有效。但是，一旦 video_call 中有多个用户，它就不起作用，我想向所有这些用户的流进行广播。

我采用的方法是否正确，如何实现向多个用户流的动态广播。

Answer 1

所以我通过以下方式解决了这个问题。查看源代码，我意识到重写在创建、更新和销毁时调用的三个回调是有意义的。所以我删除了这段代码

  broadcasts_to ->(video_call) {
    video_call.users.map{|u| "video_calls:user_#{u.id}"}
  }, inserts_by: :prepend

并用这个替换它

  after_create_commit  -> {
    self.users.each do |u|
      broadcast_action_later_to "video_calls:users_#{u.id}", action: :prepend, target: broadcast_target_default
    end
  }

  after_update_commit  -> {
    self.users.each do |u|
      broadcast_replace_later_to "video_calls:users_#{u.id}"
    end
  }

  after_destroy_commit -> {
    self.users.each do |u|
      broadcast_remove_to "video_calls:users_#{u.id}", action: :prepend, target: broadcast_target_default
    end
  }

现在在上面的代码中，我可以遍历每个关联模型，在我的例子中，每个视频通话有很多用户，并广播到包含用户 ID 的频道名称。所以订阅视频通话的所有用户都只会收到更新，而不是所有人。