Sha256: 8503f63435babfc7427664f17aa00396a9f2b9bf8764d802512ea5d9ab4db393
Contents?: true
Size: 1.83 KB
Versions: 5
Compression:
Stored size: 1.83 KB
Contents
module Slack
module RealTime
class Socket
attr_accessor :url
attr_accessor :options
attr_reader :driver
attr_reader :logger
protected :logger
def initialize(url, options = {})
@url = url
@options = options
@driver = nil
@logger = options.delete(:logger) || Slack::RealTime::Config.logger || Slack::Config.logger
end
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
def connect!
return if connected?
connect
logger.debug("#{self.class}##{__method__}") { driver.class }
yield driver if block_given?
end
def disconnect!
driver.close
end
def connected?
!driver.nil?
end
def start_sync(client)
thread = start_async(client)
thread.join if thread
rescue Interrupt
thread.exit if thread
end
# @return [#join]
def start_async(_client)
raise NotImplementedError, "Expected #{self.class} to implement #{__method__}."
end
def close
@driver = nil
end
protected
def addr
URI(url).host
end
def secure?
port == URI::HTTPS::DEFAULT_PORT
end
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
def connect
raise NotImplementedError, "Expected #{self.class} to implement #{__method__}."
end
end
end
end
Version data entries
5 entries across 5 versions & 1 rubygems