From 3a4773c3c2bd0bbef244eb519b07208da9108e49 Mon Sep 17 00:00:00 2001
From: dcc <dcc@logografos.com>
Date: Sat, 2 Sep 2023 00:52:52 -0700
Subject: First

---
 .../workers/scheduled_activity_worker_test.exs     | 52 ++++++++++++++++++++++
 1 file changed, 52 insertions(+)
 create mode 100644 test/pleroma/workers/scheduled_activity_worker_test.exs

(limited to 'test/pleroma/workers/scheduled_activity_worker_test.exs')

diff --git a/test/pleroma/workers/scheduled_activity_worker_test.exs b/test/pleroma/workers/scheduled_activity_worker_test.exs
new file mode 100644
index 0000000..4b3dfb9
--- /dev/null
+++ b/test/pleroma/workers/scheduled_activity_worker_test.exs
@@ -0,0 +1,52 @@
+# Pleroma: A lightweight social networking server
+# Copyright © 2017-2022 Pleroma Authors <https://pleroma.social/>
+# SPDX-License-Identifier: AGPL-3.0-only
+
+defmodule Pleroma.Workers.ScheduledActivityWorkerTest do
+  use Pleroma.DataCase
+
+  alias Pleroma.ScheduledActivity
+  alias Pleroma.Workers.ScheduledActivityWorker
+
+  import Pleroma.Factory
+  import ExUnit.CaptureLog
+
+  setup do: clear_config([ScheduledActivity, :enabled], true)
+
+  test "creates a status from the scheduled activity" do
+    user = insert(:user)
+
+    naive_datetime =
+      NaiveDateTime.add(
+        NaiveDateTime.utc_now(),
+        -:timer.minutes(2),
+        :millisecond
+      )
+
+    scheduled_activity =
+      insert(
+        :scheduled_activity,
+        scheduled_at: naive_datetime,
+        user: user,
+        params: %{status: "hi"}
+      )
+
+    {:ok, %{id: activity_id}} =
+      ScheduledActivityWorker.perform(%Oban.Job{args: %{"activity_id" => scheduled_activity.id}})
+
+    refute Repo.get(ScheduledActivity, scheduled_activity.id)
+
+    object =
+      Pleroma.Activity
+      |> Repo.get(activity_id)
+      |> Pleroma.Object.normalize()
+
+    assert object.data["content"] == "hi"
+  end
+
+  test "error message for non-existent scheduled activity" do
+    assert capture_log([level: :error], fn ->
+             ScheduledActivityWorker.perform(%Oban.Job{args: %{"activity_id" => 42}})
+           end) =~ "Couldn't find scheduled activity: 42"
+  end
+end
-- 
cgit v1.2.3