Add updatedAt to filter when fetching docs

lichess-org · Jun 21, 2024 · 477f321 · 477f321
1 parent 5bcbebf
commit 477f321
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/modules/ingestor/src/main/scala/cli.scala b/modules/ingestor/src/main/scala/cli.scala
@@ -12,7 +12,6 @@ import org.typelevel.log4cats.slf4j.Slf4jLogger
 
 import java.time.Instant
 
-// TODO: support flags: dry, verbose
 object cli
     extends CommandIOApp(
       name = "lila-search-cli",

diff --git a/modules/ingestor/src/main/scala/ingestor.forum.scala b/modules/ingestor/src/main/scala/ingestor.forum.scala
@@ -62,7 +62,9 @@ object ForumIngestor:
                 *> saveLastIndexedTimestamp(lastEventTimestamp.getOrElse(Instant.now()))
 
     def run(since: Instant, until: Option[Instant], dryRun: Boolean): fs2.Stream[IO, Unit] =
-      val filter = range("createdAt")(since, until).or(range("erasedAt")(since, until))
+      val filter = range("createdAt")(since, until)
+        .or(range("updatedAt")(since, until))
+        .or(range("erasedAt")(since, until))
       posts
         .find(filter)
         .projection(postProjection)