diff options
author | Eugen Rochko <eugen@zeonfederated.com> | 2016-03-08 20:16:11 +0100 |
---|---|---|
committer | Eugen Rochko <eugen@zeonfederated.com> | 2016-03-08 20:20:45 +0100 |
commit | 6c4c84b161947cb11ad0451a39e26b25be4c93d5 (patch) | |
tree | fa2a6f4aaff71fcf76c745a57cb7732102814871 /app/services/precompute_feed_service.rb | |
parent | fe57f6330f089d023f0fa4db7f7c8a51551d2ee9 (diff) |
Distrubute statuses as a fan-out-on-write system, with optional precomputing
Diffstat (limited to 'app/services/precompute_feed_service.rb')
-rw-r--r-- | app/services/precompute_feed_service.rb | 35 |
1 files changed, 35 insertions, 0 deletions
diff --git a/app/services/precompute_feed_service.rb b/app/services/precompute_feed_service.rb new file mode 100644 index 000000000..89b034404 --- /dev/null +++ b/app/services/precompute_feed_service.rb @@ -0,0 +1,35 @@ +class PrecomputeFeedService < BaseService + MAX_FEED_SIZE = 800 + + # Fill up a user's home/mentions feed from DB and return it + # @param [Symbol] type :home or :mentions + # @param [Account] account + # @return [Array] + def call(type, account) + statuses = send(type.to_s, account).order('created_at desc').limit(MAX_FEED_SIZE) + statuses.each { |status| push(type, account.id, status) } + statuses + end + + private + + def push(type, receiver_id, status) + redis.zadd(key(type, receiver_id), status.created_at.to_i, status.id) + end + + def home(account) + Status.where(account: [account] + account.following) + end + + def mentions(account) + Status.where(id: Mention.where(account: account).pluck(:status_id)) + end + + def key(type, id) + "feed:#{type}:#{id}" + end + + def redis + $redis + end +end |