+ shell_info("Test email has been sent to #{inspect(email.to)} from #{inspect(email.from)}")
+ end
+
+ def run(["resend_confirmation_emails"]) do
+ start_pleroma()
+
+ shell_info("Sending emails to all unconfirmed users")
+
+ Pleroma.User.Query.build(%{
+ local: true,
+ is_active: true,
+ is_confirmed: false,
+ invisible: false
+ })
+ |> Pleroma.Repo.chunk_stream(500)
+ |> Stream.each(&Pleroma.User.maybe_send_confirmation_email(&1))
+ |> Stream.run()