Class: MiniMqtt::Packet

Inherits:

Object

• Object
• MiniMqtt::Packet

Includes:

BinHelper

Defined in:

lib/mini_mqtt/packet.rb

Direct Known Subclasses

ConnackPacket, ConnectPacket, DisconnectPacket, PingreqPacket, PingrespPacket, PubackPacket, PubcompPacket, PublishPacket, PubrecPacket, PubrelPacket, SubackPacket, SubscribePacket, UnsubackPacket, UnsubscribePacket

Constant Summary

@@last_packet_id =

0

@@packet_classes =

{}

Class Method Summary

• .get_packet_class(packet_type_id) ⇒ Object
• .packet_type_id ⇒ Object

Instance Method Summary

• #decode(stream, flags = 0) ⇒ Object
• #encode ⇒ Object
• #flags ⇒ Object

Methods included from BinHelper

#flag_byte, #mqtt_utf8_encode, #read_mqtt_encoded_string, #read_ushort, #uchar, #ushort

Class Method Details

.get_packet_class(packet_type_id) ⇒ Object

# File 'lib/mini_mqtt/packet.rb', line 28

def self.get_packet_class packet_type_id
  @@packet_classes[packet_type_id]
end

.packet_type_id ⇒ Object

# File 'lib/mini_mqtt/packet.rb', line 24

def self.packet_type_id
  @packet_type_id
end

Instance Method Details

#decode(stream, flags = 0) ⇒ Object

# File 'lib/mini_mqtt/packet.rb', line 8

def decode stream, flags = 0
  @stream = stream
  handle_flags flags
  read_variable_header
  read_payload
  self
end

#encode ⇒ Object

# File 'lib/mini_mqtt/packet.rb', line 16

def encode
  build_variable_header + build_payload
end

#flags ⇒ Object

# File 'lib/mini_mqtt/packet.rb', line 20

def flags
  0b000
end