git.squeep.com Git - akkoma/blob - test/workers/cron/purge_expired_activities_worker_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.Cron.PurgeExpiredActivitiesWorkerTest do
   6   use Pleroma.DataCase
   7
   8   alias Pleroma.ActivityExpiration
   9   alias Pleroma.Workers.Cron.PurgeExpiredActivitiesWorker
  10
  11   import Pleroma.Factory
  12   import ExUnit.CaptureLog
  13
  14   setup do
  15     clear_config([ActivityExpiration, :enabled])
  16   end
  17
  18   test "deletes an expiration activity" do
  19     Pleroma.Config.put([ActivityExpiration, :enabled], true)
  20     activity = insert(:note_activity)
  21
  22     naive_datetime =
  23       NaiveDateTime.add(
  24         NaiveDateTime.utc_now(),
  25         -:timer.minutes(2),
  26         :millisecond
  27       )
  28
  29     expiration =
  30       insert(
  31         :expiration_in_the_past,
  32         %{activity_id: activity.id, scheduled_at: naive_datetime}
  33       )
  34
  35     Pleroma.Workers.Cron.PurgeExpiredActivitiesWorker.perform(:ops, :pid)
  36
  37     refute Pleroma.Repo.get(Pleroma.Activity, activity.id)
  38     refute Pleroma.Repo.get(Pleroma.ActivityExpiration, expiration.id)
  39   end
  40
  41   test "works with ActivityExpirationPolicy" do
  42     Pleroma.Config.put([ActivityExpiration, :enabled], true)
  43
  44     clear_config([:mrf, :policies], Pleroma.Web.ActivityPub.MRF.ActivityExpirationPolicy)
  45
  46     user = insert(:user)
  47
  48     days = Pleroma.Config.get([:mrf_activity_expiration, :days], 365)
  49
  50     {:ok, %{id: id} = activity} = Pleroma.Web.CommonAPI.post(user, %{status: "cofe"})
  51
  52     past_date =
  53       NaiveDateTime.utc_now() |> Timex.shift(days: -days) |> NaiveDateTime.truncate(:second)
  54
  55     activity
  56     |> Repo.preload(:expiration)
  57     |> Map.get(:expiration)
  58     |> Ecto.Changeset.change(%{scheduled_at: past_date})
  59     |> Repo.update!()
  60
  61     Pleroma.Workers.Cron.PurgeExpiredActivitiesWorker.perform(:ops, :pid)
  62
  63     assert [%{data: %{"type" => "Delete", "deleted_activity_id" => ^id}}] =
  64              Pleroma.Repo.all(Pleroma.Activity)
  65   end
  66
  67   describe "delete_activity/1" do
  68     test "adds log message if activity isn't find" do
  69       assert capture_log([level: :error], fn ->
  70                PurgeExpiredActivitiesWorker.delete_activity(%ActivityExpiration{
  71                  activity_id: "test-activity"
  72                })
  73              end) =~ "Couldn't delete expired activity: not found activity"
  74     end
  75
  76     test "adds log message if actor isn't find" do
  77       assert capture_log([level: :error], fn ->
  78                PurgeExpiredActivitiesWorker.delete_activity(%ActivityExpiration{
  79                  activity_id: "test-activity"
  80                })
  81              end) =~ "Couldn't delete expired activity: not found activity"
  82     end
  83   end
  84 end