RUBY-3685 Fix insert_many in transaction with csot (#2996)

Author: comandeo-mongo

lib/mongo/bulk_write.rb

@@ -67,7 +67,7 @@ def execute
           context = Operation::Context.new(
             client: client,
             session: session,
-            operation_timeouts: { operation_timeout_ms: op_timeout_ms(deadline) }
+            operation_timeouts: operation_timeouts(deadline)
           )
           if single_statement?(operation)
             write_concern = write_concern(session)
@@ -182,6 +182,22 @@ def calculate_deadline
       end
     end
 
+    # Returns the operation_timeouts hash for creating an Operation::Context.
+    # Uses operation_timeout_ms when the timeout was explicitly set on the
+    # bulk write, or inherited_timeout_ms when it comes from the collection
+    # or client. This distinction is important inside transactions where
+    # operation_timeout_ms is not allowed (RUBY-3685).
+    def operation_timeouts(deadline)
+      timeout = op_timeout_ms(deadline)
+      return {} if timeout.nil?
+
+      if @options[:timeout_ms]
+        { operation_timeout_ms: timeout }
+      else
+        { inherited_timeout_ms: timeout }
+      end
+    end
+
     # @param [ Float | nil ] deadline Deadline for the batch of operations.
     #
     # @return [ Integer | nil ] Timeout in milliseconds for the next operation.

spec/mongo/session_transaction_spec.rb

@@ -263,6 +263,36 @@ class SessionTransactionSpecError < StandardError; end
           end
         end
       end
+
+      # RUBY-3685: insert_many (and bulk_write) raise ArgumentError inside
+      # with_transaction when the client has timeout_ms set.
+      # BulkWrite#execute passes operation_timeout_ms derived from
+      # collection.timeout_ms, which conflicts with the transaction deadline
+      # check in CsotTimeoutHolder.
+      context 'when client has timeout_ms and insert_many is used inside with_transaction' do
+        let(:client) do
+          authorized_client.with(timeout_ms: 10_000)
+        end
+
+        let(:collection) do
+          client['session-transaction-test']
+        end
+
+        it 'insert_many does not raise ArgumentError' do
+          session.with_transaction do
+            collection.insert_many([{ a: 1 }], session: session)
+          end
+        end
+
+        it 'bulk_write does not raise ArgumentError' do
+          session.with_transaction do
+            collection.bulk_write(
+              [{ insert_one: { a: 1 } }],
+              session: session
+            )
+          end
+        end
+      end
     end
   end
 end