defmodule Pleroma.Web.ActivityPub.Builder do @moduledoc """ This module builds the objects. Meant to be used for creating local objects. This module encodes our addressing policies and general shape of our objects. """ alias Pleroma.Emoji alias Pleroma.Object alias Pleroma.User alias Pleroma.Web.ActivityPub.Relay alias Pleroma.Web.ActivityPub.Utils alias Pleroma.Web.ActivityPub.Visibility require Pleroma.Constants @spec accept(User.t(), Activity.t()) :: {:ok, map(), keyword()} def accept(actor, accepted_activity) do data = %{ "id" => Utils.generate_activity_id(), "actor" => actor.ap_id, "type" => "Accept", "object" => accepted_activity.data["id"], "to" => [accepted_activity.actor] } {:ok, data, []} end @spec follow(User.t(), User.t()) :: {:ok, map(), keyword()} def follow(follower, followed) do data = %{ "id" => Utils.generate_activity_id(), "actor" => follower.ap_id, "type" => "Follow", "object" => followed.ap_id, "to" => [followed.ap_id] } {:ok, data, []} end @spec emoji_react(User.t(), Object.t(), String.t()) :: {:ok, map(), keyword()} def emoji_react(actor, object, emoji) do with {:ok, data, meta} <- object_action(actor, object) do data = data |> Map.put("content", emoji) |> Map.put("type", "EmojiReact") {:ok, data, meta} end end @spec undo(User.t(), Activity.t()) :: {:ok, map(), keyword()} def undo(actor, object) do {:ok, %{ "id" => Utils.generate_activity_id(), "actor" => actor.ap_id, "type" => "Undo", "object" => object.data["id"], "to" => object.data["to"] || [], "cc" => object.data["cc"] || [] }, []} end @spec delete(User.t(), String.t()) :: {:ok, map(), keyword()} def delete(actor, object_id) do object = Object.normalize(object_id, false) user = !object && User.get_cached_by_ap_id(object_id) to = case {object, user} do {%Object{}, _} -> # We are deleting an object, address everyone who was originally mentioned (object.data["to"] || []) ++ (object.data["cc"] || []) {_, %User{follower_address: follower_address}} -> # We are deleting a user, address the followers of that user [follower_address] end {:ok, %{ "id" => Utils.generate_activity_id(), "actor" => actor.ap_id, "object" => object_id, "to" => to, "type" => "Delete" }, []} end def create(actor, object, recipients) do context = if is_map(object) do object["context"] else nil end {:ok, %{ "id" => Utils.generate_activity_id(), "actor" => actor.ap_id, "to" => recipients, "object" => object, "type" => "Create", "published" => DateTime.utc_now() |> DateTime.to_iso8601() } |> Pleroma.Maps.put_if_present("context", context), []} end def chat_message(actor, recipient, content, opts \\ []) do basic = %{ "id" => Utils.generate_object_id(), "actor" => actor.ap_id, "type" => "ChatMessage", "to" => [recipient], "content" => content, "published" => DateTime.utc_now() |> DateTime.to_iso8601(), "emoji" => Emoji.Formatter.get_emoji_map(content) } case opts[:attachment] do %Object{data: attachment_data} -> { :ok, Map.put(basic, "attachment", attachment_data), [] } _ -> {:ok, basic, []} end end def answer(user, object, name) do {:ok, %{ "type" => "Answer", "actor" => user.ap_id, "attributedTo" => user.ap_id, "cc" => [object.data["actor"]], "to" => [], "name" => name, "inReplyTo" => object.data["id"], "context" => object.data["context"], "published" => DateTime.utc_now() |> DateTime.to_iso8601(), "id" => Utils.generate_object_id() }, []} end @spec tombstone(String.t(), String.t()) :: {:ok, map(), keyword()} def tombstone(actor, id) do {:ok, %{ "id" => id, "actor" => actor, "type" => "Tombstone" }, []} end @spec like(User.t(), Object.t()) :: {:ok, map(), keyword()} def like(actor, object) do with {:ok, data, meta} <- object_action(actor, object) do data = data |> Map.put("type", "Like") {:ok, data, meta} end end # Retricted to user updates for now, always public @spec update(User.t(), Object.t()) :: {:ok, map(), keyword()} def update(actor, object) do to = [Pleroma.Constants.as_public(), actor.follower_address] {:ok, %{ "id" => Utils.generate_activity_id(), "type" => "Update", "actor" => actor.ap_id, "object" => object, "to" => to }, []} end @spec block(User.t(), User.t()) :: {:ok, map(), keyword()} def block(blocker, blocked) do {:ok, %{ "id" => Utils.generate_activity_id(), "type" => "Block", "actor" => blocker.ap_id, "object" => blocked.ap_id, "to" => [blocked.ap_id] }, []} end @spec announce(User.t(), Object.t(), keyword()) :: {:ok, map(), keyword()} def announce(actor, object, options \\ []) do public? = Keyword.get(options, :public, false) to = cond do actor.ap_id == Relay.relay_ap_id() -> [actor.follower_address] public? -> [actor.follower_address, object.data["actor"], Pleroma.Constants.as_public()] true -> [actor.follower_address, object.data["actor"]] end {:ok, %{ "id" => Utils.generate_activity_id(), "actor" => actor.ap_id, "object" => object.data["id"], "to" => to, "context" => object.data["context"], "type" => "Announce", "published" => Utils.make_date() }, []} end @spec object_action(User.t(), Object.t()) :: {:ok, map(), keyword()} defp object_action(actor, object) do object_actor = User.get_cached_by_ap_id(object.data["actor"]) # Address the actor of the object, and our actor's follower collection if the post is public. to = if Visibility.is_public?(object) do [actor.follower_address, object.data["actor"]] else [object.data["actor"]] end # CC everyone who's been addressed in the object, except ourself and the object actor's # follower collection cc = (object.data["to"] ++ (object.data["cc"] || [])) |> List.delete(actor.ap_id) |> List.delete(object_actor.follower_address) {:ok, %{ "id" => Utils.generate_activity_id(), "actor" => actor.ap_id, "object" => object.data["id"], "to" => to, "cc" => cc, "context" => object.data["context"] }, []} end end