nocebo/diaspora
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Fix condition for queuing job

Browse source
This commit is contained in:
Raphael Sofaer 2011-03-17 14:12:33 -07:00
parent 1de52d3ba2
commit 5a1d8d091a
1 changed files with 11 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
lib/postzord/dispatch.rb
View file

@ -45,6 +45,17 @@ class Postzord::Dispatch
def deliver_to_local(people)
return if people.blank?
if @object.is_a?(Post)
batch_deliver_to_local(people)
else
people.each do |person|
Rails.logger.info("event=push route=local sender=#{@sender_person.diaspora_handle} recipient=#{person.diaspora_handle} payload_type=#{@object.class}")
Resque.enqueue(Job::Receive, person.owner_id, @xml, @sender_person.id)
end
end
end
def batch_deliver_to_local(people)
ids = people.map{ |p| p.owner_id }
Resque.enqueue(Job::ReceiveLocalBatch, @object.id, ids)
Rails.logger.info("event=push route=local sender=#{@sender_person.diaspora_handle} recipients=#{ids.join(',')} payload_type=#{@object.class}")