40 lines
1 KiB
Ruby
40 lines
1 KiB
Ruby
module Jobs
|
|
class HttpMulti
|
|
@queue = :http
|
|
|
|
MAX_RETRIES = 3
|
|
OPTS = {:max_redirects => 3, :timeout => 5000, :method => :post}
|
|
|
|
def self.perform(user_id, object_type, object_id, person_ids, retry_count=0)
|
|
user = User.find(user_id)
|
|
people = Person.all(:id.in => person_ids)
|
|
|
|
object = object_type.constantize.find(object_id)
|
|
salmon = user.salmon(object)
|
|
|
|
failed_request_people = []
|
|
|
|
hydra = Typhoeus::Hydra.new
|
|
people.each do |person|
|
|
|
|
url = person.receive_url
|
|
xml = salmon.xml_for(person)
|
|
|
|
request = Typhoeus::Request.new(url, OPTS.merge(:params => {:xml => xml}))
|
|
|
|
request.on_complete do |response|
|
|
unless response.success?
|
|
failed_request_people << person.id
|
|
end
|
|
end
|
|
|
|
hydra.queue request
|
|
end
|
|
hydra.run
|
|
|
|
unless failed_request_people.empty? || retry_count >= MAX_RETRIES
|
|
Resque.enqueue(Jobs::HttpMulti, user_id, object_type, object_id, failed_request_people, retry_count+=1 )
|
|
end
|
|
end
|
|
end
|
|
end
|