summaryrefslogtreecommitdiff
path: root/test
diff options
context:
space:
mode:
authorMark Felder <feld@feld.me>2024-09-30 14:17:35 -0400
committerMark Felder <feld@feld.me>2024-09-30 14:17:35 -0400
commit47ce3a4a961bd7496f8105bc957dbf958b77d342 (patch)
tree27360e5338b4b541189d8da9830022dce11c4447 /test
parent4b3f604f9529c9ced23f747cb6f6d82fedfadab0 (diff)
downloadpleroma-47ce3a4a961bd7496f8105bc957dbf958b77d342.tar.gz
pleroma-47ce3a4a961bd7496f8105bc957dbf958b77d342.zip
Schedule a final poll refresh before streaming out the notifications
Diffstat (limited to 'test')
-rw-r--r--test/pleroma/workers/poll_worker_test.exs6
1 files changed, 6 insertions, 0 deletions
diff --git a/test/pleroma/workers/poll_worker_test.exs b/test/pleroma/workers/poll_worker_test.exs
index 749df8aff..e1c67f057 100644
--- a/test/pleroma/workers/poll_worker_test.exs
+++ b/test/pleroma/workers/poll_worker_test.exs
@@ -44,6 +44,12 @@ defmodule Pleroma.Workers.PollWorkerTest do
# Ensure notifications were streamed out when job executes
assert called(Pleroma.Web.Streamer.stream(["user", "user:notification"], :_))
assert called(Pleroma.Web.Push.send(:_))
+
+ # Ensure we scheduled a final refresh of the poll
+ assert_enqueued(
+ worker: PollWorker,
+ args: %{"op" => "refresh", "activity_id" => activity.id}
+ )
end
end
end