2fee79e1f5
:discard marks jobs as "discarded", i.e. jobs which permanently failed
due to e.g. exhausting all retries or explicitly being discared due to a
fatal error.
:cancel marks jobs as "cancelled" which does not imply failure.
While neither method counts as a job "exception" in the set of
telemetries we currently export via Prometheus, the different state
is visible in the (not-exported) metadata of oban job telemetry.
We can use handlers of those events to build bespoke statistics.
Ideally we'd like to distinguish in the receiver worker between
"invalid" and "already present or delete of unknown" documents,
but this is cumbersome to get get right with a list of
free-form, human-readable descriptions oof the violated constraints.
For now, just count both as an fatal error.
# but that is cumbersome to get right with a list of string error descriptions
69 lines
2 KiB
Elixir
69 lines
2 KiB
Elixir
# Pleroma: A lightweight social networking server
|
|
# Copyright © 2017-2023 Pleroma Authors <https://pleroma.social/>
|
|
# SPDX-License-Identifier: AGPL-3.0-only
|
|
|
|
defmodule Pleroma.Workers.RemoteFetcherWorkerTest do
|
|
use Pleroma.DataCase
|
|
use Oban.Testing, repo: Pleroma.Repo
|
|
|
|
alias Pleroma.Workers.RemoteFetcherWorker
|
|
|
|
@deleted_object_one "https://deleted-404.example.com/"
|
|
@deleted_object_two "https://deleted-410.example.com/"
|
|
@unauthorized_object "https://unauthorized.example.com/"
|
|
@depth_object "https://depth.example.com/"
|
|
|
|
describe "RemoteFetcherWorker" do
|
|
setup do
|
|
Tesla.Mock.mock(fn
|
|
%{method: :get, url: @deleted_object_one} ->
|
|
%Tesla.Env{
|
|
status: 404
|
|
}
|
|
|
|
%{method: :get, url: @deleted_object_two} ->
|
|
%Tesla.Env{
|
|
status: 410
|
|
}
|
|
|
|
%{method: :get, url: @unauthorized_object} ->
|
|
%Tesla.Env{
|
|
status: 403
|
|
}
|
|
|
|
%{method: :get, url: @depth_object} ->
|
|
%Tesla.Env{
|
|
status: 200
|
|
}
|
|
end)
|
|
end
|
|
|
|
test "does not requeue a deleted object" do
|
|
assert {:cancel, _} =
|
|
RemoteFetcherWorker.perform(%Oban.Job{
|
|
args: %{"op" => "fetch_remote", "id" => @deleted_object_one}
|
|
})
|
|
|
|
assert {:cancel, _} =
|
|
RemoteFetcherWorker.perform(%Oban.Job{
|
|
args: %{"op" => "fetch_remote", "id" => @deleted_object_two}
|
|
})
|
|
end
|
|
|
|
test "does not requeue an unauthorized object" do
|
|
assert {:cancel, _} =
|
|
RemoteFetcherWorker.perform(%Oban.Job{
|
|
args: %{"op" => "fetch_remote", "id" => @unauthorized_object}
|
|
})
|
|
end
|
|
|
|
test "does not requeue an object that exceeded depth" do
|
|
clear_config([:instance, :federation_incoming_replies_max_depth], 0)
|
|
|
|
assert {:cancel, _} =
|
|
RemoteFetcherWorker.perform(%Oban.Job{
|
|
args: %{"op" => "fetch_remote", "id" => @depth_object, "depth" => 1}
|
|
})
|
|
end
|
|
end
|
|
end
|