问题描述
我想在 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
<%= turbo_stream_from "video_calls:user_#{current_user.id}" %>
如果我在 users_video_calls 表中有一个用户,这会起作用。但是一旦 video_call 中有多个用户,它就不起作用,我想广播到所有这些用户的流中。
解决方法
所以我通过以下方式解决了这个问题。查看源代码,我意识到覆盖在创建、更新和销毁时调用的三个回调是有意义的。所以我删除了这段代码
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}",target: broadcast_target_default
end
}
在上面的代码中,现在我可以遍历每个关联的模型,在我的例子中,每个视频通话都有很多用户,并广播到包含用户 ID 的频道名称。因此,所有订阅视频通话的用户只会收到更新,而不是所有人。