1 defmodule Pleroma.Web.ActivityPub.ActivityPubController do
2 use Pleroma.Web, :controller
3 alias Pleroma.{User, Repo, Object, Activity}
4 alias Pleroma.Web.ActivityPub.{ObjectView, UserView, Transmogrifier}
5 alias Pleroma.Web.ActivityPub.ActivityPub
6 alias Pleroma.Web.Federator
10 action_fallback :errors
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
16 |> put_resp_header("content-type", "application/activity+json")
17 |> json(UserView.render("user.json", %{user: user}))
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) do
25 |> put_resp_header("content-type", "application/activity+json")
26 |> json(ObjectView.render("object.json", %{object: object}))
30 def following(conn, %{"nickname" => nickname, "page" => page}) do
31 with %User{} = user <- User.get_cached_by_nickname(nickname),
32 {:ok, user} <- Pleroma.Web.WebFinger.ensure_keys_present(user) do
33 {page, _} = Integer.parse(page)
35 |> put_resp_header("content-type", "application/activity+json")
36 |> json(UserView.render("following.json", %{user: user, page: page}))
40 def following(conn, %{"nickname" => nickname}) do
41 with %User{} = user <- User.get_cached_by_nickname(nickname),
42 {:ok, user} <- Pleroma.Web.WebFinger.ensure_keys_present(user) do
44 |> put_resp_header("content-type", "application/activity+json")
45 |> json(UserView.render("following.json", %{user: user}))
49 def followers(conn, %{"nickname" => nickname, "page" => page}) do
50 with %User{} = user <- User.get_cached_by_nickname(nickname),
51 {:ok, user} <- Pleroma.Web.WebFinger.ensure_keys_present(user) do
52 {page, _} = Integer.parse(page)
54 |> put_resp_header("content-type", "application/activity+json")
55 |> json(UserView.render("followers.json", %{user: user, page: page}))
59 def followers(conn, %{"nickname" => nickname}) do
60 with %User{} = user <- User.get_cached_by_nickname(nickname),
61 {:ok, user} <- Pleroma.Web.WebFinger.ensure_keys_present(user) do
63 |> put_resp_header("content-type", "application/activity+json")
64 |> json(UserView.render("followers.json", %{user: user}))
68 # TODO: Ensure that this inbox is a recipient of the message
69 def inbox(%{assigns: %{valid_signature: true}} = conn, params) do
70 Federator.enqueue(:incoming_ap_doc, params)
74 def inbox(conn, params) do
75 headers = Enum.into(conn.req_headers, %{})
76 if !(String.contains?(headers["signature"] || "", params["actor"])) do
77 Logger.info("Signature not from author, relayed message, fetching from source")
78 ActivityPub.fetch_object_from_id(params["object"]["id"])
80 Logger.info("Signature error")
81 Logger.info("Could not validate #{params["actor"]}")
82 Logger.info(inspect(conn.req_headers))
88 def errors(conn, _e) do