Contents

module Ohm
  module Versioned
    def self.included(model)
      model.attribute :_version, lambda { |x| x.to_i }
    end

    def save!
      super do |t|
        t.read do |store|
          current_version = key.hget(:_version).to_i

          if current_version != _version
            raise Ohm::VersionConflict.new(attributes)
          end

          self._version = current_version + 1
        end

        yield t if block_given?
      end
    end
  end

  class VersionConflict < StandardError
    attr :attributes

    def initialize(attributes)
      @attributes = attributes
    end
  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
ohm-contrib-1.2	lib/ohm/versioned.rb
ohm-contrib-1.1.0	lib/ohm/versioned.rb
ohm-contrib-1.0.1	lib/ohm/versioned.rb
ohm-contrib-1.0.0	lib/ohm/versioned.rb
ohm-contrib-1.0.0.rc5	lib/ohm/versioned.rb
ohm-contrib-1.0.0.rc4	lib/ohm/versioned.rb
ohm-contrib-1.0.0.rc3	lib/ohm/versioned.rb
ohm-contrib-1.0.0.rc2	lib/ohm/versioned.rb