Sha256: 7b0d9f24ed3f5e3ff85f713e9cb7e8f2e2c493fca7f811422c67ec23acf58de0
Contents?: true
Size: 800 Bytes
Versions: 31
Compression:
Stored size: 800 Bytes
Contents
module ActiveFedora
class Base
def stream
Nest.new(self.class.name, $redis)[to_param]
rescue
nil
end
def self.stream
Nest.new(name, $redis)
rescue
nil
end
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
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
def log_event(event_id)
stream[:event].lpush(event_id)
rescue
nil
end
end
end
Version data entries
31 entries across 31 versions & 2 rubygems