From c942d1b955c10948baf3a387de29a5262881a735 Mon Sep 17 00:00:00 2001
From: Shadowfacts <me@shadowfacts.net>
Date: Wed, 25 Aug 2021 22:47:08 -0400
Subject: [PATCH] Add federator error logging

---
 lib/clacks/activitypub/federator.ex | 3 +++
 lib/clacks/worker/federate.ex       | 9 ++++++++-
 2 files changed, 11 insertions(+), 1 deletion(-)

diff --git a/lib/clacks/activitypub/federator.ex b/lib/clacks/activitypub/federator.ex
index f665e5d..93016dc 100644
--- a/lib/clacks/activitypub/federator.ex
+++ b/lib/clacks/activitypub/federator.ex
@@ -81,6 +81,9 @@ defmodule Clacks.ActivityPub.Federator do
       {:ok, %HTTPoison.Response{status_code: status_code}} when status_code in 200..299 ->
         :ok
 
+      {:ok, %HTTPoison.Response{status_code: status_code, body: body}} ->
+        {:error, "unexpected response code #{status_code}: #{inspect(body)}"}
+
       {:error, _} = err ->
         err
     end
diff --git a/lib/clacks/worker/federate.ex b/lib/clacks/worker/federate.ex
index 1d19e0d..afa3eac 100644
--- a/lib/clacks/worker/federate.ex
+++ b/lib/clacks/worker/federate.ex
@@ -10,6 +10,13 @@ defmodule Clacks.Worker.Federate do
     activity = Repo.get(Activity, activity_id)
     actor = Repo.get(Actor, actor_id)
 
-    :ok = ActivityPub.Federator.federate_to_involved(activity, actor)
+    case ActivityPub.Federator.federate_to_involved(activity, actor) do
+      :ok ->
+        :ok
+
+      {:error, reason} ->
+        Logger.error("Error federating '#{activity_id}' to '#{actor_id}': #{inspect(reason)}")
+        {:error, reason}
+    end
   end
 end