import Ecto.Query
@type t :: %__MODULE__{}
+ @min_activity_lifetime :timer.hours(1)
schema "activity_expirations" do
belongs_to(:activity, Activity, type: FlakeId)
expiration
|> cast(attrs, [:scheduled_at])
|> validate_required([:scheduled_at])
+ |> validate_scheduled_at()
end
def get_by_activity_id(activity_id) do
|> where([exp], exp.scheduled_at < ^naive_datetime)
|> Repo.all()
end
+
+ def validate_scheduled_at(changeset) do
+ validate_change(changeset, :scheduled_at, fn _, scheduled_at ->
+ if not expires_late_enough?(scheduled_at) do
+ [scheduled_at: "an ephemeral activity must live for at least one hour"]
+ else
+ []
+ end
+ end)
+ end
+
+ def expires_late_enough?(scheduled_at) do
+ now = NaiveDateTime.utc_now()
+ diff = NaiveDateTime.diff(scheduled_at, now, :millisecond)
+ diff >= @min_activity_lifetime
+ end
end
end
end
+ defp check_expiry_date(expiry_str) do
+ {:ok, expiry} = Ecto.Type.cast(:naive_datetime, expiry_str)
+
+ if is_nil(expiry) || ActivityExpiration.expires_late_enough?(expiry) do
+ {:ok, expiry}
+ else
+ {:error, "Expiry date is too soon"}
+ end
+ end
+
def post(user, %{"status" => status} = data) do
limit = Pleroma.Config.get([:instance, :limit])
context <- make_context(in_reply_to),
cw <- data["spoiler_text"] || "",
sensitive <- data["sensitive"] || Enum.member?(tags, {"#nsfw", "nsfw"}),
- {:ok, expires_at} <- Ecto.Type.cast(:naive_datetime, data["expires_at"]),
+ {:ok, expires_at} <- check_expiry_date(data["expires_at"]),
full_payload <- String.trim(status <> cw),
:ok <- validate_character_limit(full_payload, attachments, limit),
object <-
if expires_at do
with {:ok, activity} <- result do
- ActivityExpiration.create(activity, expires_at)
+ {:ok, _} = ActivityExpiration.create(activity, expires_at)
end
end
assert length(expirations) == 1
assert hd(expirations) == expiration_due
end
+
+ test "denies expirations that don't live long enough" do
+ activity = insert(:note_activity)
+ now = NaiveDateTime.utc_now()
+ assert {:error, _} = ActivityExpiration.create(activity, now)
+ end
end
end
def expiration_in_the_future_factory(attrs \\ %{}) do
- expiration_offset_by_minutes(attrs, 60)
+ expiration_offset_by_minutes(attrs, 61)
end
def article_activity_factory do