summaryrefslogtreecommitdiff
path: root/test/activity_expiration_test.exs
diff options
context:
space:
mode:
authorrinpatch <rinpatch@sdf.org>2020-02-11 00:04:06 +0000
committerrinpatch <rinpatch@sdf.org>2020-02-11 00:04:06 +0000
commit94e5ca11054567e0edc15ef3a350f02c386d3ead (patch)
tree36f42f1532c76e44d3959e368a046bff474aea3b /test/activity_expiration_test.exs
parenta7287e2e3a9291469c489a5a1df26480fdeab3a3 (diff)
parent6813c0302c2b665d337d5f5831d2df6312b6b277 (diff)
downloadpleroma-94e5ca11054567e0edc15ef3a350f02c386d3ead.tar.gz
pleroma-94e5ca11054567e0edc15ef3a350f02c386d3ead.zip
Merge branch 'issue/1383' into 'develop'
[#1383] Switch periodic jobs from quantum to oban See merge request pleroma/pleroma!2015
Diffstat (limited to 'test/activity_expiration_test.exs')
-rw-r--r--test/activity_expiration_test.exs25
1 files changed, 25 insertions, 0 deletions
diff --git a/test/activity_expiration_test.exs b/test/activity_expiration_test.exs
index 4948fae16..2fc593b8c 100644
--- a/test/activity_expiration_test.exs
+++ b/test/activity_expiration_test.exs
@@ -7,6 +7,8 @@ defmodule Pleroma.ActivityExpirationTest do
alias Pleroma.ActivityExpiration
import Pleroma.Factory
+ clear_config([ActivityExpiration, :enabled])
+
test "finds activities due to be deleted only" do
activity = insert(:note_activity)
expiration_due = insert(:expiration_in_the_past, %{activity_id: activity.id})
@@ -24,4 +26,27 @@ defmodule Pleroma.ActivityExpirationTest do
now = NaiveDateTime.utc_now()
assert {:error, _} = ActivityExpiration.create(activity, now)
end
+
+ test "deletes an expiration activity" do
+ Pleroma.Config.put([ActivityExpiration, :enabled], true)
+ activity = insert(:note_activity)
+
+ naive_datetime =
+ NaiveDateTime.add(
+ NaiveDateTime.utc_now(),
+ -:timer.minutes(2),
+ :millisecond
+ )
+
+ expiration =
+ insert(
+ :expiration_in_the_past,
+ %{activity_id: activity.id, scheduled_at: naive_datetime}
+ )
+
+ Pleroma.Workers.Cron.PurgeExpiredActivitiesWorker.perform(:ops, :pid)
+
+ refute Pleroma.Repo.get(Pleroma.Activity, activity.id)
+ refute Pleroma.Repo.get(Pleroma.ActivityExpiration, expiration.id)
+ end
end