1 # Pleroma: A lightweight social networking server
2 # Copyright © 2017-2020 Pleroma Authors <https://pleroma.social/>
3 # SPDX-License-Identifier: AGPL-3.0-only
5 defmodule Pleroma.Filter do
15 belongs_to(:user, User, type: FlakeId.Ecto.CompatType)
16 field(:filter_id, :integer)
17 field(:hide, :boolean, default: false)
18 field(:whole_word, :boolean, default: true)
19 field(:phrase, :string)
20 field(:context, {:array, :string})
21 field(:expires_at, :utc_datetime)
26 def get(id, %{id: user_id} = _user) do
30 where: f.filter_id == ^id,
31 where: f.user_id == ^user_id
37 def get_active(query) do
38 from(f in query, where: is_nil(f.expires_at) or f.expires_at > ^NaiveDateTime.utc_now())
41 def get_irreversible(query) do
42 from(f in query, where: f.hide)
45 def get_filters(query \\ __MODULE__, %User{id: user_id}) do
49 where: f.user_id == ^user_id,
56 def create(%Pleroma.Filter{user_id: user_id, filter_id: nil} = filter) do
57 # If filter_id wasn't given, use the max filter_id for this user plus 1.
58 # XXX This could result in a race condition if a user tries to add two
59 # different filters for their account from two different clients at the
60 # same time, but that should be unlikely.
65 where: f.user_id == ^user_id,
66 select: max(f.filter_id)
70 case Repo.one(max_id_query) do
71 # Start allocating from 1
80 |> Map.put(:filter_id, filter_id)
84 def create(%Pleroma.Filter{} = filter) do
88 def delete(%Pleroma.Filter{id: filter_key} = filter) when is_number(filter_key) do
92 def delete(%Pleroma.Filter{id: filter_key} = filter) when is_nil(filter_key) do
93 %Pleroma.Filter{id: id} = get(filter.filter_id, %{id: filter.user_id})
100 def update(%Pleroma.Filter{} = filter, params) do
102 |> cast(params, [:phrase, :context, :hide, :expires_at, :whole_word])
103 |> validate_required([:phrase, :context])
107 def compose_regex(user_or_filters, format \\ :postgres)
109 def compose_regex(%User{} = user, format) do
112 |> get_irreversible()
114 |> compose_regex(format)
117 def compose_regex([_ | _] = filters, format) do
120 |> Enum.map(& &1.phrase)
135 def compose_regex(_, _), do: nil