- Logger.info("Fetching #{id} via AP")
- {status, data} = fetch_and_contain_remote_object_from_id(id)
- object = Object.normalize(data, false)
-
- if status == :ok and object == nil do
- with params <- %{
- "type" => "Create",
- "to" => data["to"],
- "cc" => data["cc"],
- # Should we seriously keep this attributedTo thing?
- "actor" => data["actor"] || data["attributedTo"],
- "object" => data
- },
- :ok <- Containment.contain_origin(id, params),
- {:ok, activity} <- Transmogrifier.handle_incoming(params, options),
- {:object, _data, %Object{} = object} <-
- {:object, data, Object.normalize(activity, false)} do
- {:ok, object}
- else
- {:error, {:reject, nil}} ->
- {:reject, nil}
-
- {:object, data, nil} ->
- reinject_object(data)
-
- object = %Object{} ->
- {:ok, object}
-
- :error ->
- {:error, "Object containment failed."}
-
- e ->
- e
- end
- else
- if status == :ok and object != nil do
- {:ok, object}
- else
- # Only fallback when receiving a fetch/normalization error with ActivityPub
- Logger.info("Couldn't get object via AP, trying out OStatus fetching...")
-
- # FIXME: OStatus Object Containment?
- case OStatus.fetch_activity_from_url(id) do
- {:ok, [activity | _]} -> {:ok, Object.normalize(activity, false)}
- e -> e
- end
- end
- end
+ {:containment, _} ->
+ {:error, "Object containment failed."}
+
+ {:transmogrifier, {:error, {:reject, nil}}} ->
+ {:reject, nil}
+
+ {:transmogrifier, _} ->
+ {:error, "Transmogrifier failure."}
+
+ {:object, data, nil} ->
+ reinject_object(%Object{}, data)
+
+ {:normalize, object = %Object{}} ->
+ {:ok, object}
+
+ {:fetch_object, %Object{} = object} ->
+ {:ok, object}
+
+ e ->
+ e