akkoma/lib/pleroma/list.ex

156 lines
3.5 KiB
Elixir
Raw Normal View History

# Pleroma: A lightweight social networking server
2018-12-31 15:41:47 +00:00
# Copyright © 2017-2019 Pleroma Authors <https://pleroma.social/>
# SPDX-License-Identifier: AGPL-3.0-only
2018-04-29 13:02:46 +00:00
defmodule Pleroma.List do
use Ecto.Schema
2019-02-09 15:16:26 +00:00
import Ecto.Query
import Ecto.Changeset
alias Pleroma.Activity
alias Pleroma.Repo
alias Pleroma.User
2018-04-29 13:02:46 +00:00
schema "lists" do
2019-01-09 15:08:24 +00:00
belongs_to(:user, User, type: Pleroma.FlakeId)
2018-04-29 13:02:46 +00:00
field(:title, :string)
field(:following, {:array, :string}, default: [])
2019-05-17 12:56:37 +00:00
field(:ap_id, :string)
2018-04-29 13:02:46 +00:00
timestamps()
end
def title_changeset(list, attrs \\ %{}) do
list
|> cast(attrs, [:title])
|> validate_required([:title])
end
def follow_changeset(list, attrs \\ %{}) do
list
|> cast(attrs, [:following])
|> validate_required([:following])
end
2018-12-09 09:12:48 +00:00
def for_user(user, _opts) do
2018-04-29 13:02:46 +00:00
query =
from(
l in Pleroma.List,
where: l.user_id == ^user.id,
order_by: [desc: l.id],
limit: 50
)
Repo.all(query)
end
2018-04-29 13:02:46 +00:00
def get(id, %{id: user_id} = _user) do
2018-04-29 13:02:46 +00:00
query =
from(
l in Pleroma.List,
where: l.id == ^id,
where: l.user_id == ^user_id
)
Repo.one(query)
end
2019-05-13 09:15:14 +00:00
def get_by_ap_id(ap_id) do
2019-05-17 12:56:37 +00:00
Repo.get_by(__MODULE__, ap_id: ap_id)
2019-05-13 09:15:14 +00:00
end
2018-12-09 09:12:48 +00:00
def get_following(%Pleroma.List{following: following} = _list) do
2018-04-29 13:02:46 +00:00
q =
from(
u in User,
where: u.follower_address in ^following
)
2018-04-29 13:02:46 +00:00
{:ok, Repo.all(q)}
end
2018-05-30 13:33:37 +00:00
# Get lists the activity should be streamed to.
def get_lists_from_activity(%Activity{actor: ap_id}) do
actor = User.get_cached_by_ap_id(ap_id)
query =
from(
l in Pleroma.List,
where: fragment("? && ?", l.following, ^[actor.follower_address])
)
Repo.all(query)
end
# Get lists to which the account belongs.
def get_lists_account_belongs(%User{} = owner, account_id) do
2019-04-22 07:20:43 +00:00
user = User.get_cached_by_id(account_id)
query =
from(
l in Pleroma.List,
where:
l.user_id == ^owner.id and
fragment(
"? = ANY(?)",
^user.follower_address,
l.following
)
)
Repo.all(query)
end
2018-04-29 13:02:46 +00:00
def rename(%Pleroma.List{} = list, title) do
list
|> title_changeset(%{title: title})
|> Repo.update()
end
def create(title, %User{} = creator) do
list = %Pleroma.List{user_id: creator.id, title: title}
2019-05-17 12:56:37 +00:00
Repo.transaction(fn ->
list = Repo.insert!(list)
list
|> change(ap_id: "#{creator.ap_id}/lists/#{list.id}")
|> Repo.update!()
end)
2018-04-29 13:02:46 +00:00
end
def follow(%Pleroma.List{following: following} = list, %User{} = followed) do
update_follows(list, %{following: Enum.uniq([followed.follower_address | following])})
end
def unfollow(%Pleroma.List{following: following} = list, %User{} = unfollowed) do
update_follows(list, %{following: List.delete(following, unfollowed.follower_address)})
end
def delete(%Pleroma.List{} = list) do
Repo.delete(list)
end
def update_follows(%Pleroma.List{} = list, attrs) do
list
|> follow_changeset(attrs)
|> Repo.update()
end
2019-05-13 09:15:14 +00:00
def memberships(%User{follower_address: follower_address}) do
Pleroma.List
|> where([l], ^follower_address in l.following)
2019-05-17 12:56:37 +00:00
|> select([l], l.ap_id)
2019-05-13 09:15:14 +00:00
|> Repo.all()
end
def memberships(_), do: []
2019-07-11 12:29:24 +00:00
def member?(%Pleroma.List{following: following}, %User{follower_address: follower_address}) do
Enum.member?(following, follower_address)
end
def member?(_, _), do: false
2018-04-29 13:02:46 +00:00
end