|
|
@@ -10,6 +10,9 @@ defmodule Pleroma.Web.ActivityPub.ActivityPub do |
|
|
|
|
|
|
|
@httpoison Application.get_env(:pleroma, :httpoison) |
|
|
|
|
|
|
|
@instance Application.get_env(:pleroma, :instance) |
|
|
|
@rewrite_policy Keyword.get(@instance, :rewrite_policy) |
|
|
|
|
|
|
|
def get_recipients(data) do |
|
|
|
(data["to"] || []) ++ (data["cc"] || []) |
|
|
|
end |
|
|
@@ -17,7 +20,8 @@ defmodule Pleroma.Web.ActivityPub.ActivityPub do |
|
|
|
def insert(map, local \\ true) when is_map(map) do |
|
|
|
with nil <- Activity.get_by_ap_id(map["id"]), |
|
|
|
map <- lazy_put_activity_defaults(map), |
|
|
|
:ok <- insert_full_object(map) do |
|
|
|
:ok <- insert_full_object(map), |
|
|
|
{:ok, map} <- @rewrite_policy.filter(map) do |
|
|
|
{:ok, activity} = |
|
|
|
Repo.insert(%Activity{ |
|
|
|
data: map, |
|
|
|