1 # Pleroma: A lightweight social networking server
2 # Copyright © 2017-2021 Pleroma Authors <https://pleroma.social/>
3 # SPDX-License-Identifier: AGPL-3.0-only
5 defmodule Pleroma.FilterTest do
6 use Pleroma.DataCase, async: true
17 describe "creating filters" do
18 test "creation validation error", %{user: user} do
24 {:error, _} = Filter.create(attrs)
26 assert Repo.all(Job) == []
29 test "use passed expires_at instead expires_in", %{user: user} do
30 now = NaiveDateTime.utc_now()
40 {:ok, %Filter{} = filter} = Filter.create(attrs)
42 result = Filter.get(filter.filter_id, user)
43 assert result.expires_at == NaiveDateTime.truncate(now, :second)
47 assert DateTime.truncate(job.scheduled_at, :second) ==
48 now |> NaiveDateTime.truncate(:second) |> DateTime.from_naive!("Etc/UTC")
51 test "creating one filter", %{user: user} do
59 {:ok, %Filter{} = filter} = Filter.create(attrs)
60 result = Filter.get(filter.filter_id, user)
61 assert attrs.phrase == result.phrase
64 test "creating with expired_at", %{user: user} do
73 {:ok, %Filter{} = filter} = Filter.create(attrs)
74 result = Filter.get(filter.filter_id, user)
75 assert attrs.phrase == result.phrase
77 assert [_] = Repo.all(Job)
80 test "creating one filter without a pre-defined filter_id", %{user: user} do
87 {:ok, %Filter{} = filter} = Filter.create(attrs)
89 assert filter.filter_id == 1
92 test "creating additional filters uses previous highest filter_id + 1", %{user: user} do
93 filter1 = insert(:filter, user: user)
102 {:ok, %Filter{} = filter2} = Filter.create(attrs)
103 assert filter2.filter_id == filter1.filter_id + 1
106 test "filter_id is unique per user", %{user: user_one} do
107 user_two = insert(:user)
110 user_id: user_one.id,
115 {:ok, %Filter{} = filter_one} = Filter.create(attrs1)
118 user_id: user_two.id,
123 {:ok, %Filter{} = filter_two} = Filter.create(attrs2)
125 assert filter_one.filter_id == 1
126 assert filter_two.filter_id == 1
128 result_one = Filter.get(filter_one.filter_id, user_one)
129 assert result_one.phrase == filter_one.phrase
131 result_two = Filter.get(filter_two.filter_id, user_two)
132 assert result_two.phrase == filter_two.phrase
136 test "deleting a filter", %{user: user} do
137 filter = insert(:filter, user: user)
139 assert Repo.get(Filter, filter.id)
140 {:ok, filter} = Filter.delete(filter)
141 refute Repo.get(Filter, filter.id)
144 test "deleting a filter with expires_at is removing Oban job too", %{user: user} do
152 {:ok, filter} = Filter.create(attrs)
153 assert %Job{id: job_id} = Pleroma.Workers.PurgeExpiredFilter.get_expiration(filter.id)
154 {:ok, _} = Filter.delete(filter)
156 assert Repo.get(Job, job_id) == nil
159 test "getting all filters by an user", %{user: user} do
160 filter1 = insert(:filter, user: user)
161 filter2 = insert(:filter, user: user)
163 filter_ids = user |> Filter.get_filters() |> collect_ids()
165 assert filter1.id in filter_ids
166 assert filter2.id in filter_ids
169 test "updating a filter", %{user: user} do
170 filter = insert(:filter, user: user)
174 context: ["home", "timeline"]
177 {:ok, updated_filter} = Filter.update(filter, changes)
179 assert filter != updated_filter
180 assert updated_filter.phrase == changes.phrase
181 assert updated_filter.context == changes.context
184 test "updating with error", %{user: user} do
185 filter = insert(:filter, user: user)
191 {:error, _} = Filter.update(filter, changes)