mod: requery dm

Signed-off-by: bggRGjQaUbCoE <githubaccount56556@proton.me>
This commit is contained in:
bggRGjQaUbCoE
2025-03-06 16:27:51 +08:00
parent 64f37fa743
commit 3048e36d2f

View File

@@ -9,12 +9,23 @@ class DanmakuHttp {
required int cid, required int cid,
required int segmentIndex, required int segmentIndex,
required bool mergeDanmaku, required bool mergeDanmaku,
int queryCount = 1,
}) async { }) async {
// 构建参数对象 // 构建参数对象
final response = final response =
await GrpcRepo.dmSegMobile(cid: cid, segmentIndex: segmentIndex); await GrpcRepo.dmSegMobile(cid: cid, segmentIndex: segmentIndex);
if (!response['status']) { if (!response['status']) {
return DmSegMobileReply(); if (queryCount >= 3) {
return DmSegMobileReply();
} else {
await Future.delayed(const Duration(seconds: 1));
return await queryDanmaku(
cid: cid,
segmentIndex: segmentIndex,
mergeDanmaku: mergeDanmaku,
queryCount: ++queryCount,
);
}
} }
DmSegMobileReply data = response['data']; DmSegMobileReply data = response['data'];
if (mergeDanmaku && data.elems.isNotEmpty) { if (mergeDanmaku && data.elems.isNotEmpty) {