defmodule Mobilizon.Service.ActivityPub do @moduledoc """ # ActivityPub Every ActivityPub method """ alias Mobilizon.Events alias Mobilizon.Events.{Event, Category, Comment} alias Mobilizon.Service.ActivityPub.Transmogrifier alias Mobilizon.Service.WebFinger alias Mobilizon.Activity alias Mobilizon.Actors alias Mobilizon.Actors.Actor alias Mobilizon.Service.Federator require Logger import Mobilizon.Service.ActivityPub.Utils @doc """ Get recipients for an activity or object """ @spec get_recipients(map()) :: list() def get_recipients(data) do (data["to"] || []) ++ (data["cc"] || []) end @doc """ Wraps an object into an activity TODO: Rename me """ @spec insert(map(), boolean()) :: {:ok, %Activity{}} | {:error, any()} def insert(map, local \\ true) when is_map(map) do with map <- lazy_put_activity_defaults(map), :ok <- insert_full_object(map, local) do object_id = cond do is_map(map["object"]) -> map["object"]["id"] is_binary(map["object"]) -> map["id"] end map = Map.put(map, "id", "#{object_id}/activity") activity = %Activity{ data: map, local: local, actor: map["actor"], recipients: get_recipients(map) } # Notification.create_notifications(activity) # stream_out(activity) {:ok, activity} else %Activity{} = activity -> {:ok, activity} error -> {:error, error} end end @doc """ Fetch an object from an URL, from our local database of events and comments, then eventually remote """ @spec fetch_object_from_url(String.t()) :: {:ok, %Event{}} | {:ok, %Comment{}} | {:error, any()} def fetch_object_from_url(url) do with true <- String.starts_with?(url, "http"), nil <- Events.get_event_by_url(url), nil <- Events.get_comment_from_url(url), {:ok, %{body: body, status_code: code}} when code in 200..299 <- HTTPoison.get( url, [Accept: "application/activity+json"], follow_redirect: true, timeout: 10_000, recv_timeout: 20_000 ), {:ok, data} <- Jason.decode(body), params <- %{ "type" => "Create", "to" => data["to"], "cc" => data["cc"], "actor" => data["attributedTo"], "object" => data }, {:ok, activity} <- Transmogrifier.handle_incoming(params) do case data["type"] do "Event" -> {:ok, Events.get_event_by_url!(activity.data["object"]["id"])} "Note" -> {:ok, Events.get_comment_from_url!(activity.data["object"]["id"])} end else object = %Event{} -> {:ok, object} object = %Comment{} -> {:ok, object} e -> {:error, e} end end def create(%{to: to, actor: actor, object: object} = params) do Logger.debug("creating an activity") additional = params[:additional] || %{} # only accept false as false value local = !(params[:local] == false) published = params[:published] with create_data <- make_create_data( %{to: to, actor: actor, published: published, object: object}, additional ), {:ok, activity} <- insert(create_data, local), :ok <- maybe_federate(activity) do # {:ok, actor} <- Actors.increase_event_count(actor) do {:ok, activity} else err -> Logger.error("Something went wrong") Logger.error(inspect(err)) end end def accept(%{to: to, actor: actor, object: object} = params) do # only accept false as false value local = !(params[:local] == false) with data <- %{"to" => to, "type" => "Accept", "actor" => actor, "object" => object}, {:ok, activity} <- insert(data, local), :ok <- maybe_federate(activity) do {:ok, activity} end end def update(%{to: to, cc: cc, actor: actor, object: object} = params) do # only accept false as false value local = !(params[:local] == false) with data <- %{ "to" => to, "cc" => cc, "type" => "Update", "actor" => actor, "object" => object }, {:ok, activity} <- insert(data, local), :ok <- maybe_federate(activity) do {:ok, activity} end end def follow(%Actor{} = follower, %Actor{} = followed, _activity_id \\ nil, local \\ true) do with {:ok, follow} <- Actor.follow(followed, follower, true), data <- make_follow_data(follower, followed, follow.id), {:ok, activity} <- insert(data, local), :ok <- maybe_federate(activity) do {:ok, activity} else {err, _} when err in [:already_following, :suspended] -> {:error, err} end end def delete(object, local \\ true) def delete(%Event{url: url, organizer_actor: actor} = event, local) do data = %{ "type" => "Delete", "actor" => actor.url, "object" => url, "to" => [actor.url <> "/followers", "https://www.w3.org/ns/activitystreams#Public"] } with Events.delete_event(event), {:ok, activity} <- insert(data, local), :ok <- maybe_federate(activity) do {:ok, activity} end end def delete(%Comment{url: url, actor: actor} = comment, local) do data = %{ "type" => "Delete", "actor" => actor.url, "object" => url, "to" => [actor.url <> "/followers", "https://www.w3.org/ns/activitystreams#Public"] } with Events.delete_comment(comment), {:ok, activity} <- insert(data, local), :ok <- maybe_federate(activity) do {:ok, activity} end end @doc """ Create an actor locally by it's URL (AP ID) """ @spec make_actor_from_url(String.t(), boolean()) :: {:ok, %Actor{}} | {:error, any()} def make_actor_from_url(url, preload \\ false) do with {:ok, data} <- fetch_and_prepare_actor_from_url(url) do Actors.insert_or_update_actor(data, preload) else # Request returned 410 {:error, :actor_deleted} -> {:error, :actor_deleted} e -> Logger.error("Failed to make actor from url") Logger.error(inspect(e)) {:error, e} end end @doc """ Find an actor in our local database or call Webfinger to find what's its AP ID is and then fetch it """ @spec find_or_make_actor_from_nickname(String.t(), atom() | nil) :: tuple() def find_or_make_actor_from_nickname(nickname, type \\ nil) do with %Actor{} = actor <- Actors.get_actor_by_name(nickname, type) do {:ok, actor} else nil -> make_actor_from_nickname(nickname) end end @spec find_or_make_person_from_nickname(String.t()) :: tuple() def find_or_make_person_from_nickname(nick), do: find_or_make_actor_from_nickname(nick, :Person) @spec find_or_make_group_from_nickname(String.t()) :: tuple() def find_or_make_group_from_nickname(nick), do: find_or_make_actor_from_nickname(nick, :Group) @doc """ Create an actor inside our database from username, using Webfinger to find out it's AP ID and then fetch it """ @spec make_actor_from_nickname(String.t()) :: {:ok, %Actor{}} | {:error, any()} def make_actor_from_nickname(nickname) do with {:ok, %{"url" => url}} when not is_nil(url) <- WebFinger.finger(nickname) do make_actor_from_url(url) else _e -> {:error, "No ActivityPub URL found in WebFinger"} end end def publish(actor, activity) do Logger.debug("Publishing an activity") followers = if actor.followers_url in activity.recipients do Actor.get_followers(actor) |> Enum.filter(fn follower -> is_nil(follower.domain) end) else [] end remote_inboxes = (remote_actors(activity) ++ followers) |> Enum.map(fn follower -> follower.shared_inbox_url end) |> Enum.uniq() {:ok, data} = Transmogrifier.prepare_outgoing(activity.data) json = Jason.encode!(data) Logger.debug("Remote inboxes are : #{inspect(remote_inboxes)}") Enum.each(remote_inboxes, fn inbox -> Federator.enqueue(:publish_single_ap, %{ inbox: inbox, json: json, actor: actor, id: activity.data["id"] }) end) end def publish_one(%{inbox: inbox, json: json, actor: actor, id: id}) do Logger.info("Federating #{id} to #{inbox}") host = URI.parse(inbox).host signature = Mobilizon.Service.HTTPSignatures.sign(actor, %{ host: host, "content-length": byte_size(json) }) HTTPoison.post( inbox, json, [{"Content-Type", "application/activity+json"}, {"signature", signature}], hackney: [pool: :default] ) end # Fetching a remote actor's informations through it's AP ID @spec fetch_and_prepare_actor_from_url(String.t()) :: {:ok, struct()} | {:error, atom()} | any() defp fetch_and_prepare_actor_from_url(url) do Logger.debug("Fetching and preparing actor from url") with {:ok, %HTTPoison.Response{status_code: 200, body: body}} <- HTTPoison.get(url, [Accept: "application/activity+json"], follow_redirect: true), {:ok, data} <- Jason.decode(body) do actor_data_from_actor_object(data) else # Actor is gone, probably deleted {:ok, %HTTPoison.Response{status_code: 410}} -> {:error, :actor_deleted} e -> Logger.error("Could not decode actor at fetch #{url}, #{inspect(e)}") e end end @doc """ Creating proper actor data struct from AP data """ @spec actor_data_from_actor_object(map()) :: {:ok, map()} def actor_data_from_actor_object(data) when is_map(data) do actor_data = %{ url: data["id"], info: %{ "ap_enabled" => true, "source_data" => data }, avatar_url: data["icon"]["url"], banner_url: data["image"]["url"], name: data["name"], preferred_username: data["preferredUsername"], follower_address: data["followers"], summary: data["summary"], keys: data["publicKey"]["publicKeyPem"], inbox_url: data["inbox"], outbox_url: data["outbox"], following_url: data["following"], followers_url: data["followers"], shared_inbox_url: data["endpoints"]["sharedInbox"], domain: URI.parse(data["id"]).host, manually_approves_followers: data["manuallyApprovesFollowers"], type: data["type"] } {:ok, actor_data} end @doc """ Return all public activities (events & comments) for an actor """ @spec fetch_public_activities_for_actor(Actor.t(), integer(), integer()) :: {list(), integer()} def fetch_public_activities_for_actor(%Actor{} = actor, page \\ 1, limit \\ 10) do case actor.type do :Person -> {:ok, events, total_events} = Events.get_events_for_actor(actor, page, limit) {:ok, comments, total_comments} = Events.get_comments_for_actor(actor, page, limit) event_activities = Enum.map(events, &event_to_activity/1) comment_activities = Enum.map(comments, &comment_to_activity/1) activities = event_activities ++ comment_activities {activities, total_events + total_comments} :Service -> bot = Actors.get_bot_by_actor(actor) case bot.type do "ics" -> {:ok, %HTTPoison.Response{body: body} = _resp} = HTTPoison.get(bot.source) ical_events = body |> ExIcal.parse() |> ExIcal.by_range(DateTime.utc_now(), DateTime.utc_now() |> Timex.shift(years: 1)) activities = ical_events |> Enum.chunk_every(limit) |> Enum.at(page - 1) |> Enum.map(fn event -> {:ok, activity} = ical_event_to_activity(event, actor, bot.source) activity end) {activities, length(ical_events)} end end end # Create an activity from an event @spec event_to_activity(%Event{}, boolean()) :: Activity.t() defp event_to_activity(%Event{} = event, local \\ true) do %Activity{ recipients: ["https://www.w3.org/ns/activitystreams#Public"], actor: event.organizer_actor.url, data: event |> make_event_data, local: local } end # Create an activity from a comment @spec comment_to_activity(%Comment{}, boolean()) :: Activity.t() defp comment_to_activity(%Comment{} = comment, local \\ true) do %Activity{ recipients: ["https://www.w3.org/ns/activitystreams#Public"], actor: comment.actor.url, data: comment |> make_comment_data, local: local } end defp ical_event_to_activity(%ExIcal.Event{} = ical_event, %Actor{} = actor, _source) do # Logger.debug(inspect ical_event) # TODO : refactor me ! # TODO : also, there should be a form of cache that allows this to be more efficient category = if is_nil(ical_event.categories) do nil else ical_category = ical_event.categories |> hd() |> String.downcase() case ical_category |> Events.get_category_by_title() do nil -> case Events.create_category(%{"title" => ical_category}) do {:ok, %Category{} = category} -> category _ -> nil end category -> category end end {:ok, event} = Events.create_event(%{ begins_on: ical_event.start, ends_on: ical_event.end, inserted_at: ical_event.stamp, updated_at: ical_event.stamp, description: ical_event.description |> sanitize_ical_event_strings, title: ical_event.summary |> sanitize_ical_event_strings, organizer_actor: actor, category: category }) event_to_activity(event, false) end defp sanitize_ical_event_strings(string) when is_binary(string) do string |> String.replace(~s"\r\n", "") |> String.replace(~s"\\,", ",") end defp sanitize_ical_event_strings(nil) do nil end end