20171212164525_fill_recipients_in_activities.exs
No OneTemporary
Actions

Size

748 B

Referenced Files

None

Subscribers

None

20171212164525_fill_recipients_in_activities.exs
View Options

	# Pleroma: A lightweight social networking server
	# Copyright © 2017-2022 Pleroma Authors <https://pleroma.social/>
	# SPDX-License-Identifier: AGPL-3.0-only

	defmodule Pleroma.Repo.Migrations.FillRecipientsInActivities do
	use Ecto.Migration
	alias Pleroma.{Repo, Activity}

	def up do
	max = Repo.aggregate(Activity, :max, :id)

	if max do
	IO.puts("#{max} activities")
	chunks = 0..round(max / 10_000)

	Enum.each(chunks, fn i ->
	min = i * 10_000
	max = min + 10_000

	execute("""
	update activities set recipients = array(select jsonb_array_elements_text(data->'to')) where id > #{min} and id <= #{max};
	""")
	\|> IO.inspect()
	end)
	end
	end

	def down, do: :ok
	end