diff options
author | rinpatch <rinpatch@sdf.org> | 2019-09-18 19:53:51 +0300 |
---|---|---|
committer | Ariadne Conill <ariadne@dereferenced.org> | 2019-10-06 14:53:40 +0000 |
commit | 644bc1e64a81408be6ffc82b063e19ffb9a9a1a6 (patch) | |
tree | d07d8261559cd9fcf3233af59feea8b4df537fee /lib | |
parent | 845e8ad5f62d92666403c4e7c12d590b514c4bc5 (diff) | |
download | pleroma-644bc1e64a81408be6ffc82b063e19ffb9a9a1a6.tar.gz |
Preserve internal fields when reinjecting
Diffstat (limited to 'lib')
-rw-r--r-- | lib/pleroma/object/fetcher.ex | 10 |
1 files changed, 10 insertions, 0 deletions
diff --git a/lib/pleroma/object/fetcher.ex b/lib/pleroma/object/fetcher.ex index 786e31cce..fecc97c5e 100644 --- a/lib/pleroma/object/fetcher.ex +++ b/lib/pleroma/object/fetcher.ex @@ -13,6 +13,7 @@ defmodule Pleroma.Object.Fetcher do alias Pleroma.Web.OStatus require Logger + require Pleroma.Constants defp touch_changeset(changeset) do updated_at = @@ -22,10 +23,19 @@ defmodule Pleroma.Object.Fetcher do Ecto.Changeset.put_change(changeset, :updated_at, updated_at) end + defp maybe_reinject_internal_fields(data, %{data: %{} = old_data}) do + internal_fields = Map.take(old_data, Pleroma.Constants.object_internal_fields()) + + Map.merge(data, internal_fields) + end + + defp maybe_reinject_internal_fields(data, _), do: data + defp reinject_object(struct, data) do Logger.debug("Reinjecting object #{data["id"]}") with data <- Transmogrifier.fix_object(data), + data <- maybe_reinject_internal_fields(data, struct), changeset <- Object.change(struct, %{data: data}), changeset <- touch_changeset(changeset), {:ok, object} <- Repo.insert_or_update(changeset) do |