mirror of
https://akkoma.dev/AkkomaGang/akkoma.git
synced 2024-11-26 07:52:17 +00:00
Added migration to update existing user note counters
This commit is contained in:
parent
c46950d3b1
commit
8a1e0c9bee
|
@ -0,0 +1,41 @@
|
|||
defmodule Pleroma.Repo.Migrations.UpdateUserNoteCounters do
|
||||
use Ecto.Migration
|
||||
|
||||
@public "https://www.w3.org/ns/activitystreams#Public"
|
||||
|
||||
def up do
|
||||
execute """
|
||||
WITH public_note_count AS (
|
||||
SELECT
|
||||
data->>'actor' AS actor,
|
||||
count(id) AS count
|
||||
FROM objects
|
||||
WHERE data->>'type' = 'Note' AND (
|
||||
data->'cc' ? '#{@public}' OR data->'to' ? '#{@public}'
|
||||
)
|
||||
GROUP BY data->>'actor'
|
||||
)
|
||||
UPDATE users AS u
|
||||
SET "info" = jsonb_set(u.info, '{note_count}', o.count::varchar::jsonb, true)
|
||||
FROM public_note_count AS o
|
||||
WHERE u.ap_id = o.actor
|
||||
"""
|
||||
end
|
||||
|
||||
def down do
|
||||
execute """
|
||||
WITH public_note_count AS (
|
||||
SELECT
|
||||
data->>'actor' AS actor,
|
||||
count(id) AS count
|
||||
FROM objects
|
||||
WHERE data->>'type' = 'Note'
|
||||
GROUP BY data->>'actor'
|
||||
)
|
||||
UPDATE users AS u
|
||||
SET "info" = jsonb_set(u.info, '{note_count}', o.count::varchar::jsonb, true)
|
||||
FROM public_note_count AS o
|
||||
WHERE u.ap_id = o.actor
|
||||
"""
|
||||
end
|
||||
end
|
Loading…
Reference in a new issue