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

   1 # Pleroma: A lightweight social networking server
   2 # Copyright © 2017-2020 Pleroma Authors <https://pleroma.social/>
   3 # SPDX-License-Identifier: AGPL-3.0-only
   4
   5 defmodule Pleroma.Workers.PurgeExpiredActivityTest do
   6   use Pleroma.DataCase, async: true
   7   use Oban.Testing, repo: Pleroma.Repo
   8
   9   import Pleroma.Factory
  10
  11   alias Pleroma.Workers.PurgeExpiredActivity
  12
  13   test "denies expirations that don't live long enough" do
  14     activity = insert(:note_activity)
  15
  16     assert {:error, :expiration_too_close} =
  17              PurgeExpiredActivity.enqueue(%{
  18                activity_id: activity.id,
  19                expires_at: DateTime.utc_now()
  20              })
  21
  22     refute_enqueued(
  23       worker: Pleroma.Workers.PurgeExpiredActivity,
  24       args: %{activity_id: activity.id}
  25     )
  26   end
  27
  28   test "enqueue job" do
  29     activity = insert(:note_activity)
  30
  31     assert {:ok, _} =
  32              PurgeExpiredActivity.enqueue(%{
  33                activity_id: activity.id,
  34                expires_at: DateTime.add(DateTime.utc_now(), 3601)
  35              })
  36
  37     assert_enqueued(
  38       worker: Pleroma.Workers.PurgeExpiredActivity,
  39       args: %{activity_id: activity.id}
  40     )
  41
  42     assert {:ok, _} =
  43              perform_job(Pleroma.Workers.PurgeExpiredActivity, %{activity_id: activity.id})
  44
  45     assert %Oban.Job{} = Pleroma.Workers.PurgeExpiredActivity.get_expiration(activity.id)
  46   end
  47
  48   test "don't delete pinned posts, schedule deletion on next day" do
  49     activity = insert(:note_activity)
  50
  51     assert {:ok, _} =
  52              PurgeExpiredActivity.enqueue(%{
  53                activity_id: activity.id,
  54                expires_at: DateTime.utc_now(),
  55                validate: false
  56              })
  57
  58     user = Pleroma.User.get_by_ap_id(activity.actor)
  59     {:ok, activity} = Pleroma.Web.CommonAPI.pin(activity.id, user)
  60
  61     assert %{success: 1, failure: 0} ==
  62              Oban.drain_queue(queue: :activity_expiration, with_scheduled: true)
  63
  64     job = Pleroma.Workers.PurgeExpiredActivity.get_expiration(activity.id)
  65
  66     assert DateTime.diff(job.scheduled_at, DateTime.add(DateTime.utc_now(), 24 * 3600)) in [0, 1]
  67   end
  68 end