Contents

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

    def save
      current_version = new? ? 0 : redis.call("HGET", key, :_version).to_i

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

      self._version = current_version + 1

      super
    end
  end

  class VersionConflict < StandardError
    attr :attributes

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

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
ohm-contrib-3.0.0	lib/ohm/versioned.rb
ohm-contrib-2.2.0	lib/ohm/versioned.rb
ohm-contrib-2.0.1	lib/ohm/versioned.rb
ohm-contrib-2.0.0	lib/ohm/versioned.rb
ohm-contrib-2.0.0.rc2	lib/ohm/versioned.rb
ohm-contrib-2.0.0.rc1	lib/ohm/versioned.rb