aboutsummaryrefslogtreecommitdiff
path: root/lib/pleroma
diff options
context:
space:
mode:
authorHaelwenn <contact+git.pleroma.social@hacktivis.me>2022-08-12 01:37:40 +0000
committerHaelwenn <contact+git.pleroma.social@hacktivis.me>2022-08-12 01:37:40 +0000
commit06f9324afeef813dbd299926000cb21076d5f41c (patch)
tree021a2b8c4a48613215eb724a14642712bdf47982 /lib/pleroma
parent837d4dc87f502c044414e4155c5401c13008047e (diff)
parentd487e0160cdc4cdf84c45e4c64f6589b317479cc (diff)
downloadpleroma-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.ex8
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