git.squeep.com Git - akkoma/blob - lib/pleroma/workers/cron/purge_expired_activities_worker.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.Cron.PurgeExpiredActivitiesWorker do
   6   @moduledoc """
   7   The worker to purge expired activities.
   8   """
   9
  10   use Oban.Worker, queue: "activity_expiration"
  11
  12   alias Pleroma.Activity
  13   alias Pleroma.ActivityExpiration
  14   alias Pleroma.Config
  15   alias Pleroma.User
  16   alias Pleroma.Web.CommonAPI
  17
  18   require Logger
  19
  20   @interval :timer.minutes(1)
  21
  22   @impl Oban.Worker
  23   def perform(_opts, _job) do
  24     if Config.get([ActivityExpiration, :enabled]) do
  25       Enum.each(ActivityExpiration.due_expirations(@interval), &delete_activity/1)
  26     end
  27   end
  28
  29   def delete_activity(%ActivityExpiration{activity_id: activity_id}) do
  30     with {:activity, %Activity{} = activity} <-
  31            {:activity, Activity.get_by_id_with_object(activity_id)},
  32          {:user, %User{} = user} <- {:user, User.get_by_ap_id(activity.object.data["actor"])} do
  33       CommonAPI.delete(activity.id, user)
  34     else
  35       {:activity, _} ->
  36         Logger.error(
  37           "#{__MODULE__} Couldn't delete expired activity: not found activity ##{activity_id}"
  38         )
  39
  40       {:user, _} ->
  41         Logger.error(
  42           "#{__MODULE__} Couldn't delete expired activity: not found actorof ##{activity_id}"
  43         )
  44     end
  45   end
  46 end