1 # Pleroma: A lightweight social networking server
2 # Copyright © 2017-2019 Pleroma Authors <https://pleroma.social/>
3 # SPDX-License-Identifier: AGPL-3.0-only
5 defmodule Pleroma.Web.ActivityPub.ActivityPubController do
6 use Pleroma.Web, :controller
7 alias Pleroma.{Activity, User, Object}
8 alias Pleroma.Web.ActivityPub.{ObjectView, UserView}
9 alias Pleroma.Web.ActivityPub.ActivityPub
10 alias Pleroma.Web.ActivityPub.Relay
11 alias Pleroma.Web.ActivityPub.Utils
12 alias Pleroma.Web.ActivityPub.Transmogrifier
13 alias Pleroma.Web.Federator
17 action_fallback(:errors)
19 plug(Pleroma.Web.FederatingPlug when action in [:inbox, :relay])
20 plug(:relay_active? when action in [:relay])
22 def relay_active?(conn, _) do
23 if Keyword.get(Application.get_env(:pleroma, :instance), :allow_relay) do
28 |> json(%{error: "not found"})
33 def user(conn, %{"nickname" => nickname}) do
34 with %User{} = user <- User.get_cached_by_nickname(nickname),
35 {:ok, user} <- Pleroma.Web.WebFinger.ensure_keys_present(user) do
37 |> put_resp_header("content-type", "application/activity+json")
38 |> json(UserView.render("user.json", %{user: user}))
40 nil -> {:error, :not_found}
44 def object(conn, %{"uuid" => uuid}) do
45 with ap_id <- o_status_url(conn, :object, uuid),
46 %Object{} = object <- Object.get_cached_by_ap_id(ap_id),
47 {_, true} <- {:public?, ActivityPub.is_public?(object)} do
49 |> put_resp_header("content-type", "application/activity+json")
50 |> json(ObjectView.render("object.json", %{object: object}))
57 def object_likes(conn, %{"uuid" => uuid, "page" => page}) do
58 with ap_id <- o_status_url(conn, :object, uuid),
59 %Object{} = object <- Object.get_cached_by_ap_id(ap_id),
60 {_, true} <- {:public?, ActivityPub.is_public?(object)},
61 likes <- Utils.get_object_likes(object) do
62 {page, _} = Integer.parse(page)
65 |> put_resp_header("content-type", "application/activity+json")
66 |> json(ObjectView.render("likes.json", ap_id, likes, page))
73 def object_likes(conn, %{"uuid" => uuid}) do
74 with ap_id <- o_status_url(conn, :object, uuid),
75 %Object{} = object <- Object.get_cached_by_ap_id(ap_id),
76 {_, true} <- {:public?, ActivityPub.is_public?(object)},
77 likes <- Utils.get_object_likes(object) do
79 |> put_resp_header("content-type", "application/activity+json")
80 |> json(ObjectView.render("likes.json", ap_id, likes))
87 def activity(conn, %{"uuid" => uuid}) do
88 with ap_id <- o_status_url(conn, :activity, uuid),
89 %Activity{} = activity <- Activity.normalize(ap_id),
90 {_, true} <- {:public?, ActivityPub.is_public?(activity)} do
92 |> put_resp_header("content-type", "application/activity+json")
93 |> json(ObjectView.render("object.json", %{object: activity}))
100 def following(conn, %{"nickname" => nickname, "page" => page}) do
101 with %User{} = user <- User.get_cached_by_nickname(nickname),
102 {:ok, user} <- Pleroma.Web.WebFinger.ensure_keys_present(user) do
103 {page, _} = Integer.parse(page)
106 |> put_resp_header("content-type", "application/activity+json")
107 |> json(UserView.render("following.json", %{user: user, page: page}))
111 def following(conn, %{"nickname" => nickname}) do
112 with %User{} = user <- User.get_cached_by_nickname(nickname),
113 {:ok, user} <- Pleroma.Web.WebFinger.ensure_keys_present(user) do
115 |> put_resp_header("content-type", "application/activity+json")
116 |> json(UserView.render("following.json", %{user: user}))
120 def followers(conn, %{"nickname" => nickname, "page" => page}) do
121 with %User{} = user <- User.get_cached_by_nickname(nickname),
122 {:ok, user} <- Pleroma.Web.WebFinger.ensure_keys_present(user) do
123 {page, _} = Integer.parse(page)
126 |> put_resp_header("content-type", "application/activity+json")
127 |> json(UserView.render("followers.json", %{user: user, page: page}))
131 def followers(conn, %{"nickname" => nickname}) do
132 with %User{} = user <- User.get_cached_by_nickname(nickname),
133 {:ok, user} <- Pleroma.Web.WebFinger.ensure_keys_present(user) do
135 |> put_resp_header("content-type", "application/activity+json")
136 |> json(UserView.render("followers.json", %{user: user}))
140 def outbox(conn, %{"nickname" => nickname} = params) do
141 with %User{} = user <- User.get_cached_by_nickname(nickname),
142 {:ok, user} <- Pleroma.Web.WebFinger.ensure_keys_present(user) do
144 |> put_resp_header("content-type", "application/activity+json")
145 |> json(UserView.render("outbox.json", %{user: user, max_id: params["max_id"]}))
149 def inbox(%{assigns: %{valid_signature: true}} = conn, %{"nickname" => nickname} = params) do
150 with %User{} = user <- User.get_cached_by_nickname(nickname),
151 true <- Utils.recipient_in_message(user.ap_id, params),
152 params <- Utils.maybe_splice_recipient(user.ap_id, params) do
153 Federator.enqueue(:incoming_ap_doc, params)
158 def inbox(%{assigns: %{valid_signature: true}} = conn, params) do
159 Federator.enqueue(:incoming_ap_doc, params)
163 # only accept relayed Creates
164 def inbox(conn, %{"type" => "Create"} = params) do
166 "Signature missing or not from author, relayed Create message, fetching object from source"
169 ActivityPub.fetch_object_from_id(params["object"]["id"])
174 def inbox(conn, params) do
175 headers = Enum.into(conn.req_headers, %{})
177 if String.contains?(headers["signature"], params["actor"]) do
179 "Signature validation error for: #{params["actor"]}, make sure you are forwarding the HTTP Host header!"
182 Logger.info(inspect(conn.req_headers))
188 def relay(conn, _params) do
189 with %User{} = user <- Relay.get_actor(),
190 {:ok, user} <- Pleroma.Web.WebFinger.ensure_keys_present(user) do
192 |> put_resp_header("content-type", "application/activity+json")
193 |> json(UserView.render("user.json", %{user: user}))
195 nil -> {:error, :not_found}
199 def read_inbox(%{assigns: %{user: user}} = conn, %{"nickname" => nickname} = params) do
200 if nickname == user.nickname do
202 |> put_resp_header("content-type", "application/activity+json")
203 |> json(UserView.render("inbox.json", %{user: user, max_id: params["max_id"]}))
206 |> put_status(:forbidden)
207 |> json("can't read inbox of #{nickname} as #{user.nickname}")
211 def handle_user_activity(user, %{"type" => "Create"} = params) do
214 |> Map.merge(Map.take(params, ["to", "cc"]))
215 |> Map.put("attributedTo", user.ap_id())
216 |> Transmogrifier.fix_object()
218 ActivityPub.create(%{
221 context: object["context"],
223 additional: Map.take(params, ["cc"])
227 def handle_user_activity(user, %{"type" => "Delete"} = params) do
228 with %Object{} = object <- Object.normalize(params["object"]),
229 true <- user.info.is_moderator || user.ap_id == object.data["actor"],
230 {:ok, delete} <- ActivityPub.delete(object) do
233 _ -> {:error, "Can't delete object"}
237 def handle_user_activity(user, %{"type" => "Like"} = params) do
238 with %Object{} = object <- Object.normalize(params["object"]),
239 {:ok, activity, _object} <- ActivityPub.like(user, object) do
242 _ -> {:error, "Can't like object"}
246 def handle_user_activity(_, _) do
247 {:error, "Unhandled activity type"}
251 %{assigns: %{user: user}} = conn,
252 %{"nickname" => nickname} = params
254 if nickname == user.nickname do
260 |> Map.put("actor", actor)
261 |> Transmogrifier.fix_addressing()
263 with {:ok, %Activity{} = activity} <- handle_user_activity(user, params) do
265 |> put_status(:created)
266 |> put_resp_header("location", activity.data["id"])
267 |> json(activity.data)
271 |> put_status(:bad_request)
276 |> put_status(:forbidden)
277 |> json("can't update outbox of #{nickname} as #{user.nickname}")
281 def errors(conn, {:error, :not_found}) do
287 def errors(conn, _e) do