git.squeep.com Git - akkoma/blob - lib/pleroma/object/fetcher.ex

   1 # Pleroma: A lightweight social networking server
   2 # Copyright © 2017-2019 Pleroma Authors <https://pleroma.social/>
   3 # SPDX-License-Identifier: AGPL-3.0-only
   4
   5 defmodule Pleroma.Object.Fetcher do
   6   alias Pleroma.HTTP
   7   alias Pleroma.Object
   8   alias Pleroma.Object.Containment
   9   alias Pleroma.Web.ActivityPub.Transmogrifier
  10   alias Pleroma.Web.OStatus
  11
  12   require Logger
  13
  14   defp reinject_object(data) do
  15     Logger.debug("Reinjecting object #{data["id"]}")
  16
  17     with data <- Transmogrifier.fix_object(data),
  18          {:ok, object} <- Object.create(data) do
  19       {:ok, object}
  20     else
  21       e ->
  22         Logger.error("Error while processing object: #{inspect(e)}")
  23         {:error, e}
  24     end
  25   end
  26
  27   # TODO:
  28   # This will create a Create activity, which we need internally at the moment.
  29   def fetch_object_from_id(id, options \\ []) do
  30     if object = Object.get_cached_by_ap_id(id) do
  31       {:ok, object}
  32     else
  33       Logger.info("Fetching #{id} via AP")
  34       {status, data} = fetch_and_contain_remote_object_from_id(id)
  35       object = Object.normalize(data, false)
  36
  37       if status == :ok and object == nil do
  38         with params <- %{
  39                "type" => "Create",
  40                "to" => data["to"],
  41                "cc" => data["cc"],
  42                # Should we seriously keep this attributedTo thing?
  43                "actor" => data["actor"] || data["attributedTo"],
  44                "object" => data
  45              },
  46              :ok <- Containment.contain_origin(id, params),
  47              {:ok, activity} <- Transmogrifier.handle_incoming(params, options),
  48              {:object, _data, %Object{} = object} <-
  49                {:object, data, Object.normalize(activity, false)} do
  50           {:ok, object}
  51         else
  52           {:error, {:reject, nil}} ->
  53             {:reject, nil}
  54
  55           {:object, data, nil} ->
  56             reinject_object(data)
  57
  58           object = %Object{} ->
  59             {:ok, object}
  60
  61           :error ->
  62             {:error, "Object containment failed."}
  63
  64           e ->
  65             e
  66         end
  67       else
  68         if status == :ok and object != nil do
  69           {:ok, object}
  70         else
  71           # Only fallback when receiving a fetch/normalization error with ActivityPub
  72           Logger.info("Couldn't get object via AP, trying out OStatus fetching...")
  73
  74           # FIXME: OStatus Object Containment?
  75           case OStatus.fetch_activity_from_url(id) do
  76             {:ok, [activity | _]} -> {:ok, Object.normalize(activity, false)}
  77             e -> e
  78           end
  79         end
  80       end
  81     end
  82   end
  83
  84   def fetch_object_from_id!(id, options \\ []) do
  85     with {:ok, object} <- fetch_object_from_id(id, options) do
  86       object
  87     else
  88       _e ->
  89         nil
  90     end
  91   end
  92
  93   def fetch_and_contain_remote_object_from_id(id) do
  94     Logger.info("Fetching object #{id} via AP")
  95
  96     with true <- String.starts_with?(id, "http"),
  97          {:ok, %{body: body, status: code}} when code in 200..299 <-
  98            HTTP.get(
  99              id,
 100              [{:Accept, "application/activity+json"}]
 101            ),
 102          {:ok, data} <- Jason.decode(body),
 103          :ok <- Containment.contain_origin_from_id(id, data) do
 104       {:ok, data}
 105     else
 106       {:ok, %{status: code}} when code in [404, 410] ->
 107         {:error, "Object has been deleted"}
 108
 109       e ->
 110         {:error, e}
 111     end
 112   end
 113 end