git.squeep.com Git - akkoma/blob - lib/pleroma/workers/subscriber.ex

   1 # Pleroma: A lightweight social networking server
   2 # Copyright © 2017-2019 Pleroma Authors <https://pleroma.social/>
   3 # SPDX-License-Identifier: AGPL-3.0-only
   4
   5 defmodule Pleroma.Workers.Subscriber do
   6   alias Pleroma.Repo
   7   alias Pleroma.Web.Federator
   8   alias Pleroma.Web.Websub
   9
  10   # Note: `max_attempts` is intended to be overridden in `new/1` call
  11   use Oban.Worker,
  12     queue: "federator_outgoing",
  13     max_attempts: 1
  14
  15   @impl Oban.Worker
  16   def perform(%{"op" => "refresh_subscriptions"}, _job) do
  17     Federator.perform(:refresh_subscriptions)
  18   end
  19
  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)
  23   end
  24
  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)
  28   end
  29 end