No OneTemporary
Actions

Size

1 KB

Referenced Files

None

Subscribers

None

View Options

	diff --git a/priv/repo/migrations/20190414125034_migrate_old_bookmarks.exs b/priv/repo/migrations/20190414125034_migrate_old_bookmarks.exs
	index c30c302f7..09f02c223 100644
	--- a/priv/repo/migrations/20190414125034_migrate_old_bookmarks.exs
	+++ b/priv/repo/migrations/20190414125034_migrate_old_bookmarks.exs
	@@ -1,31 +1,29 @@
	defmodule Pleroma.Repo.Migrations.MigrateOldBookmarks do
	use Ecto.Migration
	import Ecto.Query
	alias Pleroma.Activity
	alias Pleroma.Bookmark
	alias Pleroma.User
	alias Pleroma.Repo

	def up do
	query =
	from(u in User,
	where: u.local == true,
	where: fragment("array_length(?, 1)", u.old_bookmarks) > 0,
	select: %{id: u.id, old_bookmarks: u.old_bookmarks}
	)

	- Repo.transaction(fn ->
	- Repo.stream(query)
	- \|> Enum.each(fn user ->
	- Enum.each(user.old_bookmarks, fn id ->
	- activity = Activity.get_create_by_object_ap_id(id)
	- {:ok, _} = Bookmark.create(user.id, activity.id)
	- end)
	+ Repo.stream(query)
	+ \|> Enum.each(fn user ->
	+ Enum.each(user.old_bookmarks, fn id ->
	+ activity = Activity.get_create_by_object_ap_id(id)
	+ {:ok, _} = Bookmark.create(user.id, activity.id)
	end)
	end)
	end

	def down do
	execute("TRUNCATE TABLE bookmarks")
	end
	end