class Progressrus class Store class Redis < Base BACKEND_EXCEPTIONS = [ ::Redis::BaseError ] attr_reader :redis, :interval, :prefix, :name def initialize(instance, prefix: "progressrus", interval: 1, now: Time.now) @name = :redis @redis = instance @persisted_ats = Hash.new({}) @interval = interval @prefix = prefix end def persist(progress, now: Time.now, force: false, expires_at: nil) if outdated?(progress) || force key_for_scope = key(progress.scope) redis.pipelined do redis.hset(key_for_scope, progress.id, progress.to_serializeable.to_json) redis.expireat(key_for_scope, expires_at.to_i) if expires_at end @persisted_ats[progress.scope][progress.id] = now end rescue *BACKEND_EXCEPTIONS => e raise Progressrus::Store::BackendError.new(e) end def scope(scope) scope = redis.hgetall(key(scope)) scope.each_pair { |id, value| scope[id] = Progressrus.new(deserialize(value)) } rescue *BACKEND_EXCEPTIONS => e raise Progressrus::Store::BackendError.new(e) end def find(scope, id) value = redis.hget(key(scope), id) return unless value Progressrus.new(deserialize(value)) rescue *BACKEND_EXCEPTIONS => e raise Progressrus::Store::BackendError.new(e) end def flush(scope, id = nil) if id redis.hdel(key(scope), id) else redis.del(key(scope)) end rescue *BACKEND_EXCEPTIONS => e raise Progressrus::Store::BackendError.new(e) end private def key(scope) "#{prefix}:#{scope.join(":")}" end def deserialize(value) JSON.parse(value, symbolize_names: true).merge(persisted: true) end def outdated?(progress, now: Time.now) (now - interval).to_i >= persisted_at(progress).to_i end def persisted_at(progress) @persisted_ats[progress.scope][progress.id] end end end end