stream.rb

#!/usr/bin/env ruby

require 'json'
require 'openssl'
require 'eventmachine'
require 'websocket-eventmachine-client'

access_key = 'your access key'
secret_key = 'your secret key'

EM.run do
  ws = WebSocket::EventMachine::Client.connect(uri: 'ws://localhost:8080')

  ws.onopen do
    puts "Connected."
  end

  ws.onmessage do |msg, type|
    p type
    msg = JSON.parse(msg)
    p msg

    key = msg.keys.first
    data = msg[key]
    case key
    when 'challenge'
      str = "#{access_key}#{data}"
      answer = OpenSSL::HMAC.hexdigest 'SHA256', secret_key, str
      payload = JSON.dump({
        auth: {
          access_key: access_key,
          answer: answer
        }
      })
      ws.send payload
    else
    end
  end

  ws.onclose do
    puts "Closed."
    EM.stop
  end

end