aboutsummaryrefslogtreecommitdiffstats
path: root/app/models/favorite.rb
diff options
context:
space:
mode:
authorrhenium <rhenium@rhe.jp>2014-12-12 07:18:25 +0900
committerrhenium <rhenium@rhe.jp>2014-12-12 07:18:25 +0900
commitf2f74d11f94d1d692e34b1e31d37c0962055aca8 (patch)
tree06c1f550e521f80ff882871f0f8acf5442f49b2d /app/models/favorite.rb
parent56ae9c7ef8eb91a18db10075accf10bf248e2776 (diff)
downloadaclog-f2f74d11f94d1d692e34b1e31d37c0962055aca8.tar.gz
collector: optimize (creating model class instance is so slow)
Diffstat (limited to 'app/models/favorite.rb')
-rw-r--r--app/models/favorite.rb10
1 files changed, 7 insertions, 3 deletions
diff --git a/app/models/favorite.rb b/app/models/favorite.rb
index da8087c..701b8ca 100644
--- a/app/models/favorite.rb
+++ b/app/models/favorite.rb
@@ -7,12 +7,16 @@ class Favorite < ActiveRecord::Base
#
# @param [Array] array An array of Streaming API events.
def self.create_bulk_from_json(array)
+ return if array.empty?
+
objects = array.map do |json|
- self.new(user_id: json[:source][:id],
- tweet_id: json[:target_object][:id])
+ {
+ user_id: json[:source][:id],
+ tweet_id: json[:target_object][:id]
+ }
end
- self.import(objects, ignore: true)
+ self.import(objects.first.keys, objects.map(&:values), ignore: true)
end
# Unregisters favorite event in bulk from an array of Streaming API 'unfavorite' events.