github / searchkick

Download as
Browse Code ยป

Commit 9a9bc336782b97231f334862568662b3d1e07b61

Authored by Andrew Kane
1 parent 122d6b85
Exists in master and in 19 other branches allow_missing, conversions_period, conversions_v2, eager_load, find_in_batches, highlighted, index_name, lazy_index_name, less_deps, nested, reindex_refactor, relation, relation_search, routing_queue, scope_attributes, search_as_you_type, synonyms_ci, test_language, wildcard

Fixed notifications for records missing ids

Showing 2 changed files with 6 additions and 2 deletions   Show diff stats
lib/searchkick/index.rb
  Diff comments   View file @9a9bc33
... ... @@ -76,7 +76,7 @@ module Searchkick
76 76 end
77 77  
78 78 def bulk_delete(records)
79   - Searchkick.indexer.queue(records.reject { |r| r.id.blank? }.map { |r| {delete: record_data(r)} })
  79 + bulk_delete_helper(records.reject { |r| r.id.blank? })
80 80 end
81 81  
82 82 def bulk_index(records)
... ... @@ -475,6 +475,10 @@ module Searchkick
475 475 end
476 476 end
477 477  
  478 + def bulk_delete_helper(records)
  479 + Searchkick.indexer.queue(records.map { |r| {delete: record_data(r)} })
  480 + end
  481 +
478 482 def redis
479 483 Searchkick.redis
480 484 end
... ...
lib/searchkick/logging.rb
  Diff comments   View file @9a9bc33
... ... @@ -48,7 +48,7 @@ module Searchkick
48 48 end
49 49 end
50 50  
51   - def bulk_delete(records)
  51 + def bulk_delete_helper(records)
52 52 if records.any?
53 53 event = {
54 54 name: "#{records.first.searchkick_klass.name} Delete",
... ...