Sha256: 24d7d0332686183d7adcb5b5b70a86101872f99c62ff950f10544d6dfa101598
Contents?: true
Size: 1.12 KB
Versions: 12
Compression:
Stored size: 1.12 KB
Contents
module Spree
class OrderMutex < ActiveRecord::Base
class LockFailed < StandardError; end
belongs_to :order, class_name: "Spree::Order"
scope :expired, -> { where(arel_table[:created_at].lteq(Spree::Config[:order_mutex_max_age].seconds.ago)) }
class << self
# Obtain a lock on an order, execute the supplied block and then release the lock.
# Raise a LockFailed exception immediately if we cannot obtain the lock.
# We raise instead of blocking to avoid tying up multiple server processes waiting for the lock.
def with_lock!(order)
raise ArgumentError, "order must be supplied" if order.nil?
# limit the maximum lock time just in case a lock is somehow left in place accidentally
expired.where(order: order).delete_all
begin
order_mutex = create!(order: order)
rescue ActiveRecord::RecordNotUnique
error = LockFailed.new("Could not obtain lock on order #{order.id}")
logger.error error.inspect
raise error
end
yield
ensure
order_mutex.destroy if order_mutex
end
end
end
end
Version data entries
12 entries across 12 versions & 1 rubygems