feat: SDK update for version 17.0.0 (#110)

* chore: update Apple SDK to 16.1.0

* chore: update Apple SDK to 16.2.0

* chore: sync generated SDK for latest

Made-with: Cursor

* chore: restore .github metadata

Made-with: Cursor

* chore: update Apple SDK to 17.0.0

Author: ArnabChatterjee20k

CHANGELOG.md

@@ -1,5 +1,11 @@
 # Change Log
 
+## 17.0.0
+
+* Breaking: Added `unsubscribe()`, `update()`, and `close()` for Realtime subscription lifecycle.
+* Added: Added `userPhone` to the `Membership` model.
+* Updated: Updated `X-Appwrite-Response-Format` header to `1.9.2`.
+
 ## 16.1.0
 
 * Added `x` OAuth provider to `OAuthProvider` enum

README.md

@@ -2,7 +2,7 @@
 
 ![Swift Package Manager](https://img.shields.io/github/v/release/appwrite/sdk-for-apple.svg?color=green&style=flat-square)
 ![License](https://img.shields.io/github/license/appwrite/sdk-for-apple.svg?style=flat-square)
-![Version](https://img.shields.io/badge/api%20version-1.9.1-blue.svg?style=flat-square)
+![Version](https://img.shields.io/badge/api%20version-1.9.2-blue.svg?style=flat-square)
 [![Build Status](https://img.shields.io/travis/com/appwrite/sdk-generator?style=flat-square)](https://travis-ci.com/appwrite/sdk-generator)
 [![Twitter Account](https://img.shields.io/twitter/follow/appwrite?color=00acee&label=twitter&style=flat-square)](https://twitter.com/appwrite)
 [![Discord](https://img.shields.io/discord/564160730845151244?label=discord&style=flat-square)](https://appwrite.io/discord)
@@ -31,7 +31,7 @@ Add the package to your `Package.swift` dependencies:
 
 ```swift
     dependencies: [
-        .package(url: "git@github.com:appwrite/sdk-for-apple.git", from: "16.1.0"),
+        .package(url: "git@github.com:appwrite/sdk-for-apple.git", from: "17.0.0"),
     ],
 ```
 

Sources/Appwrite/Client.swift

@@ -26,8 +26,8 @@ open class Client {
         "x-sdk-name": "Apple",
         "x-sdk-platform": "client",
         "x-sdk-language": "apple",
-        "x-sdk-version": "16.1.0",
-        "x-appwrite-response-format": "1.9.1"
+        "x-sdk-version": "17.0.0",
+        "x-appwrite-response-format": "1.9.2"
     ]
 
     internal var config: [String: String] = [:]
@@ -355,7 +355,7 @@ open class Client {
         headers: [String: String] = [:],
         params: [String: Any?] = [:],
         sink: ((ByteBuffer) -> Void)? = nil,
-        converter: ((Any) -> T)? = nil
+        converter: ((Any) throws -> T)? = nil
     ) async throws -> T {
         let validParams = params.filter { $0.value != nil }
 
@@ -395,7 +395,7 @@ open class Client {
     private func execute<T>(
         _ request: HTTPClientRequest,
         withSink bufferSink: ((ByteBuffer) -> Void)? = nil,
-        converter: ((Any) -> T)? = nil
+        converter: ((Any) throws -> T)? = nil
     ) async throws -> T {
         let response = try await http.execute(
             request,
@@ -431,7 +431,11 @@ open class Client {
                 }
                 let dict = try JSONSerialization.jsonObject(with: Data(data.readableBytesView)) as? [String: Any]
 
-                return converter?(dict!) ?? dict! as! T
+                if let converter = converter {
+                    return try converter(dict!)
+                }
+
+                return dict! as! T
             }
         default:
             var message = ""
@@ -464,7 +468,7 @@ open class Client {
         params: inout [String: Any?],
         paramName: String,
         idParamName: String? = nil,
-        converter: ((Any) -> T)? = nil,
+        converter: ((Any) throws -> T)? = nil,
         onProgress: ((UploadProgress) -> Void)? = nil
     ) async throws -> T {
         let input = params[paramName] as! InputFile
@@ -537,7 +541,7 @@ open class Client {
             ))
         }
 
-        return converter!(result)
+        return try converter!(result)
     }
 
     private static func randomBoundary() -> String {

Sources/Appwrite/Models/RealtimeModels.swift

@@ -1,26 +1,60 @@
 import Foundation
 
+public class RealtimeSubscriptionUpdate {
+    public let channels: [ChannelValue]?
+    public let queries: [String]?
+
+    public init(channels: [ChannelValue]? = nil, queries: [String]? = nil) {
+        self.channels = channels
+        self.queries = queries
+    }
+}
+
 public class RealtimeSubscription {
-    private var close: () async throws -> Void
+    private var unsubscribeAction: () async throws -> Void
+    private var updateAction: (RealtimeSubscriptionUpdate) async throws -> Void
+    private var closeAction: () async throws -> Void
+
+    init(
+        unsubscribe: @escaping () async throws -> Void,
+        update: @escaping (RealtimeSubscriptionUpdate) async throws -> Void,
+        close: @escaping () async throws -> Void
+    ) {
+        self.unsubscribeAction = unsubscribe
+        self.updateAction = update
+        self.closeAction = close
+    }
+
+    /// Remove this subscription only. The WebSocket stays open so other subscriptions keep
+    /// receiving events; use `Realtime.disconnect()` to shut the connection down.
+    public func unsubscribe() async throws {
+        try await self.unsubscribeAction()
+    }
 
-    init(close: @escaping () async throws-> Void) {
-        self.close = close
+    /// Replace the channels and/or queries on this subscription without recreating it.
+    public func update(_ changes: RealtimeSubscriptionUpdate) async throws {
+        try await self.updateAction(changes)
     }
 
+    /// Alias of `unsubscribe()` that also tears the socket down when this was the last active
+    /// subscription. Prefer `unsubscribe()` plus `Realtime.disconnect()` for explicit control.
     public func close() async throws {
-        try await self.close()
+        try await self.closeAction()
     }
 }
 
 public class RealtimeCallback {
-    public let channels: Set<String>
+    public var channels: Set<String>
+    public var queries: [String]
     public let callback: (RealtimeResponseEvent) -> Void
 
     init(
         for channels: Set<String>,
+        queries: [String],
         with callback: @escaping (RealtimeResponseEvent) -> Void
     ) {
         self.channels = channels
+        self.queries = queries
         self.callback = callback
     }
 }