diff options
author | Mark Felder <feld@feld.me> | 2024-09-30 14:17:35 -0400 |
---|---|---|
committer | Mark Felder <feld@feld.me> | 2024-09-30 14:17:35 -0400 |
commit | 47ce3a4a961bd7496f8105bc957dbf958b77d342 (patch) | |
tree | 27360e5338b4b541189d8da9830022dce11c4447 /test | |
parent | 4b3f604f9529c9ced23f747cb6f6d82fedfadab0 (diff) | |
download | pleroma-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.exs | 6 |
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 |