class Mumble::Connection

Public Class Methods

new(host, port, cert_manager) click to toggle source
# File lib/mumble-ruby2/connection.rb, line 7
def initialize(host, port, cert_manager)
  @host = host
  @port = port
  @cert_manager = cert_manager
  @write_lock = Mutex.new
end

Public Instance Methods

connect() click to toggle source
# File lib/mumble-ruby2/connection.rb, line 14
def connect
  context = OpenSSL::SSL::SSLContext.new(:TLSv1)
  context.verify_mode = OpenSSL::SSL::VERIFY_NONE
  [:key, :cert].each { |s| context.send("#{s}=", @cert_manager.send(s)) }
  tcp_sock = TCPSocket.new @host, @port
  @sock = OpenSSL::SSL::SSLSocket.new tcp_sock, context
  @sock.connect
end
disconnect() click to toggle source
# File lib/mumble-ruby2/connection.rb, line 23
def disconnect
  @sock.close
end
read_message() click to toggle source
# File lib/mumble-ruby2/connection.rb, line 27
def read_message
  header = read_data 6
  type, len = header.unpack Messages::HEADER_FORMAT
  data = read_data len
  if type == message_type(:udp_tunnel)
    # UDP Packet -- No Protobuf
    message = message_class(:udp_tunnel).new
    message.packet = data
  else
    message = message_raw type, data
  end
  message
end
send_message(sym, attrs) click to toggle source
# File lib/mumble-ruby2/connection.rb, line 46
def send_message(sym, attrs)
  type, klass = message(sym)
  message = klass.new
  attrs.each { |k, v| message.send("#{k}=", v) }
  serial = message.serialize_to_string
  header = [type, serial.size].pack Messages::HEADER_FORMAT
  send_data(header + serial)
end
send_udp_packet(packet) click to toggle source
# File lib/mumble-ruby2/connection.rb, line 41
def send_udp_packet(packet)
  header = [message_type(:udp_tunnel), packet.length].pack Messages::HEADER_FORMAT
  send_data(header + packet)
end

Private Instance Methods

message(obj) click to toggle source
# File lib/mumble-ruby2/connection.rb, line 66
def message(obj)
  return message_type(obj), message_class(obj)
end
message_class(obj) click to toggle source
# File lib/mumble-ruby2/connection.rb, line 77
def message_class(obj)
  Messages.type_to_class(message_type(obj))
end
message_raw(type, data) click to toggle source
# File lib/mumble-ruby2/connection.rb, line 81
def message_raw(type, data)
  Messages.raw_to_obj(type, data)
end
message_type(obj) click to toggle source
# File lib/mumble-ruby2/connection.rb, line 70
def message_type(obj)
  if obj.is_a? Protobuf::Message
    obj = obj.class.to_s.demodulize.underscore.to_sym
  end
  Messages.sym_to_type(obj)
end
read_data(len) click to toggle source
# File lib/mumble-ruby2/connection.rb, line 62
def read_data(len)
  @sock.read len
end
send_data(data) click to toggle source
# File lib/mumble-ruby2/connection.rb, line 56
def send_data(data)
  @write_lock.synchronize do
    @sock.write data
  end
end