aboutsummaryrefslogtreecommitdiff
path: root/lib/pleroma/workers/remote_fetcher_worker.ex
diff options
context:
space:
mode:
Diffstat (limited to 'lib/pleroma/workers/remote_fetcher_worker.ex')
-rw-r--r--lib/pleroma/workers/remote_fetcher_worker.ex17
1 files changed, 17 insertions, 0 deletions
diff --git a/lib/pleroma/workers/remote_fetcher_worker.ex b/lib/pleroma/workers/remote_fetcher_worker.ex
new file mode 100644
index 0000000..d2a77aa
--- /dev/null
+++ b/lib/pleroma/workers/remote_fetcher_worker.ex
@@ -0,0 +1,17 @@
+# Pleroma: A lightweight social networking server
+# Copyright © 2017-2022 Pleroma Authors <https://pleroma.social/>
+# SPDX-License-Identifier: AGPL-3.0-only
+
+defmodule Pleroma.Workers.RemoteFetcherWorker do
+ alias Pleroma.Object.Fetcher
+
+ use Pleroma.Workers.WorkerHelper, queue: "remote_fetcher"
+
+ @impl Oban.Worker
+ def perform(%Job{args: %{"op" => "fetch_remote", "id" => id} = args}) do
+ {:ok, _object} = Fetcher.fetch_object_from_id(id, depth: args["depth"])
+ end
+
+ @impl Oban.Worker
+ def timeout(_job), do: :timer.seconds(10)
+end