fix(realtime): make realtime default to MainActor

Author: grdsdev

Sources/Realtime/RealtimeChannelV2.swift

@@ -24,32 +24,33 @@ public struct RealtimeChannelConfig: Sendable {
   public var isPrivate: Bool
 }
 
-protocol RealtimeChannelProtocol: AnyObject, Sendable {
-  @MainActor var config: RealtimeChannelConfig { get }
+@MainActor
+protocol RealtimeChannelProtocol: AnyObject {
+  var config: RealtimeChannelConfig { get }
   var topic: String { get }
   var logger: (any SupabaseLogger)? { get }
 
   var socket: any RealtimeClientProtocol { get }
 }
 
+@MainActor
 public final class RealtimeChannelV2: Sendable, RealtimeChannelProtocol {
   struct MutableState {
     var clientChanges: [PostgresJoinConfig] = []
     var joinRef: String?
     var pushes: [String: PushV2] = [:]
   }
 
-  @MainActor
   private var mutableState = MutableState()
 
   let topic: String
 
-  @MainActor var config: RealtimeChannelConfig
+  var config: RealtimeChannelConfig
 
   let logger: (any SupabaseLogger)?
   let socket: any RealtimeClientProtocol
 
-  @MainActor var joinRef: String? { mutableState.joinRef }
+  var joinRef: String? { mutableState.joinRef }
 
   let callbackManager = CallbackManager()
   private let statusSubject = AsyncValueSubject<RealtimeChannelStatus>(.unsubscribed)
@@ -162,13 +163,6 @@ public final class RealtimeChannelV2: Sendable, RealtimeChannelProtocol {
     throw RealtimeError.maxRetryAttemptsReached
   }
 
-  /// Subscribes to the channel.
-  @available(*, deprecated, message: "Use `subscribeWithError` instead")
-  @MainActor
-  public func subscribe() async {
-    try? await subscribeWithError()
-  }
-
   /// Calculates retry delay with exponential backoff and jitter
   private func calculateRetryDelay(for attempt: Int) -> TimeInterval {
     let baseDelay: TimeInterval = 1.0
@@ -186,7 +180,6 @@ public final class RealtimeChannelV2: Sendable, RealtimeChannelProtocol {
   }
 
   /// Subscribes to the channel
-  @MainActor
   private func _subscribe() async {
     if socket.status != .connected {
       if socket.options.connectOnSubscribe != true {
@@ -236,20 +229,6 @@ public final class RealtimeChannelV2: Sendable, RealtimeChannelProtocol {
     await push(ChannelEvent.leave)
   }
 
-  @available(
-    *,
-    deprecated,
-    message:
-      "manually updating auth token per channel is not recommended, please use `setAuth` in RealtimeClient instead."
-  )
-  public func updateAuth(jwt: String?) async {
-    logger?.debug("Updating auth token for channel \(topic)")
-    await push(
-      ChannelEvent.accessToken,
-      payload: ["access_token": jwt.map { .string($0) } ?? .null]
-    )
-  }
-
   /// Sends a broadcast message explicitly via REST API.
   ///
   /// This method always uses the REST API endpoint regardless of WebSocket connection state.
@@ -295,7 +274,7 @@ public final class RealtimeChannelV2: Sendable, RealtimeChannelProtocol {
     }
     headers[.authorization] = "Bearer \(accessToken)"
 
-    let body = try await JSONEncoder.supabase().encode(
+    let body = try JSONEncoder.supabase().encode(
       BroadcastMessagePayload(
         messages: [
           BroadcastMessagePayload.Message(
@@ -317,7 +296,7 @@ public final class RealtimeChannelV2: Sendable, RealtimeChannelProtocol {
 
     let response = try await withTimeout(interval: timeout ?? socket.options.timeoutInterval) {
       [self] in
-      await Result {
+      await Result { @Sendable in
         try await socket.http.send(request)
       }
     }.get()
@@ -475,7 +454,7 @@ public final class RealtimeChannelV2: Sendable, RealtimeChannelProtocol {
           throw RealtimeError("Received a reply with unexpected payload: \(message)")
         }
 
-        await didReceiveReply(ref: ref, status: status)
+        didReceiveReply(ref: ref, status: status)
 
         if message.payload["response"]?.objectValue?.keys
           .contains(ChannelEvent.postgresChanges) == true
@@ -692,9 +671,7 @@ public final class RealtimeChannelV2: Sendable, RealtimeChannelProtocol {
       filter: filter
     )
 
-    Task { @MainActor in
-      mutableState.clientChanges.append(config)
-    }
+    mutableState.clientChanges.append(config)
 
     let id = callbackManager.addPostgresCallback(filter: config, callback: callback)
     return RealtimeSubscription { [weak callbackManager, logger] in
@@ -733,7 +710,6 @@ public final class RealtimeChannelV2: Sendable, RealtimeChannelProtocol {
     self.onSystem { _ in callback() }
   }
 
-  @MainActor
   @discardableResult
   func push(_ event: String, ref: String? = nil, payload: JSONObject = [:]) async -> PushStatus {
     let message = RealtimeMessageV2(
@@ -752,7 +728,6 @@ public final class RealtimeChannelV2: Sendable, RealtimeChannelProtocol {
     return await push.send()
   }
 
-  @MainActor
   private func didReceiveReply(ref: String, status: String) {
     let push = mutableState.pushes.removeValue(forKey: ref)
     push?.didReceive(status: PushStatus(rawValue: status) ?? .ok)