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 end