git.squeep.com Git - akkoma/blob - lib/pleroma/web/activity_pub/activity_pub_controller.ex

   1 defmodule Pleroma.Web.ActivityPub.ActivityPubController do
   2   use Pleroma.Web, :controller
   3   alias Pleroma.{User, Object}
   4   alias Pleroma.Web.ActivityPub.{ObjectView, UserView}
   5   alias Pleroma.Web.ActivityPub.ActivityPub
   6   alias Pleroma.Web.ActivityPub.Relay
   7   alias Pleroma.Web.Federator
   8
   9   require Logger
  10
  11   action_fallback(:errors)
  12
  13   def user(conn, %{"nickname" => nickname}) do
  14     with %User{} = user <- User.get_cached_by_nickname(nickname),
  15          {:ok, user} <- Pleroma.Web.WebFinger.ensure_keys_present(user) do
  16       conn
  17       |> put_resp_header("content-type", "application/activity+json")
  18       |> json(UserView.render("user.json", %{user: user}))
  19     else
  20       nil -> {:error, :not_found}
  21     end
  22   end
  23
  24   def object(conn, %{"uuid" => uuid}) do
  25     with ap_id <- o_status_url(conn, :object, uuid),
  26          %Object{} = object <- Object.get_cached_by_ap_id(ap_id),
  27          {_, true} <- {:public?, ActivityPub.is_public?(object)} do
  28       conn
  29       |> put_resp_header("content-type", "application/activity+json")
  30       |> json(ObjectView.render("object.json", %{object: object}))
  31     else
  32       {:public?, false} ->
  33         {:error, :not_found}
  34     end
  35   end
  36
  37   def following(conn, %{"nickname" => nickname, "page" => page}) do
  38     with %User{} = user <- User.get_cached_by_nickname(nickname),
  39          {:ok, user} <- Pleroma.Web.WebFinger.ensure_keys_present(user) do
  40       {page, _} = Integer.parse(page)
  41
  42       conn
  43       |> put_resp_header("content-type", "application/activity+json")
  44       |> json(UserView.render("following.json", %{user: user, page: page}))
  45     end
  46   end
  47
  48   def following(conn, %{"nickname" => nickname}) do
  49     with %User{} = user <- User.get_cached_by_nickname(nickname),
  50          {:ok, user} <- Pleroma.Web.WebFinger.ensure_keys_present(user) do
  51       conn
  52       |> put_resp_header("content-type", "application/activity+json")
  53       |> json(UserView.render("following.json", %{user: user}))
  54     end
  55   end
  56
  57   def followers(conn, %{"nickname" => nickname, "page" => page}) do
  58     with %User{} = user <- User.get_cached_by_nickname(nickname),
  59          {:ok, user} <- Pleroma.Web.WebFinger.ensure_keys_present(user) do
  60       {page, _} = Integer.parse(page)
  61
  62       conn
  63       |> put_resp_header("content-type", "application/activity+json")
  64       |> json(UserView.render("followers.json", %{user: user, page: page}))
  65     end
  66   end
  67
  68   def followers(conn, %{"nickname" => nickname}) do
  69     with %User{} = user <- User.get_cached_by_nickname(nickname),
  70          {:ok, user} <- Pleroma.Web.WebFinger.ensure_keys_present(user) do
  71       conn
  72       |> put_resp_header("content-type", "application/activity+json")
  73       |> json(UserView.render("followers.json", %{user: user}))
  74     end
  75   end
  76
  77   def outbox(conn, %{"nickname" => nickname, "max_id" => max_id}) do
  78     with %User{} = user <- User.get_cached_by_nickname(nickname),
  79          {:ok, user} <- Pleroma.Web.WebFinger.ensure_keys_present(user) do
  80       conn
  81       |> put_resp_header("content-type", "application/activity+json")
  82       |> json(UserView.render("outbox.json", %{user: user, max_id: max_id}))
  83     end
  84   end
  85
  86   def outbox(conn, %{"nickname" => nickname}) do
  87     outbox(conn, %{"nickname" => nickname, "max_id" => nil})
  88   end
  89
  90   # TODO: Ensure that this inbox is a recipient of the message
  91   def inbox(%{assigns: %{valid_signature: true}} = conn, params) do
  92     Federator.enqueue(:incoming_ap_doc, params)
  93     json(conn, "ok")
  94   end
  95
  96   def inbox(conn, params) do
  97     headers = Enum.into(conn.req_headers, %{})
  98
  99     if !String.contains?(headers["signature"] || "", params["actor"]) do
 100       Logger.info("Signature not from author, relayed message, fetching from source")
 101       ActivityPub.fetch_object_from_id(params["object"]["id"])
 102     else
 103       Logger.info("Signature error - make sure you are forwarding the HTTP Host header!")
 104       Logger.info("Could not validate #{params["actor"]}")
 105       Logger.info(inspect(conn.req_headers))
 106     end
 107
 108     json(conn, "ok")
 109   end
 110
 111   def relay(conn, params) do
 112     with %User{} = user <- Relay.get_actor(),
 113          {:ok, user} <- Pleroma.Web.WebFinger.ensure_keys_present(user) do
 114       conn
 115       |> put_resp_header("content-type", "application/activity+json")
 116       |> json(UserView.render("user.json", %{user: user}))
 117     else
 118       nil -> {:error, :not_found}
 119     end
 120   end
 121
 122   def errors(conn, {:error, :not_found}) do
 123     conn
 124     |> put_status(404)
 125     |> json("Not found")
 126   end
 127
 128   def errors(conn, _e) do
 129     conn
 130     |> put_status(500)
 131     |> json("error")
 132   end
 133 end