Page MenuHomePhorge
Files F85829988

No OneTemporary
Actions

Authored By
Unknown
Size
5 KB
Referenced Files
None
Subscribers
None

View Options

diff --git a/priv/repo/migrations/20191007073319_create_following_relationships.exs b/priv/repo/migrations/20191007073319_create_following_relationships.exs
index 7b8a2f9bd..fe229240b 100644
--- a/priv/repo/migrations/20191007073319_create_following_relationships.exs
+++ b/priv/repo/migrations/20191007073319_create_following_relationships.exs
@@ -1,92 +1,111 @@
defmodule Pleroma.Repo.Migrations.CreateFollowingRelationships do
use Ecto.Migration
# had to disable these to be able to restore `following` index concurrently
# https://hexdocs.pm/ecto_sql/Ecto.Migration.html#index/3-adding-dropping-indexes-concurrently
@disable_ddl_transaction true
@disable_migration_lock true
def change do
create_if_not_exists table(:following_relationships) do
add(:follower_id, references(:users, type: :uuid, on_delete: :delete_all), null: false)
add(:following_id, references(:users, type: :uuid, on_delete: :delete_all), null: false)
add(:state, :string, null: false)
timestamps()
end
create_if_not_exists(index(:following_relationships, :follower_id))
create_if_not_exists(unique_index(:following_relationships, [:follower_id, :following_id]))
- execute(insert_following_relationships_rows(), restore_following_column())
+ execute(import_following_from_users(), "")
+ execute(import_following_from_activities(), restore_following_column())
drop(index(:users, [:following], concurrently: true, using: :gin))
alter table(:users) do
remove(:following, {:array, :string}, default: [])
end
end
- defp insert_following_relationships_rows do
+ defp import_following_from_users do
+ """
+ INSERT INTO following_relationships (follower_id, following_id, state, inserted_at, updated_at)
+ SELECT
+ relations.follower_id,
+ following.id,
+ 'accept',
+ now(),
+ now()
+ FROM (
+ SELECT
+ users.id AS follower_id,
+ unnest(users.following) AS following_ap_id
+ FROM
+ users
+ WHERE
+ users.following != '{}'
+ AND users.local = false OR users.local = true AND users.email IS NOT NULL -- Exclude `internal/fetch` and `relay`
+ ) AS relations
+ JOIN users AS "following" ON "following".follower_address = relations.following_ap_id
+
+ WHERE relations.follower_id != following.id
+ ON CONFLICT DO NOTHING
+ """
+ end
+
+ defp import_following_from_activities do
"""
INSERT INTO
following_relationships (
follower_id,
following_id,
state,
inserted_at,
updated_at
)
SELECT
followers.id,
following.id,
activities.data ->> 'state',
(activities.data ->> 'published') :: timestamp,
now()
FROM
activities
JOIN users AS followers ON (activities.actor = followers.ap_id)
JOIN users AS following ON (activities.data ->> 'object' = following.ap_id)
WHERE
activities.data ->> 'type' = 'Follow'
- AND activities.data ->> 'state' IN ('accept', 'pending', 'reject') ON CONFLICT DO NOTHING
+ AND activities.data ->> 'state' IN ('accept', 'pending', 'reject')
+ ORDER BY activities.updated_at DESC
+ ON CONFLICT DO NOTHING
"""
end
defp restore_following_column do
"""
UPDATE
users
SET
- following = following_query.following,
+ following = following_query.following_array,
updated_at = now()
- FROM
- (
- SELECT
- followers.id AS follower_id,
- array_prepend(
- followers.follower_address,
- array_agg(DISTINCT following.ap_id) FILTER (
- WHERE
- following.ap_id IS NOT NULL
- )
- ) as following
- FROM
- users AS followers
- LEFT OUTER JOIN activities ON (
- followers.ap_id = activities.actor
- AND activities.data ->> 'type' = 'Follow'
- AND activities.data ->> 'state' IN ('accept', 'pending', 'reject')
- )
- LEFT OUTER JOIN users AS following ON (activities.data ->> 'object' = following.ap_id)
- WHERE
- followers.email IS NOT NULL -- Exclude `internal/fetch` and `relay`
- GROUP BY
- followers.id,
- followers.ap_id
- ) AS following_query
+ FROM (
+ SELECT
+ follwer.id AS follower_id,
+ CASE follwer.local
+ WHEN TRUE THEN
+ array_prepend(follwer.follower_address, array_agg(following.follower_address))
+ ELSE
+ array_agg(following.follower_address)
+ END AS following_array
+ FROM
+ following_relationships
+ JOIN users AS follwer ON follwer.id = following_relationships.follower_id
+ JOIN users AS FOLLOWING ON following.id = following_relationships.following_id
+ GROUP BY
+ follwer.id) AS following_query
WHERE
- following_query.follower_id = users.id;
+ following_query.follower_id = users.id
"""
end
end

File Metadata

Mime Type
text/x-diff
Expires
Sun, Nov 1, 1:05 AM (16 h, 24 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
1802112
Default Alt Text
(5 KB)

Event Timeline