Update Tests

Author: LucasAbijmil

Sources/Realtime/RealtimeChannel+AsyncAwait.swift

@@ -28,7 +28,7 @@ extension RealtimeChannelV2 {
     _: InsertAction.Type,
     schema: String = "public",
     table: String? = nil,
-    filter: RealtimeFilter? = nil
+    filter: RealtimePostgresFilter? = nil
   ) -> AsyncStream<InsertAction> {
     postgresChange(event: .insert, schema: schema, table: table, filter: filter?.value)
       .compactErase()
@@ -56,7 +56,7 @@ extension RealtimeChannelV2 {
     _: UpdateAction.Type,
     schema: String = "public",
     table: String? = nil,
-    filter: RealtimeFilter? = nil
+    filter: RealtimePostgresFilter? = nil
   ) -> AsyncStream<UpdateAction> {
     postgresChange(event: .update, schema: schema, table: table, filter: filter?.value)
       .compactErase()
@@ -84,7 +84,7 @@ extension RealtimeChannelV2 {
     _: DeleteAction.Type,
     schema: String = "public",
     table: String? = nil,
-    filter: RealtimeFilter? = nil
+    filter: RealtimePostgresFilter? = nil
   ) -> AsyncStream<DeleteAction> {
     postgresChange(event: .delete, schema: schema, table: table, filter: filter?.value)
       .compactErase()
@@ -112,7 +112,7 @@ extension RealtimeChannelV2 {
     _: AnyAction.Type,
     schema: String = "public",
     table: String? = nil,
-    filter: RealtimeFilter? = nil
+    filter: RealtimePostgresFilter? = nil
   ) -> AsyncStream<AnyAction> {
     postgresChange(event: .all, schema: schema, table: table, filter: filter?.value)
   }

Sources/Realtime/RealtimePostgresFilter.swift

@@ -30,7 +30,7 @@ public enum RealtimePostgresFilter {
     case let .lte(column, value):
       return "\(column)=lte.\(value.rawValue)"
     case let .in(column, values):
-      return "\(column)=in.(\(values.map(\.rawValue)))"
+      return "\(column)=in.(\(values.map(\.rawValue).joined(separator: ",")))"
     }
   }
 }

Tests/RealtimeTests/RealtimePostgresFilterTests.swift

@@ -0,0 +1,68 @@
+//
+//  RealtimePostgresFilterTests.swift
+//  Supabase
+//
+//  Created by Lucas Abijmil on 20/02/2025.
+//
+
+import XCTest
+@testable import Realtime
+
+final class RealtimePostgresFilterTests: XCTestCase {
+
+  func testEq() {
+    let value = "value"
+    let column = "column"
+    let filter: RealtimePostgresFilter = .eq(column, value: value)
+
+    XCTAssertEqual(filter.value, "column=eq.value")
+  }
+
+  func testNeq() {
+    let value = "value"
+    let column = "column"
+    let filter: RealtimePostgresFilter = .neq(column, value: value)
+
+    XCTAssertEqual(filter.value, "column=neq.value")
+  }
+
+  func testGt() {
+    let value = "value"
+    let column = "column"
+    let filter: RealtimePostgresFilter = .gt(column, value: value)
+
+    XCTAssertEqual(filter.value, "column=gt.value")
+  }
+
+  func testGte() {
+    let value = "value"
+    let column = "column"
+    let filter: RealtimePostgresFilter = .gte(column, value: value)
+
+    XCTAssertEqual(filter.value, "column=gte.value")
+  }
+
+  func testLt() {
+    let value = "value"
+    let column = "column"
+    let filter: RealtimePostgresFilter = .lt(column, value: value)
+
+    XCTAssertEqual(filter.value, "column=lt.value")
+  }
+
+  func testLte() {
+    let value = "value"
+    let column = "column"
+    let filter: RealtimePostgresFilter = .lte(column, value: value)
+
+    XCTAssertEqual(filter.value, "column=lte.value")
+  }
+
+  func testIn() {
+    let values = ["value1", "value2"]
+    let column = "column"
+    let filter: RealtimePostgresFilter = .in(column, values: values)
+
+    XCTAssertEqual(filter.value, "column=in.(value1,value2)")
+  }
+}

Tests/RealtimeTests/RealtimeFilterValueTests.swift renamed to Tests/RealtimeTests/RealtimePostgresFilterValueTests.swift

@@ -1,5 +1,5 @@
 //
-//  RealtimeFilterValueTests.swift
+//  RealtimePostgresFilterValueTests.swift
 //  Supabase
 //
 //  Created by Lucas Abijmil on 19/02/2025.
@@ -8,7 +8,7 @@
 import XCTest
 @testable import Realtime
 
-final class RealtimeFilterValueTests: XCTestCase {
+final class RealtimePostgresFilterValueTests: XCTestCase {
   func testUUID() {
     XCTAssertEqual(
       UUID(uuidString: "E621E1F8-C36C-495A-93FC-0C247A3E6E5F")!.rawValue,
@@ -21,8 +21,4 @@ final class RealtimeFilterValueTests: XCTestCase {
       "2025-01-21T13:26:25.000Z"
     )
   }
-
-  func testArray() {
-    XCTAssertEqual(["a", "b", "c"].rawValue, "a,b,c")
-  }
 }