1 defmodule Pleroma.Repo.Migrations.MigrateFollowingRelationships do
5 execute(import_pending_follows_from_activities(), "")
8 defp import_pending_follows_from_activities do
11 following_relationships (
21 activities.data ->> 'state',
22 (activities.data ->> 'published') :: timestamp,
26 JOIN users AS followers ON (activities.actor = followers.ap_id)
27 JOIN users AS following ON (activities.data ->> 'object' = following.ap_id)
29 activities.data ->> 'type' = 'Follow'
30 AND activities.data ->> 'state' = 'pending'
31 ORDER BY activities.updated_at DESC
32 ON CONFLICT DO NOTHING