class Firehose::Client::Consumer::WebSocket

TODO - This won’t even work. Dropping ws:// above until this is tested. This thing should be sending message sequences to Firehose. Connect to Firehose via WebSockets and consume messages.

Attributes

logger[R]
url[R]

Public Class Methods

new(url, logger = Firehose.logger) click to toggle source
# File lib/firehose/client/consumer.rb, line 35
def initialize(url, logger = Firehose.logger)
  @url, @logger = url, logger
end

Public Instance Methods

request() click to toggle source
# File lib/firehose/client/consumer.rb, line 39
def request
  ws = Faye::WebSocket::Client.new(url)
  ws.onmessage = lambda do |event|
    logger.info "WS | #{event.data[0...40].inspect}"
  end
  ws.onclose = lambda do |event|
    logger.info "WS | Closed"
  end
  ws.onerror do
    logger.error "WS | Failed"
  end
end