HCha/PiliPlus
1
0
Fork 0
mirror of https://github.com/HChaZZY/PiliPlus.git synced 2025-12-06 09:13:48 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: handle grpc response

Browse Source 
Signed-off-by: bggRGjQaUbCoE <githubaccount56556@proton.me>
This commit is contained in:
bggRGjQaUbCoE
2025-02-24 15:54:51 +08:00
parent 307db51aec
commit d9ae1dd97a
1 changed files with 29 additions and 26 deletions
Download Patch File Download Diff File Expand all files Collapse all files

55
lib/grpc/grpc_repo.dart
View File

@@ -122,8 +122,7 @@ class GrpcRepo {
'x-bili-exps-bin': '',
};
static final unprintableRegExp =
RegExp(r"[^\0u0020-\u007e\u4e00-\u9fa5，。；！？]");
static final unprintableRegExp = RegExp(r"[^\u4e00-\u9fa5，。；！？UP]");
static Uint8List compressProtobuf(Uint8List proto) {
proto = gzipEncoder.encodeBytes(proto, level: 0);
@@ -156,31 +155,35 @@ class GrpcRepo {
if (response.data is Map) {
return {'status': false, 'msg': response.data['message']};
}
Uint8List data = response.data;
// if (int.tryParse(response.headers.value('grpc-status') ?? '0') == 0) {
// try {
data = decompressProtobuf(data);
final grpcResponse = grpcParser(data);
return {
'status': true,
'data': onSuccess == null ? grpcResponse : onSuccess(grpcResponse)
};
// } catch (e) {}
// }
// if (data.isNotEmpty) {
// try {
// String msg = utf8
// .decode(data, allowMalformed: true)
// .replaceAll(unprintableRegExp, '');
// if (msg.isNotEmpty) {
// return {'status': false, 'msg': msg};
// }
// } catch (e1) {}
// }
// return {'status': false, 'msg': response.headers.map.toString()};
if (response.headers.value('Grpc-Status') == '0') {
try {
Uint8List data = response.data;
data = decompressProtobuf(data);
final grpcResponse = grpcParser(data);
return {
'status': true,
'data': onSuccess == null ? grpcResponse : onSuccess(grpcResponse),
};
} catch (e) {
return {'status': false, 'msg': e.toString()};
}
} else {
try {
String msg = response.headers.value('Grpc-Status-Details-Bin') ?? '';
if (msg != '') {
while (msg.length % 4 != 0) {
msg += '=';
}
msg = utf8
.decode(base64Decode(msg), allowMalformed: true)
.replaceAll(unprintableRegExp, '');
}
return {'status': false, 'msg': msg};
} catch (e) {
return {'status': false, 'msg': e.toString()};
}
}
}
static Future playerOnline({