- def handle_incoming(
- %{"type" => "Announce", "object" => object_id, "actor" => _actor, "id" => id} = data,
- _options
- ) do
- with actor <- Containment.get_actor(data),
- {_, {:ok, %User{} = actor}} <- {:fetch_user, User.get_or_fetch_by_ap_id(actor)},
- {_, {:ok, object}} <- {:get_embedded, get_embedded_obj_helper(object_id, actor)},
- public <- Visibility.is_public?(data),
- {_, {:ok, activity, _object}} <-
- {:announce, ActivityPub.announce(actor, object, id, false, public)} do
- {:ok, activity}
- else
- e -> {:error, e}
- end
- end
-