Contents

require 'websocket-client-simple'
require 'eventmachine'

require_relative './constants'

module Swarmclient
  module Connection
    include Constants

  private

    def connect_and_send req:, endpoint:
      res, err = [nil, nil]

      begin
        EventMachine.run do
          ws = WebSocket::Client::Simple.connect endpoint

          ws.on :message do |msg|
            res = msg.data
            EventMachine::stop_event_loop
          end

          ws.on :open do
            ws.send req
          end

          ws.on :close do |e|
            EventMachine::stop_event_loop
          end

          ws.on :error do |e|
            err ||= e
            EventMachine::stop_event_loop
          end

          EventMachine::Timer.new(CONNECTION_TIMEOUT_LIMIT) { ws.close }
        end
      rescue => e
        err = e
      end

      return [err, res]
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
swarmclient-0.1.5	lib/swarmclient/connection.rb
swarmclient-0.1.4	lib/swarmclient/connection.rb