fix(realtime): add RealtimeSubscription and deprecate Subscription

supabase · Sep 27, 2024 · 9a0f67d · 9a0f67d
1 parent d9ba673
commit 9a0f67d
Show file tree

Hide file tree

Showing 3 changed files with 21 additions and 11 deletions.
diff --git a/Package.resolved b/Package.resolved
@@ -1,5 +1,14 @@
 {
   "pins" : [
+    {
+      "identity" : "multipartformdata",
+      "kind" : "remoteSourceControl",
+      "location" : "https://github.com/grdsdev/MultipartFormData",
+      "state" : {
+        "revision" : "ed7abea9cfc6c3b5e77a73fe6842c57a372d2017",
+        "version" : "0.1.0"
+      }
+    },
     {
       "identity" : "swift-concurrency-extras",
       "kind" : "remoteSourceControl",

diff --git a/Sources/Realtime/V2/RealtimeChannelV2.swift b/Sources/Realtime/V2/RealtimeChannelV2.swift
@@ -64,6 +64,7 @@ extension Socket {
 }
 
 public final class RealtimeChannelV2: Sendable {
+  @available(*, deprecated, renamed: "RealtimeRealtimeSubscription")
   public typealias Subscription = ObservationToken
 
   public enum Status: Sendable {
@@ -464,9 +465,9 @@ public final class RealtimeChannelV2: Sendable {
   /// Listen for clients joining / leaving the channel using presences.
   public func onPresenceChange(
     _ callback: @escaping @Sendable (any PresenceAction) -> Void
-  ) -> Subscription {
+  ) -> RealtimeSubscription {
     let id = callbackManager.addPresenceCallback(callback: callback)
-    return Subscription { [weak callbackManager, logger] in
+    return RealtimeSubscription { [weak callbackManager, logger] in
       logger?.debug("Removing presence callback with id: \(id)")
       callbackManager?.removeCallback(id: id)
     }
@@ -479,7 +480,7 @@ public final class RealtimeChannelV2: Sendable {
     table: String? = nil,
     filter: String? = nil,
     callback: @escaping @Sendable (AnyAction) -> Void
-  ) -> Subscription {
+  ) -> RealtimeSubscription {
     _onPostgresChange(
       event: .all,
       schema: schema,
@@ -497,7 +498,7 @@ public final class RealtimeChannelV2: Sendable {
     table: String? = nil,
     filter: String? = nil,
     callback: @escaping @Sendable (InsertAction) -> Void
-  ) -> Subscription {
+  ) -> RealtimeSubscription {
     _onPostgresChange(
       event: .insert,
       schema: schema,
@@ -516,7 +517,7 @@ public final class RealtimeChannelV2: Sendable {
     table: String? = nil,
     filter: String? = nil,
     callback: @escaping @Sendable (UpdateAction) -> Void
-  ) -> Subscription {
+  ) -> RealtimeSubscription {
     _onPostgresChange(
       event: .update,
       schema: schema,
@@ -535,7 +536,7 @@ public final class RealtimeChannelV2: Sendable {
     table: String? = nil,
     filter: String? = nil,
     callback: @escaping @Sendable (DeleteAction) -> Void
-  ) -> Subscription {
+  ) -> RealtimeSubscription {
     _onPostgresChange(
       event: .delete,
       schema: schema,
@@ -553,7 +554,7 @@ public final class RealtimeChannelV2: Sendable {
     table: String?,
     filter: String?,
     callback: @escaping @Sendable (AnyAction) -> Void
-  ) -> Subscription {
+  ) -> RealtimeSubscription {
     precondition(
       status != .subscribed,
       "You cannot call postgresChange after joining the channel"
@@ -571,7 +572,7 @@ public final class RealtimeChannelV2: Sendable {
     }
 
     let id = callbackManager.addPostgresCallback(filter: config, callback: callback)
-    return Subscription { [weak callbackManager, logger] in
+    return RealtimeSubscription { [weak callbackManager, logger] in
       logger?.debug("Removing postgres callback with id: \(id)")
       callbackManager?.removeCallback(id: id)
     }
@@ -581,9 +582,9 @@ public final class RealtimeChannelV2: Sendable {
   public func onBroadcast(
     event: String,
     callback: @escaping @Sendable (JSONObject) -> Void
-  ) -> Subscription {
+  ) -> RealtimeSubscription {
     let id = callbackManager.addBroadcastCallback(event: event, callback: callback)
-    return Subscription { [weak callbackManager, logger] in
+    return RealtimeSubscription { [weak callbackManager, logger] in
       logger?.debug("Removing broadcast callback with id: \(id)")
       callbackManager?.removeCallback(id: id)
     }

diff --git a/Sources/Realtime/V2/RealtimeClientV2.swift b/Sources/Realtime/V2/RealtimeClientV2.swift
@@ -108,7 +108,7 @@ public final class RealtimeClientV2: Sendable {
   /// - Note: Use ``statusChange`` if you prefer to use Async/Await.
   public func onStatusChange(
     _ listener: @escaping @Sendable (Status) -> Void
-  ) -> ObservationToken {
+  ) -> RealtimeSubscription {
     statusEventEmitter.attach(listener)
   }