attr_reader :account
def populate_feed
- redis.pipelined do
- statuses.reverse_each do |status|
- process_status(status)
- end
+ pairs = statuses.reverse_each.map(&method(:process_status))
+ redis.pipelined do
+ redis.zadd(account_home_key, pairs)
redis.del("account:#{@account.id}:regeneration")
end
end
def process_status(status)
- add_status_to_feed(status) unless status_filtered?(status)
- end
-
- def add_status_to_feed(status)
- redis.zadd(account_home_key, status.id, status.reblog? ? status.reblog_of_id : status.id)
+ [status.id, status.reblog? ? status.reblog_of_id : status.id] unless status_filtered?(status)
end
def status_filtered?(status)