mirror of
https://github.com/discourse/discourse-rewind.git
synced 2025-09-08 20:51:53 +00:00
439950e300
Also make it so we limit the amount of words returned on the server, no point returning 100 to the client and slicing.
86 lines
1.9 KiB
Ruby
86 lines
1.9 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
module DiscourseRewind
|
|
# Service responsible to fetch a rewind for a username/year.
|
|
#
|
|
# @example
|
|
# ::DiscourseRewind::Rewind::Fetch.call(
|
|
# guardian: guardian,
|
|
# params: { year: 2023, username: 'codinghorror' }
|
|
# )
|
|
#
|
|
class FetchReports
|
|
include Service::Base
|
|
|
|
# @!method self.call(guardian:, params:)
|
|
# @param [Guardian] guardian
|
|
# @param [Hash] params
|
|
# @option params [Integer] :year of the rewind
|
|
# @option params [Integer] :username of the rewind
|
|
# @return [Service::Base::Context]
|
|
|
|
CACHE_DURATION = Rails.env.development? ? 10.seconds : 5.minutes
|
|
|
|
# order matters
|
|
REPORTS = [
|
|
Action::TopWords,
|
|
Action::ReadingTime,
|
|
Action::Reactions,
|
|
Action::Fbff,
|
|
Action::FavoriteTags,
|
|
Action::FavoriteCategories,
|
|
Action::BestTopics,
|
|
Action::BestPosts,
|
|
Action::ActivityCalendar,
|
|
]
|
|
|
|
model :year
|
|
model :user
|
|
model :date
|
|
model :reports
|
|
|
|
private
|
|
|
|
def fetch_user(guardian:)
|
|
User.find_by_username(guardian.user.username)
|
|
end
|
|
|
|
def fetch_year
|
|
current_date = Time.zone.now
|
|
current_month = current_date.month
|
|
current_year = current_date.year
|
|
|
|
case current_month
|
|
when 1
|
|
current_year - 1
|
|
when 12
|
|
current_year
|
|
else
|
|
if Rails.env.development?
|
|
current_year
|
|
else
|
|
false
|
|
end
|
|
end
|
|
end
|
|
|
|
def fetch_date(params:, year:)
|
|
Date.new(year).all_year
|
|
end
|
|
|
|
def fetch_reports(date:, user:, guardian:, year:)
|
|
key = "rewind:#{guardian.user.username}:#{year}"
|
|
reports = Discourse.redis.get(key)
|
|
|
|
if !reports
|
|
reports = REPORTS.map { |report| report.call(date:, user:, guardian:) }
|
|
Discourse.redis.setex(key, CACHE_DURATION, MultiJson.dump(reports))
|
|
else
|
|
reports = MultiJson.load(reports, symbolize_keys: true)
|
|
end
|
|
|
|
reports
|
|
end
|
|
end
|
|
end
|