mirror of
https://github.com/discourse/discourse.git
synced 2025-03-20 21:05:53 +08:00
DEV: Fix MessageBus::InvalidMessageTarget
error after upgrading mb.
Follow-up to c2f2b57a9bbd9fdef74d1bde7a71de1abbcc08c5
This commit is contained in:
parent
c2f2b57a9b
commit
f7438fc64b
@ -368,8 +368,22 @@ class Category < ActiveRecord::Base
|
||||
end
|
||||
|
||||
def publish_category
|
||||
group_ids = self.groups.pluck(:id) if self.read_restricted
|
||||
MessageBus.publish('/categories', { categories: ActiveModel::ArraySerializer.new([self]).as_json }, group_ids: group_ids)
|
||||
if self.read_restricted
|
||||
group_ids = self.groups.pluck(:id)
|
||||
|
||||
if group_ids.present?
|
||||
MessageBus.publish(
|
||||
'/categories',
|
||||
{ categories: ActiveModel::ArraySerializer.new([self]).as_json },
|
||||
group_ids: group_ids
|
||||
)
|
||||
end
|
||||
else
|
||||
MessageBus.publish(
|
||||
'/categories',
|
||||
{ categories: ActiveModel::ArraySerializer.new([self]).as_json }
|
||||
)
|
||||
end
|
||||
end
|
||||
|
||||
def remove_site_settings
|
||||
|
@ -218,7 +218,9 @@ class Post < ActiveRecord::Base
|
||||
.pluck(:id)
|
||||
end
|
||||
|
||||
MessageBus.publish(channel, message, opts)
|
||||
if opts[:user_ids] != [] && opts[:group_ids] != []
|
||||
MessageBus.publish(channel, message, opts)
|
||||
end
|
||||
end
|
||||
|
||||
def trash!(trashed_by = nil)
|
||||
|
Loading…
x
Reference in New Issue
Block a user