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.ActivityPub.Utils
8 alias Pleroma.Web.Federator
12 action_fallback(:errors)
14 plug(Pleroma.Web.FederatingPlug when action in [:inbox, :relay])
15 plug(:relay_active? when action in [:relay])
17 def relay_active?(conn, _) do
18 if Keyword.get(Application.get_env(:pleroma, :instance), :allow_relay) do
23 |> json(%{error: "not found"})
28 def user(conn, %{"nickname" => nickname}) do
29 with %User{} = user <- User.get_cached_by_nickname(nickname),
30 {:ok, user} <- Pleroma.Web.WebFinger.ensure_keys_present(user) do
32 |> put_resp_header("content-type", "application/activity+json")
33 |> json(UserView.render("user.json", %{user: user}))
35 nil -> {:error, :not_found}
39 def object(conn, %{"uuid" => uuid}) do
40 with ap_id <- o_status_url(conn, :object, uuid),
41 %Object{} = object <- Object.get_cached_by_ap_id(ap_id),
42 {_, true} <- {:public?, ActivityPub.is_public?(object)} do
44 |> put_resp_header("content-type", "application/activity+json")
45 |> json(ObjectView.render("object.json", %{object: object}))
52 def following(conn, %{"nickname" => nickname, "page" => page}) do
53 with %User{} = user <- User.get_cached_by_nickname(nickname),
54 {:ok, user} <- Pleroma.Web.WebFinger.ensure_keys_present(user) do
55 {page, _} = Integer.parse(page)
58 |> put_resp_header("content-type", "application/activity+json")
59 |> json(UserView.render("following.json", %{user: user, page: page}))
63 def following(conn, %{"nickname" => nickname}) do
64 with %User{} = user <- User.get_cached_by_nickname(nickname),
65 {:ok, user} <- Pleroma.Web.WebFinger.ensure_keys_present(user) do
67 |> put_resp_header("content-type", "application/activity+json")
68 |> json(UserView.render("following.json", %{user: user}))
72 def followers(conn, %{"nickname" => nickname, "page" => page}) do
73 with %User{} = user <- User.get_cached_by_nickname(nickname),
74 {:ok, user} <- Pleroma.Web.WebFinger.ensure_keys_present(user) do
75 {page, _} = Integer.parse(page)
78 |> put_resp_header("content-type", "application/activity+json")
79 |> json(UserView.render("followers.json", %{user: user, page: page}))
83 def followers(conn, %{"nickname" => nickname}) do
84 with %User{} = user <- User.get_cached_by_nickname(nickname),
85 {:ok, user} <- Pleroma.Web.WebFinger.ensure_keys_present(user) do
87 |> put_resp_header("content-type", "application/activity+json")
88 |> json(UserView.render("followers.json", %{user: user}))
92 def outbox(conn, %{"nickname" => nickname, "max_id" => max_id}) do
93 with %User{} = user <- User.get_cached_by_nickname(nickname),
94 {:ok, user} <- Pleroma.Web.WebFinger.ensure_keys_present(user) do
96 |> put_resp_header("content-type", "application/activity+json")
97 |> json(UserView.render("outbox.json", %{user: user, max_id: max_id}))
101 def outbox(conn, %{"nickname" => nickname}) do
102 outbox(conn, %{"nickname" => nickname, "max_id" => nil})
105 def inbox(%{assigns: %{valid_signature: true}} = conn, %{"nickname" => nickname} = params) do
106 with %User{} = user <- User.get_cached_by_nickname(nickname),
107 true <- Utils.recipient_in_message(user.ap_id, params),
108 params <- Utils.maybe_splice_recipient(user.ap_id, params) do
109 Federator.enqueue(:incoming_ap_doc, params)
114 def inbox(%{assigns: %{valid_signature: true}} = conn, params) do
115 Federator.enqueue(:incoming_ap_doc, params)
119 # only accept relayed Creates
120 def inbox(conn, %{"type" => "Create"} = params) do
122 "Signature missing or not from author, relayed Create message, fetching object from source"
125 ActivityPub.fetch_object_from_id(params["object"]["id"])
130 def inbox(conn, params) do
131 headers = Enum.into(conn.req_headers, %{})
133 if String.contains?(headers["signature"], params["actor"]) do
135 "Signature validation error for: #{params["actor"]}, make sure you are forwarding the HTTP Host header!"
138 Logger.info(inspect(conn.req_headers))
144 def relay(conn, params) do
145 with %User{} = user <- Relay.get_actor(),
146 {:ok, user} <- Pleroma.Web.WebFinger.ensure_keys_present(user) do
148 |> put_resp_header("content-type", "application/activity+json")
149 |> json(UserView.render("user.json", %{user: user}))
151 nil -> {:error, :not_found}
155 def errors(conn, {:error, :not_found}) do
161 def errors(conn, _e) do