Sha256: 5e00b94809b79fa9e99e9b15419ace14d6fbe1c6a93d2c51f73fc73e33b09637
Contents?: true
Size: 1.69 KB
Versions: 15
Compression:
Stored size: 1.69 KB
Contents
module Pageflow
class EditLock < ActiveRecord::Base
TIME_TO_LIVE = 10.seconds
scope :active, ->(time = Time.now - TIME_TO_LIVE) { where('pageflow_edit_locks.updated_at >= ?', time) }
class Error < RuntimeError
def code
self.class.name.split('::').last.underscore
end
end
class HeldByOtherUserError < Error
attr_reader :user
def initialize(user)
@user = user
end
end
class HeldByOtherSessionError < Error; end
class NotHeldError < Error; end
belongs_to :user
belongs_to :entry, :inverse_of => :edit_lock
def held_by?(user)
self.user == user
end
def matches?(id)
self.id == id.to_i
end
def timed_out?
Time.now > self.updated_at + TIME_TO_LIVE
end
def aquire(current_user, options = {})
verify!(current_user, options)
rescue Error
if options[:force] || timed_out?
entry.create_edit_lock(:user => current_user)
else
raise
end
end
def release(current_user)
if user == current_user
destroy
end
end
def verify!(current_user, options)
raise HeldByOtherUserError.new(user) unless held_by?(current_user)
raise HeldByOtherSessionError unless matches?(options[:id])
touch
end
class Null
attr_reader :entry
def initialize(entry)
@entry = entry
end
def held_by?(user)
false
end
def blank?
true
end
def aquire(user, options = {})
entry.create_edit_lock!(:user => user)
end
def release(user)
end
def verify!(user, options = {})
raise NotHeldError.new
end
end
end
end
Version data entries
15 entries across 15 versions & 1 rubygems