class Slack::RealTime::Socket

Attributes

driver[R]
logger[R]
options[RW]
url[RW]

Public Class Methods

new(url, options = {}) click to toggle source
# File lib/slack/real_time/socket.rb, line 10
def initialize(url, options = {})
  @url = url
  @options = options
  @driver = nil
  @logger = options.delete(:logger) || Slack::RealTime::Config.logger || Slack::Config.logger
end

Public Instance Methods

close() click to toggle source
# File lib/slack/real_time/socket.rb, line 56
def close
  @driver = nil
end
connect!() { |driver| ... } click to toggle source
# File lib/slack/real_time/socket.rb, line 27
def connect!
  return if connected?

  connect
  logger.debug("#{self.class}##{__method__}") { driver.class }

  yield driver if block_given?
end
connected?() click to toggle source
# File lib/slack/real_time/socket.rb, line 40
def connected?
  !driver.nil?
end
disconnect!() click to toggle source
# File lib/slack/real_time/socket.rb, line 36
def disconnect!
  driver.close
end
send_data(message) click to toggle source
# File lib/slack/real_time/socket.rb, line 17
def send_data(message)
  logger.debug("#{self.class}##{__method__}") { message }
  case message
  when Numeric then driver.text(message.to_s)
  when String  then driver.text(message)
  when Array   then driver.binary(message)
  else false
  end
end
start_async(_client) click to toggle source

@return [#join]

# File lib/slack/real_time/socket.rb, line 52
def start_async(_client)
  raise NotImplementedError, "Expected #{self.class} to implement #{__method__}."
end
start_sync(client) click to toggle source
# File lib/slack/real_time/socket.rb, line 44
def start_sync(client)
  thread = start_async(client)
  thread.join if thread
rescue Interrupt
  thread.exit if thread
end

Protected Instance Methods

addr() click to toggle source
# File lib/slack/real_time/socket.rb, line 62
def addr
  URI(url).host
end
connect() click to toggle source
# File lib/slack/real_time/socket.rb, line 81
def connect
  raise NotImplementedError, "Expected #{self.class} to implement #{__method__}."
end
port() click to toggle source
# File lib/slack/real_time/socket.rb, line 70
def port
  case (uri = URI(url)).scheme
  when 'wss'.freeze, 'https'.freeze
    URI::HTTPS::DEFAULT_PORT
  when 'ws', 'http'.freeze
    URI::HTTP::DEFAULT_PORT
  else
    uri.port
  end
end
secure?() click to toggle source
# File lib/slack/real_time/socket.rb, line 66
def secure?
  port == URI::HTTPS::DEFAULT_PORT
end