added test

[akkoma] / test / scheduled_activity_test.exs

diff --git a/test/scheduled_activity_test.exs b/test/scheduled_activity_test.exs
index d3d05745f4c218703d53a6fd297a6312ef7e1310..b367ae5fbf9c8e2818b10baa8a4ad0fcc635820c 100644 (file)
--- 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))