No OneTemporary
Actions

Size

1 KB

Referenced Files

None

Subscribers

None

View Options

	diff --git a/priv/repo/migrations/20200415181818_update_markers.exs b/priv/repo/migrations/20200415181818_update_markers.exs
	index 976363565..bb9d8e860 100644
	--- a/priv/repo/migrations/20200415181818_update_markers.exs
	+++ b/priv/repo/migrations/20200415181818_update_markers.exs
	@@ -1,40 +1,44 @@
	defmodule Pleroma.Repo.Migrations.UpdateMarkers do
	use Ecto.Migration
	import Ecto.Query
	alias Pleroma.Repo

	def up do
	update_markers()
	end

	def down do
	:ok
	end

	defp update_markers do
	now = NaiveDateTime.utc_now()

	markers_attrs =
	from(q in "notifications",
	select: %{
	timeline: "notifications",
	user_id: q.user_id,
	last_read_id:
	type(fragment("MAX( CASE WHEN seen = true THEN id ELSE null END )"), :string)
	},
	group_by: [q.user_id]
	)
	\|> Repo.all()
	\|> Enum.map(fn %{last_read_id: last_read_id} = attrs ->
	attrs
	\|> Map.put(:last_read_id, last_read_id \|\| "")
	\|> Map.put_new(:inserted_at, now)
	\|> Map.put_new(:updated_at, now)
	end)

	- Repo.insert_all("markers", markers_attrs,
	- on_conflict: {:replace, [:last_read_id]},
	- conflict_target: [:user_id, :timeline]
	- )
	+ markers_attrs
	+ \|> Enum.chunk_every(1000)
	+ \|> Enum.each(fn markers_attrs_chunked ->
	+ Repo.insert_all("markers", markers_attrs_chunked,
	+ on_conflict: {:replace, [:last_read_id]},
	+ conflict_target: [:user_id, :timeline]
	+ )
	+ end)
	end
	end