Sha256: 2140756b3a801f5cabfdcca6c9c47edf651a8f0788255b105754481a8bb2d2a6

Contents?: true

Size: 1.16 KB

Versions: 91

Compression:

Stored size: 1.16 KB

Contents

# frozen_string_literal: true

module Spree
  class OrderMutex < Spree::Base
    class LockFailed < StandardError; end

    belongs_to :order, class_name: "Spree::Order", optional: true

    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

91 entries across 91 versions & 1 rubygems

Version Path
solidus_core-2.11.13 app/models/spree/order_mutex.rb
solidus_core-3.0.4 app/models/spree/order_mutex.rb
solidus_core-3.1.4 app/models/spree/order_mutex.rb
solidus_core-2.11.12 app/models/spree/order_mutex.rb
solidus_core-3.0.3 app/models/spree/order_mutex.rb
solidus_core-3.1.3 app/models/spree/order_mutex.rb
solidus_core-3.1.2 app/models/spree/order_mutex.rb
solidus_core-3.1.1 app/models/spree/order_mutex.rb
solidus_core-3.1.0 app/models/spree/order_mutex.rb
solidus_core-2.11.11 app/models/spree/order_mutex.rb
solidus_core-3.0.2 app/models/spree/order_mutex.rb
solidus_core-2.10.5 app/models/spree/order_mutex.rb
solidus_core-2.11.10 app/models/spree/order_mutex.rb
solidus_core-3.0.1 app/models/spree/order_mutex.rb
solidus_core-3.0.0 app/models/spree/order_mutex.rb
solidus_core-2.11.9 app/models/spree/order_mutex.rb
solidus_core-2.11.8 app/models/spree/order_mutex.rb
solidus_core-2.11.7 app/models/spree/order_mutex.rb
solidus_core-2.11.6 app/models/spree/order_mutex.rb
solidus_core-3.0.0.rc2 app/models/spree/order_mutex.rb