Send salmons and websub in background tasks.
This commit is contained in:
parent
7752f103f6
commit
04f6ece99e
|
@ -150,8 +150,10 @@ def publish(%{info: %{"keys" => keys}} = user, activity, poster) do
|
|||
|
||||
remote_users(activity)
|
||||
|> Enum.each(fn(remote_user) ->
|
||||
Logger.debug(fn -> "sending salmon to #{remote_user.ap_id}" end)
|
||||
send_to_user(remote_user, feed, poster)
|
||||
Task.start(fn ->
|
||||
Logger.debug(fn -> "sending salmon to #{remote_user.ap_id}" end)
|
||||
send_to_user(remote_user, feed, poster)
|
||||
end)
|
||||
end)
|
||||
end
|
||||
end
|
||||
|
|
|
@ -51,10 +51,12 @@ def publish(topic, user, activity) do
|
|||
signature = sign(sub.secret || "", response)
|
||||
Logger.debug(fn -> "Pushing to #{sub.callback}" end)
|
||||
|
||||
@httpoison.post(sub.callback, response, [
|
||||
{"Content-Type", "application/atom+xml"},
|
||||
{"X-Hub-Signature", "sha1=#{signature}"}
|
||||
])
|
||||
Task.start(fn ->
|
||||
@httpoison.post(sub.callback, response, [
|
||||
{"Content-Type", "application/atom+xml"},
|
||||
{"X-Hub-Signature", "sha1=#{signature}"}
|
||||
])
|
||||
end)
|
||||
end)
|
||||
end
|
||||
|
||||
|
|
Loading…
Reference in a new issue