Add support for redis channels

1 files changed, 32 insertions, 0 deletions

diff --git a/lib/action_cable/channel/redis.rb b/lib/action_cable/channel/redis.rb
new file mode 100644
index 0000000000..215cc3c975
--- /dev/null
+++ b/lib/action_cable/channel/redis.rb
@@ -0,0 +1,32 @@
+module ActionCable
+  module Channel
+
+    module Redis
+      extend ActiveSupport::Concern
+
+      included do
+        on_unsubscribe :unsubscribe_from_redis_channels
+      end
+
+      def subscribe_to(redis_channel, callback = nil)
+        @_redis_channels ||= []
+        @_redis_channels << redis_channel
+
+        callback ||= -> (message) { broadcast ActiveSupport::JSON.decode(message) }
+        redis.pubsub.subscribe(redis_channel, &callback)
+      end
+
+      protected
+        def unsubscribe_from_redis_channels
+          if @_redis_channels
+            @_redis_channels.each { |channel| @connection.pubsub.unsubscribe(channel) }
+          end
+        end
+
+        def redis
+          @connection.redis
+        end
+    end
+
+  end
+end
\ No newline at end of file