Unverified Commit 2894b8fb authored by Chris Hobbs's avatar Chris Hobbs

Don't use perform_bulk, it doesn't set retry correctly

parent 2d6aad10
Pipeline #178 passed with stage
in 47 seconds
......@@ -78,19 +78,13 @@ class InboxHandler
def handle_forward(actor, request_body)
# TODO: cache the subscriptions
bulk_args = PubRelay.redis.keys("subscription:*").compact_map do |key|
bulk_args = PubRelay.redis.keys("subscription:*").each do |key|
key = key.as(String)
domain = key.lchop("subscription:")
raise "redis bug" if domain == key
if domain == actor.domain
nil
else
{domain, request_body}
end
DeliverWorker.async.perform(domain, request_body) unless domain == actor.domain
end
DeliverWorker.async.perform_bulk(bulk_args)
end
# Verify HTTP signatures according to https://tools.ietf.org/html/draft-cavage-http-signatures-06.
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment