Update swiftformat (#151)

* Update to swiftformat 0.52.10

This is the latest version of swiftformat.

The .swiftformat config is modified to target Swift 5.7, which is the
oldest Swift currently supported by mqtt-nio.

The validate.sh script is updated to resolve some shellcheck issues.

Signed-off-by: Peter Grayson <[email protected]>

* Formatting fixes for swiftformat 0.52.10

Signed-off-by: Peter Grayson <[email protected]>

---------

Signed-off-by: Peter Grayson <[email protected]>

Author: jpgrayson

.github/workflows/validate.yml

@@ -14,6 +14,6 @@ jobs:
     - name: Install Dependencies
       run: |
         brew install mint
-        mint install nicklockwood/swiftformat@0.48.17 --no-link
+        mint install nicklockwood/swiftformat@0.52.10 --no-link
     - name: run script
       run: ./scripts/validate.sh

.swiftformat

@@ -1,8 +1,8 @@
 # Minimum swiftformat version
---minversion 0.47.4
+--minversion 0.52.0
 
 # Swift version
---swiftversion 5.1
+--swiftversion 5.7
 
 # file options
 --exclude .build

CONTRIBUTING.md

@@ -35,4 +35,4 @@ docker-compose run test
 
 ### Formatting
 
-We use Nick Lockwood's SwiftFormat for formatting code. PRs will not be accepted if they haven't be formatted. The current version of SwiftFormat we are using is v0.48.17.
+We use Nick Lockwood's SwiftFormat for formatting code. PRs will not be accepted if they haven't be formatted. The current version of SwiftFormat we are using is v0.52.10.

Sources/MQTTNIO/AsyncAwaitSupport/MQTTClient+async.swift

@@ -28,7 +28,7 @@ extension MQTTClient {
     public func shutdown(queue: DispatchQueue = .global()) async throws {
         return try await withUnsafeThrowingContinuation { cont in
             self.shutdown(queue: queue) { error in
-                if let error = error {
+                if let error {
                     cont.resume(throwing: error)
                 } else {
                     cont.resume()

Sources/MQTTNIO/ChannelHandlers/WebSocketHandler.swift

@@ -107,7 +107,7 @@ final class WebSocketHandler: ChannelDuplexHandler {
 
     /// Send ping and setup task to check for pong and send new ping
     private func sendPingAndWait(context: ChannelHandlerContext) {
-        guard context.channel.isActive, let pingInterval = pingInterval else {
+        guard context.channel.isActive, let pingInterval else {
             return
         }
         if self.waitingOnPong {

Sources/MQTTNIO/MQTTClient.swift

@@ -74,7 +74,7 @@ public final class MQTTClient {
         return self.host
     }
 
-    internal let globalPacketId = ManagedAtomic<UInt16>(1)
+    let globalPacketId = ManagedAtomic<UInt16>(1)
     /// default logger that logs nothing
     private static let loggingDisabled = Logger(label: "MQTT-do-not-log", factory: { _ in SwiftLogNoOpLogHandler() })
     /// inflight messages
@@ -101,7 +101,7 @@ public final class MQTTClient {
         configuration: Configuration = Configuration()
     ) {
         self.host = host
-        if let port = port {
+        if let port {
             self.port = port
         } else {
             switch (configuration.useSSL, configuration.useWebSockets) {
@@ -190,7 +190,7 @@ public final class MQTTClient {
         var errorStorage: Error?
         let continuation = DispatchWorkItem {}
         self.shutdown(queue: DispatchQueue(label: "mqtt-client.shutdown")) { error in
-            if let error = error {
+            if let error {
                 errorStorageLock.withLock {
                     errorStorage = error
                 }
@@ -334,7 +334,7 @@ public final class MQTTClient {
             will: publish
         )
 
-        return self.connect(packet: packet).map { $0.sessionPresent }
+        return self.connect(packet: packet).map(\.sessionPresent)
     }
 
     /// Publish message to topic
@@ -441,7 +441,7 @@ public final class MQTTClient {
         self.shutdownListeners.removeListener(named: name)
     }
 
-    internal func updatePacketId() -> UInt16 {
+    func updatePacketId() -> UInt16 {
         let id = self.globalPacketId.wrappingIncrementThenLoad(by: 1, ordering: .relaxed)
 
         // packet id must be non-zero
@@ -468,7 +468,7 @@ public final class MQTTClient {
     private var lock = NIOLock()
 }
 
-internal extension MQTTClient {
+extension MQTTClient {
     /// connect to broker
     func connect(
         packet: MQTTConnectPacket,
@@ -513,7 +513,7 @@ internal extension MQTTClient {
                     }
                 case let auth as MQTTAuthPacket:
                     // auth messages require an auth workflow closure
-                    guard let authWorkflow = authWorkflow else { return eventLoop.makeFailedFuture(MQTTError.authWorkflowRequired) }
+                    guard let authWorkflow else { return eventLoop.makeFailedFuture(MQTTError.authWorkflowRequired) }
                     return self.processAuth(auth, authWorkflow: authWorkflow, on: eventLoop)
                         .flatMapThrowing { result -> MQTTConnAckPacket in
                             // once auth workflow is finished we should receive a connack

Sources/MQTTNIO/MQTTClientV5.swift

@@ -187,7 +187,7 @@ extension MQTTClient {
                 if auth.reason == .success {
                     return eventLoop.makeSucceededFuture(auth)
                 }
-                guard let authWorkflow = authWorkflow else { return eventLoop.makeFailedFuture(MQTTError.authWorkflowRequired) }
+                guard let authWorkflow else { return eventLoop.makeFailedFuture(MQTTError.authWorkflowRequired) }
                 return self.client.processAuth(authPacket, authWorkflow: authWorkflow, on: eventLoop)
             }
             .flatMapThrowing { response -> MQTTAuthV5 in

Sources/MQTTNIO/MQTTInflight.swift

@@ -24,22 +24,22 @@ struct MQTTInflight {
     /// add packet
     mutating func add(packet: MQTTPacket) {
         self.lock.withLock {
-            packets.append(packet)
+            self.packets.append(packet)
         }
     }
 
     /// remove packert
     mutating func remove(id: UInt16) {
         self.lock.withLock {
             guard let first = packets.firstIndex(where: { $0.packetId == id }) else { return }
-            packets.remove(at: first)
+            self.packets.remove(at: first)
         }
     }
 
     /// remove all packets
     mutating func clear() {
         self.lock.withLock {
-            packets = []
+            self.packets = []
         }
     }
 

Sources/MQTTNIO/MQTTListeners.swift

@@ -28,13 +28,13 @@ final class MQTTListeners<ReturnType> {
 
     func addListener(named name: String, listener: @escaping Listener) {
         self.lock.withLock {
-            listeners[name] = listener
+            self.listeners[name] = listener
         }
     }
 
     func removeListener(named name: String) {
         self.lock.withLock {
-            listeners[name] = nil
+            self.listeners[name] = nil
         }
     }
 

Sources/MQTTNIO/MQTTPacket.swift

@@ -13,7 +13,7 @@
 
 import NIOCore
 
-internal enum InternalError: Swift.Error {
+enum InternalError: Swift.Error {
     case incompletePacket
     case notImplemented
 }
@@ -99,7 +99,7 @@ struct MQTTConnectPacket: MQTTPacket {
         byteBuffer.writeInteger(version.versionByte)
         // connect flags
         var flags = self.cleanSession ? ConnectFlags.cleanSession : 0
-        if let will = will {
+        if let will {
             flags |= ConnectFlags.willFlag
             flags |= will.retain ? ConnectFlags.willRetain : 0
             flags |= will.qos.rawValue << ConnectFlags.willQoSShift
@@ -116,17 +116,17 @@ struct MQTTConnectPacket: MQTTPacket {
 
         // payload
         try MQTTSerializer.writeString(self.clientIdentifier, to: &byteBuffer)
-        if let will = will {
+        if let will {
             if version == .v5_0 {
                 try will.properties.write(to: &byteBuffer)
             }
             try MQTTSerializer.writeString(will.topicName, to: &byteBuffer)
             try MQTTSerializer.writeBuffer(will.payload, to: &byteBuffer)
         }
-        if let userName = userName {
+        if let userName {
             try MQTTSerializer.writeString(userName, to: &byteBuffer)
         }
-        if let password = password {
+        if let password {
             try MQTTSerializer.writeString(password, to: &byteBuffer)
         }
     }
@@ -149,7 +149,7 @@ struct MQTTConnectPacket: MQTTPacket {
         // client identifier
         size += self.clientIdentifier.utf8.count + 2
         // will publish
-        if let will = will {
+        if let will {
             // properties
             if version == .v5_0 {
                 let propertiesPacketSize = will.properties.packetSize
@@ -161,11 +161,11 @@ struct MQTTConnectPacket: MQTTPacket {
             size += will.payload.readableBytes + 2
         }
         // user name
-        if let userName = userName {
+        if let userName {
             size += userName.utf8.count + 2
         }
         // password
-        if let password = password {
+        if let password {
             size += password.utf8.count + 2
         }
         return size
@@ -370,7 +370,7 @@ struct MQTTPubAckPacket: MQTTPacket {
     let reason: MQTTReasonCode
     let properties: MQTTProperties
 
-    internal init(
+    init(
         type: MQTTPacketType,
         packetId: UInt16,
         reason: MQTTReasonCode = .success,