add Sendable

Sources/Auth/Types.swift

@@ -501,7 +501,7 @@
     self.phone = phone
     self.password = password
     self.nonce = nonce
     self.emailChangeToken = emailChangeToken
     self.data = data
   }
 }
@@ -619,7 +619,7 @@
   }
 }
 
-public struct MFAChallengeParams: Encodable, Hashable {
+public struct MFAChallengeParams: Encodable, Hashable, Sendable {
   /// ID of the factor to be challenged. Returned in ``AuthMFA/enroll(params:)``.
   public let factorId: String
 
@@ -632,7 +632,7 @@
   }
 }
 
-public struct MFAVerifyParams: Encodable, Hashable {
+public struct MFAVerifyParams: Encodable, Hashable, Sendable {
   /// ID of the factor being verified. Returned in ``AuthMFA/enroll(params:)``.
   public let factorId: String
 

Sources/Realtime/Defaults.swift

@@ -21,7 +21,7 @@
 import Foundation
 
 /// A collection of default values and behaviors used across the Client
-public enum Defaults {
+public enum Defaults: Sendable {
   /// Default timeout when sending messages
   public static let timeoutInterval: TimeInterval = 10.0
 
@@ -33,19 +33,19 @@
   public static let heartbeatLeeway: DispatchTimeInterval = .milliseconds(10)
 
   /// Default reconnect algorithm for the socket
   public static let reconnectSteppedBackOff: (Int) -> TimeInterval = { tries in
     tries > 9 ? 5.0 : [0.01, 0.05, 0.1, 0.15, 0.2, 0.25, 0.5, 1.0, 2.0][tries - 1]
   }
 
   /** Default rejoin algorithm for individual channels */
   public static let rejoinSteppedBackOff: (Int) -> TimeInterval = { tries in
     tries > 3 ? 10 : [1, 2, 5][tries - 1]
   }
 
   public static let vsn = "2.0.0"
 
   /// Default encode function, utilizing JSONSerialization.data
   public static let encode: (Any) -> Data = { json in
     try! JSONSerialization
       .data(
         withJSONObject: json,
@@ -54,7 +54,7 @@
   }
 
   /// Default decode function, utilizing JSONSerialization.jsonObject
   public static let decode: (Data) -> Any? = { data in
     guard
       let json =
       try? JSONSerialization
@@ -73,7 +73,7 @@
 
 /// Represents the multiple states that a Channel can be in
 /// throughout it's lifecycle.
-public enum ChannelState: String {
+public enum ChannelState: String, Sendable {
   case closed
   case errored
   case joined
@@ -83,7 +83,7 @@
 
 /// Represents the different events that can be sent through
 /// a channel regarding a Channel's lifecycle.
-public enum ChannelEvent {
+public enum ChannelEvent: Sendable {
   public static let join = "phx_join"
   public static let leave = "phx_leave"
   public static let close = "phx_close"

Sources/Realtime/PhoenixTransport.swift

@@ -110,7 +110,7 @@
 
 // ----------------------------------------------------------------------
 /// Available `ReadyState`s of a `Transport` layer.
-public enum PhoenixTransportReadyState {
+public enum PhoenixTransportReadyState: Sendable {
   /// The `Transport` is opening a connection to the server.
   case connecting
 
@@ -137,7 +137,7 @@
 /// `Transport` implementations. Or you can create your own implementation using
 /// your own WebSocket library or implementation.
 @available(macOS 10.15, iOS 13, watchOS 6, tvOS 13, *)
 open class URLSessionTransport: NSObject, PhoenixTransport, URLSessionWebSocketDelegate {
   /// The URL to connect to
   let url: URL
 
@@ -145,7 +145,7 @@
   let configuration: URLSessionConfiguration
 
   /// The underling URLSession. Assigned during `connect()`
   private var session: URLSession? = nil
 
   /// The ongoing task. Assigned during `connect()`
   private var task: URLSessionWebSocketTask? = nil
@@ -201,7 +201,7 @@
     var request = URLRequest(url: url)
 
     for (key, value) in headers {
       guard let value = value as? String else { continue }
       request.addValue(value, forHTTPHeaderField: key)
     }
 
@@ -229,7 +229,7 @@
 
   open func send(data: Data) {
     Task {
       try? await task?.send(.string(String(data: data, encoding: .utf8)!))
     }
   }
 
@@ -278,7 +278,7 @@
   private func receive() {
     Task {
       do {
         let result = try await task?.receive()
         switch result {
         case .data:
           print("Data received. This method is unsupported by the Client")
@@ -310,7 +310,7 @@
     // so inform the delegate that the Transport has closed abnormally. This will kick off
     // the reconnect logic.
     delegate?.onClose(
       code: RealtimeClient.CloseCode.abnormal.rawValue, reason: error.localizedDescription
     )
   }
 }

Sources/Realtime/Presence.swift

@@ -108,7 +108,7 @@ public final class Presence {
   ///
   ///     let options = Options(events: [.state: "my_state", .diff: "my_diff"])
   ///     let presence = Presence(channel, opts: options)
-  public struct Options {
+  public struct Options: Sendable {
     let events: [Events: String]
 
     /// Default set of Options used when creating Presence. Uses the
@@ -124,7 +124,7 @@ public final class Presence {
   }
 
   /// Presense Events
-  public enum Events: String {
+  public enum Events: String, Sendable {
     case state
     case diff
   }

Sources/Realtime/RealtimeChannel.swift

@@ -35,7 +35,7 @@
   let id: String?
 }
 
-public struct ChannelFilter {
+public struct ChannelFilter: Sendable {
   public var event: String?
   public var schema: String?
   public let table: String?
@@ -60,18 +60,18 @@
   }
 }
 
-public enum ChannelResponse {
+public enum ChannelResponse: Sendable {
   case ok, timedOut, error
 }
 
-public enum RealtimeListenTypes: String {
+public enum RealtimeListenTypes: String, Sendable {
   case postgresChanges = "postgres_changes"
   case broadcast
   case presence
 }
 
 /// Represents the broadcast and presence options for a channel.
-public struct RealtimeChannelOptions {
+public struct RealtimeChannelOptions: Sendable {
   /// Used to track presence payload across clients. Must be unique per client. If `nil`, the server
   /// will generate one.
   var presenceKey: String?
@@ -106,7 +106,7 @@
   }
 }
 
-public enum RealtimeSubscribeStates {
+public enum RealtimeSubscribeStates: Sendable {
   case subscribed
   case timedOut
   case closed
@@ -1004,7 +1004,7 @@
 // MARK: - Public API
 
 // ----------------------------------------------------------------------
 extension RealtimeChannel {
   /// - return: True if the RealtimeChannel has been closed
   public var isClosed: Bool {
     state == .closed

Sources/Realtime/RealtimeClient.swift

@@ -1006,8 +1006,8 @@
 // MARK: - Close Codes
 
 // ----------------------------------------------------------------------
 extension RealtimeClient {
-  public enum CloseCode: Int {
+  public enum CloseCode: Int, Sendable {
     case abnormal = 999
 
     case normal = 1000

Sources/Realtime/RealtimeMessage.swift

@@ -22,7 +22,7 @@ import Foundation
 import Helpers
 
 /// Data that is received from the Server.
-public struct RealtimeMessage {
+public struct RealtimeMessage: Sendable {
   /// Reference number. Empty if missing
   public let ref: String
 

Sources/Realtime/V2/RealtimeMessageV2.swift

@@ -54,7 +54,7 @@ public struct RealtimeMessageV2: Hashable, Codable, Sendable {
     }
   }
 
-  public enum EventType {
+  public enum EventType: Sendable {
     case system
     case postgresChanges
     case broadcast

Sources/Storage/Deprecated.swift

@@ -103,7 +103,7 @@ extension StorageFileApi {
   deprecated,
   message: "File was deprecated and it isn't used in the package anymore, if you're using it on your application, consider replacing it as it will be removed on the next major release."
 )
-public struct File: Hashable, Equatable {
+public struct File: Hashable, Equatable, Sendable {
   public var name: String
   public var data: Data
   public var fileName: String?