discourse/db/migrate/20190130163001_migrate_revi...

122 lines
3.3 KiB
Ruby
Raw Normal View History

# frozen_string_literal: true
class MigrateReviewableFlaggedPosts < ActiveRecord::Migration[5.2]
def up
# for the migration we'll do 1.0 + trust_level and not take into account user flagging accuracy
# It should be good enough for old flags whose scores are not as important as pending flags.
execute(<<~SQL)
INSERT INTO reviewables (
type,
status,
topic_id,
reviewable_by_moderator,
category_id,
payload,
target_type,
target_id,
target_created_by_id,
score,
created_by_id,
created_at,
updated_at
)
SELECT 'ReviewableFlaggedPost',
CASE
WHEN MAX(pa.agreed_at) IS NOT NULL THEN 1
WHEN MAX(pa.disagreed_at) IS NOT NULL THEN 2
WHEN MAX(pa.deferred_at) IS NOT NULL THEN 3
WHEN MAX(pa.deleted_at) IS NOT NULL THEN 4
ELSE 0
END,
t.id,
true,
t.category_id,
json_build_object(),
'Post',
pa.post_id,
p.user_id,
0,
MAX(pa.user_id),
MIN(pa.created_at),
MAX(pa.updated_at)
FROM post_actions AS pa
INNER JOIN posts AS p ON pa.post_id = p.id
INNER JOIN topics AS t ON t.id = p.topic_id
INNER JOIN post_action_types AS pat ON pat.id = pa.post_action_type_id
WHERE pat.is_flag
AND pat.name_key <> 'notify_user'
AND p.user_id > 0
AND p.deleted_at IS NULL
AND t.deleted_at IS NULL
GROUP BY pa.post_id,
t.id,
t.category_id,
p.user_id
SQL
execute(<<~SQL)
INSERT INTO reviewable_scores (
reviewable_id,
user_id,
reviewable_score_type,
status,
score,
meta_topic_id,
created_at,
updated_at
)
SELECT r.id,
pa.user_id,
pa.post_action_type_id,
CASE
WHEN pa.agreed_at IS NOT NULL THEN 1
WHEN pa.disagreed_at IS NOT NULL THEN 2
WHEN pa.deferred_at IS NOT NULL THEN 3
WHEN pa.deleted_at IS NOT NULL THEN 3
ELSE 0
END,
1.0 +
(CASE
WHEN pau.moderator OR pau.admin THEN 5.0
ELSE pau.trust_level
END) +
(CASE
WHEN pa.staff_took_action THEN 5.0
ELSE 0.0
END),
rp.topic_id,
pa.created_at,
pa.updated_at
FROM post_actions AS pa
INNER JOIN post_action_types AS pat ON pat.id = pa.post_action_type_id
INNER JOIN users AS pau ON pa.user_id = pau.id
INNER JOIN reviewables AS r ON pa.post_id = r.target_id
LEFT OUTER JOIN posts AS rp ON rp.id = pa.related_post_id
WHERE pat.is_flag
AND r.type = 'ReviewableFlaggedPost'
SQL
execute(<<~SQL)
UPDATE reviewables
SET score = COALESCE((
SELECT sum(score)
FROM reviewable_scores AS rs
WHERE rs.reviewable_id = reviewables.id
AND rs.status = 0
), 0),
potential_spam = EXISTS(
SELECT 1
FROM reviewable_scores AS rs
WHERE rs.reviewable_id = reviewables.id
AND rs.reviewable_score_type = 8
)
SQL
end
def down
execute "DELETE FROM reviewables WHERE type = 'ReviewableFlaggedPost'"
execute "DELETE FROM reviewable_scores"
end
end