2022-09-04 18:51:35 -07:00
|
|
|
# Pleroma: A lightweight social networking server
|
2023-01-02 12:38:50 -08:00
|
|
|
# Copyright © 2017-2022 Pleroma Authors <https://pleroma.social/>
|
2022-09-04 18:51:35 -07:00
|
|
|
# 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
|
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|
Repo.stream(query)
|
|
|
|
|
|> Enum.each(fn user ->
|
|
|
|
|
with {:ok, pem} <- Keys.generate_rsa_pem() do
|
|
|
|
|
Ecto.Changeset.cast(user, %{keys: pem}, [:keys])
|
|
|
|
|
|> Repo.update()
|
|
|
|
|
end
|
|
|
|
|
end)
|
|
|
|
|
end
|
|
|
|
|
end
|
