katafrakt/akkoma
1
0
Fork 0
forked from AkkomaGang/akkoma
Code Pull requests Activity

Chase Pleroma.RepoStreamer.chunk_stream -> Pleroma.Repo.chunk_stream

Browse source
This commit is contained in:
Mark Felder 2020-09-23 12:32:47 -05:00
parent f3a1f9c3bb
commit 8af8eb5ce7
2 changed files with 4 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
lib/mix/tasks/pleroma/email.ex
View file

@ -31,11 +31,8 @@ def run(["resend_confirmation_emails"]) do
confirmation_pending: true, confirmation_pending: true,
invisible: false invisible: false
}) })
|> Pleroma.RepoStreamer.chunk_stream(500) |> Pleroma.Repo.chunk_stream(500, :batches)
|> Stream.each(fn users -> |> Stream.each(&Pleroma.User.try_send_confirmation_email(&1))
users
|> Enum.each(fn user -> Pleroma.User.try_send_confirmation_email(user) end)
end)
|> Stream.run() |> Stream.run()
end end
end end

4
lib/mix/tasks/pleroma/user.ex
View file

@ -370,7 +370,7 @@ def run(["confirm_all"]) do
is_admin: false, is_admin: false,
invisible: false invisible: false
}) })
|> Pleroma.RepoStreamer.chunk_stream(500) |> Pleroma.Repo.chunk_stream(500, :batches)
|> Stream.each(fn users -> |> Stream.each(fn users ->
users users
|> Enum.each(fn user -> User.need_confirmation(user, false) end) |> Enum.each(fn user -> User.need_confirmation(user, false) end)
@ -388,7 +388,7 @@ def run(["unconfirm_all"]) do
is_admin: false, is_admin: false,
invisible: false invisible: false
}) })
|> Pleroma.RepoStreamer.chunk_stream(500) |> Pleroma.Repo.chunk_stream(500, :batches)
|> Stream.each(fn users -> |> Stream.each(fn users ->
users users
|> Enum.each(fn user -> User.need_confirmation(user, true) end) |> Enum.each(fn user -> User.need_confirmation(user, true) end)