Logging changes

packets are reported using trace
report connection established/closed

Author: adam-fowler

Sources/MQTTNIO/MQTTChannelHandlers.swift

@@ -14,7 +14,7 @@ final class MQTTEncodeHandler: ChannelOutboundHandler {
 
     func write(context: ChannelHandlerContext, data: NIOAny, promise: EventLoopPromise<Void>?) {
         let message = unwrapOutboundIn(data)
-        self.client.logger.debug("MQTT Out", metadata: ["mqtt_message": .string("\(message)"), "mqtt_packet_id": .string("\(message.packetId)")])
+        self.client.logger.trace("MQTT Out", metadata: ["mqtt_message": .string("\(message)"), "mqtt_packet_id": .string("\(message.packetId)")])
         var bb = context.channel.allocator.buffer(capacity: 0)
         do {
             try message.write(version: self.client.configuration.version, to: &bb)
@@ -46,7 +46,7 @@ struct ByteToMQTTMessageDecoder: ByteToMessageDecoder {
                     let publishMessage = try MQTTPublishPacket.read(version: self.client.configuration.version, from: packet)
                     // let publish = try MQTTSerializer.readPublish(from: packet)
                     // let publishMessage = MQTTPublishPacket(publish: publish.publishInfo, packetId: publish.packetId)
-                    self.client.logger.debug("MQTT In", metadata: [
+                    self.client.logger.trace("MQTT In", metadata: [
                         "mqtt_message": .string("\(publishMessage)"),
                         "mqtt_packet_id": .string("\(publishMessage.packetId)"),
                         "mqtt_topicName": .string("\(publishMessage.publish.topicName)"),
@@ -80,7 +80,7 @@ struct ByteToMQTTMessageDecoder: ByteToMessageDecoder {
             default:
                 throw MQTTError.decodeError
             }
-            self.client.logger.debug("MQTT In", metadata: ["mqtt_message": .string("\(message)"), "mqtt_packet_id": .string("\(message.packetId)")])
+            self.client.logger.trace("MQTT In", metadata: ["mqtt_message": .string("\(message)"), "mqtt_packet_id": .string("\(message.packetId)")])
             context.fireChannelRead(wrapInboundOut(message))
         } catch InternalError.incompletePacket {
             return .needMoreData

Sources/MQTTNIO/MQTTClient.swift

@@ -312,8 +312,10 @@ extension MQTTClient {
                     if self.connection === connection {
                         self.connection = nil
                     }
+                    self.logger.debug("Network connection closed")
                     self.closeListeners.notify(result)
                 }
+                self.logger.debug("Network connection established")
                 return connection.sendMessage(packet) { message -> Bool in
                     guard message.type == .CONNACK || message.type == .AUTH else { throw MQTTError.failedToConnect }
                     return true