s/class_name/name/g

app/jobs/regular/index.rb

@@ -6,7 +6,7 @@ class Index < ::Jobs::Base
 
     def execute(args)
       id = args[:id]
-      type = "::InstantSearch::Collections::#{args[:type]}".constantize
+      type = args[:type].constantize
       object = type.model.find_by(id: id)
 
       return unless object.present?

lib/instant_search/collections/base.rb

@@ -7,7 +7,7 @@ def initialize(object)
     end
 
     def self.model
-      self.class_name.constantize
+      self.name.demodulize.constantize
     end
 
     def create
@@ -37,7 +37,7 @@ def self.default_sorting_field
     end
 
     def self.collection
-      self.class_name.demodulize.underscore.pluralize
+      self.name.demodulize.underscore.pluralize
     end
 
     def self.create_collection

lib/instant_search/event_handler.rb

@@ -4,16 +4,16 @@ module ::InstantSearch
   class EventHandler
     def self.setup(plugin)
       ::InstantSearch::Collections::Base.subclasses.each do |collection|
-        symbol_prefix = collection.class_name.underscore
+        symbol_prefix = collection.name.demodulize.underscore
 
         %w[created edited].each do |action|
           plugin.on("#{symbol_prefix}_#{action}".to_sym) do |target|
-            Jobs.enqueue(:index, id: target.id, type: collection.class_name, action: "upsert")
+            Jobs.enqueue(:index, id: target.id, type: collection.name, action: "upsert")
           end
         end
 
         plugin.on("#{symbol_prefix}_destroyed".to_sym) do |target|
-          Jobs.enqueue(:index, id: target.id, type: collection.class_name, action: "delete")
+          Jobs.enqueue(:index, id: target.id, type: collection.name, action: "delete")
         end
       end
     end

lib/tasks/index.rake

@@ -13,10 +13,10 @@ end
 task "instant_search:index", %i[concurrency] => [:environment] do |_, args|
   load!
   InstantSearch::Collections::Base.subclasses.each do |collection|
-    puts "### Indexing #{collection.class_name}"
+    puts "### Indexing #{collection.name}"
     i = 0
     total = collection.model.count
-    queue = SizedQueue.new(50)
+    queue = SizedQueue.new(20)
     Thread.new do
       collection.model.find_in_batches { |batch| batch.each { |object| queue.push object } }
       queue.push Parallel::Stop
@@ -26,10 +26,10 @@ task "instant_search:index", %i[concurrency] => [:environment] do |_, args|
       ActiveRecord::Base.connection_pool.with_connection do
         collection.new(item).create
         i += 1
-        print "### Indexed #{i * 100 * args[:concurrency].to_i / total}% of #{collection.class_name}          \r"
+        print "### Indexed #{i * 100 * args[:concurrency].to_i / total}% of #{collection.name}          \r"
       end
     end
-    puts "### Indexed #{collection.class_name} done                      "
+    puts "### Indexed #{collection.name} done                      "
   end
 end