66 lines
1.9 KiB
Elixir
66 lines
1.9 KiB
Elixir
# Pleroma: A lightweight social networking server
|
|
# Copyright © 2017-2022 Pleroma Authors <https://pleroma.social/>
|
|
# SPDX-License-Identifier: AGPL-3.0-only
|
|
|
|
defmodule Pleroma.Workers.PurgeExpiredActivityTest do
|
|
use Pleroma.DataCase, async: true
|
|
use Oban.Testing, repo: Pleroma.Repo
|
|
|
|
import Pleroma.Factory
|
|
|
|
alias Pleroma.Workers.PurgeExpiredActivity
|
|
|
|
test "enqueue job" do
|
|
activity = insert(:note_activity)
|
|
|
|
assert {:ok, _} =
|
|
PurgeExpiredActivity.enqueue(
|
|
%{
|
|
activity_id: activity.id
|
|
},
|
|
scheduled_at: DateTime.add(DateTime.utc_now(), 3601)
|
|
)
|
|
|
|
assert_enqueued(
|
|
worker: Pleroma.Workers.PurgeExpiredActivity,
|
|
args: %{activity_id: activity.id}
|
|
)
|
|
|
|
assert {:ok, _} =
|
|
perform_job(Pleroma.Workers.PurgeExpiredActivity, %{activity_id: activity.id})
|
|
|
|
assert %Oban.Job{} = Pleroma.Workers.PurgeExpiredActivity.get_expiration(activity.id)
|
|
end
|
|
|
|
test "error if user was not found" do
|
|
activity = insert(:note_activity)
|
|
|
|
assert {:ok, _} =
|
|
PurgeExpiredActivity.enqueue(
|
|
%{
|
|
activity_id: activity.id
|
|
},
|
|
scheduled_at: DateTime.add(DateTime.utc_now(), 3601)
|
|
)
|
|
|
|
user = Pleroma.User.get_by_ap_id(activity.actor)
|
|
Pleroma.Repo.delete(user)
|
|
|
|
assert {:cancel, :user_not_found} =
|
|
perform_job(Pleroma.Workers.PurgeExpiredActivity, %{activity_id: activity.id})
|
|
end
|
|
|
|
test "error if actiivity was not found" do
|
|
assert {:ok, _} =
|
|
PurgeExpiredActivity.enqueue(
|
|
%{
|
|
activity_id: "some_id"
|
|
},
|
|
scheduled_at: DateTime.add(DateTime.utc_now(), 3601)
|
|
)
|
|
|
|
assert {:cancel, :activity_not_found} =
|
|
perform_job(Pleroma.Workers.PurgeExpiredActivity, %{activity_id: "some_if"})
|
|
end
|
|
end
|