git.squeep.com Git - akkoma/blob - lib/pleroma/web/admin_api/admin_api_controller.ex

   1 defmodule Pleroma.Web.AdminAPI.AdminAPIController do
   2   use Pleroma.Web, :controller
   3   alias Pleroma.{User, Repo}
   4   alias Pleroma.Web.ActivityPub.Relay
   5
   6   require Logger
   7
   8   action_fallback(:errors)
   9
  10   def user_delete(conn, %{"nickname" => nickname}) do
  11     user = User.get_by_nickname(nickname)
  12
  13     if user[:local] == true do
  14       User.delete(user)
  15     else
  16       User.delete(user)
  17     end
  18
  19     conn
  20     |> json(nickname)
  21   end
  22
  23   def user_create(conn, %{
  24         user: %{"nickname" => nickname, "email" => email, "password" => password} = user
  25       }) do
  26     new_user = %User{
  27       nickname: nickname,
  28       name: user.name || nickname,
  29       email: email,
  30       password: password,
  31       password_confirmation: password,
  32       bio: user.bio || "."
  33     }
  34
  35     User.register_changeset(%User{}, new_user)
  36
  37     Repo.insert!(new_user)
  38
  39     conn
  40     |> json(new_user.nickname)
  41   end
  42
  43   def right_add(conn, %{"permission_group" => permission_group, "nickname" => nickname})
  44       when permission_group in ["moderator", "admin"] do
  45     user = User.get_by_nickname(nickname)
  46
  47     info =
  48       user.info
  49       |> Map.put("is_" <> permission_group, true)
  50
  51     cng = User.info_changeset(user, %{info: info})
  52     {:ok, user} = User.update_and_set_cache(cng)
  53
  54     conn
  55     |> json(user.info)
  56   end
  57
  58   def right_get(conn, %{"nickname" => nickname}) do
  59     user = User.get_by_nickname(nickname)
  60
  61     conn
  62     |> json(user.info)
  63   end
  64
  65   def right_add(conn, _) do
  66     conn
  67     |> put_status(404)
  68     |> json(%{error: "No such permission_group"})
  69   end
  70
  71   def right_delete(
  72         %{assigns: %{user: %User{:nickname => admin_nickname}}} = conn,
  73         %{
  74           "permission_group" => permission_group,
  75           "nickname" => nickname
  76         }
  77       )
  78       when permission_group in ["moderator", "admin"] do
  79     if admin_nickname == nickname do
  80       conn
  81       |> put_status(403)
  82       |> json(%{error: "You can't revoke your own admin status."})
  83     else
  84       user = User.get_by_nickname(nickname)
  85
  86       info =
  87         user.info
  88         |> Map.put("is_" <> permission_group, false)
  89
  90       cng = User.info_changeset(user, %{info: info})
  91       {:ok, user} = User.update_and_set_cache(cng)
  92
  93       conn
  94       |> json(user.info)
  95     end
  96   end
  97
  98   def right_delete(conn, _) do
  99     conn
 100     |> put_status(404)
 101     |> json(%{error: "No such permission_group"})
 102   end
 103
 104   def relay_follow(conn, %{"relay_url" => target}) do
 105     status = Relay.follow(target)
 106
 107     if status == :ok do
 108       conn
 109       |> json(target)
 110     else
 111       conn
 112       |> put_status(500)
 113       |> json(target)
 114     end
 115   end
 116
 117   def relay_unfollow(conn, %{"relay_url" => target}) do
 118     status = Relay.unfollow(target)
 119
 120     if status == :ok do
 121       conn
 122       |> json(target)
 123     else
 124       conn
 125       |> put_status(500)
 126       |> json(target)
 127     end
 128   end
 129
 130   @shortdoc "Get a account registeration invite token (base64 string)"
 131   def get_invite_token(conn, _params) do
 132     {:ok, token} = Pleroma.UserInviteToken.create_token()
 133
 134     conn
 135     |> json(token.token)
 136   end
 137
 138   @shortdoc "Get a password reset token (base64 string) for given nickname"
 139   def get_password_reset(conn, %{"nickname" => nickname}) do
 140     (%User{local: true} = user) = User.get_by_nickname(nickname)
 141     {:ok, token} = Pleroma.PasswordResetToken.create_token(user)
 142
 143     conn
 144     |> json(token.token)
 145   end
 146
 147   def errors(conn, {:param_cast, _}) do
 148     conn
 149     |> put_status(400)
 150     |> json("Invalid parameters")
 151   end
 152
 153   def errors(conn, _) do
 154     conn
 155     |> put_status(500)
 156     |> json("Something went wrong")
 157   end
 158 end