Rename stage to sync

pat · Jul 7, 2024 · 06b719f · 06b719f
1 parent 433cbb7
commit 06b719f
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 8 deletions.
diff --git a/lib/thinking_sphinx/processor.rb b/lib/thinking_sphinx/processor.rb
@@ -27,7 +27,7 @@ def upsert
   end
 
   # Will upsert or delete instance into all matching indices based on index scope
-  def stage
+  def sync
     real_time_indices.each do |index|
       found = find_in(index)
 

diff --git a/spec/acceptance/real_time_updates_spec.rb b/spec/acceptance/real_time_updates_spec.rb
@@ -61,14 +61,14 @@
 
     article  = Article.last
 
-    ThinkingSphinx::Processor.new(model: article.class, id: article.id).stage
+    ThinkingSphinx::Processor.new(model: article.class, id: article.id).sync
 
     expect(ThinkingSphinx.search('Nice', :indices => ["published_articles_core"])).to include(article)
 
     Article.connection.execute <<~SQL
       UPDATE articles SET published = FALSE WHERE title = 'Nice Title';
     SQL
-    ThinkingSphinx::Processor.new(model: article.class, id: article.id).stage
+    ThinkingSphinx::Processor.new(model: article.class, id: article.id).sync
 
     expect(ThinkingSphinx.search('Nice', :indices => ["published_articles_core"])).to be_empty
   end
@@ -80,35 +80,35 @@
     SQL
 
     article  = Article.last
-    ThinkingSphinx::Processor.new(:instance => article).stage
+    ThinkingSphinx::Processor.new(:instance => article).sync
 
     expect(ThinkingSphinx.search('Nice', :indices => ["published_articles_core"])).to include(article)
 
     Article.connection.execute <<~SQL
       DELETE FROM articles where title = 'Nice Title';
     SQL
 
-    ThinkingSphinx::Processor.new(:instance => article).stage
+    ThinkingSphinx::Processor.new(:instance => article).sync
 
     expect(ThinkingSphinx.search('Nice', :indices => ["published_articles_core"])).to be_empty
   end
 
-  it "stages records in real-time index with alternate ids" do
+  it "syncs records in real-time index with alternate ids" do
     Album.connection.execute <<~SQL
       INSERT INTO albums (id, name, artist, integer_id)
       VALUES ('#{("a".."z").to_a.sample}', 'Sing to the Moon', 'Laura Mvula', #{rand(10000)});
     SQL
 
     album  = Album.last
-    ThinkingSphinx::Processor.new(:model => Album, id: album.integer_id).stage
+    ThinkingSphinx::Processor.new(:model => Album, id: album.integer_id).sync
 
     expect(ThinkingSphinx.search('Laura', :indices => ["album_real_core"])).to include(album)
 
     Article.connection.execute <<~SQL
       DELETE FROM albums where id = '#{album.id}';
     SQL
 
-    ThinkingSphinx::Processor.new(:instance => album).stage
+    ThinkingSphinx::Processor.new(:instance => album).sync
 
     expect(ThinkingSphinx.search('Laura', :indices => ["album_real_core"])).to be_empty
   end