git.squeep.com Git - akkoma/blob - test/workers/scheduled_activity_worker_test.exs

   1 # Pleroma: A lightweight social networking server
   2 # Copyright © 2017-2019 Pleroma Authors <https://pleroma.social/>
   3 # SPDX-License-Identifier: AGPL-3.0-only
   4
   5 defmodule Pleroma.Workers.ScheduledActivityWorkerTest do
   6   use Pleroma.DataCase
   7
   8   alias Pleroma.ScheduledActivity
   9   alias Pleroma.Workers.ScheduledActivityWorker
  10
  11   import Pleroma.Factory
  12   import ExUnit.CaptureLog
  13
  14   clear_config([ScheduledActivity, :enabled])
  15
  16   test "creates a status from the scheduled activity" do
  17     Pleroma.Config.put([ScheduledActivity, :enabled], true)
  18     user = insert(:user)
  19
  20     naive_datetime =
  21       NaiveDateTime.add(
  22         NaiveDateTime.utc_now(),
  23         -:timer.minutes(2),
  24         :millisecond
  25       )
  26
  27     scheduled_activity =
  28       insert(
  29         :scheduled_activity,
  30         scheduled_at: naive_datetime,
  31         user: user,
  32         params: %{status: "hi"}
  33       )
  34
  35     ScheduledActivityWorker.perform(
  36       %{"activity_id" => scheduled_activity.id},
  37       :pid
  38     )
  39
  40     refute Repo.get(ScheduledActivity, scheduled_activity.id)
  41     activity = Repo.all(Pleroma.Activity) |> Enum.find(&(&1.actor == user.ap_id))
  42     assert Pleroma.Object.normalize(activity).data["content"] == "hi"
  43   end
  44
  45   test "adds log message if ScheduledActivity isn't find" do
  46     Pleroma.Config.put([ScheduledActivity, :enabled], true)
  47
  48     assert capture_log([level: :error], fn ->
  49              ScheduledActivityWorker.perform(%{"activity_id" => 42}, :pid)
  50            end) =~ "Couldn't find scheduled activity"
  51   end
  52 end