small hack untill we can figure out more batching
This commit is contained in:
parent
ce199e770d
commit
91d940376f
1 changed files with 9 additions and 1 deletions
|
|
@ -139,7 +139,15 @@ class Postzord::Dispatcher
|
||||||
# @param services [Array<User>]
|
# @param services [Array<User>]
|
||||||
def notify_users(users)
|
def notify_users(users)
|
||||||
return unless users.present? && @object.respond_to?(:persisted?)
|
return unless users.present? && @object.respond_to?(:persisted?)
|
||||||
Resque.enqueue(Jobs::NotifyLocalUsers, users.map{|u| u.id}, @object.class.to_s, @object.id, @object.author.id)
|
|
||||||
|
#temp hax
|
||||||
|
unless object_is_related_to_diaspora_hq?
|
||||||
|
Resque.enqueue(Jobs::NotifyLocalUsers, users.map{|u| u.id}, @object.class.to_s, @object.id, @object.author.id)
|
||||||
|
end
|
||||||
|
end
|
||||||
|
|
||||||
|
def object_is_related_to_diaspora_hq?
|
||||||
|
(@object.author.diaspora_handle == 'diasporahq@joindiaspora.com' || (@object.respond_to?(:relayable?) && @object.parent.author.diaspora_handle == 'diasporahq@joindiaspora.com'))
|
||||||
end
|
end
|
||||||
|
|
||||||
# @param services [Array<User>]
|
# @param services [Array<User>]
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue