class ActiveFedora::Base

Public Class Methods

stream() click to toggle source
# File lib/sufia/models/active_fedora/redis.rb, line 9
def self.stream
  Nest.new(name, $redis)
rescue
  nil
end

Public Instance Methods

create_event(action, timestamp) click to toggle source
# File lib/sufia/models/active_fedora/redis.rb, line 26
def create_event(action, timestamp)
  event_id = $redis.incr("events:latest_id")
  $redis.hmset("events:#{event_id}", "action", action, "timestamp", timestamp)
  event_id
rescue
  nil
end
events(size = -1) click to toggle source
# File lib/sufia/models/active_fedora/redis.rb, line 15
def events(size = -1)
  stream[:event].lrange(0, size).map do |event_id|
    {
      action: $redis.hget("events:#{event_id}", "action"),
      timestamp: $redis.hget("events:#{event_id}", "timestamp")
    }
  end
rescue
  []
end
log_event(event_id) click to toggle source
# File lib/sufia/models/active_fedora/redis.rb, line 34
def log_event(event_id)
  stream[:event].lpush(event_id)
rescue
  nil
end
stream() click to toggle source
# File lib/sufia/models/active_fedora/redis.rb, line 3
def stream
  Nest.new(self.class.name, $redis)[to_param]
rescue
  nil
end