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(expiration) do
  30     try do
  31       activity = Activity.get_by_id_with_object(expiration.activity_id)
  32       user = User.get_by_ap_id(activity.object.data["actor"])
  33       CommonAPI.delete(activity.id, user)
  34     rescue
  35       error ->
  36         Logger.error("#{__MODULE__} Couldn't delete expired activity: #{inspect(error)}")
  37     end
  38   end
  39 end