feat: session secondary

Closes #837

Signed-off-by: bggRGjQaUbCoE <githubaccount56556@proton.me>

lib/grpc/reply.dart

@@ -0,0 +1,189 @@
+import 'package:PiliPlus/common/constants.dart';
+import 'package:PiliPlus/grpc/bilibili/main/community/reply/v1.pb.dart';
+import 'package:PiliPlus/grpc/bilibili/pagination.pb.dart';
+import 'package:PiliPlus/grpc/grpc_repo.dart';
+import 'package:PiliPlus/http/loading_state.dart';
+import 'package:PiliPlus/http/reply.dart';
+import 'package:fixnum/fixnum.dart';
+
+class ReplyGrpc {
+  // static Future replyInfo({required int rpid}) {
+  //   return _request(
+  //     GrpcUrl.replyInfo,
+  //     ReplyInfoReq(rpid: Int64(rpid)),
+  //     ReplyInfoReply.fromBuffer,
+  //     onSuccess: (response) => response.reply,
+  //   );
+  // }
+
+  // ref BiliRoamingX
+  static bool needRemoveGrpc(ReplyInfo reply) {
+    if ((reply.content.urls.isNotEmpty &&
+            reply.content.urls.values.any((url) {
+              return url.hasExtra() &&
+                  (url.extra.goodsCmControl == 1 ||
+                      url.extra.goodsItemId != 0 ||
+                      url.extra.goodsPrefetchedCache.isNotEmpty);
+            })) ||
+        reply.content.message.contains(Constants.goodsUrlPrefix)) {
+      return true;
+    }
+    return false;
+  }
+
+  static Future<LoadingState<MainListReply>> mainList({
+    int type = 1,
+    required int oid,
+    required Mode mode,
+    required String? offset,
+    required Int64? cursorNext,
+    required bool antiGoodsReply,
+  }) async {
+    dynamic res = await GrpcRepo.request(
+      GrpcUrl.mainList,
+      MainListReq(
+        oid: Int64(oid),
+        type: Int64(type),
+        rpid: Int64(0),
+        cursor: CursorReq(
+          mode: mode,
+          next: cursorNext,
+        ),
+        // pagination: FeedPagination(offset: offset ?? ''),
+      ),
+      MainListReply.fromBuffer,
+    );
+    if (res['status']) {
+      MainListReply mainListReply = res['data'];
+      // keyword filter
+      if (ReplyHttp.replyRegExp.pattern.isNotEmpty) {
+        // upTop
+        if (mainListReply.hasUpTop() &&
+            ReplyHttp.replyRegExp
+                .hasMatch(mainListReply.upTop.content.message)) {
+          mainListReply.clearUpTop();
+        }
+
+        // replies
+        if (mainListReply.replies.isNotEmpty) {
+          mainListReply.replies.removeWhere((item) {
+            bool hasMatch =
+                ReplyHttp.replyRegExp.hasMatch(item.content.message);
+            // remove subreplies
+            if (!hasMatch) {
+              if (item.replies.isNotEmpty) {
+                item.replies.removeWhere((item) =>
+                    ReplyHttp.replyRegExp.hasMatch(item.content.message));
+              }
+            }
+            return hasMatch;
+          });
+        }
+      }
+
+      // antiGoodsReply
+      if (antiGoodsReply) {
+        // upTop
+        if (mainListReply.hasUpTop() && needRemoveGrpc(mainListReply.upTop)) {
+          mainListReply.clearUpTop();
+        }
+
+        // replies
+        if (mainListReply.replies.isNotEmpty) {
+          mainListReply.replies.removeWhere((item) {
+            bool hasMatch = needRemoveGrpc(item);
+            // remove subreplies
+            if (!hasMatch) {
+              if (item.replies.isNotEmpty) {
+                item.replies.removeWhere(needRemoveGrpc);
+              }
+            }
+            return hasMatch;
+          });
+        }
+      }
+      return LoadingState.success(mainListReply);
+    } else {
+      return LoadingState.error(res['msg']);
+    }
+  }
+
+  static Future<LoadingState<DetailListReply>> detailList({
+    int type = 1,
+    required int oid,
+    required int root,
+    required int rpid,
+    required Mode mode,
+    required String? offset,
+    required bool antiGoodsReply,
+  }) async {
+    dynamic res = await GrpcRepo.request(
+      GrpcUrl.detailList,
+      DetailListReq(
+        oid: Int64(oid),
+        type: Int64(type),
+        root: Int64(root),
+        rpid: Int64(rpid),
+        scene: DetailListScene.REPLY,
+        mode: mode,
+        pagination: FeedPagination(offset: offset ?? ''),
+      ),
+      DetailListReply.fromBuffer,
+    );
+    if (res['status']) {
+      DetailListReply detailListReply = res['data'];
+      if (ReplyHttp.replyRegExp.pattern.isNotEmpty) {
+        if (detailListReply.root.replies.isNotEmpty) {
+          detailListReply.root.replies.removeWhere(
+              (item) => ReplyHttp.replyRegExp.hasMatch(item.content.message));
+        }
+      }
+      if (antiGoodsReply) {
+        if (detailListReply.root.replies.isNotEmpty) {
+          detailListReply.root.replies.removeWhere(needRemoveGrpc);
+        }
+      }
+      return LoadingState.success(detailListReply);
+    } else {
+      return LoadingState.error(res['msg']);
+    }
+  }
+
+  static Future<LoadingState<DialogListReply>> dialogList({
+    int type = 1,
+    required int oid,
+    required int root,
+    required int dialog,
+    required String? offset,
+    required bool antiGoodsReply,
+  }) async {
+    dynamic res = await GrpcRepo.request(
+      GrpcUrl.dialogList,
+      DialogListReq(
+        oid: Int64(oid),
+        type: Int64(type),
+        root: Int64(root),
+        dialog: Int64(dialog),
+        pagination: FeedPagination(offset: offset ?? ''),
+      ),
+      DialogListReply.fromBuffer,
+    );
+    if (res['status']) {
+      DialogListReply dialogListReply = res['data'];
+      if (ReplyHttp.replyRegExp.pattern.isNotEmpty) {
+        if (dialogListReply.replies.isNotEmpty) {
+          dialogListReply.replies.removeWhere(
+              (item) => ReplyHttp.replyRegExp.hasMatch(item.content.message));
+        }
+      }
+      if (antiGoodsReply) {
+        if (dialogListReply.replies.isNotEmpty) {
+          dialogListReply.replies.removeWhere(needRemoveGrpc);
+        }
+      }
+      return LoadingState.success(dialogListReply);
+    } else {
+      return LoadingState.error(res['msg']);
+    }
+  }
+}