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