Contents

# frozen_string_literal: true

module Isolator
  class Configuration
    attr_accessor :disallow_per_thread_concurrent_transactions

    alias_method :disallow_per_thread_concurrent_transactions?, :disallow_per_thread_concurrent_transactions
  end

  class ConcurrentTransactionError < UnsafeOperationError
    MESSAGE = "You are trying to open a transaction while there is an open transation to another database." \
  end

  Isolator.before_isolate do
    next unless Isolator.config.disallow_per_thread_concurrent_transactions?

    isolated_connections = Isolator.all_transactions.count do |conn_id, depth|
      depth >= Isolator.connection_threshold(conn_id)
    end

    next unless isolated_connections > 1

    Isolator.notify(exception: ConcurrentTransactionError.new, backtrace: caller)
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
isolator-1.1.1	lib/isolator/plugins/concurrent_database_transactions.rb
isolator-1.1.0	lib/isolator/plugins/concurrent_database_transactions.rb
isolator-1.0.1	lib/isolator/plugins/concurrent_database_transactions.rb
isolator-1.0.0	lib/isolator/plugins/concurrent_database_transactions.rb