2018-12-23 21:04:54 +01:00
|
|
|
# Pleroma: A lightweight social networking server
|
2018-12-31 16:41:47 +01:00
|
|
|
# Copyright © 2017-2019 Pleroma Authors <https://pleroma.social/>
|
2018-12-23 21:04:54 +01:00
|
|
|
# SPDX-License-Identifier: AGPL-3.0-only
|
|
|
|
|
2017-12-11 10:37:22 +01:00
|
|
|
defmodule Pleroma.Web.ActivityPub.ActivityPubController do
|
|
|
|
use Pleroma.Web, :controller
|
2019-01-24 15:37:23 +01:00
|
|
|
|
2019-02-09 16:16:26 +01:00
|
|
|
alias Pleroma.Activity
|
|
|
|
alias Pleroma.Object
|
2018-12-01 23:53:10 +01:00
|
|
|
alias Pleroma.Object.Fetcher
|
2019-03-05 03:52:23 +01:00
|
|
|
alias Pleroma.User
|
2017-12-11 10:37:22 +01:00
|
|
|
alias Pleroma.Web.ActivityPub.ActivityPub
|
2019-07-17 19:34:57 +02:00
|
|
|
alias Pleroma.Web.ActivityPub.InternalFetchActor
|
2019-03-05 03:52:23 +01:00
|
|
|
alias Pleroma.Web.ActivityPub.ObjectView
|
2018-08-06 08:15:22 +02:00
|
|
|
alias Pleroma.Web.ActivityPub.Relay
|
2018-12-29 18:21:45 +01:00
|
|
|
alias Pleroma.Web.ActivityPub.Transmogrifier
|
2019-03-05 03:52:23 +01:00
|
|
|
alias Pleroma.Web.ActivityPub.UserView
|
2018-10-25 07:02:21 +02:00
|
|
|
alias Pleroma.Web.ActivityPub.Utils
|
2019-03-05 03:52:23 +01:00
|
|
|
alias Pleroma.Web.ActivityPub.Visibility
|
2018-02-21 08:51:03 +01:00
|
|
|
alias Pleroma.Web.Federator
|
2017-12-11 10:37:22 +01:00
|
|
|
|
2018-02-18 12:51:35 +01:00
|
|
|
require Logger
|
|
|
|
|
2018-03-30 15:01:53 +02:00
|
|
|
action_fallback(:errors)
|
2018-02-15 20:00:43 +01:00
|
|
|
|
2019-09-09 20:53:08 +02:00
|
|
|
plug(Pleroma.Plugs.Cache, [query_params: false] when action in [:activity, :object])
|
2018-11-05 15:19:03 +01:00
|
|
|
plug(Pleroma.Web.FederatingPlug when action in [:inbox, :relay])
|
2019-01-29 11:12:28 +01:00
|
|
|
plug(:set_requester_reachable when action in [:inbox])
|
2018-09-08 14:02:38 +02:00
|
|
|
plug(:relay_active? when action in [:relay])
|
|
|
|
|
|
|
|
def relay_active?(conn, _) do
|
2019-05-30 10:33:58 +02:00
|
|
|
if Pleroma.Config.get([:instance, :allow_relay]) do
|
2018-09-08 14:02:38 +02:00
|
|
|
conn
|
|
|
|
else
|
|
|
|
conn
|
2019-07-10 11:25:58 +02:00
|
|
|
|> render_error(:not_found, "not found")
|
|
|
|
|> halt()
|
2018-09-08 14:02:38 +02:00
|
|
|
end
|
|
|
|
end
|
|
|
|
|
2017-12-11 10:37:22 +01:00
|
|
|
def user(conn, %{"nickname" => nickname}) do
|
2017-12-11 18:21:33 +01:00
|
|
|
with %User{} = user <- User.get_cached_by_nickname(nickname),
|
2019-05-22 05:58:15 +02:00
|
|
|
{:ok, user} <- User.ensure_keys_present(user) do
|
2018-02-24 12:49:56 +01:00
|
|
|
conn
|
2019-08-24 16:17:17 +02:00
|
|
|
|> put_resp_content_type("application/activity+json")
|
2018-02-24 12:49:56 +01:00
|
|
|
|> json(UserView.render("user.json", %{user: user}))
|
2018-06-08 06:23:30 +02:00
|
|
|
else
|
|
|
|
nil -> {:error, :not_found}
|
2017-12-11 10:37:22 +01:00
|
|
|
end
|
|
|
|
end
|
|
|
|
|
2017-12-11 18:21:33 +01:00
|
|
|
def object(conn, %{"uuid" => uuid}) do
|
|
|
|
with ap_id <- o_status_url(conn, :object, uuid),
|
2018-05-30 20:00:27 +02:00
|
|
|
%Object{} = object <- Object.get_cached_by_ap_id(ap_id),
|
2019-02-22 13:29:52 +01:00
|
|
|
{_, true} <- {:public?, Visibility.is_public?(object)} do
|
2018-02-24 12:49:56 +01:00
|
|
|
conn
|
2019-09-09 20:53:08 +02:00
|
|
|
|> set_cache_ttl_for(object)
|
2019-08-24 16:17:17 +02:00
|
|
|
|> put_resp_content_type("application/activity+json")
|
2019-09-09 20:53:08 +02:00
|
|
|
|> put_view(ObjectView)
|
|
|
|
|> render("object.json", object: object)
|
2018-05-30 20:00:27 +02:00
|
|
|
else
|
|
|
|
{:public?, false} ->
|
2018-06-03 19:58:59 +02:00
|
|
|
{:error, :not_found}
|
2017-12-11 18:21:33 +01:00
|
|
|
end
|
|
|
|
end
|
|
|
|
|
2019-01-11 23:34:32 +01:00
|
|
|
def object_likes(conn, %{"uuid" => uuid, "page" => page}) do
|
|
|
|
with ap_id <- o_status_url(conn, :object, uuid),
|
|
|
|
%Object{} = object <- Object.get_cached_by_ap_id(ap_id),
|
2019-02-22 13:29:52 +01:00
|
|
|
{_, true} <- {:public?, Visibility.is_public?(object)},
|
2019-01-11 23:34:32 +01:00
|
|
|
likes <- Utils.get_object_likes(object) do
|
|
|
|
{page, _} = Integer.parse(page)
|
|
|
|
|
|
|
|
conn
|
2019-08-24 16:17:17 +02:00
|
|
|
|> put_resp_content_type("application/activity+json")
|
2019-01-11 23:34:32 +01:00
|
|
|
|> json(ObjectView.render("likes.json", ap_id, likes, page))
|
|
|
|
else
|
|
|
|
{:public?, false} ->
|
|
|
|
{:error, :not_found}
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
|
|
|
def object_likes(conn, %{"uuid" => uuid}) do
|
|
|
|
with ap_id <- o_status_url(conn, :object, uuid),
|
|
|
|
%Object{} = object <- Object.get_cached_by_ap_id(ap_id),
|
2019-02-22 13:29:52 +01:00
|
|
|
{_, true} <- {:public?, Visibility.is_public?(object)},
|
2019-01-11 23:34:32 +01:00
|
|
|
likes <- Utils.get_object_likes(object) do
|
|
|
|
conn
|
2019-08-24 16:17:17 +02:00
|
|
|
|> put_resp_content_type("application/activity+json")
|
2019-01-11 23:34:32 +01:00
|
|
|
|> json(ObjectView.render("likes.json", ap_id, likes))
|
|
|
|
else
|
|
|
|
{:public?, false} ->
|
|
|
|
{:error, :not_found}
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
2019-01-08 23:22:15 +01:00
|
|
|
def activity(conn, %{"uuid" => uuid}) do
|
|
|
|
with ap_id <- o_status_url(conn, :activity, uuid),
|
|
|
|
%Activity{} = activity <- Activity.normalize(ap_id),
|
2019-02-22 13:29:52 +01:00
|
|
|
{_, true} <- {:public?, Visibility.is_public?(activity)} do
|
2019-01-08 23:22:15 +01:00
|
|
|
conn
|
2019-09-09 20:53:08 +02:00
|
|
|
|> set_cache_ttl_for(activity)
|
2019-08-24 16:17:17 +02:00
|
|
|
|> put_resp_content_type("application/activity+json")
|
2019-09-09 20:53:08 +02:00
|
|
|
|> put_view(ObjectView)
|
|
|
|
|> render("object.json", object: activity)
|
2019-01-08 23:22:15 +01:00
|
|
|
else
|
2019-09-09 20:53:08 +02:00
|
|
|
{:public?, false} -> {:error, :not_found}
|
|
|
|
nil -> {:error, :not_found}
|
2019-01-08 23:22:15 +01:00
|
|
|
end
|
|
|
|
end
|
|
|
|
|
2019-09-09 20:53:08 +02:00
|
|
|
defp set_cache_ttl_for(conn, %Activity{object: object}) do
|
|
|
|
set_cache_ttl_for(conn, object)
|
|
|
|
end
|
|
|
|
|
|
|
|
defp set_cache_ttl_for(conn, entity) do
|
|
|
|
ttl =
|
|
|
|
case entity do
|
|
|
|
%Object{data: %{"type" => "Question"}} ->
|
|
|
|
Pleroma.Config.get([:web_cache_ttl, :activity_pub_question])
|
|
|
|
|
|
|
|
%Object{} ->
|
|
|
|
Pleroma.Config.get([:web_cache_ttl, :activity_pub])
|
|
|
|
|
|
|
|
_ ->
|
|
|
|
nil
|
|
|
|
end
|
|
|
|
|
|
|
|
assign(conn, :cache_ttl, ttl)
|
|
|
|
end
|
|
|
|
|
2019-08-22 05:57:55 +02:00
|
|
|
# GET /relay/following
|
|
|
|
def following(%{assigns: %{relay: true}} = conn, _params) do
|
|
|
|
conn
|
2019-08-24 16:17:17 +02:00
|
|
|
|> put_resp_content_type("application/activity+json")
|
2019-08-22 05:57:55 +02:00
|
|
|
|> json(UserView.render("following.json", %{user: Relay.get_actor()}))
|
|
|
|
end
|
|
|
|
|
2019-07-12 19:54:20 +02:00
|
|
|
def following(%{assigns: %{user: for_user}} = conn, %{"nickname" => nickname, "page" => page}) do
|
2018-03-21 18:23:27 +01:00
|
|
|
with %User{} = user <- User.get_cached_by_nickname(nickname),
|
2019-07-12 19:54:20 +02:00
|
|
|
{user, for_user} <- ensure_user_keys_present_and_maybe_refresh_for_user(user, for_user),
|
|
|
|
{:show_follows, true} <-
|
|
|
|
{:show_follows, (for_user && for_user == user) || !user.info.hide_follows} do
|
2018-03-21 18:23:27 +01:00
|
|
|
{page, _} = Integer.parse(page)
|
2018-03-30 15:01:53 +02:00
|
|
|
|
2018-03-21 18:23:27 +01:00
|
|
|
conn
|
2019-08-24 16:17:17 +02:00
|
|
|
|> put_resp_content_type("application/activity+json")
|
2019-07-12 19:54:20 +02:00
|
|
|
|> json(UserView.render("following.json", %{user: user, page: page, for: for_user}))
|
|
|
|
else
|
|
|
|
{:show_follows, _} ->
|
|
|
|
conn
|
2019-08-24 16:17:17 +02:00
|
|
|
|> put_resp_content_type("application/activity+json")
|
2019-07-12 19:54:20 +02:00
|
|
|
|> send_resp(403, "")
|
2018-03-21 18:23:27 +01:00
|
|
|
end
|
|
|
|
end
|
|
|
|
|
2019-07-12 19:54:20 +02:00
|
|
|
def following(%{assigns: %{user: for_user}} = conn, %{"nickname" => nickname}) do
|
2018-03-21 18:23:27 +01:00
|
|
|
with %User{} = user <- User.get_cached_by_nickname(nickname),
|
2019-07-12 19:54:20 +02:00
|
|
|
{user, for_user} <- ensure_user_keys_present_and_maybe_refresh_for_user(user, for_user) do
|
2018-03-21 18:23:27 +01:00
|
|
|
conn
|
2019-08-24 16:17:17 +02:00
|
|
|
|> put_resp_content_type("application/activity+json")
|
2019-07-12 19:54:20 +02:00
|
|
|
|> json(UserView.render("following.json", %{user: user, for: for_user}))
|
2018-03-21 18:23:27 +01:00
|
|
|
end
|
|
|
|
end
|
|
|
|
|
2019-08-22 05:57:55 +02:00
|
|
|
# GET /relay/followers
|
|
|
|
def followers(%{assigns: %{relay: true}} = conn, _params) do
|
|
|
|
conn
|
2019-08-24 16:17:17 +02:00
|
|
|
|> put_resp_content_type("application/activity+json")
|
2019-08-22 05:57:55 +02:00
|
|
|
|> json(UserView.render("followers.json", %{user: Relay.get_actor()}))
|
|
|
|
end
|
|
|
|
|
2019-07-12 19:54:20 +02:00
|
|
|
def followers(%{assigns: %{user: for_user}} = conn, %{"nickname" => nickname, "page" => page}) do
|
2018-03-21 18:23:27 +01:00
|
|
|
with %User{} = user <- User.get_cached_by_nickname(nickname),
|
2019-07-12 19:54:20 +02:00
|
|
|
{user, for_user} <- ensure_user_keys_present_and_maybe_refresh_for_user(user, for_user),
|
|
|
|
{:show_followers, true} <-
|
|
|
|
{:show_followers, (for_user && for_user == user) || !user.info.hide_followers} do
|
2018-03-21 18:23:27 +01:00
|
|
|
{page, _} = Integer.parse(page)
|
2018-03-30 15:01:53 +02:00
|
|
|
|
2018-03-21 18:23:27 +01:00
|
|
|
conn
|
2019-08-24 16:17:17 +02:00
|
|
|
|> put_resp_content_type("application/activity+json")
|
2019-07-12 19:54:20 +02:00
|
|
|
|> json(UserView.render("followers.json", %{user: user, page: page, for: for_user}))
|
|
|
|
else
|
|
|
|
{:show_followers, _} ->
|
|
|
|
conn
|
2019-08-24 16:17:17 +02:00
|
|
|
|> put_resp_content_type("application/activity+json")
|
2019-07-12 19:54:20 +02:00
|
|
|
|> send_resp(403, "")
|
2018-03-21 18:23:27 +01:00
|
|
|
end
|
|
|
|
end
|
|
|
|
|
2019-07-12 19:54:20 +02:00
|
|
|
def followers(%{assigns: %{user: for_user}} = conn, %{"nickname" => nickname}) do
|
2018-03-21 18:23:27 +01:00
|
|
|
with %User{} = user <- User.get_cached_by_nickname(nickname),
|
2019-07-12 19:54:20 +02:00
|
|
|
{user, for_user} <- ensure_user_keys_present_and_maybe_refresh_for_user(user, for_user) do
|
2018-03-21 18:23:27 +01:00
|
|
|
conn
|
2019-08-24 16:17:17 +02:00
|
|
|
|> put_resp_content_type("application/activity+json")
|
2019-07-12 19:54:20 +02:00
|
|
|
|> json(UserView.render("followers.json", %{user: user, for: for_user}))
|
2018-03-21 18:23:27 +01:00
|
|
|
end
|
|
|
|
end
|
|
|
|
|
2019-09-25 14:59:04 +02:00
|
|
|
def outbox(conn, %{"nickname" => nickname, "page" => page?} = params)
|
|
|
|
when page? in [true, "true"] do
|
|
|
|
with %User{} = user <- User.get_cached_by_nickname(nickname),
|
2019-09-25 15:20:48 +02:00
|
|
|
{:ok, user} <- User.ensure_keys_present(user) do
|
|
|
|
activities =
|
|
|
|
if params["max_id"] do
|
|
|
|
ActivityPub.fetch_user_activities(user, nil, %{
|
|
|
|
"max_id" => params["max_id"],
|
2019-09-25 15:36:46 +02:00
|
|
|
# This is a hack because postgres generates inefficient queries when filtering by
|
|
|
|
# 'Answer', poll votes will be hidden by the visibility filter in this case anyway
|
2019-09-25 15:20:48 +02:00
|
|
|
"include_poll_votes" => true,
|
|
|
|
"limit" => 10
|
|
|
|
})
|
|
|
|
else
|
|
|
|
ActivityPub.fetch_user_activities(user, nil, %{
|
|
|
|
"limit" => 10,
|
|
|
|
"include_poll_votes" => true
|
|
|
|
})
|
|
|
|
end
|
|
|
|
|
2019-09-25 14:59:04 +02:00
|
|
|
conn
|
|
|
|
|> put_resp_content_type("application/activity+json")
|
|
|
|
|> put_view(UserView)
|
|
|
|
|> render("activity_collection_page.json", %{
|
|
|
|
activities: activities,
|
|
|
|
iri: "#{user.ap_id}/outbox"
|
|
|
|
})
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
|
|
|
def outbox(conn, %{"nickname" => nickname}) do
|
2018-03-22 06:23:05 +01:00
|
|
|
with %User{} = user <- User.get_cached_by_nickname(nickname),
|
2019-05-22 05:58:15 +02:00
|
|
|
{:ok, user} <- User.ensure_keys_present(user) do
|
2018-03-22 06:23:05 +01:00
|
|
|
conn
|
2019-08-24 16:17:17 +02:00
|
|
|
|> put_resp_content_type("application/activity+json")
|
2019-09-25 14:59:04 +02:00
|
|
|
|> put_view(UserView)
|
|
|
|
|> render("activity_collection.json", %{iri: "#{user.ap_id}/outbox"})
|
2018-03-22 06:23:05 +01:00
|
|
|
end
|
|
|
|
end
|
|
|
|
|
2018-10-25 07:02:21 +02:00
|
|
|
def inbox(%{assigns: %{valid_signature: true}} = conn, %{"nickname" => nickname} = params) do
|
2019-04-16 20:10:15 +02:00
|
|
|
with %User{} = recipient <- User.get_cached_by_nickname(nickname),
|
2019-05-01 11:09:53 +02:00
|
|
|
{:ok, %User{} = actor} <- User.get_or_fetch_by_ap_id(params["actor"]),
|
2019-04-16 20:10:15 +02:00
|
|
|
true <- Utils.recipient_in_message(recipient, actor, params),
|
|
|
|
params <- Utils.maybe_splice_recipient(recipient.ap_id, params) do
|
2019-01-28 16:17:17 +01:00
|
|
|
Federator.incoming_ap_doc(params)
|
2018-10-25 07:02:21 +02:00
|
|
|
json(conn, "ok")
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
2017-12-12 10:17:50 +01:00
|
|
|
def inbox(%{assigns: %{valid_signature: true}} = conn, params) do
|
2019-01-28 16:17:17 +01:00
|
|
|
Federator.incoming_ap_doc(params)
|
2018-02-21 08:51:03 +01:00
|
|
|
json(conn, "ok")
|
2017-12-11 10:37:22 +01:00
|
|
|
end
|
2018-02-15 20:00:43 +01:00
|
|
|
|
2018-09-28 02:01:54 +02:00
|
|
|
# only accept relayed Creates
|
|
|
|
def inbox(conn, %{"type" => "Create"} = params) do
|
|
|
|
Logger.info(
|
|
|
|
"Signature missing or not from author, relayed Create message, fetching object from source"
|
|
|
|
)
|
|
|
|
|
2018-12-01 23:53:10 +01:00
|
|
|
Fetcher.fetch_object_from_id(params["object"]["id"])
|
2018-09-28 02:01:54 +02:00
|
|
|
|
|
|
|
json(conn, "ok")
|
|
|
|
end
|
|
|
|
|
2018-02-18 22:40:08 +01:00
|
|
|
def inbox(conn, params) do
|
2018-02-24 18:49:09 +01:00
|
|
|
headers = Enum.into(conn.req_headers, %{})
|
2018-03-30 15:01:53 +02:00
|
|
|
|
2018-09-28 02:01:54 +02:00
|
|
|
if String.contains?(headers["signature"], params["actor"]) do
|
|
|
|
Logger.info(
|
|
|
|
"Signature validation error for: #{params["actor"]}, make sure you are forwarding the HTTP Host header!"
|
|
|
|
)
|
|
|
|
|
2018-02-24 18:47:08 +01:00
|
|
|
Logger.info(inspect(conn.req_headers))
|
|
|
|
end
|
|
|
|
|
2019-07-10 11:25:58 +02:00
|
|
|
json(conn, dgettext("errors", "error"))
|
2018-02-18 22:40:08 +01:00
|
|
|
end
|
2018-02-18 22:41:38 +01:00
|
|
|
|
2019-07-17 18:22:57 +02:00
|
|
|
defp represent_service_actor(%User{} = user, conn) do
|
|
|
|
with {:ok, user} <- User.ensure_keys_present(user) do
|
2018-08-06 08:11:51 +02:00
|
|
|
conn
|
2019-08-24 16:17:17 +02:00
|
|
|
|> put_resp_content_type("application/activity+json")
|
2018-08-06 08:11:51 +02:00
|
|
|
|> json(UserView.render("user.json", %{user: user}))
|
|
|
|
else
|
|
|
|
nil -> {:error, :not_found}
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
2019-07-17 18:22:57 +02:00
|
|
|
defp represent_service_actor(nil, _), do: {:error, :not_found}
|
|
|
|
|
|
|
|
def relay(conn, _params) do
|
|
|
|
Relay.get_actor()
|
|
|
|
|> represent_service_actor(conn)
|
|
|
|
end
|
|
|
|
|
2019-07-17 19:34:57 +02:00
|
|
|
def internal_fetch(conn, _params) do
|
|
|
|
InternalFetchActor.get_actor()
|
|
|
|
|> represent_service_actor(conn)
|
|
|
|
end
|
|
|
|
|
2019-02-04 23:58:29 +01:00
|
|
|
def whoami(%{assigns: %{user: %User{} = user}} = conn, _params) do
|
|
|
|
conn
|
2019-08-24 16:17:17 +02:00
|
|
|
|> put_resp_content_type("application/activity+json")
|
2019-02-04 23:58:29 +01:00
|
|
|
|> json(UserView.render("user.json", %{user: user}))
|
|
|
|
end
|
|
|
|
|
|
|
|
def whoami(_conn, _params), do: {:error, :not_found}
|
|
|
|
|
2019-09-09 20:11:57 +02:00
|
|
|
def read_inbox(
|
|
|
|
%{assigns: %{user: %{nickname: nickname} = user}} = conn,
|
2019-09-25 14:59:04 +02:00
|
|
|
%{"nickname" => nickname, "page" => page?} = params
|
|
|
|
)
|
|
|
|
when page? in [true, "true"] do
|
2019-09-25 15:26:47 +02:00
|
|
|
activities =
|
|
|
|
if params["max_id"] do
|
|
|
|
ActivityPub.fetch_activities([user.ap_id | user.following], %{
|
|
|
|
"max_id" => params["max_id"],
|
|
|
|
"limit" => 10
|
|
|
|
})
|
|
|
|
else
|
|
|
|
ActivityPub.fetch_activities([user.ap_id | user.following], %{"limit" => 10})
|
|
|
|
end
|
|
|
|
|
|
|
|
conn
|
|
|
|
|> put_resp_content_type("application/activity+json")
|
|
|
|
|> put_view(UserView)
|
|
|
|
|> render("activity_collection_page.json", %{
|
|
|
|
activities: activities,
|
|
|
|
iri: "#{user.ap_id}/inbox"
|
|
|
|
})
|
2019-09-25 14:59:04 +02:00
|
|
|
end
|
|
|
|
|
|
|
|
def read_inbox(%{assigns: %{user: %{nickname: nickname} = user}} = conn, %{
|
|
|
|
"nickname" => nickname
|
|
|
|
}) do
|
|
|
|
with {:ok, user} <- User.ensure_keys_present(user) do
|
|
|
|
conn
|
|
|
|
|> put_resp_content_type("application/activity+json")
|
|
|
|
|> put_view(UserView)
|
|
|
|
|> render("activity_collection.json", %{iri: "#{user.ap_id}/inbox"})
|
|
|
|
end
|
2019-09-09 20:11:57 +02:00
|
|
|
end
|
2019-07-10 11:25:58 +02:00
|
|
|
|
2019-09-09 20:11:57 +02:00
|
|
|
def read_inbox(%{assigns: %{user: nil}} = conn, %{"nickname" => nickname}) do
|
|
|
|
err = dgettext("errors", "can't read inbox of %{nickname}", nickname: nickname)
|
|
|
|
|
|
|
|
conn
|
|
|
|
|> put_status(:forbidden)
|
|
|
|
|> json(err)
|
|
|
|
end
|
|
|
|
|
|
|
|
def read_inbox(%{assigns: %{user: %{nickname: as_nickname}}} = conn, %{
|
|
|
|
"nickname" => nickname
|
|
|
|
}) do
|
|
|
|
err =
|
|
|
|
dgettext("errors", "can't read inbox of %{nickname} as %{as_nickname}",
|
|
|
|
nickname: nickname,
|
|
|
|
as_nickname: as_nickname
|
|
|
|
)
|
|
|
|
|
|
|
|
conn
|
|
|
|
|> put_status(:forbidden)
|
|
|
|
|> json(err)
|
2018-12-29 18:01:15 +01:00
|
|
|
end
|
|
|
|
|
2019-01-01 22:16:46 +01:00
|
|
|
def handle_user_activity(user, %{"type" => "Create"} = params) do
|
|
|
|
object =
|
|
|
|
params["object"]
|
|
|
|
|> Map.merge(Map.take(params, ["to", "cc"]))
|
|
|
|
|> Map.put("attributedTo", user.ap_id())
|
|
|
|
|> Transmogrifier.fix_object()
|
|
|
|
|
|
|
|
ActivityPub.create(%{
|
|
|
|
to: params["to"],
|
|
|
|
actor: user,
|
|
|
|
context: object["context"],
|
|
|
|
object: object,
|
|
|
|
additional: Map.take(params, ["cc"])
|
|
|
|
})
|
|
|
|
end
|
|
|
|
|
2019-01-01 23:19:40 +01:00
|
|
|
def handle_user_activity(user, %{"type" => "Delete"} = params) do
|
|
|
|
with %Object{} = object <- Object.normalize(params["object"]),
|
|
|
|
true <- user.info.is_moderator || user.ap_id == object.data["actor"],
|
|
|
|
{:ok, delete} <- ActivityPub.delete(object) do
|
|
|
|
{:ok, delete}
|
|
|
|
else
|
2019-07-10 11:25:58 +02:00
|
|
|
_ -> {:error, dgettext("errors", "Can't delete object")}
|
2019-01-01 23:19:40 +01:00
|
|
|
end
|
|
|
|
end
|
|
|
|
|
2019-01-08 19:22:26 +01:00
|
|
|
def handle_user_activity(user, %{"type" => "Like"} = params) do
|
|
|
|
with %Object{} = object <- Object.normalize(params["object"]),
|
|
|
|
{:ok, activity, _object} <- ActivityPub.like(user, object) do
|
|
|
|
{:ok, activity}
|
|
|
|
else
|
2019-07-10 11:25:58 +02:00
|
|
|
_ -> {:error, dgettext("errors", "Can't like object")}
|
2019-01-08 19:22:26 +01:00
|
|
|
end
|
|
|
|
end
|
|
|
|
|
2019-01-01 22:16:46 +01:00
|
|
|
def handle_user_activity(_, _) do
|
2019-07-10 11:25:58 +02:00
|
|
|
{:error, dgettext("errors", "Unhandled activity type")}
|
2019-01-01 22:16:46 +01:00
|
|
|
end
|
|
|
|
|
2018-12-29 18:22:40 +01:00
|
|
|
def update_outbox(
|
2019-08-27 19:37:19 +02:00
|
|
|
%{assigns: %{user: %User{nickname: nickname} = user}} = conn,
|
2019-01-01 22:16:46 +01:00
|
|
|
%{"nickname" => nickname} = params
|
2019-08-27 19:37:19 +02:00
|
|
|
) do
|
2019-08-27 15:21:03 +02:00
|
|
|
actor = user.ap_id()
|
2018-12-29 18:21:45 +01:00
|
|
|
|
2019-08-27 15:21:03 +02:00
|
|
|
params =
|
|
|
|
params
|
|
|
|
|> Map.drop(["id"])
|
|
|
|
|> Map.put("actor", actor)
|
|
|
|
|> Transmogrifier.fix_addressing()
|
2019-07-10 11:25:58 +02:00
|
|
|
|
2019-08-27 15:21:03 +02:00
|
|
|
with {:ok, %Activity{} = activity} <- handle_user_activity(user, params) do
|
2018-12-29 18:01:15 +01:00
|
|
|
conn
|
2019-08-27 15:21:03 +02:00
|
|
|
|> put_status(:created)
|
|
|
|
|> put_resp_header("location", activity.data["id"])
|
|
|
|
|> json(activity.data)
|
|
|
|
else
|
|
|
|
{:error, message} ->
|
|
|
|
conn
|
|
|
|
|> put_status(:bad_request)
|
|
|
|
|> json(message)
|
2018-12-29 18:01:15 +01:00
|
|
|
end
|
|
|
|
end
|
|
|
|
|
2019-08-27 15:21:03 +02:00
|
|
|
def update_outbox(%{assigns: %{user: user}} = conn, %{"nickname" => nickname} = _) do
|
|
|
|
err =
|
|
|
|
dgettext("errors", "can't update outbox of %{nickname} as %{as_nickname}",
|
|
|
|
nickname: nickname,
|
|
|
|
as_nickname: user.nickname
|
|
|
|
)
|
|
|
|
|
|
|
|
conn
|
|
|
|
|> put_status(:forbidden)
|
|
|
|
|> json(err)
|
|
|
|
end
|
|
|
|
|
2018-06-03 19:58:59 +02:00
|
|
|
def errors(conn, {:error, :not_found}) do
|
|
|
|
conn
|
2019-07-10 11:25:58 +02:00
|
|
|
|> put_status(:not_found)
|
|
|
|
|> json(dgettext("errors", "Not found"))
|
2018-06-03 19:58:59 +02:00
|
|
|
end
|
|
|
|
|
2018-02-15 20:00:43 +01:00
|
|
|
def errors(conn, _e) do
|
|
|
|
conn
|
2019-07-10 11:25:58 +02:00
|
|
|
|> put_status(:internal_server_error)
|
|
|
|
|> json(dgettext("errors", "error"))
|
2018-02-15 20:00:43 +01:00
|
|
|
end
|
2019-01-29 11:12:28 +01:00
|
|
|
|
|
|
|
defp set_requester_reachable(%Plug.Conn{} = conn, _) do
|
|
|
|
with actor <- conn.params["actor"],
|
|
|
|
true <- is_binary(actor) do
|
|
|
|
Pleroma.Instances.set_reachable(actor)
|
|
|
|
end
|
|
|
|
|
|
|
|
conn
|
|
|
|
end
|
2019-07-12 19:54:20 +02:00
|
|
|
|
|
|
|
defp ensure_user_keys_present_and_maybe_refresh_for_user(user, for_user) do
|
|
|
|
{:ok, new_user} = User.ensure_keys_present(user)
|
|
|
|
|
|
|
|
for_user =
|
|
|
|
if new_user != user and match?(%User{}, for_user) do
|
|
|
|
User.get_cached_by_nickname(for_user.nickname)
|
|
|
|
else
|
|
|
|
for_user
|
|
|
|
end
|
|
|
|
|
|
|
|
{new_user, for_user}
|
|
|
|
end
|
2017-12-11 10:37:22 +01:00
|
|
|
end
|