X-Git-Url: http://git.squeep.com/?a=blobdiff_plain;f=test%2Fscheduled_activity_test.exs;h=b367ae5fbf9c8e2818b10baa8a4ad0fcc635820c;hb=c0d572d0bf842fae08c609aa58c82554bee3a263;hp=d3d05745f4c218703d53a6fd297a6312ef7e1310;hpb=b7c449118bc09ab36610e85292d153ace67c2b89;p=akkoma

diff --git a/test/scheduled_activity_test.exs b/test/scheduled_activity_test.exs
index d3d05745f..b367ae5fb 100644
--- a/test/scheduled_activity_test.exs
+++ b/test/scheduled_activity_test.exs
@@ -24,8 +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
@@ -83,7 +88,10 @@ defmodule Pleroma.ScheduledActivityTest do
         params: %{status: "hi"}
       )
 
-    Pleroma.Workers.Cron.ScheduledActivityWorker.perform(:opts, :pid)
+    Pleroma.Workers.ScheduledActivityWorker.perform(
+      %{"activity_id" => scheduled_activity.id},
+      :pid
+    )
 
     refute Repo.get(ScheduledActivity, scheduled_activity.id)
     activity = Repo.all(Pleroma.Activity) |> Enum.find(&(&1.actor == user.ap_id))