Contents

module Turbo::Replay
  module Overrides
    module StreamsChannelReceive
      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

      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
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
turbo-replay-0.1.2	lib/turbo/replay/overrides/streams_channel_receive.rb
turbo-replay-0.1.1	lib/turbo/replay/overrides/streams_channel_receive.rb