61 lines
1.3 KiB
Ruby
61 lines
1.3 KiB
Ruby
|
module AfterCommitQueue
|
||
|
|
extend ActiveSupport::Concern
|
||
|
|
|
||
|
|
included do
|
||
|
|
after_commit :_run_after_commit_queue
|
||
|
|
after_rollback :_clear_after_commit_queue
|
||
|
|
end
|
||
|
|
|
||
|
|
def run_after_commit(&block)
|
||
|
|
_after_commit_queue << block if block
|
||
|
|
|
||
|
|
true
|
||
|
|
end
|
||
|
|
|
||
|
|
def run_after_commit_or_now(&block)
|
||
|
|
if AfterCommitQueue.inside_transaction?
|
||
|
|
if ActiveRecord::Base.connection.current_transaction.records.include?(self)
|
||
|
|
run_after_commit(&block)
|
||
|
|
else
|
||
|
|
# If the current transaction does not include this record, we can run
|
||
|
|
# the block now, even if it queues a Sidekiq job.
|
||
|
|
Sidekiq::Worker.skipping_transaction_check do
|
||
|
|
instance_eval(&block)
|
||
|
|
end
|
||
|
|
end
|
||
|
|
else
|
||
|
|
instance_eval(&block)
|
||
|
|
end
|
||
|
|
|
||
|
|
true
|
||
|
|
end
|
||
|
|
|
||
|
|
def self.open_transactions_baseline
|
||
|
|
if ::Rails.env.test?
|
||
|
|
return DatabaseCleaner.connections.count { |conn| conn.strategy.is_a?(DatabaseCleaner::ActiveRecord::Transaction) }
|
||
|
|
end
|
||
|
|
|
||
|
|
0
|
||
|
|
end
|
||
|
|
|
||
|
|
def self.inside_transaction?
|
||
|
|
ActiveRecord::Base.connection.open_transactions > open_transactions_baseline
|
||
|
|
end
|
||
|
|
|
||
|
|
protected
|
||
|
|
|
||
|
|
def _run_after_commit_queue
|
||
|
|
while action = _after_commit_queue.pop
|
||
|
|
self.instance_eval(&action)
|
||
|
|
end
|
||
|
|
end
|
||
|
|
|
||
|
|
def _after_commit_queue
|
||
|
|
@after_commit_queue ||= []
|
||
|
|
end
|
||
|
|
|
||
|
|
def _clear_after_commit_queue
|
||
|
|
_after_commit_queue.clear
|
||
|
|
end
|
||
|
|
end
|