Sha256: e341ba1b29d63b637cbe5ce1e08240afc0319b013ae0d764c596e01394ff7501
Contents?: true
Size: 837 Bytes
Versions: 29
Compression:
Stored size: 837 Bytes
Contents
# frozen_string_literal: true
module AnyCable
module RPC
module Handlers
module Connect
def connect(request)
logger.debug("RPC Connect: #{request.inspect}")
socket = build_socket(env: request.env)
connection = factory.call(socket)
connection.handle_open
if socket.closed?
AnyCable::ConnectionResponse.new(
status: AnyCable::Status::FAILURE,
transmissions: socket.transmissions
)
else
AnyCable::ConnectionResponse.new(
status: AnyCable::Status::SUCCESS,
identifiers: connection.identifiers_json,
transmissions: socket.transmissions,
env: build_env_response(socket)
)
end
end
end
end
end
end
Version data entries
29 entries across 29 versions & 1 rubygems