PiliPlus/lib/grpc/grpc_repo.dart

import 'dart:convert';

import 'package:PiliPalaX/common/constants.dart';
import 'package:PiliPalaX/grpc/app/dynamic/v2/dynamic.pb.dart';
import 'package:PiliPalaX/grpc/app/main/community/reply/v1/reply.pb.dart';
import 'package:PiliPalaX/grpc/app/playeronline/v1/playeronline.pbgrpc.dart';
import 'package:PiliPalaX/grpc/app/show/popular/v1/popular.pb.dart';
import 'package:PiliPalaX/grpc/device/device.pb.dart';
import 'package:PiliPalaX/grpc/fawkes/fawkes.pb.dart';
import 'package:PiliPalaX/grpc/grpc_client.dart';
import 'package:PiliPalaX/grpc/locale/locale.pb.dart';
import 'package:PiliPalaX/grpc/metadata/metadata.pb.dart';
import 'package:PiliPalaX/grpc/network/network.pb.dart' as network;
import 'package:PiliPalaX/grpc/restriction/restriction.pb.dart';
import 'package:PiliPalaX/utils/login.dart';
import 'package:PiliPalaX/utils/storage.dart';
import 'package:PiliPalaX/utils/utils.dart';
import 'package:fixnum/src/int64.dart';
import 'package:flutter/material.dart';
import 'package:grpc/grpc.dart';

class GrpcRepo {
  static final bool _isLogin = GStorage.userInfo.get('userInfoCache') != null;
  static final int? _mid = GStorage.userInfo.get('userInfoCache')?.mid;
  static final String? _accessKey = GStorage.localCache
      .get(LocalCacheKey.accessKey, defaultValue: {})['value'];
  static const _build = 1462100;
  static const _biliChannel = 'bili';
  static const _mobiApp = 'android_hd';
  static const _phone = 'phone';

  static final _eId = _isLogin ? Utils.genAuroraEid(_mid!) : '';
  static final _buvid = LoginUtils.buvid();
  static final _traceId = Utils.genTraceId();
  static final _sessionId = Utils.generateRandomString(8);

  static final Map<String, String> metadata = {
    'user-agent': '${Constants.userAgent} grpc-java-cronet/1.36.1',
    'x-bili-gaia-vtoken': '',
    'x-bili-aurora-eid': _isLogin ? _eId : '',
    'x-bili-mid': _isLogin ? _mid.toString() : '0',
    'x-bili-aurora-zone': '',
    'x-bili-trace-id': _traceId,
    if (_isLogin) 'authorization': 'identify_v1 $_accessKey',
    'buvid': _buvid,
    'bili-http-engine': 'cronet',
    'te': 'trailers',
    'x-bili-fawkes-req-bin': base64Encode((FawkesReq()
          ..appkey = _mobiApp
          ..env = 'prod'
          ..sessionId = _sessionId)
        .writeToBuffer()),
    'x-bili-metadata-bin': base64Encode((Metadata()
          ..accessKey = _accessKey ?? ''
          ..mobiApp = _mobiApp
          ..device = _phone
          ..build = _build
          ..channel = _biliChannel
          ..buvid = _buvid
          ..platform = _mobiApp)
        .writeToBuffer()),
    'x-bili-device-bin': base64Encode((Device()
          ..appId = 1
          ..build = _build
          ..buvid = _buvid
          ..mobiApp = _mobiApp
          ..platform = _mobiApp
          ..device = _phone
          ..channel = _biliChannel
          ..brand = _phone
          ..model = _phone
          ..osver = '14'
          ..fpLocal = ''
          ..fpRemote = ''
          ..versionName = _build.toString()
          ..fp = ''
          ..fts = Int64())
        .writeToBuffer()),
    'x-bili-network-bin': base64Encode((network.Network()
          ..type = network.NetworkType.WIFI
          ..tf = network.TFType.TF_UNKNOWN
          ..oid = '')
        .writeToBuffer()),
    'x-bili-restriction-bin': base64Encode((Restriction()
          ..teenagersMode = false
          ..lessonsMode = false
          ..mode = ModeType.NORMAL
          ..review = false
          ..disableRcmd = false
          ..basicMode = false)
        .writeToBuffer()),
    'x-bili-locale-bin': base64Encode((Locale()
          ..cLocale = LocaleIds(language: 'zh', region: 'CN')
          ..sLocale = LocaleIds(language: 'zh', region: 'CN')
          ..simCode = ''
          ..timezone = 'Asia/Shanghai')
        .writeToBuffer()),
    'x-bili-exps-bin': '',
  };

  static final CallOptions options = CallOptions(metadata: metadata);

  static Future _request(Function request) async {
    try {
      return await request();
    } catch (e) {
      dynamic defMsg() => {'status': false, 'msg': e.toString()};
      if (e is GrpcError) {
        try {
          String msg = utf8.decode(
            e.details?.firstOrNull?.getFieldOrNull(2),
            allowMalformed: true,
          );
          if (msg.isNotEmpty) {
            return {'status': false, 'msg': msg};
          } else {
            return defMsg();
          }
        } catch (e1) {
          debugPrint(e1.toString());
          return defMsg();
        }
      }
      return defMsg();
    }
  }

  static Future playerOnline({
    int aid = 0,
    int cid = 0,
  }) async {
    return await _request(() async {
      final request = PlayerOnlineReq()
        ..aid = Int64(aid)
        ..cid = Int64(cid)
        ..playOpen = true;
      final response = await GrpcClient.instance.playerOnlineClient
          .playerOnline(request, options: options);
      return {'status': true, 'data': response.totalNumberText};
    });
  }

  static Future popular(int idx) async {
    return await _request(() async {
      final request = PopularResultReq()..idx = Int64(idx);
      final response = await GrpcClient.instance.popularClient
          .index(request, options: options);
      response.items.retainWhere((item) => item.smallCoverV5.base.goto == 'av');
      return {'status': true, 'data': response.items};
    });
  }

  static Future dialogList({
    int type = 1,
    required int oid,
    required int root,
    required int rpid,
    required CursorReq cursor,
    DetailListScene scene = DetailListScene.REPLY,
  }) async {
    return await _request(() async {
      final request = DialogListReq()
        ..oid = Int64(oid)
        ..type = Int64(type)
        ..root = Int64(root)
        ..rpid = Int64(rpid)
        ..cursor = cursor;
      final response = await GrpcClient.instance.replyClient
          .dialogList(request, options: options);
      return {'status': true, 'data': response};
    });
  }

  static Future detailList({
    int type = 1,
    required int oid,
    required int root,
    required int rpid,
    required CursorReq cursor,
    DetailListScene scene = DetailListScene.REPLY,
  }) async {
    return await _request(() async {
      final request = DetailListReq()
        ..oid = Int64(oid)
        ..type = Int64(type)
        ..root = Int64(root)
        ..rpid = Int64(rpid)
        ..cursor = cursor
        ..scene = scene;
      final response = await GrpcClient.instance.replyClient
          .detailList(request, options: options);
      return {'status': true, 'data': response};
    });
  }

  static Future replyInfo({
    required int rpid,
  }) async {
    return await _request(() async {
      final request = ReplyInfoReq()..rpid = Int64(rpid);
      final response = await GrpcClient.instance.replyClient
          .replyInfo(request, options: options);
      return {'status': true, 'data': response.reply};
    });
  }

  static Future mainList({
    int type = 1,
    required int oid,
    required CursorReq cursor,
  }) async {
    return await _request(() async {
      final request = MainListReq()
        ..oid = Int64(oid)
        ..type = Int64(type)
        ..rpid = Int64(0)
        ..cursor = cursor;
      final response = await GrpcClient.instance.replyClient
          .mainList(request, options: options);
      return {'status': true, 'data': response};
    });
  }

  static Future dynSpace({
    required int uid,
    required int page,
  }) async {
    return await _request(() async {
      final request = DynSpaceReq()
        ..hostUid = Int64(uid)
        ..localTime = 8
        ..page = Int64(page)
        ..from = 'space';
      final DynSpaceRsp response = await GrpcClient.instance.dynamicClient
          .dynSpace(request, options: options);
      return {'status': true, 'data': response};
    });
  }
}