Module: Turbo::Replay::Overrides::StreamsChannelReceive

Defined in:
lib/turbo/replay/overrides/streams_channel_receive.rb

Constant Summary collapse

GetCurrentSequenceNumber = 
lambda do |broadcasting, _params|
  sequence_number =
    Message.get_current_sequence_number(broadcasting: broadcasting)

  {get_current_sequence_number: sequence_number}
end
GetMessagesAfterSequenceNumber = 
lambda do |broadcasting, params|
  messages =
    Message.get_after_sequence_number(
      broadcasting: broadcasting,
      sequence_number: params["sequence_number"]&.to_i
    )

  {get_messages_after_sequence_number: messages}
end
CMD_HANDLERS = 
{
  "get_current_sequence_number" => GetCurrentSequenceNumber,
  "get_messages_after_sequence_number" => GetMessagesAfterSequenceNumber
}.freeze

Instance Method Summary collapse

Instance Method Details

#receive(data) ⇒ Object 



28
29
30
31
32
33
34
35
36
 
# File 'lib/turbo/replay/overrides/streams_channel_receive.rb', line 28

def receive(data)
  cmd_handler =
    CMD_HANDLERS[data["cmd"]]

  broadcasting =
    self.class.verified_stream_name(params[:signed_stream_name])

  transmit(cmd_handler.call(broadcasting, data)) if cmd_handler.present?
end