1 # Pleroma: A lightweight social networking server
2 # Copyright © 2019 Pleroma Authors <https://pleroma.social/>
3 # SPDX-License-Identifier: AGPL-3.0-only
5 defmodule Pleroma.ActivityExpirationWorker do
7 alias Pleroma.ActivityExpiration
11 alias Pleroma.Web.CommonAPI
16 @schedule_interval :timer.minutes(1)
19 GenServer.start_link(__MODULE__, nil)
24 if Config.get([ActivityExpiration, :enabled]) do
32 def perform(:execute, expiration_id) do
36 |> where([e], e.id == ^expiration_id)
39 activity = Activity.get_by_id_with_object(expiration.activity_id)
40 user = User.get_by_ap_id(activity.object.data["actor"])
41 CommonAPI.delete(activity.id, user)
44 Logger.error("#{__MODULE__} Couldn't delete expired activity: #{inspect(error)}")
49 def handle_info(:perform, state) do
50 ActivityExpiration.due_expirations(@schedule_interval)
51 |> Enum.each(fn expiration ->
52 PleromaJobQueue.enqueue(:activity_expiration, __MODULE__, [:execute, expiration.id])
60 Process.send_after(self(), :perform, @schedule_interval)