mirror of
https://github.com/discourse/discourse-rewind.git
synced 2025-07-10 07:13:27 +00:00
113 lines
3.4 KiB
Ruby
113 lines
3.4 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
# Forum Best Friend Forever ranking
|
|
# Score is informative only, do not show in UI
|
|
module DiscourseRewind
|
|
class Rewind::Action::Fbff < Rewind::Action::BaseReport
|
|
MAX_SUMMARY_RESULTS ||= 50
|
|
LIKE_SCORE ||= 1
|
|
REPLY_SCORE ||= 10
|
|
|
|
def call
|
|
most_liked_users =
|
|
like_query(date)
|
|
.where(acting_user_id: user.id)
|
|
.group(:user_id)
|
|
.order("COUNT(*) DESC")
|
|
.limit(MAX_SUMMARY_RESULTS)
|
|
.pluck("user_actions.user_id, COUNT(*)")
|
|
.map { |user_id, count| { user_id => count } }
|
|
.reduce({}, :merge)
|
|
|
|
most_liked_by_users =
|
|
like_query(date)
|
|
.where(user: user)
|
|
.group(:acting_user_id)
|
|
.order("COUNT(*) DESC")
|
|
.limit(MAX_SUMMARY_RESULTS)
|
|
.pluck("acting_user_id, COUNT(*)")
|
|
.map { |acting_user_id, count| { acting_user_id => count } }
|
|
.reduce({}, :merge)
|
|
|
|
users_who_most_replied_me =
|
|
post_query(user, date)
|
|
.where(posts: { user_id: user.id })
|
|
.group("replies.user_id")
|
|
.order("COUNT(*) DESC")
|
|
.limit(MAX_SUMMARY_RESULTS)
|
|
.pluck("replies.user_id, COUNT(*)")
|
|
.map { |user_id, count| { user_id => count } }
|
|
.reduce({}, :merge)
|
|
|
|
users_i_most_replied =
|
|
post_query(user, date)
|
|
.where("replies.user_id = ?", user.id)
|
|
.group("posts.user_id")
|
|
.order("COUNT(*) DESC")
|
|
.limit(MAX_SUMMARY_RESULTS)
|
|
.pluck("posts.user_id, COUNT(*)")
|
|
.map { |user_id, count| { user_id => count } }
|
|
.reduce({}, :merge)
|
|
|
|
#TODO include chat?
|
|
|
|
fbffs = [
|
|
apply_score(most_liked_users, LIKE_SCORE),
|
|
apply_score(most_liked_by_users, LIKE_SCORE),
|
|
apply_score(users_who_most_replied_me, REPLY_SCORE),
|
|
apply_score(users_i_most_replied, REPLY_SCORE),
|
|
]
|
|
|
|
fbff_id =
|
|
fbffs
|
|
.flatten
|
|
.inject { |h1, h2| h1.merge(h2) { |_, v1, v2| v1 + v2 } }
|
|
&.sort_by { |_, v| -v }
|
|
&.first
|
|
&.first
|
|
|
|
return if !fbff_id
|
|
|
|
{
|
|
data: {
|
|
fbff: BasicUserSerializer.new(User.find(fbff_id), root: false).as_json,
|
|
yourself: BasicUserSerializer.new(user, root: false).as_json,
|
|
},
|
|
identifier: "fbff",
|
|
}
|
|
end
|
|
|
|
def post_query(user, date)
|
|
Post
|
|
.joins(:topic)
|
|
.includes(:topic)
|
|
.where(
|
|
"posts.post_type IN (?)",
|
|
Topic.visible_post_types(user, include_moderator_actions: false),
|
|
)
|
|
.joins(
|
|
"INNER JOIN posts replies ON posts.topic_id = replies.topic_id AND posts.reply_to_post_number = replies.post_number",
|
|
)
|
|
.joins(
|
|
"INNER JOIN topics ON replies.topic_id = topics.id AND topics.archetype <> 'private_message'",
|
|
)
|
|
.joins(
|
|
"AND replies.post_type IN (#{Topic.visible_post_types(user, include_moderator_actions: false).join(",")})",
|
|
)
|
|
.where("replies.created_at BETWEEN ? AND ?", date.first, date.last)
|
|
.where("replies.user_id <> posts.user_id")
|
|
end
|
|
|
|
def like_query(date)
|
|
UserAction
|
|
.joins(:target_topic, :target_post)
|
|
.where(created_at: date)
|
|
.where(action_type: UserAction::WAS_LIKED)
|
|
end
|
|
|
|
def apply_score(users, score)
|
|
users.map { |user_id, count| { user_id => count * score } }
|
|
end
|
|
end
|
|
end
|