1 # Pleroma: A lightweight social networking server
2 # Copyright © 2017-2022 Pleroma Authors <https://pleroma.social/>
3 # SPDX-License-Identifier: AGPL-3.0-only
5 defmodule Pleroma.Repo.Migrations.UsersAndActivitiesFlakeId do
12 # This migrates from int serial IDs to custom Flake:
13 # 1- create a temporary uuid column
14 # 2- fill this column with compatibility ids (see below)
15 # 3- remove pkeys constraints
16 # 4- update relation pkeys with the new ids
17 # 5- rename the temporary column to id
18 # 6- re-create the constraints
20 # Old serial int ids are transformed to 128bits with extra padding.
21 # The application (in `Pleroma.FlakeId`) handles theses IDs properly as integers; to keep compatibility
22 # with previously issued ids.
23 # execute "update activities set external_id = CAST( LPAD( TO_HEX(id), 32, '0' ) AS uuid);"
24 # execute "update users set external_id = CAST( LPAD( TO_HEX(id), 32, '0' ) AS uuid);"
26 clippy = start_clippy_heartbeats()
28 # Lock both tables to avoid a running server to meddling with our transaction
29 execute("LOCK TABLE activities;")
30 execute("LOCK TABLE users;")
33 ALTER TABLE activities
34 DROP CONSTRAINT activities_pkey CASCADE,
35 ALTER COLUMN id DROP default,
36 ALTER COLUMN id SET DATA TYPE uuid USING CAST( LPAD( TO_HEX(id), 32, '0' ) AS uuid),
42 DROP CONSTRAINT users_pkey CASCADE,
43 ALTER COLUMN id DROP default,
44 ALTER COLUMN id SET DATA TYPE uuid USING CAST( LPAD( TO_HEX(id), 32, '0' ) AS uuid),
49 "UPDATE users SET info = jsonb_set(info, '{pinned_activities}', array_to_json(ARRAY(select jsonb_array_elements_text(info->'pinned_activities')))::jsonb);"
53 # Activities - Referenced by:
54 # TABLE "notifications" CONSTRAINT "notifications_activity_id_fkey" FOREIGN KEY (activity_id) REFERENCES activities(id) ON DELETE CASCADE
55 # Users - Referenced by:
56 # TABLE "filters" CONSTRAINT "filters_user_id_fkey" FOREIGN KEY (user_id) REFERENCES users(id) ON DELETE CASCADE
57 # TABLE "lists" CONSTRAINT "lists_user_id_fkey" FOREIGN KEY (user_id) REFERENCES users(id) ON DELETE CASCADE
58 # TABLE "notifications" CONSTRAINT "notifications_user_id_fkey" FOREIGN KEY (user_id) REFERENCES users(id) ON DELETE CASCADE
59 # TABLE "oauth_authorizations" CONSTRAINT "oauth_authorizations_user_id_fkey" FOREIGN KEY (user_id) REFERENCES users(id)
60 # TABLE "oauth_tokens" CONSTRAINT "oauth_tokens_user_id_fkey" FOREIGN KEY (user_id) REFERENCES users(id)
61 # TABLE "password_reset_tokens" CONSTRAINT "password_reset_tokens_user_id_fkey" FOREIGN KEY (user_id) REFERENCES users(id)
62 # TABLE "push_subscriptions" CONSTRAINT "push_subscriptions_user_id_fkey" FOREIGN KEY (user_id) REFERENCES users(id) ON DELETE CASCADE
63 # TABLE "websub_client_subscriptions" CONSTRAINT "websub_client_subscriptions_user_id_fkey" FOREIGN KEY (user_id) REFERENCES users(id)
66 ALTER TABLE notifications
67 ALTER COLUMN activity_id SET DATA TYPE uuid USING CAST( LPAD( TO_HEX(activity_id), 32, '0' ) AS uuid),
68 ADD CONSTRAINT notifications_activity_id_fkey FOREIGN KEY (activity_id) REFERENCES activities(id) ON DELETE CASCADE;
72 ~w(notifications filters lists oauth_authorizations oauth_tokens password_reset_tokens push_subscriptions websub_client_subscriptions) do
75 ALTER COLUMN user_id SET DATA TYPE uuid USING CAST( LPAD( TO_HEX(user_id), 32, '0' ) AS uuid),
76 ADD CONSTRAINT #{table}_user_id_fkey FOREIGN KEY (user_id) REFERENCES users(id) ON DELETE CASCADE;
82 stop_clippy_heartbeats(clippy)
87 defp start_clippy_heartbeats() do
88 count = from(a in "activities", select: count(a.id)) |> Repo.one!()
91 heartbeat_interval = :timer.minutes(2) + :timer.seconds(30)
96 "The migration is still running, maybe it's time for another “tea”?",
97 "Happy rabbits practice a cute behavior known as a\n“binky:” they jump up in the air\nand twist\nand spin around!",
98 "Nothing and everything.\n\nI still work.",
99 "Pleroma runs on a Raspberry Pi!\n\n … but this migration will take forever if you\nactually run on a raspberry pi",
100 "Status? Stati? Post? Note? Toot?\nRepeat? Reboost? Boost? Retweet? Retoot??\n\nI-I'm confused."
103 heartbeat = fn heartbeat, runs, all_tips, tips ->
105 if Integer.is_even(runs) do
106 tips = if tips == [], do: all_tips, else: tips
107 [tip | tips] = Enum.shuffle(tips)
112 "\n -- #{DateTime.to_string(DateTime.utc_now())} Migration still running, please wait…\n"
118 :timer.sleep(heartbeat_interval)
119 heartbeat.(heartbeat, runs + 1, all_tips, tips)
123 [:red, :bright, "It looks like you are running an older instance!"],
125 [:bright, "This migration may take a long time", :reset, " -- so you probably should"],
126 ["go drink a cofe, or a tea, or a beer, a whiskey, a vodka,"],
127 ["while it runs to deal with your temporary fediverse pause!"]
130 :timer.sleep(heartbeat_interval)
131 spawn_link(fn -> heartbeat.(heartbeat, 1, all_tips, []) end)
135 defp stop_clippy_heartbeats(pid) do
138 Process.exit(pid, :kill)
139 Clippy.puts([[:green, :bright, "Hurray!!", "", "", "Migration completed!"]])