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.ActivityExpiration do
9 alias Pleroma.ActivityExpiration
16 @type t :: %__MODULE__{}
18 schema "activity_expirations" do
19 belongs_to(:activity, Activity, type: FlakeId)
20 field(:scheduled_at, :naive_datetime)
23 def changeset(%ActivityExpiration{} = expiration, attrs) do
25 |> cast(attrs, [:scheduled_at])
26 |> validate_required([:scheduled_at])
29 def get_by_activity_id(activity_id) do
31 |> where([exp], exp.activity_id == ^activity_id)
35 def create(%Activity{} = activity, scheduled_at) do
36 %ActivityExpiration{activity_id: activity.id}
37 |> changeset(%{scheduled_at: scheduled_at})
41 def due_expirations(offset \\ 0) do
43 NaiveDateTime.utc_now()
44 |> NaiveDateTime.add(offset, :millisecond)
47 |> where([exp], exp.scheduled_at < ^naive_datetime)