Add support for client certificate authentication

Fixes #116

Ensure your config has `{ssl_cert_login, true}` in the `rabbitmq_web_stomp` section.

Author: lukebakken

src/rabbit_web_stomp_handler.erl

@@ -95,11 +95,12 @@ init_processor_state(#state{socket=Sock, peername=PeerAddr, auth_hd=AuthHd}) ->
                       ok
               end,
 
+    SSLLogin = application:get_env(rabbitmq_stomp, ssl_cert_login, false),
+    StompConfig0 = #stomp_configuration{ssl_cert_login = SSLLogin, implicit_connect = false},
     UseHTTPAuth = application:get_env(rabbitmq_web_stomp, use_http_auth, false),
-    StompConfig0 = #stomp_configuration{implicit_connect = false},
     UserConfig = application:get_env(rabbitmq_stomp, default_user, undefined),
     StompConfig1 = rabbit_stomp:parse_default_user(UserConfig, StompConfig0),
-    StompConfig = case UseHTTPAuth of
+    StompConfig2 = case UseHTTPAuth of
         true ->
             case AuthHd of
                 undefined ->
@@ -118,10 +119,11 @@ init_processor_state(#state{socket=Sock, peername=PeerAddr, auth_hd=AuthHd}) ->
     end,
 
     AdapterInfo = amqp_connection:socket_adapter_info(Sock, {'Web STOMP', 0}),
-
+    RealSocket = rabbit_net:unwrap_socket(Sock),
+    SSLLoginName = rabbit_stomp_reader:ssl_login_name(RealSocket, StompConfig2),
     ProcessorState = rabbit_stomp_processor:initial_state(
-        StompConfig,
-        {SendFun, AdapterInfo, none, PeerAddr}),
+        StompConfig2,
+        {SendFun, AdapterInfo, SSLLoginName, PeerAddr}),
     {ok, ProcessorState}.
 
 websocket_handle({text, Data}, State) ->