fix linux build

supabase · Jan 17, 2025 · b63bd61 · b63bd61
1 parent d800a95
commit b63bd61
Show file tree

Hide file tree

Showing 3 changed files with 27 additions and 11 deletions.
diff --git a/Package.swift b/Package.swift
@@ -99,7 +99,10 @@ let package = Package(
         "Supabase",
         "TestHelpers",
       ],
-      resources: [.process("Fixtures")]
+      resources: [
+        .process("Fixtures"),
+        .process("supabase"),
+      ]
     ),
     .target(
       name: "PostgREST",
@@ -149,6 +152,9 @@ let package = Package(
         .product(name: "InlineSnapshotTesting", package: "swift-snapshot-testing"),
         .product(name: "XCTestDynamicOverlay", package: "xctest-dynamic-overlay"),
         "Storage",
+      ],
+      resources: [
+        .copy("sadcat.jpg")
       ]
     ),
     .target(

diff --git a/Sources/Realtime/WebSocket/URLSessionWebSocket.swift b/Sources/Realtime/WebSocket/URLSessionWebSocket.swift
@@ -130,10 +130,11 @@ final class URLSessionWebSocket: WebSocket {
   }
 
   private func _scheduleReceive() {
-    _task.receive { [weak self] result in
+    Task {
+      let result = await Result { try await _task.receive() }
       switch result {
-      case .success(let value): self?._handleMessage(value)
-      case .failure(let error): self?._closeConnectionWithError(error)
+      case .success(let value): _handleMessage(value)
+      case .failure(let error): _closeConnectionWithError(error)
       }
     }
   }
@@ -168,9 +169,11 @@ final class URLSessionWebSocket: WebSocket {
       return
     }
 
-    _task.send(.string(text)) { [weak self] error in
-      if let error {
-        self?._closeConnectionWithError(error)
+    Task {
+      do {
+        try await _task.send(.string(text))
+      } catch {
+        _closeConnectionWithError(error)
       }
     }
   }
@@ -198,9 +201,11 @@ final class URLSessionWebSocket: WebSocket {
       return
     }
 
-    _task.send(.data(binary)) { [weak self] error in
-      if let error {
-        self?._closeConnectionWithError(error)
+    Task {
+      do {
+        try await _task.send(.data(binary))
+      } catch {
+        _closeConnectionWithError(error)
       }
     }
   }

diff --git a/Tests/IntegrationTests/RealtimeIntegrationTests.swift b/Tests/IntegrationTests/RealtimeIntegrationTests.swift
@@ -30,7 +30,12 @@ final class RealtimeIntegrationTests: XCTestCase {
 
   let client = SupabaseClient(
     supabaseURL: URL(string: DotEnv.SUPABASE_URL)!,
-    supabaseKey: DotEnv.SUPABASE_ANON_KEY
+    supabaseKey: DotEnv.SUPABASE_ANON_KEY,
+    options: SupabaseClientOptions(
+      auth: SupabaseClientOptions.AuthOptions(
+        storage: InMemoryLocalStorage()
+      )
+    )
   )
 
   override func setUp() {