git.squeep.com Git - akkoma/blob - lib/pleroma/web/twitter_api/controllers/util_controller.ex

   1 defmodule Pleroma.Web.TwitterAPI.UtilController do
   2   use Pleroma.Web, :controller
   3   require Logger
   4   alias Pleroma.Web
   5   alias Pleroma.Formatter
   6   alias Pleroma.Web.ActivityPub.ActivityPub
   7   alias Pleroma.{Repo, PasswordResetToken, User}
   8
   9   def show_password_reset(conn, %{"token" => token}) do
  10     with %{used: false} = token <- Repo.get_by(PasswordResetToken, %{token: token}),
  11       %User{} = user <- Repo.get(User, token.user_id) do
  12       render conn, "password_reset.html", %{
  13         token: token,
  14         user: user
  15       }
  16     else
  17       _e -> render conn, "invalid_token.html"
  18     end
  19   end
  20
  21   def password_reset(conn, %{"data" => data}) do
  22     with {:ok, _} <- PasswordResetToken.reset_password(data["token"], data) do
  23       render conn, "password_reset_success.html"
  24     else
  25       _e -> render conn, "password_reset_failed.html"
  26     end
  27   end
  28
  29   def help_test(conn, _params) do
  30     json(conn, "ok")
  31   end
  32
  33   @instance Application.get_env(:pleroma, :instance)
  34   def config(conn, _params) do
  35     case get_format(conn) do
  36       "xml" ->
  37         response = """
  38         <config>
  39           <site>
  40             <name>#{Keyword.get(@instance, :name)}</name>
  41             <site>#{Web.base_url}</site>
  42             <textlimit>#{Keyword.get(@instance, :limit)}</textlimit>
  43             <closed>#{!Keyword.get(@instance, :registrations_open)}</closed>
  44           </site>
  45         </config>
  46         """
  47         conn
  48         |> put_resp_content_type("application/xml")
  49         |> send_resp(200, response)
  50       _ ->
  51         json(conn, %{
  52               site: %{
  53                 name: Keyword.get(@instance, :name),
  54                 server: Web.base_url,
  55                 textlimit: Keyword.get(@instance, :limit),
  56                 closed: if(Keyword.get(@instance, :registrations_open), do: "0", else: "1")
  57               }
  58              })
  59     end
  60   end
  61
  62   def version(conn, _params) do
  63     version = Keyword.get(@instance, :version)
  64     case get_format(conn) do
  65       "xml" ->
  66         response = "<version>#{version}</version>"
  67         conn
  68         |> put_resp_content_type("application/xml")
  69         |> send_resp(200, response)
  70       _ -> json(conn, version)
  71     end
  72   end
  73
  74   def emoji(conn, _params) do
  75     json conn, Enum.into(Formatter.get_custom_emoji(), %{})
  76   end
  77
  78   def follow_import(conn, %{"list" => %Plug.Upload{} = listfile}) do
  79     follow_import(conn, %{"list" => File.read!(listfile.path)})
  80   end
  81   def follow_import(%{assigns: %{user: user}} = conn, %{"list" => list}) do
  82     Task.start(fn ->
  83     String.split(list)
  84     |> Enum.map(fn nick ->
  85         with %User{} = follower <- User.get_cached_by_ap_id(user.ap_id),
  86         %User{} = followed <- User.get_or_fetch_by_nickname(nick),
  87         {:ok, follower} <- User.follow(follower, followed) do
  88           ActivityPub.follow(follower, followed)
  89         else
  90           _e -> Logger.debug "follow_import: following #{nick} failed"
  91         end
  92       end)
  93     end)
  94
  95     json conn, "job started"
  96   end
  97 end