You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
67 lines
1.6 KiB
67 lines
1.6 KiB
5 years ago
|
# Pleroma: A lightweight social networking server
|
||
|
# Copyright © 2019 Pleroma Authors <https://pleroma.social/>
|
||
|
# SPDX-License-Identifier: AGPL-3.0-only
|
||
|
|
||
5 years ago
|
defmodule Pleroma.Daemons.ActivityExpirationDaemon do
|
||
5 years ago
|
alias Pleroma.Activity
|
||
|
alias Pleroma.ActivityExpiration
|
||
|
alias Pleroma.Config
|
||
|
alias Pleroma.Repo
|
||
|
alias Pleroma.User
|
||
|
alias Pleroma.Web.CommonAPI
|
||
5 years ago
|
|
||
5 years ago
|
require Logger
|
||
|
use GenServer
|
||
|
import Ecto.Query
|
||
|
|
||
|
@schedule_interval :timer.minutes(1)
|
||
|
|
||
5 years ago
|
def start_link(_) do
|
||
5 years ago
|
GenServer.start_link(__MODULE__, nil)
|
||
|
end
|
||
|
|
||
|
@impl true
|
||
|
def init(_) do
|
||
|
if Config.get([ActivityExpiration, :enabled]) do
|
||
|
schedule_next()
|
||
|
{:ok, nil}
|
||
|
else
|
||
|
:ignore
|
||
|
end
|
||
|
end
|
||
|
|
||
|
def perform(:execute, expiration_id) do
|
||
|
try do
|
||
|
expiration =
|
||
|
ActivityExpiration
|
||
|
|> where([e], e.id == ^expiration_id)
|
||
|
|> Repo.one!()
|
||
|
|
||
|
activity = Activity.get_by_id_with_object(expiration.activity_id)
|
||
|
user = User.get_by_ap_id(activity.object.data["actor"])
|
||
|
CommonAPI.delete(activity.id, user)
|
||
|
rescue
|
||
|
error ->
|
||
|
Logger.error("#{__MODULE__} Couldn't delete expired activity: #{inspect(error)}")
|
||
|
end
|
||
|
end
|
||
|
|
||
|
@impl true
|
||
|
def handle_info(:perform, state) do
|
||
|
ActivityExpiration.due_expirations(@schedule_interval)
|
||
|
|> Enum.each(fn expiration ->
|
||
5 years ago
|
Pleroma.Workers.ActivityExpirationWorker.enqueue(
|
||
|
"activity_expiration",
|
||
|
%{"activity_expiration_id" => expiration.id}
|
||
|
)
|
||
5 years ago
|
end)
|
||
|
|
||
|
schedule_next()
|
||
|
{:noreply, state}
|
||
|
end
|
||
|
|
||
|
defp schedule_next do
|
||
|
Process.send_after(self(), :perform, @schedule_interval)
|
||
|
end
|
||
|
end
|