Git of dcc - anni/blob - lib/pleroma/web/admin_api/controllers/relay_controller.ex

   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.Web.AdminAPI.RelayController do
   6   use Pleroma.Web, :controller
   7
   8   alias Pleroma.ModerationLog
   9   alias Pleroma.Web.ActivityPub.Relay
  10   alias Pleroma.Web.Plugs.OAuthScopesPlug
  11
  12   require Logger
  13
  14   plug(Pleroma.Web.ApiSpec.CastAndValidate)
  15
  16   plug(
  17     OAuthScopesPlug,
  18     %{scopes: ["admin:write:follows"]}
  19     when action in [:follow, :unfollow]
  20   )
  21
  22   plug(OAuthScopesPlug, %{scopes: ["admin:read"]} when action == :index)
  23
  24   action_fallback(Pleroma.Web.AdminAPI.FallbackController)
  25
  26   defdelegate open_api_operation(action), to: Pleroma.Web.ApiSpec.Admin.RelayOperation
  27
  28   def index(conn, _params) do
  29     with {:ok, list} <- Relay.list() do
  30       json(conn, %{relays: list})
  31     end
  32   end
  33
  34   def follow(%{assigns: %{user: admin}, body_params: %{relay_url: target}} = conn, _) do
  35     with {:ok, _message} <- Relay.follow(target) do
  36       ModerationLog.insert_log(%{action: "relay_follow", actor: admin, target: target})
  37
  38       json(conn, %{actor: target, followed_back: target in Relay.following()})
  39     else
  40       _ ->
  41         conn
  42         |> put_status(500)
  43         |> json(target)
  44     end
  45   end
  46
  47   def unfollow(%{assigns: %{user: admin}, body_params: %{relay_url: target} = params} = conn, _) do
  48     with {:ok, _message} <- Relay.unfollow(target, %{force: params[:force]}) do
  49       ModerationLog.insert_log(%{action: "relay_unfollow", actor: admin, target: target})
  50
  51       json(conn, target)
  52     else
  53       _ ->
  54         conn
  55         |> put_status(500)
  56         |> json(target)
  57     end
  58   end
  59 end