|
|
|
@ -18,7 +18,7 @@ defmodule Pleroma.Web.ActivityPub.Transmogrifier do
|
|
|
|
|
"""
|
|
|
|
|
def fix_object(object) do
|
|
|
|
|
object
|
|
|
|
|
|> Map.put("actor", object["attributedTo"])
|
|
|
|
|
|> fix_actor
|
|
|
|
|
|> fix_attachments
|
|
|
|
|
|> fix_context
|
|
|
|
|
|> fix_in_reply_to
|
|
|
|
@ -27,6 +27,19 @@ defmodule Pleroma.Web.ActivityPub.Transmogrifier do
|
|
|
|
|
|> fix_content_map
|
|
|
|
|
end
|
|
|
|
|
|
|
|
|
|
def fix_actor(%{"attributedTo" => actor} = object) do
|
|
|
|
|
# attributedTo can be a list in the case of peertube or plume
|
|
|
|
|
actor =
|
|
|
|
|
if is_list(actor) do
|
|
|
|
|
Enum.at(actor, 0)
|
|
|
|
|
else
|
|
|
|
|
actor
|
|
|
|
|
end
|
|
|
|
|
|
|
|
|
|
object
|
|
|
|
|
|> Map.put("actor", actor)
|
|
|
|
|
end
|
|
|
|
|
|
|
|
|
|
def fix_in_reply_to(%{"inReplyTo" => in_reply_to_id} = object)
|
|
|
|
|
when not is_nil(in_reply_to_id) do
|
|
|
|
|
case ActivityPub.fetch_object_from_id(in_reply_to_id) do
|
|
|
|
@ -122,10 +135,14 @@ defmodule Pleroma.Web.ActivityPub.Transmogrifier do
|
|
|
|
|
# TODO: validate those with a Ecto scheme
|
|
|
|
|
# - tags
|
|
|
|
|
# - emoji
|
|
|
|
|
def handle_incoming(%{"type" => "Create", "object" => %{"type" => "Note"} = object} = data) do
|
|
|
|
|
def handle_incoming(%{"type" => "Create", "object" => %{"type" => objtype} = object} = data)
|
|
|
|
|
when objtype in ["Article", "Note"] do
|
|
|
|
|
with nil <- Activity.get_create_activity_by_object_ap_id(object["id"]),
|
|
|
|
|
%User{} = user <- User.get_or_fetch_by_ap_id(data["actor"]) do
|
|
|
|
|
object = fix_object(data["object"])
|
|
|
|
|
# prefer the activity's actor instead of attributedTo
|
|
|
|
|
object =
|
|
|
|
|
fix_object(data["object"])
|
|
|
|
|
|> Map.put("actor", data["actor"])
|
|
|
|
|
|
|
|
|
|
params = %{
|
|
|
|
|
to: data["to"],
|
|
|
|
@ -412,7 +429,7 @@ defmodule Pleroma.Web.ActivityPub.Transmogrifier do
|
|
|
|
|
def handle_incoming(_), do: :error
|
|
|
|
|
|
|
|
|
|
def get_obj_helper(id) do
|
|
|
|
|
if object = Object.get_by_ap_id(id), do: {:ok, object}, else: nil
|
|
|
|
|
if object = Object.normalize(id), do: {:ok, object}, else: nil
|
|
|
|
|
end
|
|
|
|
|
|
|
|
|
|
def set_reply_to_uri(%{"inReplyTo" => inReplyTo} = object) do
|
|
|
|
@ -460,14 +477,7 @@ defmodule Pleroma.Web.ActivityPub.Transmogrifier do
|
|
|
|
|
# Mastodon Accept/Reject requires a non-normalized object containing the actor URIs,
|
|
|
|
|
# because of course it does.
|
|
|
|
|
def prepare_outgoing(%{"type" => "Accept"} = data) do
|
|
|
|
|
follow_activity_id =
|
|
|
|
|
if is_binary(data["object"]) do
|
|
|
|
|
data["object"]
|
|
|
|
|
else
|
|
|
|
|
data["object"]["id"]
|
|
|
|
|
end
|
|
|
|
|
|
|
|
|
|
with follow_activity <- Activity.get_by_ap_id(follow_activity_id) do
|
|
|
|
|
with follow_activity <- Activity.normalize(data["object"]) do
|
|
|
|
|
object = %{
|
|
|
|
|
"actor" => follow_activity.actor,
|
|
|
|
|
"object" => follow_activity.data["object"],
|
|
|
|
@ -485,14 +495,7 @@ defmodule Pleroma.Web.ActivityPub.Transmogrifier do
|
|
|
|
|
end
|
|
|
|
|
|
|
|
|
|
def prepare_outgoing(%{"type" => "Reject"} = data) do
|
|
|
|
|
follow_activity_id =
|
|
|
|
|
if is_binary(data["object"]) do
|
|
|
|
|
data["object"]
|
|
|
|
|
else
|
|
|
|
|
data["object"]["id"]
|
|
|
|
|
end
|
|
|
|
|
|
|
|
|
|
with follow_activity <- Activity.get_by_ap_id(follow_activity_id) do
|
|
|
|
|
with follow_activity <- Activity.normalize(data["object"]) do
|
|
|
|
|
object = %{
|
|
|
|
|
"actor" => follow_activity.actor,
|
|
|
|
|
"object" => follow_activity.data["object"],
|
|
|
|
|