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) markers_attrs |> Enum.chunk(1000) |> Enum.each(fn marker_attrs -> Repo.insert_all("markers", markers_attrs, on_conflict: {:replace, [:last_read_id]}, conflict_target: [:user_id, :timeline] ) end) end end