fix(realtime): make Apikey required (#760)

Author: grdsdev

Sources/Realtime/RealtimeChannelV2.swift

@@ -499,7 +499,7 @@ public final class RealtimeChannelV2: Sendable, RealtimeChannelProtocol {
       )
       Task {
         await unsubscribe()
-        await subscribe()
+        try? await subscribeWithError()
       }
     }
 

Sources/Realtime/RealtimeClientV2.swift

@@ -53,7 +53,7 @@ public final class RealtimeClientV2: Sendable, RealtimeClientProtocol {
   let wsTransport: WebSocketTransport
   let mutableState = LockIsolated(MutableState())
   let http: any HTTPClientType
-  let apikey: String?
+  let apikey: String
 
   var conn: (any WebSocket)? {
     mutableState.conn
@@ -157,13 +157,13 @@ public final class RealtimeClientV2: Sendable, RealtimeClientProtocol {
     self.options = options
     self.wsTransport = wsTransport
     self.http = http
-    apikey = options.apikey
+
+    precondition(options.apikey != nil, "API key is required to connect to Realtime")
+    apikey = options.apikey!
 
     mutableState.withValue { [options] in
       if let accessToken = options.headers[.authorization]?.split(separator: " ").last {
         $0.accessToken = String(accessToken)
-      } else {
-        $0.accessToken = options.apikey
       }
     }
   }
@@ -360,7 +360,7 @@ public final class RealtimeClientV2: Sendable, RealtimeClientProtocol {
   private func rejoinChannels() {
     Task {
       for channel in channels.values {
-        await channel.subscribe()
+        try? await channel.subscribeWithError()
       }
     }
   }

Tests/RealtimeTests/RealtimeChannelTests.swift

@@ -22,7 +22,7 @@ final class RealtimeChannelTests: XCTestCase {
     ),
     socket: RealtimeClientV2(
       url: URL(string: "https://localhost:54321/realtime/v1")!,
-      options: RealtimeClientOptions()
+      options: RealtimeClientOptions(headers: ["apikey": "test-key"])
     ),
     logger: nil
   )
@@ -161,8 +161,8 @@ final class RealtimeChannelTests: XCTestCase {
     XCTAssertTrue(channel.callbackManager.callbacks.contains(where: { $0.isPresence }))
 
     // Start subscription process
-    let subscribeTask = Task {
-      await channel.subscribe()
+    Task {
+      try? await channel.subscribeWithError()
     }
 
     // Wait for the join message to be sent