mirror of
https://framagit.org/framasoft/mobilizon.git
synced 2024-12-23 00:14:48 +00:00
129 lines
4.3 KiB
Elixir
129 lines
4.3 KiB
Elixir
|
defmodule Mobilizon.Federation.ActivityPub.Publisher do
|
|||
|
@moduledoc """
|
|||
|
Handle publishing activities
|
|||
|
"""
|
|||
|
alias Mobilizon.Actors
|
|||
|
alias Mobilizon.Actors.Actor
|
|||
|
alias Mobilizon.Config
|
|||
|
alias Mobilizon.Federation.ActivityPub.{Activity, Federator, Relay, Transmogrifier, Visibility}
|
|||
|
alias Mobilizon.Federation.HTTPSignatures.Signature
|
|||
|
require Logger
|
|||
|
import Mobilizon.Federation.ActivityPub.Utils, only: [remote_actors: 1]
|
|||
|
|
|||
|
@doc """
|
|||
|
Publish an activity to all appropriated audiences inboxes
|
|||
|
"""
|
|||
|
# credo:disable-for-lines:47
|
|||
|
@spec publish(Actor.t(), Activity.t()) :: :ok
|
|||
|
def publish(actor, %Activity{recipients: recipients} = activity) do
|
|||
|
Logger.debug("Publishing an activity")
|
|||
|
Logger.debug(inspect(activity, pretty: true))
|
|||
|
|
|||
|
public = Visibility.is_public?(activity)
|
|||
|
Logger.debug("is public ? #{public}")
|
|||
|
|
|||
|
if public && is_create_activity?(activity) && Config.get([:instance, :allow_relay]) do
|
|||
|
Logger.info(fn -> "Relaying #{activity.data["id"]} out" end)
|
|||
|
|
|||
|
Relay.publish(activity)
|
|||
|
end
|
|||
|
|
|||
|
recipients = Enum.uniq(recipients)
|
|||
|
|
|||
|
{recipients, followers} = convert_followers_in_recipients(recipients)
|
|||
|
|
|||
|
{recipients, members} = convert_members_in_recipients(recipients)
|
|||
|
|
|||
|
remote_inboxes =
|
|||
|
(remote_actors(recipients) ++ followers ++ members)
|
|||
|
|> Enum.map(fn actor -> actor.shared_inbox_url || actor.inbox_url end)
|
|||
|
|> Enum.uniq()
|
|||
|
|
|||
|
{:ok, data} = Transmogrifier.prepare_outgoing(activity.data)
|
|||
|
json = Jason.encode!(data)
|
|||
|
Logger.debug(fn -> "Remote inboxes are : #{inspect(remote_inboxes)}" end)
|
|||
|
|
|||
|
Enum.each(remote_inboxes, fn inbox ->
|
|||
|
Federator.enqueue(:publish_single_ap, %{
|
|||
|
inbox: inbox,
|
|||
|
json: json,
|
|||
|
actor: actor,
|
|||
|
id: activity.data["id"]
|
|||
|
})
|
|||
|
end)
|
|||
|
end
|
|||
|
|
|||
|
@doc """
|
|||
|
Publish an activity to a specific inbox
|
|||
|
"""
|
|||
|
@spec publish_one(%{inbox: String.t(), json: String.t(), actor: Actor.t(), id: String.t()}) ::
|
|||
|
Tesla.Env.result()
|
|||
|
def publish_one(%{inbox: inbox, json: json, actor: actor, id: id}) do
|
|||
|
Logger.info("Federating #{id} to #{inbox}")
|
|||
|
%URI{host: host, path: path} = URI.parse(inbox)
|
|||
|
|
|||
|
digest = Signature.build_digest(json)
|
|||
|
date = Signature.generate_date_header()
|
|||
|
|
|||
|
# request_target = Signature.generate_request_target("POST", path)
|
|||
|
|
|||
|
signature =
|
|||
|
Signature.sign(actor, %{
|
|||
|
"(request-target)": "post #{path}",
|
|||
|
host: host,
|
|||
|
"content-length": byte_size(json),
|
|||
|
digest: digest,
|
|||
|
date: date
|
|||
|
})
|
|||
|
|
|||
|
Tesla.post(
|
|||
|
inbox,
|
|||
|
json,
|
|||
|
headers: [
|
|||
|
{"Content-Type", "application/activity+json"},
|
|||
|
{"signature", signature},
|
|||
|
{"digest", digest},
|
|||
|
{"date", date}
|
|||
|
]
|
|||
|
)
|
|||
|
end
|
|||
|
|
|||
|
@spec convert_followers_in_recipients(list(String.t())) :: {list(String.t()), list(String.t())}
|
|||
|
defp convert_followers_in_recipients(recipients) do
|
|||
|
Enum.reduce(recipients, {recipients, []}, fn recipient, {recipients, follower_actors} = acc ->
|
|||
|
case Actors.get_actor_by_followers_url(recipient) do
|
|||
|
%Actor{} = group ->
|
|||
|
{Enum.filter(recipients, fn recipient -> recipient != group.followers_url end),
|
|||
|
follower_actors ++ Actors.list_external_followers_for_actor(group)}
|
|||
|
|
|||
|
nil ->
|
|||
|
acc
|
|||
|
end
|
|||
|
end)
|
|||
|
end
|
|||
|
|
|||
|
@spec is_create_activity?(Activity.t()) :: boolean
|
|||
|
defp is_create_activity?(%Activity{data: %{"type" => "Create"}}), do: true
|
|||
|
defp is_create_activity?(_), do: false
|
|||
|
|
|||
|
@spec convert_members_in_recipients(list(String.t())) :: {list(String.t()), list(Actor.t())}
|
|||
|
defp convert_members_in_recipients(recipients) do
|
|||
|
Enum.reduce(recipients, {recipients, []}, fn recipient, {recipients, member_actors} = acc ->
|
|||
|
case Actors.get_group_by_members_url(recipient) do
|
|||
|
# If the group is local just add external members
|
|||
|
%Actor{domain: domain} = group when is_nil(domain) ->
|
|||
|
{Enum.filter(recipients, fn recipient -> recipient != group.members_url end),
|
|||
|
member_actors ++ Actors.list_external_actors_members_for_group(group)}
|
|||
|
|
|||
|
# If it's remote add the remote group actor as well
|
|||
|
%Actor{} = group ->
|
|||
|
{Enum.filter(recipients, fn recipient -> recipient != group.members_url end),
|
|||
|
member_actors ++ Actors.list_external_actors_members_for_group(group) ++ [group]}
|
|||
|
|
|||
|
_ ->
|
|||
|
acc
|
|||
|
end
|
|||
|
end)
|
|||
|
end
|
|||
|
end
|