projects
/
akkoma
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Merge remote-tracking branch 'remotes/origin/develop' into 1505-threads-federation
[akkoma]
/
lib
/
pleroma
/
web
/
activity_pub
/
transmogrifier.ex
diff --git
a/lib/pleroma/web/activity_pub/transmogrifier.ex
b/lib/pleroma/web/activity_pub/transmogrifier.ex
index 343228b370ef10b5ef5e11448409976b742c4b7a..5bd2baca48fb669a8a1d2e42cfc1f8c2fc562a2c 100644
(file)
--- a/
lib/pleroma/web/activity_pub/transmogrifier.ex
+++ b/
lib/pleroma/web/activity_pub/transmogrifier.ex
@@
-156,8
+156,9
@@
defmodule Pleroma.Web.ActivityPub.Transmogrifier do
when not is_nil(in_reply_to) do
in_reply_to_id = prepare_in_reply_to(in_reply_to)
object = Map.put(object, "inReplyToAtomUri", in_reply_to_id)
when not is_nil(in_reply_to) do
in_reply_to_id = prepare_in_reply_to(in_reply_to)
object = Map.put(object, "inReplyToAtomUri", in_reply_to_id)
+ depth = (options[:depth] || 0) + 1
- if Federator.allowed_
incoming_reply_depth?(options[:depth]
) do
+ if Federator.allowed_
thread_distance?(depth
) do
with {:ok, replied_object} <- get_obj_helper(in_reply_to_id, options),
%Activity{} = _ <- Activity.get_create_by_object_ap_id(replied_object.data["id"]) do
object
with {:ok, replied_object} <- get_obj_helper(in_reply_to_id, options),
%Activity{} = _ <- Activity.get_create_by_object_ap_id(replied_object.data["id"]) do
object
@@
-312,7
+313,7
@@
defmodule Pleroma.Web.ActivityPub.Transmogrifier do
def fix_type(%{"inReplyTo" => reply_id, "name" => _} = object, options)
when is_binary(reply_id) do
def fix_type(%{"inReplyTo" => reply_id, "name" => _} = object, options)
when is_binary(reply_id) do
- with true <- Federator.allowed_
incoming_reply_depth
?(options[:depth]),
+ with true <- Federator.allowed_
thread_distance
?(options[:depth]),
{:ok, %{data: %{"type" => "Question"} = _} = _} <- get_obj_helper(reply_id, options) do
Map.put(object, "type", "Answer")
else
{:ok, %{data: %{"type" => "Question"} = _} = _} <- get_obj_helper(reply_id, options) do
Map.put(object, "type", "Answer")
else
@@
-406,7
+407,6
@@
defmodule Pleroma.Web.ActivityPub.Transmogrifier do
with nil <- Activity.get_create_by_object_ap_id(object["id"]),
{:ok, %User{} = user} <- User.get_or_fetch_by_ap_id(data["actor"]) do
with nil <- Activity.get_create_by_object_ap_id(object["id"]),
{:ok, %User{} = user} <- User.get_or_fetch_by_ap_id(data["actor"]) do
- options = Keyword.put(options, :depth, (options[:depth] || 0) + 1)
object = fix_object(object, options)
params = %{
object = fix_object(object, options)
params = %{
@@
-425,8
+425,15
@@
defmodule Pleroma.Web.ActivityPub.Transmogrifier do
}
with {:ok, created_activity} <- ActivityPub.create(params) do
}
with {:ok, created_activity} <- ActivityPub.create(params) do
- for reply_id <- replies(object) do
- Pleroma.Workers.RemoteFetcherWorker.enqueue("fetch_remote", %{"id" => reply_id})
+ reply_depth = (options[:depth] || 0) + 1
+
+ if Federator.allowed_thread_distance?(reply_depth) do
+ for reply_id <- replies(object) do
+ Pleroma.Workers.RemoteFetcherWorker.enqueue("fetch_remote", %{
+ "id" => reply_id,
+ "depth" => reply_depth
+ })
+ end
end
{:ok, created_activity}
end
{:ok, created_activity}
@@
-448,7
+455,8
@@
defmodule Pleroma.Web.ActivityPub.Transmogrifier do
|> fix_addressing
with {:ok, %User{} = user} <- User.get_or_fetch_by_ap_id(data["actor"]) do
|> fix_addressing
with {:ok, %User{} = user} <- User.get_or_fetch_by_ap_id(data["actor"]) do
- options = Keyword.put(options, :depth, (options[:depth] || 0) + 1)
+ reply_depth = (options[:depth] || 0) + 1
+ options = Keyword.put(options, :depth, reply_depth)
object = fix_object(object, options)
params = %{
object = fix_object(object, options)
params = %{
@@
-935,19
+943,9
@@
defmodule Pleroma.Web.ActivityPub.Transmogrifier do
end
defp set_replies(obj, replies_uris) do
end
defp set_replies(obj, replies_uris) do
- # Note: stubs (Mastodon doesn't make separate requests via those URIs in FetchRepliesService)
- masto_replies_uri = nil
- masto_replies_next_page_uri = nil
-
replies_collection = %{
"type" => "Collection",
replies_collection = %{
"type" => "Collection",
- "id" => masto_replies_uri,
- "first" => %{
- "type" => "Collection",
- "part_of" => masto_replies_uri,
- "items" => replies_uris,
- "next" => masto_replies_next_page_uri
- }
+ "items" => replies_uris
}
Map.merge(obj, %{"replies" => replies_collection})
}
Map.merge(obj, %{"replies" => replies_collection})