ruby-on-rails - 使用 Hotwire Rails 广播到用户的 Turbo Stream

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 的 channel 名称。因此，所有订阅视频通话的用户只会收到更新，而不是所有人。