diff options
author | Haelwenn <contact+git.pleroma.social@hacktivis.me> | 2022-08-12 01:37:40 +0000 |
---|---|---|
committer | Haelwenn <contact+git.pleroma.social@hacktivis.me> | 2022-08-12 01:37:40 +0000 |
commit | 06f9324afeef813dbd299926000cb21076d5f41c (patch) | |
tree | 021a2b8c4a48613215eb724a14642712bdf47982 /lib/pleroma | |
parent | 837d4dc87f502c044414e4155c5401c13008047e (diff) | |
parent | d487e0160cdc4cdf84c45e4c64f6589b317479cc (diff) | |
download | pleroma-06f9324afeef813dbd299926000cb21076d5f41c.tar.gz |
Merge branch 'from/upstream-develop/tusooa/2912-receiver-reject-mrf' into 'develop'
Treat MRF rejects as success in Oban worker
Closes #2912
See merge request pleroma/pleroma!3720
Diffstat (limited to 'lib/pleroma')
-rw-r--r-- | lib/pleroma/workers/receiver_worker.ex | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/lib/pleroma/workers/receiver_worker.ex b/lib/pleroma/workers/receiver_worker.ex index 268b5f30f..c41b44e14 100644 --- a/lib/pleroma/workers/receiver_worker.ex +++ b/lib/pleroma/workers/receiver_worker.ex @@ -9,6 +9,12 @@ defmodule Pleroma.Workers.ReceiverWorker do @impl Oban.Worker def perform(%Job{args: %{"op" => "incoming_ap_doc", "params" => params}}) do - Federator.perform(:incoming_ap_doc, params) + with {:ok, res} <- Federator.perform(:incoming_ap_doc, params) do + {:ok, res} + else + {:error, :origin_containment_failed} -> {:cancel, :origin_containment_failed} + {:error, {:reject, reason}} -> {:cancel, reason} + e -> e + end end end |