2015-08-21 07:41:27 -04:00
|
|
|
require 'test_helper'
|
|
|
|
require 'stubs/test_server'
|
|
|
|
|
2015-10-15 22:11:49 -04:00
|
|
|
class ActionCable::Connection::StringIdentifierTest < ActionCable::TestCase
|
2015-08-21 07:41:27 -04:00
|
|
|
class Connection < ActionCable::Connection::Base
|
|
|
|
identified_by :current_token
|
|
|
|
|
|
|
|
def connect
|
|
|
|
self.current_token = "random-string"
|
|
|
|
end
|
|
|
|
|
2015-10-15 22:11:49 -04:00
|
|
|
def send_async(method, *args)
|
|
|
|
send method, *args
|
|
|
|
end
|
2015-08-21 07:41:27 -04:00
|
|
|
end
|
|
|
|
|
|
|
|
test "connection identifier" do
|
2015-10-15 22:11:49 -04:00
|
|
|
run_in_eventmachine do
|
|
|
|
open_connection_with_stubbed_pubsub
|
|
|
|
assert_equal "random-string", @connection.connection_identifier
|
|
|
|
end
|
2015-08-21 07:41:27 -04:00
|
|
|
end
|
|
|
|
|
|
|
|
protected
|
|
|
|
def open_connection_with_stubbed_pubsub
|
2015-10-15 22:11:49 -04:00
|
|
|
@server = TestServer.new
|
2015-08-21 07:41:27 -04:00
|
|
|
@server.stubs(:pubsub).returns(stub_everything('pubsub'))
|
2015-10-15 22:11:49 -04:00
|
|
|
|
2015-08-21 07:41:27 -04:00
|
|
|
open_connection
|
|
|
|
end
|
|
|
|
|
|
|
|
def open_connection
|
2015-10-15 22:11:49 -04:00
|
|
|
env = Rack::MockRequest.env_for "/test", 'HTTP_CONNECTION' => 'upgrade', 'HTTP_UPGRADE' => 'websocket'
|
|
|
|
@connection = Connection.new(@server, env)
|
|
|
|
|
2015-08-21 07:41:27 -04:00
|
|
|
@connection.process
|
|
|
|
@connection.send :on_open
|
|
|
|
end
|
|
|
|
|
|
|
|
def close_connection
|
|
|
|
@connection.send :on_close
|
|
|
|
end
|
|
|
|
end
|