update for crystal-0.26.1

README.md

@@ -2,7 +2,7 @@
 
 redis-cluster library for [Crystal](http://crystal-lang.org/).
 
-- crystal: 0.24.2
+- crystal: 0.26.1
 
 ## Classes
 

shard.yml

@@ -4,7 +4,7 @@ version: 0.7.8
 dependencies:
   redis:
     github: stefanwille/crystal-redis
-    version: ">= 1.9.0"
+    version: ">= 2.1.0"
   crc16:
     github: maiha/crc16.cr
     version: ">= 0.1.0"

src/cluster/bootstrap.cr

@@ -38,11 +38,12 @@ module Redis::Cluster
 
     def redis
       Redis.new(host: host, port: port, unixsocket: @sock, password: @pass)
-    rescue err : Errno
+    rescue err : Errno | Redis::Error
       if sock? && err.to_s =~ /No such file or directory/
         raise Errno.new("unix://%s" % sock)
       else
-        raise err
+        # convert `Redis::Error` to `Errno`
+        raise Errno.new(err.to_s)
       end
     end
 

src/cluster/commands.cr

@@ -20,7 +20,7 @@ module Redis::Cluster::Commands
     {% invoke = "#{name}(#{named_args})".id %}
     def {{ name.id }}({{ args.join(", ").id }})
       redis(key.to_s).{{ invoke }}
-    rescue error : Redis::DisconnectedError | IO::Error
+    rescue error : Redis::ConnectionError | IO::Error
       on_disconnected(key.to_s, error)
       redis(key.to_s).{{ invoke }}
     rescue moved : Redis::Error::Moved
@@ -41,7 +41,7 @@ module Redis::Cluster::Commands
       key = {{args.first}}.first { raise "{{name}}: key not found" }
       begin
         redis(key.to_s).{{ invoke }}
-      rescue error : Redis::DisconnectedError | IO::Error
+      rescue error : Redis::ConnectionError | IO::Error
         on_disconnected(key.to_s, error)
         redis(key.to_s).{{ invoke }}
       rescue moved : Redis::Error::Moved
@@ -64,7 +64,7 @@ module Redis::Cluster::Commands
       key = {{args.id}}[1]
       begin
         redis(key.to_s).{{ invoke }}
-      rescue error : Redis::DisconnectedError | IO::Error
+      rescue error : Redis::ConnectionError | IO::Error
         on_disconnected(key.to_s, error)
         redis(key.to_s).{{ invoke }}
       rescue moved : Redis::Error::Moved
@@ -88,7 +88,7 @@ module Redis::Cluster::Commands
       key = h.keys.first       # for first key
       begin
         redis(key.to_s).{{ invoke }}
-      rescue error : Redis::DisconnectedError | IO::Error
+      rescue error : Redis::ConnectionError | IO::Error
         on_disconnected(key.to_s, error)
         redis(key.to_s).{{ invoke }}
       rescue moved : Redis::Error::Moved

src/redis.cr

@@ -94,7 +94,7 @@ class ::Redis::Client
     redis_for(key).pipelined do |api|
       yield(api)
     end
-  rescue err : Redis::DisconnectedError | IO::Error | Redis::Error::Moved | Redis::Error::Ask | Errno
+  rescue err : Redis::ConnectionError | IO::Error | Redis::Error::Moved | Redis::Error::Ask | Errno
     close!
     if reconnect
       redis_for(key).pipelined do |api|
@@ -109,7 +109,7 @@ class ::Redis::Client
     redis_for(key).multi do |api|
       yield(api)
     end
-  rescue err : Redis::DisconnectedError | IO::Error | Redis::Error::Moved | Redis::Error::Ask | Errno
+  rescue err : Redis::ConnectionError | IO::Error | Redis::Error::Moved | Redis::Error::Ask | Errno
     close!
     if reconnect
       redis_for(key).multi do |api|
@@ -123,7 +123,7 @@ class ::Redis::Client
   private macro method_missing(call)
     begin
       redis.{{call.id}}
-    rescue err : Redis::DisconnectedError | IO::Error | Redis::Error::Moved | Redis::Error::Ask | Errno
+    rescue err : Redis::ConnectionError | IO::Error | Redis::Error::Moved | Redis::Error::Ask | Errno
       # We should reconnect when these errors happened.
       close!
       raise err