summaryrefslogtreecommitdiff
path: root/priv/repo/migrations/20220905011454_generate_unset_user_keys.exs
blob: 580c38841fc563b1e8e5aba399edd49888bd8a94 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
# Pleroma: A lightweight social networking server
# Copyright © 2017-2022 Pleroma Authors <https://pleroma.social/>
# SPDX-License-Identifier: AGPL-3.0-only

defmodule User do
  use Ecto.Schema

  schema "users" do
    field(:keys, :string)
    field(:local, :boolean, default: true)
  end
end

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

  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