aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMaksim Pechnikov <parallel588@gmail.com>2019-12-04 17:28:57 +0300
committerMaksim Pechnikov <parallel588@gmail.com>2019-12-04 17:28:57 +0300
commitc0d572d0bf842fae08c609aa58c82554bee3a263 (patch)
tree3da382112a685d3e49f7e1ee897c8c8b1544f0c3
parent680e071dba95d1f46a7a0eeb05d55252752c0e29 (diff)
downloadpleroma-c0d572d0bf842fae08c609aa58c82554bee3a263.tar.gz
added test
-rw-r--r--test/scheduled_activity_test.exs8
1 files changed, 6 insertions, 2 deletions
diff --git a/test/scheduled_activity_test.exs b/test/scheduled_activity_test.exs
index 663cfdd34..b367ae5fb 100644
--- a/test/scheduled_activity_test.exs
+++ b/test/scheduled_activity_test.exs
@@ -24,9 +24,13 @@ defmodule Pleroma.ScheduledActivityTest do
|> NaiveDateTime.to_iso8601()
attrs = %{params: %{}, scheduled_at: today}
- {:ok, _} = ScheduledActivity.create(user, attrs)
- {:ok, _} = ScheduledActivity.create(user, attrs)
+ {:ok, sa1} = ScheduledActivity.create(user, attrs)
+ {:ok, sa2} = ScheduledActivity.create(user, attrs)
+ jobs =
+ Repo.all(from(j in Oban.Job, where: j.queue == "scheduled_activities", select: j.args))
+
+ assert jobs == [%{"activity_id" => sa1.id}, %{"activity_id" => sa2.id}]
{:error, changeset} = ScheduledActivity.create(user, attrs)
assert changeset.errors == [scheduled_at: {"daily limit exceeded", []}]
end