This pull request introduces functionality for handling MQTT PINGREQ and PINGRESP packets, along with some code cleanup and refactoring. The most important changes include the addition of a new function to read PINGRESP packets, modifications to the main event loop to handle keep-alive messages, and updates to the packet module to support PINGREQ packets.
MQTT Keep-Alive Functionality:
src/client.rs: Added read_pingresp function to read PINGRESP packets from the stream.
src/main.rs: Modified the main event loop to send PINGREQ packets periodically and handle PINGRESP packets.
Packet Type Enhancements:
src/packet.rs: Added PingReq to the PacketType enum.
src/packet.rs: Implemented the MqttPingReq struct with an encode method to create PINGREQ packets.
Code Cleanup:
src/packet.rs: Corrected the packet type used in the MqttPublish struct's encode method.
This pull request introduces functionality for handling MQTT
PINGREQandPINGRESPpackets, along with some code cleanup and refactoring. The most important changes include the addition of a new function to readPINGRESPpackets, modifications to the main event loop to handle keep-alive messages, and updates to thepacketmodule to supportPINGREQpackets.MQTT Keep-Alive Functionality:
src/client.rs: Addedread_pingrespfunction to readPINGRESPpackets from the stream.src/main.rs: Modified the main event loop to sendPINGREQpackets periodically and handlePINGRESPpackets.Packet Type Enhancements:
src/packet.rs: AddedPingReqto thePacketTypeenum.src/packet.rs: Implemented theMqttPingReqstruct with anencodemethod to createPINGREQpackets.Code Cleanup:
src/packet.rs: Corrected the packet type used in theMqttPublishstruct'sencodemethod.