Merge pull request #303 from gravetii/refactor-unique-method

Refactor unique method to use exists without empty string
lichess-org · Sep 8, 2024 · 5f292da · 5f292da
2 parents 2f9a2c9 + 63106dc
commit 5f292da
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/modules/ingestor/src/main/scala/package.scala b/modules/ingestor/src/main/scala/package.scala
@@ -32,8 +32,7 @@ extension [A](changes: List[ChangeStreamDocument[A]])
   def unique: List[ChangeStreamDocument[A]] =
     changes
       .foldRight(List.empty[ChangeStreamDocument[A]] -> Set.empty) { case (change, p @ (acc, ids)) =>
-        val id = change.docId.getOrElse("")
-        if !ids.contains(id) && id != ""
+        if change.docId.exists(ids.contains)
         then (change :: acc) -> (ids + id)
         else p
       }