git.squeep.com Git - akkoma/blob - test/scheduled_activity_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.ScheduledActivityTest do
   6   use Pleroma.DataCase
   7   alias Pleroma.DataCase
   8   alias Pleroma.ScheduledActivity
   9   import Pleroma.Factory
  10
  11   clear_config([ScheduledActivity, :enabled])
  12
  13   setup context do
  14     DataCase.ensure_local_uploader(context)
  15   end
  16
  17   describe "creation" do
  18     test "when daily user limit is exceeded" do
  19       user = insert(:user)
  20
  21       today =
  22         NaiveDateTime.utc_now()
  23         |> NaiveDateTime.add(:timer.minutes(6), :millisecond)
  24         |> NaiveDateTime.to_iso8601()
  25
  26       attrs = %{params: %{}, scheduled_at: today}
  27       {:ok, _} = ScheduledActivity.create(user, attrs)
  28       {:ok, _} = ScheduledActivity.create(user, attrs)
  29       {:error, changeset} = ScheduledActivity.create(user, attrs)
  30       assert changeset.errors == [scheduled_at: {"daily limit exceeded", []}]
  31     end
  32
  33     test "when total user limit is exceeded" do
  34       user = insert(:user)
  35
  36       today =
  37         NaiveDateTime.utc_now()
  38         |> NaiveDateTime.add(:timer.minutes(6), :millisecond)
  39         |> NaiveDateTime.to_iso8601()
  40
  41       tomorrow =
  42         NaiveDateTime.utc_now()
  43         |> NaiveDateTime.add(:timer.hours(36), :millisecond)
  44         |> NaiveDateTime.to_iso8601()
  45
  46       {:ok, _} = ScheduledActivity.create(user, %{params: %{}, scheduled_at: today})
  47       {:ok, _} = ScheduledActivity.create(user, %{params: %{}, scheduled_at: today})
  48       {:ok, _} = ScheduledActivity.create(user, %{params: %{}, scheduled_at: tomorrow})
  49       {:error, changeset} = ScheduledActivity.create(user, %{params: %{}, scheduled_at: tomorrow})
  50       assert changeset.errors == [scheduled_at: {"total limit exceeded", []}]
  51     end
  52
  53     test "when scheduled_at is earlier than 5 minute from now" do
  54       user = insert(:user)
  55
  56       scheduled_at =
  57         NaiveDateTime.utc_now()
  58         |> NaiveDateTime.add(:timer.minutes(4), :millisecond)
  59         |> NaiveDateTime.to_iso8601()
  60
  61       attrs = %{params: %{}, scheduled_at: scheduled_at}
  62       {:error, changeset} = ScheduledActivity.create(user, attrs)
  63       assert changeset.errors == [scheduled_at: {"must be at least 5 minutes from now", []}]
  64     end
  65   end
  66
  67   test "creates a status from the scheduled activity" do
  68     Pleroma.Config.put([ScheduledActivity, :enabled], true)
  69     user = insert(:user)
  70
  71     naive_datetime =
  72       NaiveDateTime.add(
  73         NaiveDateTime.utc_now(),
  74         -:timer.minutes(2),
  75         :millisecond
  76       )
  77
  78     scheduled_activity =
  79       insert(
  80         :scheduled_activity,
  81         scheduled_at: naive_datetime,
  82         user: user,
  83         params: %{status: "hi"}
  84       )
  85
  86     Pleroma.Workers.Cron.ScheduledActivityWorker.perform(:opts, :pid)
  87
  88     refute Repo.get(ScheduledActivity, scheduled_activity.id)
  89     activity = Repo.all(Pleroma.Activity) |> Enum.find(&(&1.actor == user.ap_id))
  90     assert Pleroma.Object.normalize(activity).data["content"] == "hi"
  91   end
  92 end