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