@@ -20,3 +20,3 @@
   def cast(%{"id" => object}), do: cast(object)
 
-  def cast(_), do: :error
+  def cast(o), do: {:error, o}

@@ -1773,3 +1775,3 @@
   end
 
-  def pin_data_from_featured_collection(%{
+  def activity_data_from_outbox_collection(%{

@@ -641,0 +640,4 @@
+  defp handle_incoming_normalised(%{"object" => o}, options),
+    do: handle_incoming_normalised(o, options)
+
+  defp handle_incoming_normalised(o, _), do: {:error, {:unknown_object_class, o}}

@@ -306,6 +306,8 @@ def show(%{assigns: %{user: for_user}} = conn, %{id: nickname_or_id} = params) d
   def statuses(%{assigns: %{user: reading_user}} = conn, params) do
     with %User{} = user <- User.get_cached_by_nickname_or_id(params.id, for: reading_user),
          :visible <- User.visible_for(user, reading_user) do
+      ActivityPub.enqueue_outbox_fetches(user)

@@ -0,0 +6,4 @@
+      add_if_not_exists(:outbox, :text)
+    end
+
+    execute("update users set outbox = replace(inbox, 'inbox', 'outbox')")

@@ -1839,0 +1852,4 @@
+      {true} <-
+        {last_fetch > now ||
+           last_fetch < now - 60}
+    ) do

@@ -1857,0 +1868,4 @@
+          @timer,
+          outbox_address,
+          true,
+          ttl: Config.get!([:activitypub, :outbox_refetch_cooldown])

@@ -1857,0 +1889,4 @@
+
+  def enqueue_outbox_fetches(%{local: false} = user) do
+    make_user_from_ap_id(user.ap_id)
+    :ok

@@ -309,0 +312,4 @@
+
+        _ ->
+          ActivityPub.enqueue_outbox_fetches(user)
+      end

@@ -373,2 +373,3 @@
   authorized_fetch_mode: false,
-  max_collection_objects: 50
+  max_collection_objects: 50,
+  outbox_refetch_cooldown: 5 * 60

@@ -1589,2 +1589,3 @@
     featured_address = data["featured"]
-    {:ok, pinned_objects} = fetch_and_prepare_featured_from_ap_id(featured_address)
+    {:ok, pinned_objects} = fetch_and_prepare_collection_from_ap_id(featured_address)
+    outbox_address = data["outbox"]

@@ -1857,0 +1879,4 @@
+        })
+
+      a ->
+        Logger.debug("Not refetching outbox (TTL not reached)")

@@ -308,1 +308,4 @@
          :visible <- User.visible_for(user, reading_user) do
+
+      case reading_user do
+        nil -> {}

@@ -13,0 +18,4 @@
+      Enum.each(outbox, fn {ap_id, _} ->
+        if is_nil(Object.get_cached_by_ap_id(ap_id)) do
+          Fetcher.fetch_object_from_id(ap_id, depth: 1)
+        end

@@ -0,0 +3,4 @@
+
+  def up do
+    alter table(:users) do
+      add_if_not_exists(:outbox, :text)

@@ -0,0 +7,4 @@
+    file # libmagic
+    ffmpeg
+  ];
+}