From 8a810a66c760e33c9c47b84017d0862dfc6ba573 Mon Sep 17 00:00:00 2001 From: Christopher Bertels Date: Tue, 10 Oct 2017 14:15:41 -0700 Subject: [PATCH] Use last_message_sequence over message_sequence in Firehose protocol 'message_sequence' has been deprecated in the protocol in favor of 'last_message_sequence'. --- lib/firehose/multiplexed_web_socket.coffee | 2 +- lib/firehose/web_socket_transport.coffee | 6 +++--- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/lib/firehose/multiplexed_web_socket.coffee b/lib/firehose/multiplexed_web_socket.coffee index d390215..5cfeb07 100644 --- a/lib/firehose/multiplexed_web_socket.coffee +++ b/lib/firehose/multiplexed_web_socket.coffee @@ -8,7 +8,7 @@ class MultiplexedWebSocket extends WebSocketTransport @_sendMessage multiplex_subscribe: channel: channel - message_sequence: opts.last_sequence + last_message_sequence: opts.last_sequence unsubscribe: (channelNames...) => @_sendMessage diff --git a/lib/firehose/web_socket_transport.coffee b/lib/firehose/web_socket_transport.coffee index 2f9f727..1dcfd9b 100644 --- a/lib/firehose/web_socket_transport.coffee +++ b/lib/firehose/web_socket_transport.coffee @@ -61,10 +61,10 @@ class WebSocketTransport extends Transport @sendStartingMessageSequence @_lastMessageSequence else @config.webSocket.connectionVerified @ - sendStartingMessageSequence: (message_sequence) => - @_lastMessageSequence = message_sequence + sendStartingMessageSequence: (last_message_sequence) => + @_lastMessageSequence = last_message_sequence @socket.onmessage = @_message - @_sendMessage({message_sequence}) + @_sendMessage({last_message_sequence}) @_needToNotifyOfDisconnect = true Transport::_open.call @