Conslidate log messages for object fetcher failures and leverage Logger.metadata

lib/pleroma/object/fetcher.ex

@@ -72,23 +72,25 @@ def fetch_object_from_id(id, options \\ []) do
            {:object, data, Object.normalize(activity, fetch: false)} do
       {:ok, object}
     else
-      {:allowed_depth, false} ->
+      {:allowed_depth, false} = e ->
+        log_fetch_error(id, e)
         {:error, "Max thread distance exceeded."}
 
-      {:containment, e} ->
+      {:containment, reason} = e ->
-        Logger.error("Error while fetching #{id}: Object containment failed. #{inspect(e)}")
+        log_fetch_error(id, e)
-        {:error, e}
+        {:error, reason}
 
-      {:transmogrifier, {:error, {:reject, e}}} ->
+      {:transmogrifier, {:error, {:reject, reason}}} = e ->
-        Logger.error("Rejected #{id} while fetching: #{inspect(e)}")
+        log_fetch_error(id, e)
-        {:reject, e}
+        {:reject, reason}
 
-      {:transmogrifier, {:reject, e}} ->
+      {:transmogrifier, {:reject, reason}} = e ->
-        Logger.error("Rejected #{id} while fetching: #{inspect(e)}")
+        log_fetch_error(id, e)
-        {:reject, e}
+        {:reject, reason}
 
-      {:transmogrifier, _} = e ->
+      {:transmogrifier, reason} = e ->
-        {:error, e}
+        log_fetch_error(id, e)
+        {:error, reason}
 
       {:object, data, nil} ->
         reinject_object(%Object{}, data)
@@ -99,16 +101,21 @@ def fetch_object_from_id(id, options \\ []) do
       {:fetch_object, %Object{} = object} ->
         {:ok, object}
 
-      {:fetch, {:error, error}} ->
+      {:fetch, {:error, reason}} = e ->
-        Logger.error("Error while fetching #{id}: #{inspect(error)}")
+        log_fetch_error(id, e)
-        {:error, error}
+        {:error, reason}
 
       e ->
-        Logger.error("Error while fetching #{id}: #{inspect(e)}")
+        log_fetch_error(id, e)
         {:error, e}
     end
   end
 
+  defp log_fetch_error(id, error) do
+    Logger.metadata([object: id])
+    Logger.error("Object rejected while fetching #{id} #{inspect(error)}")
+  end
+
   defp prepare_activity_params(data) do
     %{
       "type" => "Create",

test/pleroma/web/activity_pub/transmogrifier_test.exs

@@ -132,7 +132,7 @@ test "it keeps link tags" do
                assert {:ok, activity} = Transmogrifier.handle_incoming(message)
                object = Object.normalize(activity)
                assert [%{"type" => "Mention"}, %{"type" => "Link"}] = object.data["tag"]
-             end) =~ "Error while fetching"
+             end) =~ "Object rejected while fetching"
     end
 
     test "it accepts quote posts" do
@@ -410,7 +410,7 @@ test "it rejects activities which reference objects with bogus origins" do
 
       assert capture_log(fn ->
                {:error, _} = Transmogrifier.handle_incoming(data)
-             end) =~ "Object containment failed"
+             end) =~ "Object rejected while fetching"
     end
 
     test "it rejects activities which reference objects that have an incorrect attribution (variant 1)" do
@@ -425,7 +425,7 @@ test "it rejects activities which reference objects that have an incorrect attri
 
       assert capture_log(fn ->
                {:error, _} = Transmogrifier.handle_incoming(data)
-             end) =~ "Object containment failed"
+             end) =~ "Object rejected while fetching"
     end
 
     test "it rejects activities which reference objects that have an incorrect attribution (variant 2)" do
@@ -440,7 +440,7 @@ test "it rejects activities which reference objects that have an incorrect attri
 
       assert capture_log(fn ->
                {:error, _} = Transmogrifier.handle_incoming(data)
-             end) =~ "Object containment failed"
+             end) =~ "Object rejected while fetching"
     end
   end