Add forum integration test

lichess-org · Jun 5, 2024 · 9a73460 · 9a73460
1 parent d249a5d
commit 9a73460
Show file tree

Hide file tree

Showing 2 changed files with 29 additions and 7 deletions.
diff --git a/modules/app/src/test/scala/IntegrationSuite.scala b/modules/app/src/test/scala/IntegrationSuite.scala
@@ -3,11 +3,13 @@ package app
 package test
 
 import cats.effect.{ IO, Resource }
+import cats.syntax.all.*
 import com.comcast.ip4s.*
-import lila.search.spec.{ ElasticStatus, HealthCheckOutput }
+import lila.search.spec.*
 import org.http4s.Uri
 import org.typelevel.log4cats.Logger
 import org.typelevel.log4cats.noop.NoOpLogger
+import smithy4s.Timestamp
 import weaver.*
 
 object IntegrationSuite extends IOSuite:
@@ -38,3 +40,27 @@ object IntegrationSuite extends IOSuite:
       .use:
         _.healthCheck()
           .map(expect.same(_, HealthCheckOutput(ElasticStatus.green)))
+
+  test("forum"): _ =>
+    Clients
+      .search(uri)
+      .use: service =>
+        for
+          _ <- service.mapping(lila.search.spec.Index.Forum)
+          _ <- service
+            .store(
+              "forum_id",
+              Source.forum(
+                ForumSource(
+                  body = "a forum post",
+                  topic = "chess",
+                  topicId = "chess",
+                  troll = false,
+                  date = Timestamp(2021, 1, 1, 0, 0, 0),
+                  author = "nt9".some
+                )
+              )
+            )
+          _ <- service.refresh(Index.Forum)
+          x <- service.search(Query.forum("chess", false), 0, 12)
+        yield expect(x.hitIds.size == 1)
diff --git a/modules/core/src/main/scala/ESClient.scala b/modules/core/src/main/scala/ESClient.scala
@@ -95,9 +95,7 @@ object ESClient:
       dropIndex(index) >> client
         .execute {
           createIndex(index.name)
-            .mapping(
-              properties(fields).source(false) // all false
-            )
+            .mapping(properties(fields).source(false)) // all false
             .shards(5)
             .replicas(0)
             .refreshInterval(Which.refreshInterval(index))
@@ -110,6 +108,4 @@ object ESClient:
         .flatMap(unitOrFail)
 
     private def dropIndex(index: Index) =
-      client
-        .execute(deleteIndex(index.name))
-        .flatMap(unitOrFail)
+      client.execute(deleteIndex(index.name))