Add ability to have custom HTTP sessions.

Sources/Segment/Configuration.swift

@@ -246,8 +246,8 @@ public extension Configuration {
 
     /// Specify a custom UserAgent string.  This bypasses the OS dependent check entirely.
     @discardableResult
-    func httpSession(_ httpSession: @escaping @autoclosure () -> HTTPSession) -> Configuration {
-        values.httpSession = httpSession
+    func userAgent(_ userAgent: String) -> Configuration {
+        values.userAgent = userAgent
         return self
     }
 
@@ -273,6 +273,16 @@ public extension Configuration {
         values.anonymousIdGenerator = generator
         return self
     }
+
+    /// Use a custom HTTP session; Useful for non-apple platforms where Swift networking isn't as mature
+    /// or has issues to work around.
+    /// - Parameter httpSession: A class conforming to the HTTPSession protocol
+    /// - Returns: The current configuration
+    @discardableResult
+    func httpSession(_ httpSession: @escaping @autoclosure () -> any HTTPSession) -> Configuration {
+        values.httpSession = httpSession
+        return self
+    }
 }
 
 extension Analytics {

Sources/Segment/Plugins/SegmentDestination.swift

@@ -41,7 +41,7 @@ public class SegmentDestination: DestinationPlugin, Subscriber, FlushCompletion
     internal struct UploadTaskInfo {
         let url: URL?
         let data: Data?
-        let task: URLSessionDataTask
+        let task: DataTask
         // set/used via an extension in iOSLifecycleMonitor.swift
         typealias CleanupClosure = () -> Void
         var cleanup: CleanupClosure? = nil

Sources/Segment/Utilities/HTTPClient.swift → Sources/Segment/Utilities/Networking/HTTPClient.swift

@@ -52,7 +52,7 @@ public class HTTPClient {
     ///   - batch: The array of the events, considered a batch of events.
     ///   - completion: The closure executed when done. Passes if the task should be retried or not if failed.
     @discardableResult
-    func startBatchUpload(writeKey: String, batch: URL, completion: @escaping (_ result: Result<Bool, Error>) -> Void) -> URLSessionDataTask? {
+    func startBatchUpload(writeKey: String, batch: URL, completion: @escaping (_ result: Result<Bool, Error>) -> Void) -> (any DataTask)? {
         guard let uploadURL = segmentURL(for: apiHost, path: "/b") else {
             self.analytics?.reportInternalError(HTTPClientErrors.failedToOpenBatch)
             completion(.failure(HTTPClientErrors.failedToOpenBatch))
@@ -77,7 +77,7 @@ public class HTTPClient {
     ///   - batch: The array of the events, considered a batch of events.
     ///   - completion: The closure executed when done. Passes if the task should be retried or not if failed.
     @discardableResult
-    func startBatchUpload(writeKey: String, data: Data, completion: @escaping (_ result: Result<Bool, Error>) -> Void) -> URLSessionDataTask? {
+    func startBatchUpload(writeKey: String, data: Data, completion: @escaping (_ result: Result<Bool, Error>) -> Void) -> (any UploadTask)? {
         guard let uploadURL = segmentURL(for: apiHost, path: "/b") else {
             self.analytics?.reportInternalError(HTTPClientErrors.failedToOpenBatch)
             completion(.failure(HTTPClientErrors.failedToOpenBatch))

Sources/Segment/Utilities/Networking/HTTPSession.swift

@@ -5,29 +5,30 @@ import FoundationNetworking
 #endif
 
 public protocol DataTask {
-  var state: URLSessionTask.State { get }
-  func resume()
+    var state: URLSessionTask.State { get }
+    func resume()
 }
 
 public protocol UploadTask: DataTask {}
 
 // An enumeration of default `HTTPSession` configurations to be used
 // This can be extended buy consumer to easily refer back to their configured session.
 public enum HTTPSessions {
-  /// An implementation of `HTTPSession` backed by Apple's `URLSession`.
-  public static func urlSession() -> any HTTPSession {
-      let configuration = URLSessionConfiguration.ephemeral
-      configuration.httpMaximumConnectionsPerHost = 2
-      let session = URLSession(configuration: configuration, delegate: nil, delegateQueue: nil)
-      return session
-  }
+    /// An implementation of `HTTPSession` backed by Apple's `URLSession`.
+    public static func urlSession() -> any HTTPSession {
+        let configuration = URLSessionConfiguration.ephemeral
+        configuration.httpMaximumConnectionsPerHost = 2
+        let session = URLSession(configuration: configuration, delegate: nil, delegateQueue: nil)
+        return session
+    }
 }
 
 public protocol HTTPSession {
-  associatedtype DataTaskType: DataTask
-  associatedtype UploadTaskType: UploadTask
-
-  func uploadTask(with request: URLRequest, fromFile file: URL, completionHandler: @escaping @Sendable (Data?, URLResponse?, (any Error)?) -> Void) -> UploadTaskType
-  func dataTask(with request: URLRequest, completionHandler: @escaping @Sendable (Data?, URLResponse?, (any Error)?) -> Void) -> DataTaskType
-  func finishTasksAndInvalidate()
+    associatedtype DataTaskType: DataTask
+    associatedtype UploadTaskType: UploadTask
+
+    func uploadTask(with request: URLRequest, fromFile file: URL, completionHandler: @escaping @Sendable (Data?, URLResponse?, (any Error)?) -> Void) -> UploadTaskType
+    func uploadTask(with request: URLRequest, from bodyData: Data?, completionHandler: @escaping @Sendable (Data?, URLResponse?, (any Error)?) -> Void) -> UploadTaskType
+    func dataTask(with request: URLRequest, completionHandler: @escaping @Sendable (Data?, URLResponse?, (any Error)?) -> Void) -> DataTaskType
+    func finishTasksAndInvalidate()
 }