7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
|
# File 'lib/anycable/rpc/handlers/command.rb', line 7
def command(message)
logger.debug("RPC Command: #{message.inspect}")
socket = build_socket(env: message.env)
connection = factory.call(
socket,
identifiers: message.connection_identifiers
)
result = connection.handle_channel_command(
message.identifier,
message.command,
message.data
)
AnyCable::CommandResponse.new(
status: result ? AnyCable::Status::SUCCESS : AnyCable::Status::FAILURE,
disconnect: socket.closed?,
stop_streams: socket.stop_streams?,
streams: socket.streams[:start],
stopped_streams: socket.streams[:stop],
transmissions: socket.transmissions,
env: build_env_response(socket),
presence: build_presence_response(socket)
)
end
|