ActivityPub.Federator.Worker.ReceiverHelpers (Bonfire v1.0.1-social-alpha.28)

Shared helpers for all incoming federation receiver workers.

Provides shared perform/1 and maybe_process_unsigned/2 logic for handling incoming AP docs, including unsigned and unverified cases.

Usage

defmodule ActivityPub.Federator.Workers.ReceiverMentionsWorker do
  use ActivityPub.Federator.Worker, queue: "federator_incoming_mentions"
  @impl Oban.Worker
  def perform(job), do: ActivityPub.Federator.Worker.ReceiverHelpers.perform(job, :mentions)
end

Summary

Functions

maybe_process_unsigned(headers, params)

Handles unsigned or unverified incoming AP docs.

perform(job, type)

Handles incoming AP doc jobs for all receiver queues.

Functions

maybe_process_unsigned(headers, params)

Handles unsigned or unverified incoming AP docs.

perform(job, type)

Handles incoming AP doc jobs for all receiver queues.

The type argument is an atom indicating the queue type: :mentions, :follows, :verified, :unverified, etc.