regen

Author: ChiragAgg5k

CHANGELOG.md

@@ -1,5 +1,9 @@
 # Change Log
 
+## 13.3.0
+
+* Add `onOpen`, `onClose` and `onError` callbacks to `Realtime` service
+
 ## 13.2.2
 
 * Fix issue: Missing AppwriteEnums dependency causing build failure

README.md

@@ -31,7 +31,7 @@ Add the package to your `Package.swift` dependencies:
 
 ```swift
     dependencies: [
-        .package(url: "[email protected]:appwrite/sdk-for-apple.git", from: "13.2.2"),
+        .package(url: "[email protected]:appwrite/sdk-for-apple.git", from: "13.3.0"),
     ],
 ```
 

Sources/Appwrite/Client.swift

@@ -23,7 +23,7 @@ open class Client {
         "x-sdk-name": "Apple",
         "x-sdk-platform": "client",
         "x-sdk-language": "apple",
-        "x-sdk-version": "13.2.2",
+        "x-sdk-version": "13.3.0",
         "x-appwrite-response-format": "1.8.0"
     ]
 

Sources/Appwrite/Services/Realtime.swift

@@ -22,6 +22,22 @@ open class Realtime : Service {
     private var reconnectAttempts = 0
     private var subscriptionsCounter = 0
     private var reconnect = true
+    
+    private var onErrorCallbacks: [((Swift.Error?, HTTPResponseStatus?) -> Void)] = []
+    private var onCloseCallbacks: [(() -> Void)] = []
+    private var onOpenCallbacks: [(() -> Void)] = []
+
+    public func onError(_ callback: @escaping (Swift.Error?, HTTPResponseStatus?) -> Void) {
+        self.onErrorCallbacks.append(callback)
+    }
+    
+    public func onClose(_ callback: @escaping () -> Void) {
+        self.onCloseCallbacks.append(callback)
+    }
+    
+    public func onOpen(_ callback: @escaping () -> Void) {
+        self.onOpenCallbacks.append(callback)
+    }
 
     private func startHeartbeat() {
         stopHeartbeat()
@@ -191,6 +207,7 @@ extension Realtime: WebSocketClientDelegate {
 
     public func onOpen(channel: Channel) {
         self.reconnectAttempts = 0
+        onOpenCallbacks.forEach { $0() }
         startHeartbeat()
     }
 
@@ -210,6 +227,8 @@ extension Realtime: WebSocketClientDelegate {
 
     public func onClose(channel: Channel, data: Data) async throws {
         stopHeartbeat()
+
+        onCloseCallbacks.forEach { $0() }
 
         if (!reconnect) {
             reconnect = true
@@ -230,6 +249,8 @@ extension Realtime: WebSocketClientDelegate {
     public func onError(error: Swift.Error?, status: HTTPResponseStatus?) {
         stopHeartbeat()
         print(error?.localizedDescription ?? "Unknown error")
+
+        onErrorCallbacks.forEach { $0(error, status) }
     }
 
     func handleResponseError(from json: [String: Any]) throws {