Add new option.

Author: omeH

CHANGELOG.md

@@ -1,7 +1,7 @@
 # Changelog
 All notable changes to this project will be documented in this file.
 
-## [6.9.4] - 2025-11-21
+## [6.10.0] - 2025-11-21
 ### Fixed
 - Add on_first_sync callback
 

lib/table_sync/receiving/hooks/once.rb

@@ -22,7 +22,7 @@ def perform(config:, targets:)
         next unless conditions?(target)
 
         model.transaction(isolation: model.isolation_level(:repeatable)) do
-          model.find_and_update(row: target, target_keys:) do |entry|
+          model.find_and_save(row: target, target_keys:) do |entry|
             next unless allow?(entry)
 
             entry.hooks ||= []

lib/table_sync/receiving/model/active_record.rb

@@ -129,7 +129,7 @@ def after_commit(&)
       db.add_transaction_record(AfterCommitWrap.new(&))
     end
 
-    def find_and_update(row:, target_keys:)
+    def find_and_save(row:, target_keys:)
       entry = raw_model.find_by!(row.slice(*target_keys))
       yield entry
       entry.save!

lib/table_sync/receiving/model/sequel.rb

@@ -76,7 +76,7 @@ def after_commit(&)
       db.after_commit(&)
     end
 
-    def find_and_update(row:, target_keys:)
+    def find_and_save(row:, target_keys:)
       entry = dataset.first!(row.slice(*target_keys))
       yield entry
       entry.save_changes

spec/receiving/models/active_record_spec.rb

@@ -11,7 +11,7 @@
     it { expect { model.isolation_level(:invalid) }.to raise_error(KeyError) }
   end
 
-  describe "find_and_update" do
+  describe "find_and_save" do
     let(:primary_key) { :external_id }
     let(:external_id) { 100_500 }
     let!(:player) do
@@ -26,7 +26,7 @@
     let(:row) { { external_id: } }
 
     it "finds and updates an entry" do
-      model.find_and_update(row:, target_keys: [primary_key]) do |entry|
+      model.find_and_save(row:, target_keys: [primary_key]) do |entry|
         entry.online_status = true
       end
       expect(player.reload.online_status).to be_truthy
@@ -35,7 +35,7 @@
     it "raise an error" do
       expect do
         row = { external_id: external_id + 1 }
-        model.find_and_update(row:, target_keys: [primary_key]) do |entry|
+        model.find_and_save(row:, target_keys: [primary_key]) do |entry|
           entry.online_status = true
         end
       end.to raise_error(ActiveRecord::RecordNotFound)

spec/receiving/models/sequel_spec.rb

@@ -11,7 +11,7 @@
     it { expect { model.isolation_level(:invalid) }.to raise_error(KeyError) }
   end
 
-  describe "find_and_update" do
+  describe "find_and_save" do
     let(:primary_key) { :external_id }
     let(:external_id) { 100_500 }
     let!(:player) do
@@ -26,7 +26,7 @@
     let(:row) { { external_id: } }
 
     it "finds and updates an entry" do
-      model.find_and_update(row:, target_keys: [primary_key]) do |entry|
+      model.find_and_save(row:, target_keys: [primary_key]) do |entry|
         entry.online_status = true
       end
       expect(player.reload.online_status).to be_truthy
@@ -35,7 +35,7 @@
     it "raise an error" do
       expect do
         row = { external_id: external_id + 1 }
-        model.find_and_update(row:, target_keys: [primary_key]) do |entry|
+        model.find_and_save(row:, target_keys: [primary_key]) do |entry|
           entry.online_status = true
         end
       end.to raise_error(Sequel::NoMatchingRow)