Merge branch 'patch-README' into 'develop'
[akkoma] / lib / pleroma / web / activity_pub / activity_pub_controller.ex
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
7
8 require Logger
9
10 action_fallback :errors
11
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
15 conn
16 |> put_resp_header("content-type", "application/activity+json")
17 |> json(UserView.render("user.json", %{user: user}))
18 end
19 end
20
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
24 conn
25 |> put_resp_header("content-type", "application/activity+json")
26 |> json(ObjectView.render("object.json", %{object: object}))
27 end
28 end
29
30 # TODO: Ensure that this inbox is a recipient of the message
31 def inbox(%{assigns: %{valid_signature: true}} = conn, params) do
32 Federator.enqueue(:incoming_ap_doc, params)
33 json(conn, "ok")
34 end
35
36 def inbox(conn, params) do
37 headers = Enum.into(conn.req_headers, %{})
38 if !(String.contains?(headers["signature"] || "", params["actor"])) do
39 Logger.info("Signature not from author, relayed message, ignoring")
40 else
41 Logger.info("Signature error")
42 Logger.info("Could not validate #{params["actor"]}")
43 Logger.info(inspect(conn.req_headers))
44 end
45
46 json(conn, "ok")
47 end
48
49 def errors(conn, _e) do
50 conn
51 |> put_status(500)
52 |> json("error")
53 end
54 end