diff options
author | David Yip <yipdw@member.fsf.org> | 2017-11-17 17:40:00 -0600 |
---|---|---|
committer | David Yip <yipdw@member.fsf.org> | 2017-11-17 17:40:00 -0600 |
commit | 1ab12ba38ebd42be93b63b7cf0d3c6a81060b741 (patch) | |
tree | 3899389c63c16e33dd48fadb270d3259a7c15b67 /app/models/feed.rb | |
parent | 6f8ccbfcdf7fd8ca651d1583a608e96b25a09e25 (diff) | |
parent | 24cafd73a2b644025e9aeaadf4fed46dd3ecea4d (diff) |
Merge remote-tracking branch 'origin/master' into merge-upstream
Diffstat (limited to 'app/models/feed.rb')
-rw-r--r-- | app/models/feed.rb | 23 |
1 files changed, 7 insertions, 16 deletions
diff --git a/app/models/feed.rb b/app/models/feed.rb index 5f7b7877a..d99f1ffb2 100644 --- a/app/models/feed.rb +++ b/app/models/feed.rb @@ -1,36 +1,27 @@ # frozen_string_literal: true class Feed - def initialize(type, account) - @type = type - @account = account + def initialize(type, id) + @type = type + @id = id end def get(limit, max_id = nil, since_id = nil) - if redis.exists("account:#{@account.id}:regeneration") - from_database(limit, max_id, since_id) - else - from_redis(limit, max_id, since_id) - end + from_redis(limit, max_id, since_id) end - private + protected def from_redis(limit, max_id, since_id) max_id = '+inf' if max_id.blank? since_id = '-inf' if since_id.blank? unhydrated = redis.zrevrangebyscore(key, "(#{max_id}", "(#{since_id}", limit: [0, limit], with_scores: true).map(&:first).map(&:to_i) - Status.where(id: unhydrated).cache_ids - end - def from_database(limit, max_id, since_id) - Status.as_home_timeline(@account) - .paginate_by_max_id(limit, max_id, since_id) - .reject { |status| FeedManager.instance.filter?(:home, status, @account.id) } + Status.where(id: unhydrated).cache_ids end def key - FeedManager.instance.key(@type, @account.id) + FeedManager.instance.key(@type, @id) end def redis |