Git of dcc - anni/blob - priv/repo/migrations/20200806175913_rename_instance_chat.exs

   1 # Pleroma: A lightweight social networking server
   2 # Copyright © 2017-2022 Pleroma Authors <https://pleroma.social/>
   3 # SPDX-License-Identifier: AGPL-3.0-only
   4
   5 defmodule Pleroma.Repo.Migrations.RenameInstanceChat do
   6   use Ecto.Migration
   7
   8   alias Pleroma.ConfigDB
   9
  10   @instance_params %{group: :pleroma, key: :instance}
  11   @shout_params %{group: :pleroma, key: :shout}
  12   @chat_params %{group: :pleroma, key: :chat}
  13
  14   def up do
  15     instance_updated? = maybe_update_instance_key(:up) != :noop
  16     chat_updated? = maybe_update_chat_key(:up) != :noop
  17
  18     case Enum.any?([instance_updated?, chat_updated?]) do
  19       true -> :ok
  20       false -> :noop
  21     end
  22   end
  23
  24   def down do
  25     instance_updated? = maybe_update_instance_key(:down) != :noop
  26     chat_updated? = maybe_update_chat_key(:down) != :noop
  27
  28     case Enum.any?([instance_updated?, chat_updated?]) do
  29       true -> :ok
  30       false -> :noop
  31     end
  32   end
  33
  34   # pleroma.instance.chat_limit -> pleroma.shout.limit
  35   defp maybe_update_instance_key(:up) do
  36     with %ConfigDB{value: values} <- ConfigDB.get_by_params(@instance_params),
  37          limit when is_integer(limit) <- values[:chat_limit] do
  38       @shout_params |> Map.put(:value, limit: limit) |> ConfigDB.update_or_create()
  39       @instance_params |> Map.put(:subkeys, [":chat_limit"]) |> ConfigDB.delete()
  40     else
  41       _ ->
  42         :noop
  43     end
  44   end
  45
  46   # pleroma.shout.limit -> pleroma.instance.chat_limit
  47   defp maybe_update_instance_key(:down) do
  48     with %ConfigDB{value: values} <- ConfigDB.get_by_params(@shout_params),
  49          limit when is_integer(limit) <- values[:limit] do
  50       @instance_params |> Map.put(:value, chat_limit: limit) |> ConfigDB.update_or_create()
  51       @shout_params |> Map.put(:subkeys, [":limit"]) |> ConfigDB.delete()
  52     else
  53       _ ->
  54         :noop
  55     end
  56   end
  57
  58   # pleroma.chat.enabled -> pleroma.shout.enabled
  59   defp maybe_update_chat_key(:up) do
  60     with %ConfigDB{value: values} <- ConfigDB.get_by_params(@chat_params),
  61          enabled? when is_boolean(enabled?) <- values[:enabled] do
  62       @shout_params |> Map.put(:value, enabled: enabled?) |> ConfigDB.update_or_create()
  63       @chat_params |> Map.put(:subkeys, [":enabled"]) |> ConfigDB.delete()
  64     else
  65       _ ->
  66         :noop
  67     end
  68   end
  69
  70   # pleroma.shout.enabled -> pleroma.chat.enabled
  71   defp maybe_update_chat_key(:down) do
  72     with %ConfigDB{value: values} <- ConfigDB.get_by_params(@shout_params),
  73          enabled? when is_boolean(enabled?) <- values[:enabled] do
  74       @chat_params |> Map.put(:value, enabled: enabled?) |> ConfigDB.update_or_create()
  75       @shout_params |> Map.put(:subkeys, [":enabled"]) |> ConfigDB.delete()
  76     else
  77       _ ->
  78         :noop
  79     end
  80   end
  81 end