akkoma/priv/repo/migrations/20220905011454_generate_unset_user_keys.exs

# Pleroma: A lightweight social networking server
# Copyright © 2017-2022 Pleroma Authors <https://pleroma.social/>
# SPDX-License-Identifier: AGPL-3.0-only

defmodule Pleroma.Repo.Migrations.GenerateUnsetUserKeys do
  use Ecto.Migration
  import Ecto.Query
  alias Pleroma.Keys
  alias Pleroma.Repo
  alias Pleroma.User

  def change do
    query =
      from(u in User,
        where: u.local == true,
        where: is_nil(u.keys),
        select: u.id
      )

    Repo.stream(query)
    |> Enum.each(fn user ->
      with {:ok, pem} <- Keys.generate_rsa_pem() do
        Ecto.Changeset.cast(%User{id: user}, %{keys: pem}, [:keys])
        |> Repo.update(returning: false)
      end
    end)
  end
end