From f903bfdc6e4e0309e7215ec2b16896280819b881 Mon Sep 17 00:00:00 2001
From: cssxsh <cssxsh@gmail.com>
Date: Fri, 24 Feb 2023 17:59:41 +0800
Subject: [PATCH] fix: announce unread

---
 .../contact/announcement/AnnouncementsImpl.kt | 35 ++++++++++++++++---
 1 file changed, 30 insertions(+), 5 deletions(-)

diff --git a/mirai-core/src/commonMain/kotlin/contact/announcement/AnnouncementsImpl.kt b/mirai-core/src/commonMain/kotlin/contact/announcement/AnnouncementsImpl.kt
index dea6f0c09f3..9118bddfe91 100644
--- a/mirai-core/src/commonMain/kotlin/contact/announcement/AnnouncementsImpl.kt
+++ b/mirai-core/src/commonMain/kotlin/contact/announcement/AnnouncementsImpl.kt
@@ -148,8 +148,27 @@ internal abstract class CommonAnnouncementsImpl(
 
     override suspend fun members(fid: String, confirmed: Boolean): List<NormalMember> {
         group.checkBotPermission(MemberPermission.ADMINISTRATOR) { "Only administrator have permission see announcement confirmed detail" }
-        val detail = bot.getReadDetail(groupId = group.id, fid = fid, read = confirmed)
-        return detail.users.mapNotNull { user -> group[user.uin] }
+        val flow = flow<NormalMember> {
+            var offset = 0
+            while (true) {
+                val detail = bot.getReadDetail(
+                    groupId = group.id,
+                    fid = fid,
+                    read = confirmed,
+                    offset = offset,
+                    limit = 50
+                )
+                if (detail.users.isEmpty()) break
+                for (user in detail.users) {
+                    val member = group[user.uin] ?: continue
+                    emit(member)
+                }
+                offset += detail.users.size
+                val target = if (confirmed) detail.readTotal else detail.unreadTotal
+                if (offset == target) break
+            }
+        }
+        return flow.toList()
     }
 
     override suspend fun remind(fid: String) {
@@ -318,12 +337,18 @@ internal object AnnouncementProtocol {
     private fun <T> CgiData.loadData(serializer: KSerializer<T>): T =
         defaultJson.decodeFromJsonElement(serializer, this.data)
 
-    suspend fun QQAndroidBot.getReadDetail(groupId: Long, fid: String, read: Boolean): GroupAnnouncementReadDetail {
+    suspend fun QQAndroidBot.getReadDetail(
+        groupId: Long,
+        fid: String,
+        read: Boolean,
+        offset: Int,
+        limit: Int
+    ): GroupAnnouncementReadDetail {
         val cgi = bot.components[HttpClientProvider].getHttpClient().post {
             url("https://qun.qq.com/cgi-bin/qunapp/announce_unread")
             parameter("gc", groupId)
-            parameter("start", 0)
-            parameter("num", 3000)
+            parameter("start", offset)
+            parameter("num", limit)
             parameter("feed_id", fid)
             parameter("type", if (read) 1 else 0)
             parameter("bkn", client.wLoginSigInfo.bkn)