Merge pull request #300 from lichess-org/index-forums-with-update-event

Index forum posts in update events

modules/ingestor/src/main/scala/ingestor.forum.scala

@@ -3,6 +3,7 @@ package ingestor
 
 import cats.effect.IO
 import cats.syntax.all.*
+import com.mongodb.client.model.changestream.FullDocument
 import com.mongodb.client.model.changestream.OperationType.*
 import lila.search.spec.ForumSource
 import mongo4cats.bson.Document
@@ -25,7 +26,7 @@ object ForumIngestor:
 
   private val index = Index.Forum
 
-  private val interestedOperations = List(DELETE, INSERT, REPLACE).map(_.getValue)
+  private val interestedOperations = List(DELETE, INSERT, REPLACE, UPDATE).map(_.getValue)
 
   private def maxPostSizeFilter(max: Int) =
     Filter.expr(s"{ $$lte: [{ $$strLenCP: '$$fullDocument.text' }, $max] }")
@@ -117,6 +118,7 @@ object ForumIngestor:
       val skip = since.fold(0)(_ => 1)
       since
         .fold(builder)(x => builder.startAtOperationTime(x.asBsonTimestamp))
+        .fullDocument(FullDocument.UPDATE_LOOKUP) // this is required for update event
         .batchSize(config.batchSize)
         .boundedStream(config.batchSize)
         .drop(skip)