1 # Pleroma: A lightweight social networking server
2 # Copyright © 2017-2019 Pleroma Authors <https://pleroma.social/>
3 # SPDX-License-Identifier: AGPL-3.0-only
5 defmodule Pleroma.Workers.SubscriberWorker do
7 alias Pleroma.Web.Federator
8 alias Pleroma.Web.Websub
10 # Note: `max_attempts` is intended to be overridden in `new/2` call
12 queue: "federator_outgoing",
16 def perform(%{"op" => "refresh_subscriptions"}, _job) do
17 Federator.perform(:refresh_subscriptions)
20 def perform(%{"op" => "request_subscription", "websub_id" => websub_id}, _job) do
21 websub = Repo.get(Websub.WebsubClientSubscription, websub_id)
22 Federator.perform(:request_subscription, websub)
25 def perform(%{"op" => "verify_websub", "websub_id" => websub_id}, _job) do
26 websub = Repo.get(Websub.WebsubServerSubscription, websub_id)
27 Federator.perform(:verify_websub, websub)