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
13 action_fallback(:errors)
15 plug(Pleroma.Web.FederatingPlug when action in [:inbox, :relay])
16 plug(:relay_active? when action in [:relay])
18 def relay_active?(conn, _) do
19 if Config.get([:instance, :allow_relay]) do
24 |> json(%{error: "not found"})
29 def user(conn, %{"nickname" => nickname}) do
30 with %User{} = user <- User.get_cached_by_nickname(nickname),
31 {:ok, user} <- Pleroma.Web.WebFinger.ensure_keys_present(user) do
33 |> put_resp_header("content-type", "application/activity+json")
34 |> json(UserView.render("user.json", %{user: user}))
36 nil -> {:error, :not_found}
40 def object(conn, %{"uuid" => uuid}) do
41 with ap_id <- o_status_url(conn, :object, uuid),
42 %Object{} = object <- Object.get_cached_by_ap_id(ap_id),
43 {_, true} <- {:public?, ActivityPub.is_public?(object)} do
45 |> put_resp_header("content-type", "application/activity+json")
46 |> json(ObjectView.render("object.json", %{object: object}))
53 def following(conn, %{"nickname" => nickname, "page" => page}) do
54 with %User{} = user <- User.get_cached_by_nickname(nickname),
55 {:ok, user} <- Pleroma.Web.WebFinger.ensure_keys_present(user) do
56 {page, _} = Integer.parse(page)
59 |> put_resp_header("content-type", "application/activity+json")
60 |> json(UserView.render("following.json", %{user: user, page: page}))
64 def following(conn, %{"nickname" => nickname}) do
65 with %User{} = user <- User.get_cached_by_nickname(nickname),
66 {:ok, user} <- Pleroma.Web.WebFinger.ensure_keys_present(user) do
68 |> put_resp_header("content-type", "application/activity+json")
69 |> json(UserView.render("following.json", %{user: user}))
73 def followers(conn, %{"nickname" => nickname, "page" => page}) do
74 with %User{} = user <- User.get_cached_by_nickname(nickname),
75 {:ok, user} <- Pleroma.Web.WebFinger.ensure_keys_present(user) do
76 {page, _} = Integer.parse(page)
79 |> put_resp_header("content-type", "application/activity+json")
80 |> json(UserView.render("followers.json", %{user: user, page: page}))
84 def followers(conn, %{"nickname" => nickname}) do
85 with %User{} = user <- User.get_cached_by_nickname(nickname),
86 {:ok, user} <- Pleroma.Web.WebFinger.ensure_keys_present(user) do
88 |> put_resp_header("content-type", "application/activity+json")
89 |> json(UserView.render("followers.json", %{user: user}))
93 def outbox(conn, %{"nickname" => nickname, "max_id" => max_id}) do
94 with %User{} = user <- User.get_cached_by_nickname(nickname),
95 {:ok, user} <- Pleroma.Web.WebFinger.ensure_keys_present(user) do
97 |> put_resp_header("content-type", "application/activity+json")
98 |> json(UserView.render("outbox.json", %{user: user, max_id: max_id}))
102 def outbox(conn, %{"nickname" => nickname}) do
103 outbox(conn, %{"nickname" => nickname, "max_id" => nil})
106 def inbox(%{assigns: %{valid_signature: true}} = conn, %{"nickname" => nickname} = params) do
107 with %User{} = user <- User.get_cached_by_nickname(nickname),
108 true <- Utils.recipient_in_message(user.ap_id, params),
109 params <- Utils.maybe_splice_recipient(user.ap_id, params) do
110 Federator.enqueue(:incoming_ap_doc, params)
115 def inbox(%{assigns: %{valid_signature: true}} = conn, params) do
116 Federator.enqueue(:incoming_ap_doc, params)
120 # only accept relayed Creates
121 def inbox(conn, %{"type" => "Create"} = params) do
123 "Signature missing or not from author, relayed Create message, fetching object from source"
126 ActivityPub.fetch_object_from_id(params["object"]["id"])
131 def inbox(conn, params) do
132 headers = Enum.into(conn.req_headers, %{})
134 if String.contains?(headers["signature"], params["actor"]) do
136 "Signature validation error for: #{params["actor"]}, make sure you are forwarding the HTTP Host header!"
139 Logger.info(inspect(conn.req_headers))
145 def relay(conn, params) do
146 with %User{} = user <- Relay.get_actor(),
147 {:ok, user} <- Pleroma.Web.WebFinger.ensure_keys_present(user) do
149 |> put_resp_header("content-type", "application/activity+json")
150 |> json(UserView.render("user.json", %{user: user}))
152 nil -> {:error, :not_found}
156 def errors(conn, {:error, :not_found}) do
162 def errors(conn, _e) do