From 9a9bc336782b97231f334862568662b3d1e07b61 Mon Sep 17 00:00:00 2001 From: Andrew Kane Date: Mon, 16 Jan 2017 10:04:44 -0800 Subject: [PATCH] Fixed notifications for records missing ids --- lib/searchkick/index.rb | 6 +++++- lib/searchkick/logging.rb | 2 +- 2 files changed, 6 insertions(+), 2 deletions(-) diff --git a/lib/searchkick/index.rb b/lib/searchkick/index.rb index 769ce72..b48189d 100644 --- a/lib/searchkick/index.rb +++ b/lib/searchkick/index.rb @@ -76,7 +76,7 @@ module Searchkick end def bulk_delete(records) - Searchkick.indexer.queue(records.reject { |r| r.id.blank? }.map { |r| {delete: record_data(r)} }) + bulk_delete_helper(records.reject { |r| r.id.blank? }) end def bulk_index(records) @@ -475,6 +475,10 @@ module Searchkick end end + def bulk_delete_helper(records) + Searchkick.indexer.queue(records.map { |r| {delete: record_data(r)} }) + end + def redis Searchkick.redis end diff --git a/lib/searchkick/logging.rb b/lib/searchkick/logging.rb index c4621f8..f6c5663 100644 --- a/lib/searchkick/logging.rb +++ b/lib/searchkick/logging.rb @@ -48,7 +48,7 @@ module Searchkick end end - def bulk_delete(records) + def bulk_delete_helper(records) if records.any? event = { name: "#{records.first.searchkick_klass.name} Delete", -- libgit2 0.21.0