auto process line flags report after a timeout

lichess-org · Feb 6, 2025 · 295cb65 · 295cb65
1 parent 18cc16c
commit 295cb65
Show file tree

Hide file tree

Showing 3 changed files with 23 additions and 10 deletions.
diff --git a/modules/core/src/main/security.scala b/modules/core/src/main/security.scala
@@ -7,11 +7,11 @@ import play.api.mvc.RequestHeader
 import lila.core.email.EmailAddress
 import lila.core.net.IpAddress
 import lila.core.user.User
-import lila.core.userId.{ UserId, UserName }
+import lila.core.userId.{ UserId, UserName, MyId }
 
 case class GarbageCollect(userId: UserId)
 case class CloseAccount(userId: UserId)
-case class DeletePublicChats(userId: UserId)
+case class DeletePublicChats(userId: UserId)(using val me: MyId)
 
 trait LilaCookie:
   import play.api.mvc.*

diff --git a/modules/mod/src/main/Env.scala b/modules/mod/src/main/Env.scala
@@ -97,8 +97,9 @@ final class Env(
     "analysisReady" -> { case lila.analyse.actorApi.AnalysisReady(game, analysis) =>
       assessApi.onAnalysisReady(game, analysis)
     },
-    "deletePublicChats" -> { case lila.core.security.DeletePublicChats(userId) =>
-      publicChat.deleteAll(userId)
+    "deletePublicChats" -> { case d: lila.core.security.DeletePublicChats =>
+      publicChat.deleteAll(d.userId)
+      reportApi.autoProcessRecentChatFlags(SuspectId(d.userId))(using d.me)
     },
     "autoWarning" -> { case lila.core.mod.AutoWarning(userId, subject) =>
       logApi.modMessage(userId, subject)(using UserId.lichessAsMe)

diff --git a/modules/report/src/main/ReportApi.scala b/modules/report/src/main/ReportApi.scala
@@ -283,9 +283,7 @@ final class ReportApi(
     deletedAppeal <- deleteIfAppealInquiry(report)
     _ <- (!deletedAppeal).so:
       doProcessReport($id(report.id), unsetInquiry = true)
-  yield
-    maxScoreCache.invalidateUnit()
-    lila.mon.mod.report.close.increment()
+  yield onReportClose()
 
   def autoProcess(sus: Suspect, rooms: Set[Room])(using MyId): Funit =
     val selector = $doc(
@@ -294,9 +292,23 @@ final class ReportApi(
       "open" -> true
     )
     for _ <- doProcessReport(selector, unsetInquiry = true)
-    yield
-      maxScoreCache.invalidateUnit()
-      lila.mon.mod.report.close.increment()
+    yield onReportClose()
+
+  def autoProcessRecentChatFlags(sus: SuspectId)(using MyId): Funit = for
+    opt <- coll.one[Report]:
+      $doc(
+        "user" -> sus.value,
+        "room" -> Room.Comm,
+        "open" -> true
+      )
+    rep = opt.filter(_.atoms.toList.forall(_.isFlag))
+    _ <- rep.so: r =>
+      doProcessReport($id(r.id), unsetInquiry = true)
+  yield if rep.isDefined then onReportClose()
+
+  private def onReportClose() =
+    maxScoreCache.invalidateUnit()
+    lila.mon.mod.report.close.increment()
 
   private def deleteIfAppealInquiry(report: Report)(using me: MyId): Fu[Boolean] =
     if report.isAppealInquiryByMe