about summary refs log tree commit diff
path: root/app/models/feed.rb
diff options
context:
space:
mode:
authornicolas <nclm@users.noreply.github.com>2016-11-23 15:43:27 +0100
committerGitHub <noreply@github.com>2016-11-23 15:43:27 +0100
commit23677bc51e657522049fb904e626f81f577de515 (patch)
treedc9417c57a3af3036d621940a751e9adf1b09ce3 /app/models/feed.rb
parent1e95fbb10b81ea0eedcb39a83e52f42e3dbb456c (diff)
parent82191b33831f26e071a27dd59ce2e46fb467589c (diff)
Merge branch 'master' into french-translation
Diffstat (limited to 'app/models/feed.rb')
-rw-r--r--app/models/feed.rb25
1 files changed, 24 insertions, 1 deletions
diff --git a/app/models/feed.rb b/app/models/feed.rb
index e7f2ab3a5..45cb923d1 100644
--- a/app/models/feed.rb
+++ b/app/models/feed.rb
@@ -16,7 +16,7 @@ class Feed
       RegenerationWorker.perform_async(@account.id, @type)
       @statuses = Status.send("as_#{@type}_timeline", @account).paginate_by_max_id(limit, nil, nil)
     else
-      status_map = Status.where(id: unhydrated).with_includes.with_counters.map { |status| [status.id, status] }.to_h
+      status_map = cache(unhydrated)
       @statuses = unhydrated.map { |id| status_map[id] }.compact
     end
 
@@ -25,6 +25,29 @@ class Feed
 
   private
 
+  def cache(ids)
+    raw                    = Status.where(id: ids).to_a
+    uncached_ids           = []
+    cached_keys_with_value = Rails.cache.read_multi(*raw.map(&:cache_key))
+
+    raw.each do |status|
+      uncached_ids << status.id unless cached_keys_with_value.key?(status.cache_key)
+    end
+
+    unless uncached_ids.empty?
+      uncached = Status.where(id: uncached_ids).with_includes.map { |s| [s.id, s] }.to_h
+
+      uncached.values.each do |status|
+        Rails.cache.write(status.cache_key, status)
+      end
+    end
+
+    cached = cached_keys_with_value.values.map { |s| [s.id, s] }.to_h
+    cached.merge!(uncached) unless uncached_ids.empty?
+
+    cached
+  end
+
   def key
     FeedManager.instance.key(@type, @account.id)
   end