m/akkoma
1
0
Fork 0
forked from AkkomaGang/akkoma
Code Issues Pull requests Projects Releases Packages Wiki Activity

migration without using old field name

Browse source 
removing old field from db, after bookmarks migration
This commit is contained in:
Alex S 2019-04-22 12:45:45 +07:00
parent 3c2ae80008
commit 229ce6abbc
2 changed files with 10 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
lib/pleroma/user.ex
View file

@ -55,8 +55,6 @@ defmodule Pleroma.User do
field(:search_type, :integer, virtual: true)
field(:tags, {:array, :string}, default: [])
field(:last_refreshed_at, :naive_datetime_usec)
# TODO: add migration to delete `bookmarks` field from DB
field(:old_bookmarks, {:array, :string}, default: [], source: :bookmarks)
has_many(:bookmarks, Bookmark)
has_many(:notifications, Notification)
has_many(:registrations, Registration)

20
priv/repo/migrations/20190414125034_migrate_old_bookmarks.exs
View file

@ -6,24 +6,24 @@ defmodule Pleroma.Repo.Migrations.MigrateOldBookmarks do
alias Pleroma.User
alias Pleroma.Repo
def up do
def change 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}
where: fragment("array_length(bookmarks, 1)") > 0,
select: %{id: u.id, bookmarks: fragment("bookmarks")}
)
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)
|> Enum.each(fn %{id: user_id, bookmarks: bookmarks} ->
Enum.each(bookmarks, fn ap_id ->
activity = Activity.get_create_by_object_ap_id(ap_id)
{:ok, _} = Bookmark.create(user_id, activity.id)
end)
end)
end
def down do
execute("TRUNCATE TABLE bookmarks")
alter table(:users) do
remove(:bookmarks)
end
end
end