RigInboundGatewayWeb.ConnectionInit (Reactive Interaction Gateway v3.0.0-alpha.2) View Source

Cowboy WebSocket handler.

As soon as Phoenix pulls in Cowboy 2 this will have to be rewritten using the :cowboy_websocket behaviour.

Link to this section Summary

handler_response() :: any()

on_error() :: (reason :: String.t() -> handler_response())

on_success() :: ([Rig.Subscription.t()] -> handler_response())

set_up(
  String.t(),
  RIG.AuthorizationCheck.Request.t(),
  on_success(),
  on_error(),
  pos_integer(),
  pos_integer()
) :: handler_response()

subscriptions_query_param_to_body(map()) ::
  {:ok, String.t()} | {:error, String.t()}