allow websocket compression extension

Author: yjh0502

priv/schema/rabbitmq_web_stomp.schema

@@ -77,3 +77,5 @@
     [{datatype, integer}]}.
 {mapping, "web_stomp.cowboy_opts.timeout", "rabbitmq_web_stomp.cowboy_opts.timeout",
     [{datatype, integer}]}.
+{mapping, "web_stomp.cowboy_opts.compress", "rabbitmq_web_stomp.cowboy_ws_opts.compress",
+    [{datatype, {enum, [true, false]}}]}.

src/rabbit_ws_handler.erl

@@ -52,7 +52,8 @@ init(Req0, Opts) ->
         undefined -> [];
         AuthHd    -> [{authorization, binary_to_list(AuthHd)}]
     end,
-    {cowboy_websocket, Req, {Socket, Peername, Sockname, Headers, FrameType}}.
+    {_, WsOpts} = lists:keyfind(ws_opts, 1, Opts),
+    {cowboy_websocket, Req, {Socket, Peername, Sockname, Headers, FrameType}, WsOpts}.
 
 websocket_init({Socket, Peername, Sockname, Headers, FrameType}) ->
     Info = [{socket, Socket},

src/rabbit_ws_listener.erl

@@ -34,9 +34,10 @@ init() ->
 
     WsFrame = get_env(ws_frame, text),
     CowboyOpts = maps:from_list(get_env(cowboy_opts, [])),
+    CowboyWsOpts = maps:from_list(get_env(cowboy_ws_opts, [])),
 
     VhostRoutes = [
-        {get_env(ws_path, "/ws"), rabbit_ws_handler, [{type, WsFrame}]}
+        {get_env(ws_path, "/ws"), rabbit_ws_handler, [{type, WsFrame}, {ws_opts, CowboyWsOpts}]}
     ],
     Routes = cowboy_router:compile([{'_',  VhostRoutes}]), % any vhost
     NumTcpAcceptors = case application:get_env(rabbitmq_web_stomp, num_tcp_acceptors) of