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
11 action_fallback(:errors)
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
17 |> put_resp_header("content-type", "application/activity+json")
18 |> json(UserView.render("user.json", %{user: user}))
20 nil -> {:error, :not_found}
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
29 |> put_resp_header("content-type", "application/activity+json")
30 |> json(ObjectView.render("object.json", %{object: object}))
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)
43 |> put_resp_header("content-type", "application/activity+json")
44 |> json(UserView.render("following.json", %{user: user, page: page}))
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
52 |> put_resp_header("content-type", "application/activity+json")
53 |> json(UserView.render("following.json", %{user: user}))
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)
63 |> put_resp_header("content-type", "application/activity+json")
64 |> json(UserView.render("followers.json", %{user: user, page: page}))
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
72 |> put_resp_header("content-type", "application/activity+json")
73 |> json(UserView.render("followers.json", %{user: user}))
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
81 |> put_resp_header("content-type", "application/activity+json")
82 |> json(UserView.render("outbox.json", %{user: user, max_id: max_id}))
86 def outbox(conn, %{"nickname" => nickname}) do
87 outbox(conn, %{"nickname" => nickname, "max_id" => nil})
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)
96 # only accept relayed Creates
97 def inbox(conn, %{"type" => "Create"} = params) do
99 "Signature missing or not from author, relayed Create message, fetching object from source"
102 ActivityPub.fetch_object_from_id(params["object"]["id"])
107 def inbox(conn, params) do
108 headers = Enum.into(conn.req_headers, %{})
110 if String.contains?(headers["signature"], params["actor"]) do
112 "Signature validation error for: #{params["actor"]}, make sure you are forwarding the HTTP Host header!"
115 Logger.info(inspect(conn.req_headers))
121 def relay(conn, params) do
122 with %User{} = user <- Relay.get_actor(),
123 {:ok, user} <- Pleroma.Web.WebFinger.ensure_keys_present(user) do
125 |> put_resp_header("content-type", "application/activity+json")
126 |> json(UserView.render("user.json", %{user: user}))
128 nil -> {:error, :not_found}
132 def errors(conn, {:error, :not_found}) do
138 def errors(conn, _e) do