class Slack::RealTime::Socket

def addr
  URI(url).host
end

def close
  @driver = nil
end

def connect
  fail NotImplementedError, "Expected #{self.class} to implement #{__method__}."
end

def connect!
  return if connected?
  connect
  logger.debug("#{self.class}##{__method__}") { driver.class }
  yield driver if block_given?
end

def connected?
  !driver.nil?
end

def disconnect!
  driver.close
end

def initialize(url, options = {})
  @url = url
  @options = options
  @driver = nil
  @logger = options.delete(:logger) || Slack::RealTime::Config.logger || Slack::Config.logger
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 secure?
  port == URI::HTTPS::DEFAULT_PORT
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 start_async(_client)
  fail NotImplementedError, "Expected #{self.class} to implement #{__method__}."
end

def start_sync(client)
  thread = start_async(client)
  thread.join if thread
rescue Interrupt
  thread.exit if thread
end