all: swift-format -r -i ./

Author: ydnar

Package.swift

@@ -11,7 +11,7 @@ let package = Package(
 		.library(
 			name: "RTP",
 			targets: ["RTP"]
-		),
+		)
 	],
 	dependencies: [],
 	targets: [

Sources/RTP/Connection.swift

@@ -50,14 +50,16 @@
 				if let error = error {
 					print("Error receiving UDP packet: \(error)")
 					return
-				} else if let data = data {
+				}
+				else if let data = data {
 					// print("⬇️ Received UDP packet of size: \(data.count)")
 
 					do {
 						let packet = try Packet(from: data)
 						// print("🅿️ Parsed RTP packet: \(packet)")
 						self?.receiverBlock(packet)
-					} catch {
+					}
+					catch {
 						print("Error handling RTP: \(error)")
 						return
 					}

Sources/RTP/Data+Extensions.swift

@@ -1,11 +1,11 @@
 import Foundation
 
-internal extension Data {
+extension Data {
 	// big returns a big-endian integer of type T extracted from the bytes at the specified offset.
 	func big<T: FixedWidthInteger>(at offset: Int) -> T {
 		var value: T = 0
 		withUnsafeMutablePointer(to: &value) {
-			self.copyBytes(to: UnsafeMutableBufferPointer(start: $0, count: 1), from: offset ..< offset + MemoryLayout<T>.size)
+			self.copyBytes(to: UnsafeMutableBufferPointer(start: $0, count: 1), from: offset..<offset + MemoryLayout<T>.size)
 		}
 		return T(bigEndian: value)
 	}
@@ -14,7 +14,7 @@ internal extension Data {
 	func little<T: FixedWidthInteger>(at offset: Int) -> T {
 		var value: T = 0
 		withUnsafeMutablePointer(to: &value) {
-			self.copyBytes(to: UnsafeMutableBufferPointer(start: $0, count: 1), from: offset ..< offset + MemoryLayout<T>.size)
+			self.copyBytes(to: UnsafeMutableBufferPointer(start: $0, count: 1), from: offset..<offset + MemoryLayout<T>.size)
 		}
 		return T(littleEndian: value)
 	}

Sources/RTP/FixedWidthInteger+Extensions.swift

@@ -1,8 +1,8 @@
 import Foundation
 
-public extension FixedWidthInteger {
+extension FixedWidthInteger {
 	// random is a convenience function to generate a random value of the concrete type in [min,max]
-	static func random() -> Self {
+	public static func random() -> Self {
 		Self.random(in: .min ... .max)
 	}
 }

Sources/RTP/Packet.swift

@@ -30,7 +30,7 @@ public struct Packet {
 	public let padding: UInt8
 
 	var payloadWithoutPadding: Data {
-		payload[0 ..< payload.count - Int(padding)]
+		payload[0..<payload.count - Int(padding)]
 	}
 
 	var encodedSize: Int {
@@ -81,9 +81,7 @@ public struct Packet {
 		}
 		let hasPadding = (data[0] & Self.paddingMask) != 0
 		let hasExtension = (data[0] & Self.extensionMask) != 0
-		let sizeWithPaddingAndExtension = Self.headerSize +
-			(hasPadding ? 1 : 0) +
-			(hasExtension ? Extension.headerSize : 0)
+		let sizeWithPaddingAndExtension = Self.headerSize + (hasPadding ? 1 : 0) + (hasExtension ? Extension.headerSize : 0)
 
 		// Parse second octet
 		marker = (data[Self.markerOffset] & Self.markerMask) != 0
@@ -106,10 +104,11 @@ public struct Packet {
 
 		// Parse optional CSRCs in octets 13+
 		if csrcCount > 0 {
-			csrcs = (0 ..< csrcCount).map {
+			csrcs = (0..<csrcCount).map {
 				data.big(at: Self.csrcOffset + $0)
 			}
-		} else {
+		}
+		else {
 			csrcs = nil
 		}
 
@@ -130,14 +129,10 @@ public struct Packet {
 		var data = Data(capacity: encodedSize)
 
 		// Encode first octect (version, padding, extension)
-		data.append(contentsOf: [(Self.version << 6 & Self.versionMask) |
-				(padding > 0 ? Self.paddingMask : 0) |
-				(`extension` != nil ? Self.extensionMask : 0) |
-				(UInt8(csrcs?.count ?? 0) & Self.csrcCountMask)])
+		data.append(contentsOf: [(Self.version << 6 & Self.versionMask) | (padding > 0 ? Self.paddingMask : 0) | (`extension` != nil ? Self.extensionMask : 0) | (UInt8(csrcs?.count ?? 0) & Self.csrcCountMask)])
 
 		// Encode second octet
-		data.append(contentsOf: [(marker ? Self.markerMask : 0) |
-				(payloadType.rawValue & Self.payloadTypeMask)])
+		data.append(contentsOf: [(marker ? Self.markerMask : 0) | (payloadType.rawValue & Self.payloadTypeMask)])
 
 		// Encode sequence number
 		data.append(contentsOf: [UInt8(sequenceNumber >> 8 & 0xFF), UInt8(sequenceNumber & 0xFF)])
@@ -150,7 +145,7 @@ public struct Packet {
 
 		// Encode CSRCs
 		if let csrcs = csrcs {
-			for i in 0 ..< csrcs.count {
+			for i in 0..<csrcs.count {
 				data.append(contentsOf: [UInt8(csrcs[i] >> 24 & 0xFF), UInt8(csrcs[i] >> 16 & 0xFF), UInt8(csrcs[i] >> 8 & 0xFF), UInt8(csrcs[i] & 0xFF)])
 			}
 		}
@@ -203,7 +198,7 @@ public struct Extension {
 			throw EncodingError.extensionDataTooSmall(size)
 		}
 
-		payload = data[Self.headerSize ..< size]
+		payload = data[Self.headerSize..<size]
 	}
 }
 

Tests/RTPTests/ConnectionTests.swift

@@ -17,7 +17,7 @@
 			XCTAssertEqual(conn.conn.state, .cancelled)
 			conn.conn.restart()
 			sleep(1)
-			XCTAssertEqual(conn.conn.state, .cancelled) // NWConnection instances cannot be restarted once cancelled
+			XCTAssertEqual(conn.conn.state, .cancelled)  // NWConnection instances cannot be restarted once cancelled
 		}
 	}
 

Tests/RTPTests/PacketTests.swift

@@ -5,11 +5,11 @@ import XCTest
 class PacketTests: XCTestCase {
 	func testInitWithData() throws {
 		let bytes: [UInt8] = [
-			2 << 6, // Version 2, no marker or extension
-			111, // Opus payload type
-			0, 123, // Sequence number 123
-			0, 0, 0, 1, // Timestamp 1
-			0, 255, 255, 255, // SSRC 0x00FFFFFF
+			2 << 6,  // Version 2, no marker or extension
+			111,  // Opus payload type
+			0, 123,  // Sequence number 123
+			0, 0, 0, 1,  // Timestamp 1
+			0, 255, 255, 255,  // SSRC 0x00FFFFFF
 		]
 
 		let packet = try RTP.Packet(from: Data(bytes))

Tests/RTPTests/TypeTests.swift

@@ -24,11 +24,11 @@ class TypeTests: XCTestCase {
 
 	func testPacketInitWithData() throws {
 		let bytes: [UInt8] = [
-			2 << 6, // Version 2, no marker or extension
-			111, // Opus payload type
-			0, 123, // Sequence number 123
-			0, 0, 0, 1, // Timestamp 1
-			0, 255, 255, 255, // SSRC 0x00FFFFFF
+			2 << 6,  // Version 2, no marker or extension
+			111,  // Opus payload type
+			0, 123,  // Sequence number 123
+			0, 0, 0, 1,  // Timestamp 1
+			0, 255, 255, 255,  // SSRC 0x00FFFFFF
 		]
 
 		let packet = try RTP.Packet(from: Data(bytes))