aboutsummaryrefslogtreecommitdiff
path: root/lib
diff options
context:
space:
mode:
authorkaniini <nenolod@gmail.com>2019-01-10 02:33:11 +0000
committerkaniini <nenolod@gmail.com>2019-01-10 02:33:11 +0000
commitf85d108c4181fbccf417f47d15915706c457cf1c (patch)
tree804c7e7be3e8ea41d26ab11d90a59810bb1dc257 /lib
parentd203b0b4d3fdae60c5b61df7d239004735206e1c (diff)
parent65fc2df7ccc85f07ea64b0f7340b98d5615bb1a3 (diff)
downloadpleroma-f85d108c4181fbccf417f47d15915706c457cf1c.tar.gz
Merge branch 'mass-follow' into 'develop'
Mass follow See merge request pleroma/pleroma!642
Diffstat (limited to 'lib')
-rw-r--r--lib/pleroma/user.ex24
1 files changed, 20 insertions, 4 deletions
diff --git a/lib/pleroma/user.ex b/lib/pleroma/user.ex
index 7c2849ce2..a49fa3fcd 100644
--- a/lib/pleroma/user.ex
+++ b/lib/pleroma/user.ex
@@ -247,10 +247,7 @@ defmodule Pleroma.User do
)
|> Repo.all()
- autofollowed_users
- |> Enum.reduce({:ok, user}, fn other_user, {:ok, user} ->
- follow(user, other_user)
- end)
+ follow_all(user, autofollowed_users)
end
@doc "Inserts provided changeset, performs post-registration actions (confirmation email sending etc.)"
@@ -307,6 +304,25 @@ defmodule Pleroma.User do
end
end
+ @doc "A mass follow for local users. Ignores blocks and has no side effects"
+ @spec follow_all(User.t(), list(User.t())) :: {atom(), User.t()}
+ def follow_all(follower, followeds) do
+ following =
+ (follower.following ++ Enum.map(followeds, fn %{follower_address: fa} -> fa end))
+ |> Enum.uniq()
+
+ {:ok, follower} =
+ follower
+ |> follow_changeset(%{following: following})
+ |> update_and_set_cache
+
+ Enum.each(followeds, fn followed ->
+ update_follower_count(followed)
+ end)
+
+ {:ok, follower}
+ end
+
def follow(%User{} = follower, %User{info: info} = followed) do
user_config = Application.get_env(:pleroma, :user)
deny_follow_blocked = Keyword.get(user_config, :deny_follow_blocked)