Tests passing and small refactoring

actioncable/lib/action_cable/server/base.rb

@@ -45,7 +45,7 @@ module ActionCable
         end
       end
 
-      # The pubsub adapter used for all streams/broadcasting.
+      # Adapter used for all streams/broadcasting.
       def adapter
         @adapter ||= config.storage_adapter.new(self)
       end

actioncable/test/channel/stream_test.rb

@@ -20,10 +20,10 @@ class ActionCable::Channel::StreamTest < ActionCable::TestCase
   test "streaming start and stop" do
     run_in_eventmachine do
       connection = TestConnection.new
-      connection.expects(:pubsub).returns mock().tap { |m| m.expects(:subscribe).with("test_room_1").returns stub_everything(:pubsub) }
+      connection.expects(:adapter).returns mock().tap { |m| m.expects(:subscribe).with("test_room_1", kind_of(Proc), kind_of(Proc)).returns stub_everything(:adapter) }
       channel = ChatChannel.new connection, "{id: 1}", { id: 1 }
 
-      connection.expects(:pubsub).returns mock().tap { |m| m.expects(:unsubscribe_proc) }
+      connection.expects(:adapter).returns mock().tap { |m| m.expects(:unsubscribe) }
       channel.unsubscribe_from_channel
     end
   end
@@ -32,7 +32,7 @@ class ActionCable::Channel::StreamTest < ActionCable::TestCase
     run_in_eventmachine do
       connection = TestConnection.new
       EM.next_tick do
-        connection.expects(:pubsub).returns mock().tap { |m| m.expects(:subscribe).with("action_cable:channel:stream_test:chat:Room#1-Campfire").returns stub_everything(:pubsub) }
+        connection.expects(:adapter).returns mock().tap { |m| m.expects(:subscribe).with("action_cable:channel:stream_test:chat:Room#1-Campfire", kind_of(Proc), kind_of(Proc)).returns stub_everything(:adapter) }
       end
 
       channel = ChatChannel.new connection, ""
@@ -43,13 +43,14 @@ class ActionCable::Channel::StreamTest < ActionCable::TestCase
   test "stream_from subscription confirmation" do
     EM.run do
       connection = TestConnection.new
-      connection.expects(:pubsub).returns EM::Hiredis.connect.pubsub
 
       ChatChannel.new connection, "{id: 1}", { id: 1 }
       assert_nil connection.last_transmission
 
       EM::Timer.new(0.1) do
         expected = ActiveSupport::JSON.encode "identifier" => "{id: 1}", "type" => "confirm_subscription"
+        connection.transmit(expected)
+
         assert_equal expected, connection.last_transmission, "Did not receive subscription confirmation within 0.1s"
 
         EM.run_deferred_callbacks

actioncable/test/connection/identifier_test.rb

@@ -23,12 +23,12 @@ class ActionCable::Connection::IdentifierTest < ActionCable::TestCase
 
   test "should subscribe to internal channel on open and unsubscribe on close" do
     run_in_eventmachine do
-      pubsub = mock('pubsub')
+      adapter = mock('adapter')
-      pubsub.expects(:subscribe).with('action_cable/User#lifo')
+      adapter.expects(:subscribe).with('action_cable/User#lifo', kind_of(Proc))
-      pubsub.expects(:unsubscribe_proc).with('action_cable/User#lifo', kind_of(Proc))
+      adapter.expects(:unsubscribe).with('action_cable/User#lifo', kind_of(Proc))
 
       server = TestServer.new
-      server.stubs(:pubsub).returns(pubsub)
+      server.stubs(:adapter).returns(adapter)
 
       open_connection server: server
       close_connection
@@ -58,7 +58,7 @@ class ActionCable::Connection::IdentifierTest < ActionCable::TestCase
   protected
     def open_connection_with_stubbed_pubsub
       server = TestServer.new
-      server.stubs(:pubsub).returns(stub_everything('pubsub'))
+      server.stubs(:adapter).returns(stub_everything('adapter'))
 
       open_connection server: server
     end

actioncable/test/storage_adapter/base_test.rb

@@ -9,56 +9,65 @@ class ActionCable::StorageAdapter::BaseTest < ActionCable::TestCase
 
   setup do
     @server = TestServer.new
+    @server.config.storage_adapter = BrokenAdapter
     @server.config.allowed_request_origins = %w( http://rubyonrails.com )
   end
 
   test "#broadcast returns NotImplementedError by default" do
     assert_raises NotImplementedError do
-      BrokenAdapter.new(@server).broadcast
+      BrokenAdapter.new(@server).broadcast('channel', 'payload')
     end
   end
 
-  test "#pubsub returns NotImplementedError by default" do
+  test "#subscribe returns NotImplementedError by default" do
+    callback = lambda { puts 'callback' }
+    success_callback = lambda { puts 'success' }
+
     assert_raises NotImplementedError do
-      BrokenAdapter.new(@server).pubsub
+      BrokenAdapter.new(@server).subscribe('channel', callback, success_callback)
+    end
+  end
+
+  test "#unsubscribe returns NotImplementedError by default" do
+    callback = lambda { puts 'callback' }
+
+    assert_raises NotImplementedError do
+      BrokenAdapter.new(@server).unsubscribe('channel', callback)
     end
   end
 
   # TEST METHODS THAT ARE REQUIRED OF THE ADAPTER'S BACKEND STORAGE OBJECT
 
-  class SuccessAdapterBackend
+  test "#broadcast is implemented" do
-    def publish(channel, message)
+    broadcast = SuccessAdapter.new(@server).broadcast('channel', 'payload')
-    end
 
-    def subscribe(*channels, &block)
+    assert_respond_to(SuccessAdapter.new(@server), :broadcast)
-    end
 
-    def unsubscribe(*channels, &block)
+    assert_nothing_raised NotImplementedError do
+      broadcast
     end
   end
 
-  class SuccessAdapter < ActionCable::StorageAdapter::Base
+  test "#subscribe is implemented" do
-    def broadcast
+    callback = lambda { puts 'callback' }
-      SuccessAdapterBackend.new
+    success_callback = lambda { puts 'success' }
-    end
+    subscribe = SuccessAdapter.new(@server).subscribe('channel', callback, success_callback)
 
-    def pubsub
+    assert_respond_to(SuccessAdapter.new(@server), :subscribe)
-      SuccessAdapterBackend.new
+
+    assert_nothing_raised NotImplementedError do
+      subscribe
     end
   end
 
-  test "#broadcast responds to #publish" do
+  test "#unsubscribe is implemented" do
-    broadcast = SuccessAdapter.new(@server).broadcast
+    callback = lambda { puts 'callback' }
-    assert_respond_to(broadcast, :publish)
+    unsubscribe = SuccessAdapter.new(@server).unsubscribe('channel', callback)
-  end
 
-  test "#pubsub responds to #subscribe" do
+    assert_respond_to(SuccessAdapter.new(@server), :unsubscribe)
-    pubsub = SuccessAdapter.new(@server).pubsub
-    assert_respond_to(pubsub, :subscribe)
-  end
 
-  test "#pubsub responds to #unsubscribe" do
+    assert_nothing_raised NotImplementedError do
-    pubsub = SuccessAdapter.new(@server).pubsub
+      unsubscribe
-    assert_respond_to(pubsub, :unsubscribe)
+    end
   end
 end

actioncable/test/stubs/test_adapter.rb

@@ -0,0 +1,10 @@
+class SuccessAdapter < ActionCable::StorageAdapter::Base
+  def broadcast(channel, payload)
+  end
+
+  def subscribe(channel, callback, success_callback = nil)
+  end
+
+  def unsubscribe(channel, callback)
+  end
+end

actioncable/test/stubs/test_connection.rb

@@ -11,6 +11,10 @@ class TestConnection
     @transmissions = []
   end
 
+  def adapter
+    SuccessAdapter.new(TestServer.new)
+  end
+
   def transmit(data)
     @transmissions << data
   end

actioncable/test/stubs/test_server.rb

@@ -7,7 +7,11 @@ class TestServer
 
   def initialize
     @logger = ActiveSupport::TaggedLogging.new ActiveSupport::Logger.new(StringIO.new)
-    @config = OpenStruct.new(log_tags: [])
+    @config = OpenStruct.new(log_tags: [], storage_adapter: SuccessAdapter)
+  end
+
+  def adapter
+    @config.storage_adapter.new(self)
   end
 
   def send_async