diff --git a/modules/ingestor/src/main/scala/cli.scala b/modules/ingestor/src/main/scala/cli.scala index 10eaf4b4..b929877f 100644 --- 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 index 970fb5a1..77ff163b 100644 --- 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)