V5: Use concurrency and timers from StreamCore (#3858)

* V5: Use error types from StreamCore (#3859)

* V5: Use JSON encoders and decoders from StreamCore (#3860)

* V5: Use web-socket client from StreamCore (#3861)

Author: laevandus

DemoApp/StreamChat/Components/DemoChatThreadVC.swift

@@ -72,7 +72,7 @@ class DemoChatThreadVC: ChatThreadVC, CurrentChatUserControllerDelegate {
 
     // MARK: - Dismissing the thread if the root message was hard deleted.
 
-    override func eventsController(_ controller: EventsController, didReceiveEvent event: any Event) {
+    override func eventsController(_ controller: EventsController, didReceiveEvent event: any StreamChat.Event) {
         super.eventsController(controller, didReceiveEvent: event)
 
         // Dismiss the thread if the root message was hard deleted.

Package.swift

@@ -29,7 +29,7 @@ let package = Package(
     ],
     dependencies: [
         .package(url: "https://github.com/apple/swift-docc-plugin", exact: "1.0.0"),
-        .package(url: "https://github.com/GetStream/stream-core-swift.git", exact: "0.4.1")
+        .package(url: "https://github.com/GetStream/stream-core-swift.git", exact: "0.5.0")
     ],
     targets: [
         .target(

Sources/StreamChat/APIClient/RequestDecoder.swift

@@ -46,9 +46,9 @@ struct DefaultRequestDecoder: RequestDecoder {
         log.debug("URL request response: \(httpResponse), data:\n\(data.debugPrettyPrintedJSON))", subsystems: .httpRequests)
 
         guard httpResponse.statusCode < 300 else {
-            let serverError: ErrorPayload
+            let serverError: APIError
             do {
-                serverError = try JSONDecoder.default.decode(ErrorPayload.self, from: data)
+                serverError = try JSONDecoder.default.decode(APIError.self, from: data)
             } catch {
                 log
                     .error(
@@ -58,7 +58,7 @@ struct DefaultRequestDecoder: RequestDecoder {
                 throw ClientError.Unknown("Unknown error. Server response: \(httpResponse).")
             }
 
-            if serverError.isExpiredTokenError {
+            if serverError.isTokenExpiredError {
                 log.info("Request failed because of an expired token.", subsystems: .httpRequests)
                 throw ClientError.ExpiredToken()
             }

Sources/StreamChat/APIClient/RequestEncoder.swift

@@ -304,7 +304,6 @@ protocol ConnectionDetailsProviderDelegate: AnyObject {
 }
 
 public extension ClientError {
-    final class InvalidURL: ClientError, @unchecked Sendable {}
     final class InvalidJSON: ClientError, @unchecked Sendable {}
     final class MissingConnectionId: ClientError, @unchecked Sendable {}
 }

Sources/StreamChat/ChatClient+Environment.swift

@@ -25,15 +25,18 @@ extension ChatClient {
 
         var webSocketClientBuilder: (@Sendable (
             _ sessionConfiguration: URLSessionConfiguration,
-            _ requestEncoder: RequestEncoder,
             _ eventDecoder: AnyEventDecoder,
-            _ notificationCenter: EventNotificationCenter
+            _ notificationCenter: PersistentEventNotificationCenter
         ) -> WebSocketClient)? = {
-            WebSocketClient(
+            let wsEnvironment = WebSocketClient.Environment(eventBatchingPeriod: 0.5)
+            return WebSocketClient(
                 sessionConfiguration: $0,
-                requestEncoder: $1,
-                eventDecoder: $2,
-                eventNotificationCenter: $3
+                eventDecoder: $1,
+                eventNotificationCenter: $2,
+                webSocketClientType: .coordinator,
+                environment: wsEnvironment,
+                connectRequest: nil,
+                healthCheckBeforeConnected: true
             )
         }
 
@@ -57,7 +60,7 @@ extension ChatClient {
 
         var eventDecoderBuilder: @Sendable () -> EventDecoder = { EventDecoder() }
 
-        var notificationCenterBuilder: @Sendable (_ database: DatabaseContainer, _ manualEventHandler: ManualEventHandler?) -> EventNotificationCenter = { EventNotificationCenter(database: $0, manualEventHandler: $1) }
+        var notificationCenterBuilder: @Sendable (_ database: DatabaseContainer, _ manualEventHandler: ManualEventHandler?) -> PersistentEventNotificationCenter = { PersistentEventNotificationCenter(database: $0, manualEventHandler: $1) }
 
         var internetConnection: @Sendable (_ center: NotificationCenter, _ monitor: InternetConnectionMonitor) -> InternetConnection = {
             InternetConnection(notificationCenter: $0, monitor: $1)
@@ -76,16 +79,18 @@ extension ChatClient {
         var connectionRepositoryBuilder: @Sendable (
             _ isClientInActiveMode: Bool,
             _ syncRepository: SyncRepository,
+            _ webSocketEncoder: RequestEncoder?,
             _ webSocketClient: WebSocketClient?,
             _ apiClient: APIClient,
-            _ timerType: Timer.Type
+            _ timerType: TimerScheduling.Type
         ) -> ConnectionRepository = {
             ConnectionRepository(
                 isClientInActiveMode: $0,
                 syncRepository: $1,
-                webSocketClient: $2,
-                apiClient: $3,
-                timerType: $4
+                webSocketEncoder: $2,
+                webSocketClient: $3,
+                apiClient: $4,
+                timerType: $5
             )
         }
 
@@ -103,27 +108,25 @@ extension ChatClient {
             }
         }
 
-        var timerType: Timer.Type = DefaultTimer.self
+        var timerType: TimerScheduling.Type = DefaultTimer.self
 
         var tokenExpirationRetryStrategy: RetryStrategy = DefaultRetryStrategy()
 
         var connectionRecoveryHandlerBuilder: @Sendable (
             _ webSocketClient: WebSocketClient,
             _ eventNotificationCenter: EventNotificationCenter,
-            _ syncRepository: SyncRepository,
             _ backgroundTaskScheduler: BackgroundTaskScheduler?,
             _ internetConnection: InternetConnection,
             _ keepConnectionAliveInBackground: Bool
         ) -> ConnectionRecoveryHandler = {
             DefaultConnectionRecoveryHandler(
                 webSocketClient: $0,
                 eventNotificationCenter: $1,
-                syncRepository: $2,
-                backgroundTaskScheduler: $3,
-                internetConnection: $4,
+                backgroundTaskScheduler: $2,
+                internetConnection: $3,
                 reconnectionStrategy: DefaultRetryStrategy(),
                 reconnectionTimerType: DefaultTimer.self,
-                keepConnectionAliveInBackground: $5
+                keepConnectionAliveInBackground: $4
             )
         }
 
@@ -132,7 +135,7 @@ extension ChatClient {
             _ databaseContainer: DatabaseContainer,
             _ connectionRepository: ConnectionRepository,
             _ tokenExpirationRetryStrategy: RetryStrategy,
-            _ timerType: Timer.Type
+            _ timerType: TimerScheduling.Type
         ) -> AuthenticationRepository = {
             AuthenticationRepository(
                 apiClient: $0,

Sources/StreamChat/ChatClient.swift

@@ -52,7 +52,7 @@ public class ChatClient: @unchecked Sendable {
     private(set) var connectionRecoveryHandler: ConnectionRecoveryHandler?
 
     /// The notification center used to send and receive notifications about incoming events.
-    private(set) var eventNotificationCenter: EventNotificationCenter
+    private(set) var eventNotificationCenter: PersistentEventNotificationCenter
 
     /// The registry that contains all the attachment payloads associated with their attachment types.
     /// For the meantime this is a static property to avoid breaking changes. On v5, this can be changed.
@@ -99,6 +99,7 @@ public class ChatClient: @unchecked Sendable {
 
     /// The `WebSocketClient` instance `Client` uses to communicate with Stream WS servers.
     let webSocketClient: WebSocketClient?
+    let webSocketEncoder: RequestEncoder?
 
     /// The `DatabaseContainer` instance `Client` uses to store and cache data.
     let databaseContainer: DatabaseContainer
@@ -184,13 +185,13 @@ public class ChatClient: @unchecked Sendable {
             channelListUpdater
         )
         let webSocketClient = factory.makeWebSocketClient(
-            requestEncoder: webSocketEncoder,
             urlSessionConfiguration: urlSessionConfiguration,
             eventNotificationCenter: eventNotificationCenter
         )
         let connectionRepository = environment.connectionRepositoryBuilder(
             config.isClientInActiveMode,
             syncRepository,
+            webSocketEncoder,
             webSocketClient,
             apiClient,
             environment.timerType
@@ -207,6 +208,7 @@ public class ChatClient: @unchecked Sendable {
         self.databaseContainer = databaseContainer
         self.apiClient = apiClient
         self.webSocketClient = webSocketClient
+        self.webSocketEncoder = webSocketEncoder
         self.eventNotificationCenter = eventNotificationCenter
         self.offlineRequestsRepository = offlineRequestsRepository
         self.connectionRepository = connectionRepository
@@ -268,7 +270,6 @@ public class ChatClient: @unchecked Sendable {
         connectionRecoveryHandler = environment.connectionRecoveryHandlerBuilder(
             webSocketClient,
             eventNotificationCenter,
-            syncRepository,
             environment.backgroundTaskSchedulerBuilder(),
             environment.internetConnection(eventNotificationCenter, environment.internetMonitor),
             config.staysConnectedInBackground
@@ -718,7 +719,7 @@ extension ChatClient: AuthenticationRepositoryDelegate {
 }
 
 extension ChatClient: ConnectionStateDelegate {
-    func webSocketClient(_ client: WebSocketClient, didUpdateConnectionState state: WebSocketConnectionState) {
+    public func webSocketClient(_ client: WebSocketClient, didUpdateConnectionState state: WebSocketConnectionState) {
         connectionRepository.handleConnectionUpdate(
             state: state,
             onExpiredToken: { [weak self] in

Sources/StreamChat/ChatClientFactory.swift

@@ -65,13 +65,11 @@ class ChatClientFactory {
     }
 
     func makeWebSocketClient(
-        requestEncoder: RequestEncoder,
         urlSessionConfiguration: URLSessionConfiguration,
-        eventNotificationCenter: EventNotificationCenter
+        eventNotificationCenter: PersistentEventNotificationCenter
     ) -> WebSocketClient? {
         environment.webSocketClientBuilder?(
             urlSessionConfiguration,
-            requestEncoder,
             EventDecoder(),
             eventNotificationCenter
         )
@@ -114,7 +112,7 @@ class ChatClientFactory {
     func makeEventNotificationCenter(
         databaseContainer: DatabaseContainer,
         currentUserId: @escaping () -> UserId?
-    ) -> EventNotificationCenter {
+    ) -> PersistentEventNotificationCenter {
         let center = environment.notificationCenterBuilder(databaseContainer, nil)
         let middlewares: [EventMiddleware] = [
             EventDataProcessorMiddleware(),

Sources/StreamChat/Config/ChatClientConfig.swift

@@ -227,21 +227,3 @@ extension ChatClientConfig {
         public var latestMessagesLimit = 5
     }
 }
-
-/// A struct representing an API key of the chat app.
-///
-/// An API key can be obtained by registering on [our website](https://getstream.io/chat/trial/\).
-///
-public struct APIKey: Equatable, Sendable {
-    /// The string representation of the API key
-    public let apiKeyString: String
-
-    /// Creates a new `APIKey` from the provided string. Fails, if the string is empty.
-    ///
-    /// - Warning: The `apiKeyString` must be a non-empty value, otherwise an assertion failure is raised.
-    ///
-    public init(_ apiKeyString: String) {
-        log.assert(apiKeyString.isEmpty == false, "APIKey can't be initialize with an empty string.")
-        self.apiKeyString = apiKeyString
-    }
-}

Sources/StreamChat/Config/Token.swift

@@ -72,10 +72,6 @@ public extension Token {
     }
 }
 
-extension ClientError {
-    public final class InvalidToken: ClientError, @unchecked Sendable {}
-}
-
 private extension String {
     var jwtPayload: [String: Any]? {
         let parts = split(separator: ".")