class RskSnitch::Nodes

Checks the RSK public stats websocket to see if bitex is there

Public Class Methods

debug=(debug) click to toggle source
# File lib/rsk_snitch.rb, line 11
def self.debug=(debug)
  @debug = debug
end
find(node, max_messages = 500) click to toggle source
# File lib/rsk_snitch.rb, line 15
def self.find(node, max_messages = 500)
  found = nil
  EM.run do
    ws = Faye::WebSocket::Client.new(url)
    messages = 0

    ws.on :message do |event|
      puts event.data if @debug
      messages += 1
      found = true if /"id":".*?#{node}.*?"/ =~ event.data
      ws.close if found || messages > max_messages
    end
    
    ws.on(:close) do
      found ||= false
      EM.stop_event_loop   
    end
  end

  found
end
up?(node, retries = 10, wait = 10) click to toggle source
# File lib/rsk_snitch.rb, line 37
def self.up?(node, retries = 10, wait = 10)
  retries.times do 
    return true if find(node)
    sleep wait
  end
  false
end
url() click to toggle source
# File lib/rsk_snitch.rb, line 7
def self.url
        "ws://stats.rsk.co/primus/?_primuscb=#{(Time.now.to_f * 1000).round}-0"
end