collector: bulk insert received events every seconds

1 files changed, 11 insertions, 18 deletions

diff --git a/app/models/favorite.rb b/app/models/favorite.rb
index 4447ccf..8c4202c 100644
--- a/app/models/favorite.rb
+++ b/app/models/favorite.rb
@@ -2,27 +2,20 @@ class Favorite < ActiveRecord::Base
   belongs_to :tweet
   belongs_to :user
 
-  def self.create_from_json(json)
-    tweet = Tweet.create_from_json(json[:target_object])
-    user = User.create_from_json(json[:source])
-
-    transaction do
-      favorite = Favorite.create!(tweet: tweet, user: user)
-      tweet.update_reactions_count(favorites_count: 1, json: json[:target_object])
-
-      favorite
+  # This doesn't update Tweet#reactions_count.
+  def self.create_bulk_from_json(array)
+    objects = array.map do |json|
+      self.new(user_id: json[:source][:id],
+               tweet_id: json[:target_object][:id])
     end
-  rescue ActiveRecord::RecordNotUnique => e
-    logger.debug("Duplicate favorite: #{user.id} => #{tweet.id}")
-    self.where(tweet: tweet, user: user).first
+
+    self.import objects
   end
 
-  def self.destroy_from_json(json)
-    transaction do
-      deleted_count = self.where(user_id: json[:source][:id], tweet_id: json[:target_object][:id]).delete_all
-      if deleted_count > 0
-        Tweet.find(json[:target_object][:id]).update_reactions_count(favorites_count: -1, json: json[:target_object])
-      end
+  # This doesn't update Tweet#reactions_count.
+  def self.delete_bulk_from_json(array)
+    array.each do |json|
+      self.delete_all(user_id: json[:source][:id], tweet_id: json[:target_object][:id])
     end
   end
 end