lib/redis/objects.rb in redis-objects-2.0.0.alpha vs lib/redis/objects.rb in redis-objects-2.0.0.beta

- old
+ new

@@ -60,11 +60,11 @@ class << self def redis=(conn) @redis = Objects::ConnectionPoolProxy.proxy_if_needed(conn) end def redis - @redis || $redis || Redis.current || + @redis || $redis || raise(NotConnected, "Redis::Objects.redis not set to a Redis.new connection") end def included(klass) # Core (this file) @@ -146,15 +146,15 @@ unless redis_legacy_naming || redis_silence_warnings || @silence_warnings_as_redis_prefix_was_set_manually modern = redis_modern_prefix(klass) legacy = redis_legacy_prefix(klass) if modern != legacy warn <<EOW -WARNING: In redis-objects 2.0.0, key naming will change to fix longstanding bugs. -Your class #{klass.name.to_s} will be affected by this change! -Current key prefix: #{legacy.inspect} -Future key prefix: #{modern.inspect} -Read more at https://github.com/nateware/redis-objects/issues/231 +[redis-objects] WARNING: In redis-objects 2.0.0, key naming will change to fix longstanding bugs. +[redis-objects] Your class #{klass.name.to_s} will be affected by this change! +[redis-objects] Current key prefix: #{legacy.inspect} +[redis-objects] Future key prefix: #{modern.inspect} +[redis-objects] Read more at https://github.com/nateware/redis-objects/issues/231 EOW end end end @@ -163,11 +163,11 @@ legacy = redis_legacy_prefix total_keys = 0 if legacy == redis_prefix raise "Failed to migrate keys for #{self.name.to_s} as legacy and new redis_prefix are the same (#{redis_prefix})" end - warn "Migrating keys from #{legacy} prefix to #{redis_prefix}" + warn "[redis-objects] Migrating keys from #{legacy} prefix to #{redis_prefix}" loop do cursor, keys = redis.scan(cursor, :match => "#{legacy}:*") total_keys += keys.length keys.each do |key| @@ -176,17 +176,17 @@ # Figure out the new name new_key = redis_field_key(name, id=id, context=self) # Rename the key - warn "Rename '#{key}', '#{new_key}'" + warn "[redis-objects] Rename '#{key}', '#{new_key}'" ok = redis.rename(key, new_key) - warn "Warning: Rename '#{key}', '#{new_key}' failed: #{ok}" if ok != 'OK' + warn "[redis-objects] Warning: Rename '#{key}', '#{new_key}' failed: #{ok}" if ok != 'OK' end break if cursor == "0" end - warn "Migrated #{total_keys} total number of redis keys" + warn "[redis-objects] Migrated #{total_keys} total number of redis keys" end def redis_options(name) klass = first_ancestor_with(name) return klass.redis_objects[name.to_sym] || {}