Creepso/mangayomi-mirror
1
0
Fork 0
mirror of https://github.com/kodjodevf/mangayomi.git synced 2026-05-21 09:42:13 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

update quarkuc extractor

Browse source
This commit is contained in:
yxxyun 2025-02-21 16:57:16 +08:00
parent b643dc5b2a
commit 991d733e7c
4 changed files with 155 additions and 140 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

33
lib/eval/model/m_bridge.dart
View file

@ -350,31 +350,38 @@ class MBridge {
.videosFromUrl(url, newHeaders, prefix: prefix, suffix: suffix);
}
static Future<List<Map<String, String>>> quarkFilesExtractor(
List<String> url, String cookie) async {
QuarkUcExtractor quark = QuarkUcExtractor();
await quark.initCloudDrive(cookie, CloudDriveType.quark);
return await quark.videoFilesFromUrl(url);
static final Map<CloudDriveType, QuarkUcExtractor> _extractorCache = {};
static QuarkUcExtractor _getExtractor(String cookie, CloudDriveType type) {
if (!_extractorCache.containsKey(type)) {
QuarkUcExtractor extractor = QuarkUcExtractor();
extractor.initCloudDrive(cookie, type);
_extractorCache[type] = extractor;
}
return _extractorCache[type]!;
}
static Future<List<Map<String, String>>> ucFilesExtractor(
static Future<List<Map<String, String>>> quarkFilesExtractor(
List<String> url, String cookie) async {
QuarkUcExtractor uc = QuarkUcExtractor();
await uc.initCloudDrive(cookie, CloudDriveType.uc);
return await uc.videoFilesFromUrl(url);
var quark = _getExtractor(cookie, CloudDriveType.quark);
return await quark.videoFilesFromUrl(url);
}
static Future<List<Video>> quarkVideosExtractor(
String url, String cookie) async {
QuarkUcExtractor quark = QuarkUcExtractor();
await quark.initCloudDrive(cookie, CloudDriveType.quark);
var quark = _getExtractor(cookie, CloudDriveType.quark);
return await quark.videosFromUrl(url);
}
static Future<List<Map<String, String>>> ucFilesExtractor(
List<String> url, String cookie) async {
var uc = _getExtractor(cookie, CloudDriveType.uc);
return await uc.videoFilesFromUrl(url);
}
static Future<List<Video>> ucVideosExtractor(
String url, String cookie) async {
QuarkUcExtractor uc = QuarkUcExtractor();
await uc.initCloudDrive(cookie, CloudDriveType.uc);
var uc = _getExtractor(cookie, CloudDriveType.uc);
return await uc.videosFromUrl(url);
}

186
lib/services/anime_extractors/quarkuc_extractor.dart
View file

@ -4,6 +4,7 @@ import 'dart:math';
import 'package:http_interceptor/http_interceptor.dart';
import 'package:mangayomi/models/video.dart';
import 'package:mangayomi/services/http/m_client.dart';
import 'package:mangayomi/services/torrent_server.dart';
enum CloudDriveType {
quark,
@ -12,48 +13,62 @@ enum CloudDriveType {
class QuarkUcExtractor {
late CloudDriveType cloudDriveType;
String apiUrl = ""; //"https://drive-pc.quark.cn/1/clouddrive/";
String cookie = "";
String apiUrl = "";
// String cookie = "";
String refererUrl = "";
String ua = "";
String host = "";
Map<String, dynamic> shareTokenCache = {};
String pr = ""; //"pr=ucpro&fr=pc";
String pr = "";
final List<String> subtitleExts = ['.srt', '.ass', '.scc', '.stl', '.ttml'];
Map<String, String> saveFileIdCaches = {};
String? saveDirId;
final String saveDirName = 'TV';
String _lastCookie = "";
Future<void> initCloudDrive(
String cookie, CloudDriveType cloudDriveType) async {
this.cookie = cookie;
this.cloudDriveType = cloudDriveType;
if (cloudDriveType == CloudDriveType.quark) {
apiUrl = "https://drive-pc.quark.cn/1/clouddrive/";
pr = "pr=ucpro&fr=pc";
ua =
"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) quark-cloud-drive/2.5.20 Chrome/100.0.4896.160 Electron/18.3.5.4-b478491100 Safari/537.36 Channel/pckk_other_ch";
refererUrl = "https://pan.quark.cn/";
host = "https://quark.cn";
_lastCookie = "https://quarkcookie.last";
} else {
apiUrl = "https://pc-api.uc.cn/1/clouddrive/";
pr = "pr=UCBrowser&fr=pc";
ua =
"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) uc-cloud-drive/2.5.20 Chrome/100.0.4896.160 Electron/18.3.5.4-b478491100 Safari/537.36 Channel/pckk_other_ch";
refererUrl = "https://drive.uc.cn/";
host = "https://uc.cn";
_lastCookie = "https://uccookie.last";
}
if (cookie.isNotEmpty && getLastCookie() != cookie) {
MClient.setCookie(host, ua, null, cookie: cookie);
MClient.setCookie(_lastCookie, ua, null, cookie: cookie);
}
}
String getLastCookie() {
var cookie = MClient.getCookiesPref(_lastCookie);
return cookie.isNotEmpty ? cookie.values.first : "";
}
String getCurrentCookie() {
var cookie = MClient.getCookiesPref(host);
return cookie.isNotEmpty ? cookie.values.first : "";
}
Map<String, String> getHeaders() {
if (cloudDriveType == CloudDriveType.quark) {
return {
'User-Agent':
'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) quark-cloud-drive/2.5.20 Chrome/100.0.4896.160 Electron/18.3.5.4-b478491100 Safari/537.36 Channel/pckk_other_ch',
'Referer': 'https://pan.quark.cn/',
"Content-Type": "application/json",
"Cookie": cookie,
"Host": "drive-pc.quark.cn"
};
} else {
return {
'User-Agent':
'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) uc-cloud-drive/2.5.20 Chrome/100.0.4896.160 Electron/18.3.5.4-b478491100 Safari/537.36 Channel/pckk_other_ch',
'Referer': 'https://drive.uc.cn/',
"Content-Type": "application/json",
"Cookie": cookie,
"Host": "pc-api.uc.cn"
};
}
return {
'User-Agent': ua,
'Referer': refererUrl,
"Content-Type": "application/json",
"Cookie": getCurrentCookie(),
};
}
Future<Map<String, dynamic>> api(
@ -67,18 +82,42 @@ class QuarkUcExtractor {
} else {
resp = await client.get(Uri.parse(apiUrl + url), headers: getHeaders());
}
// if (resp.headers['set-cookie'] != null) {
// print('headers: ${resp.headers}');
// final puus = resp.headers['set-cookie']!
// .split(';;;')
// .join()
// .split(';')
// .firstWhere((element) => element.startsWith('__puus='),
// orElse: () => '');
// if (puus.isNotEmpty) {
// final newPuus = puus.split('=')[1];
// var cookie = getCurrentCookie();
// if (cookie != null && cookie.contains('__puus=')) {
// cookie =
// cookie.replaceFirst(RegExp(r'__puus=[^;]+'), '__puus=$newPuus');
// }
// MClient.setCookie(host, ua, cookie: cookie);
// }
// }
// 处理 set-cookie
if (resp.headers['set-cookie'] != null) {
final puus = resp.headers['set-cookie']!
.split(';;;')
.join()
.split(';')
.firstWhere((element) => element.startsWith('__puus='),
orElse: () => '');
if (puus.isNotEmpty) {
final newPuus = puus.split('=')[1];
final cookies = resp.headers['set-cookie']!.split(';;;');
for (var cookie in cookies) {
if (cookie.contains('__puus=')) {
cookie =
cookie.replaceFirst(RegExp(r'__puus=[^;]+'), '__puus=$newPuus');
final newPuus = cookie.split(';')[0]; // 获取新的 __puus
var currentCookie = getCurrentCookie();
if (currentCookie.isNotEmpty) {
// 更新 __puus
if (currentCookie.contains('__puus=')) {
currentCookie =
currentCookie.replaceFirst(RegExp(r'__puus=[^;]+'), newPuus);
} else {
currentCookie = '$currentCookie; $newPuus';
}
MClient.setCookie(host, ua, null, cookie: currentCookie);
}
break;
}
}
}
@ -102,10 +141,6 @@ class QuarkUcExtractor {
return null;
}
List<String> getPlayFormtList() {
return ["4k", "2k", "super", "high", "normal", "low", "原画"];
}
Future<void> getShareToken(Map<String, String> shareData) async {
if (!shareTokenCache.containsKey(shareData['shareId'])) {
shareTokenCache.remove(shareData['shareId']);
@ -305,8 +340,8 @@ class QuarkUcExtractor {
return null;
}
Future<String?> getLiveTranscoding(String shareId, String stoken,
String fileId, String fileToken, String quality) async {
Future<List<Map<String, String>>?> getLiveTranscoding(
String shareId, String stoken, String fileId, String fileToken) async {
if (!saveFileIdCaches.containsKey(fileId)) {
final saveFileId = await save(shareId, stoken, fileId, fileToken, true);
if (saveFileId == null) return null;
@ -322,13 +357,14 @@ class QuarkUcExtractor {
'post');
if (transcoding['data'] != null &&
transcoding['data']['video_list'] != null) {
List<Map<String, String>> qualityOptions = [];
for (final video in transcoding['data']['video_list']) {
if (video['resolution'] == quality) {
return video['video_info']['url'];
}
qualityOptions.add({
'url': video['video_info']['url'],
'quality': video['resolution']
});
}
// 如果没有找到匹配的质量,返回null
return null;
return qualityOptions;
}
return null;
}
@ -362,12 +398,6 @@ class QuarkUcExtractor {
await getFilesByShareUrl(i + 1, shareUrl, videoItems, subItems);
}
// if (videoItems.isNotEmpty) {
// print('获取播放链接成功,分享链接为:${shareUrlList.join("\t")}');
// } else {
// print('获取播放链接失败,检查分享链接为:${shareUrlList.join("\t")}');
// }
return await getVodFile(videoItems, subItems, typeName);
}
@ -399,45 +429,23 @@ class QuarkUcExtractor {
String type = parts[0];
List<String> subtitleParts = parts.length > 5 ? parts[5].split('+') : [];
// 获取可用的质量列表
List<String> qualities = getPlayFormtList();
//List<String> qualities = getPlayFormtList();
List<Video> videos = [];
if (type == "uc") {
var headers = getHeaders();
headers.remove('Host');
headers.remove('Content-Type');
String? url = (await getDownload(
shareId, stoken, fileId, fileToken, true))?['download_url'];
if (url != null) {
videos.add(Video(url, "原画", url, headers: headers));
}
} else {
String? originalUrl = (await getLiveTranscoding(
shareId, stoken, fileId, fileToken, "4k")) ??
(await getLiveTranscoding(
shareId, stoken, fileId, fileToken, 'super'));
var headers = getHeaders();
headers.remove('Host');
headers.remove('Content-Type');
for (String quality in qualities) {
if (quality == "原画") {
String? url = (await getDownload(
shareId, stoken, fileId, fileToken, true))?['download_url'];
if (url != null) {
videos
.add(Video(url, quality, originalUrl ?? '', headers: headers));
}
} else {
String? url = await getLiveTranscoding(
shareId, stoken, fileId, fileToken, quality);
if (url != null) {
videos.add(Video(
url,
quality,
originalUrl ?? '',
headers: headers,
));
}
}
String? originalUrl;
List<Map<String, String>>? qualityOptions =
await getLiveTranscoding(shareId, stoken, fileId, fileToken);
originalUrl = qualityOptions?[0]['url'];
var headers = getHeaders();
headers.remove('Content-Type');
if (qualityOptions != null) {
for (Map<String, String> qualityOption in qualityOptions) {
videos.add(Video(
qualityOption['url'] ?? '',
qualityOption['quality'] ?? '',
originalUrl ?? '',
headers: headers,
));
}
}
@ -450,7 +458,7 @@ class QuarkUcExtractor {
String subName = subParts[0];
String subFileId = subParts[2];
var subDownload =
await getDownload(shareId, stoken, subFileId, '', true);
await getDownload(shareId, stoken, subFileId, '', false);
String? subUrl = subDownload?['download_url'];
if (subUrl != null) {
subtitles.add(Track(file: subUrl, label: subName));

10
lib/services/http/m_client.dart
View file

@ -73,12 +73,12 @@ class MClient {
flutter_inappwebview.InAppWebViewController? webViewController,
{String? cookie}) async {
List<String> cookies = [];
if (Platform.isLinux) {
// if incoming cookie is not empty, use it first
if (cookie != null && cookie.isNotEmpty) {
cookies = cookie
?.split(RegExp('(?<=)(,)(?=[^;]+?=)'))
.where((cookie) => cookie.isNotEmpty)
.toList() ??
[];
.split(RegExp('(?<=)(,)(?=[^;]+?=)'))
.where((cookie) => cookie.isNotEmpty)
.toList();
} else {
cookies = (await flutter_inappwebview.CookieManager.instance(
webViewEnvironment: webViewEnvironment)

66
pubspec.lock
View file

@ -98,10 +98,10 @@ packages:
dependency: transitive
description:
name: async
sha256: "947bfcf187f74dbc5e146c9eb9c0f10c9f8b30743e341481c1e2ed3ecc18c20c"
sha256: d2872f9c19731c2e5f10444b14686eb7cc85c76274bd6c16e1816bff9a3bab63
url: "https://pub.dev"
source: hosted
version: "2.11.0"
version: "2.12.0"
audio_session:
dependency: transitive
description:
@ -114,10 +114,10 @@ packages:
dependency: transitive
description:
name: boolean_selector
sha256: "6cfb5af12253eaf2b368f07bacc5a80d1301a071c73360d746b7f2e32d762c66"
sha256: "8aab1771e1243a5063b8b0ff68042d67334e3feab9e95b9490f9a6ebf73b42ea"
url: "https://pub.dev"
source: hosted
version: "2.1.1"
version: "2.1.2"
bot_toast:
dependency: "direct main"
description:
@ -234,10 +234,10 @@ packages:
dependency: transitive
description:
name: characters
sha256: "04a925763edad70e8443c99234dc3328f442e811f1d8fd1a72f1c8ad0f69a605"
sha256: f71061c654a3380576a52b451dd5532377954cf9dbd272a78fc8479606670803
url: "https://pub.dev"
source: hosted
version: "1.3.0"
version: "1.4.0"
checked_yaml:
dependency: transitive
description:
@ -266,10 +266,10 @@ packages:
dependency: transitive
description:
name: clock
sha256: cb6d7f03e1de671e34607e909a7213e31d7752be4fb66a86d29fe1eb14bfb5cf
sha256: fddb70d9b5277016c77a80201021d40a2247104d9f4aa7bab7157b7e3f05b84b
url: "https://pub.dev"
source: hosted
version: "1.1.1"
version: "1.1.2"
code_builder:
dependency: transitive
description:
@ -467,10 +467,10 @@ packages:
dependency: transitive
description:
name: fake_async
sha256: "511392330127add0b769b75a987850d136345d9227c6b94c96a04cf4a391bf78"
sha256: "6a95e56b2449df2273fd8c45a662d6947ce1ebb7aafe80e550a3f68297f3cacc"
url: "https://pub.dev"
source: hosted
version: "1.3.1"
version: "1.3.2"
ffi:
dependency: "direct main"
description:
@ -1049,18 +1049,18 @@ packages:
dependency: transitive
description:
name: leak_tracker
sha256: "7bb2830ebd849694d1ec25bf1f44582d6ac531a57a365a803a6034ff751d2d06"
sha256: c35baad643ba394b40aac41080300150a4f08fd0fd6a10378f8f7c6bc161acec
url: "https://pub.dev"
source: hosted
version: "10.0.7"
version: "10.0.8"
leak_tracker_flutter_testing:
dependency: transitive
description:
name: leak_tracker_flutter_testing
sha256: "9491a714cca3667b60b5c420da8217e6de0d1ba7a5ec322fab01758f6998f379"
sha256: f8b613e7e6a13ec79cfdc0e97638fddb3ab848452eff057653abd3edba760573
url: "https://pub.dev"
source: hosted
version: "3.0.8"
version: "3.0.9"
leak_tracker_testing:
dependency: transitive
description:
@ -1097,10 +1097,10 @@ packages:
dependency: transitive
description:
name: matcher
sha256: d2323aa2060500f906aa31a895b4030b6da3ebdcc5619d14ce1aada65cd161cb
sha256: dc58c723c3c24bf8d3e2d3ad3f2f9d7bd9cf43ec6feaa64181775e60190153f2
url: "https://pub.dev"
source: hosted
version: "0.12.16+1"
version: "0.12.17"
material_color_utilities:
dependency: transitive
description:
@ -1268,10 +1268,10 @@ packages:
dependency: "direct main"
description:
name: path
sha256: "087ce49c3f0dc39180befefc60fdb4acd8f8620e5682fe2476afd0b3688bb4af"
sha256: "75cca69d1490965be98c73ceaea117e8a04dd21217b37b292c9ddbec0d955bc5"
url: "https://pub.dev"
source: hosted
version: "1.9.0"
version: "1.9.1"
path_parsing:
dependency: transitive
description:
@ -1704,10 +1704,10 @@ packages:
dependency: transitive
description:
name: source_span
sha256: "53e943d4206a5e30df338fd4c6e7a077e02254531b138a15aec3bd143c1a8b3c"
sha256: "254ee5351d6cb365c859e20ee823c3bb479bf4a293c22d17a9f1bf144ce86f7c"
url: "https://pub.dev"
source: hosted
version: "1.10.0"
version: "1.10.1"
sprintf:
dependency: transitive
description:
@ -1760,10 +1760,10 @@ packages:
dependency: transitive
description:
name: stack_trace
sha256: "9f47fd3630d76be3ab26f0ee06d213679aa425996925ff3feffdec504931c377"
sha256: "8b27215b45d22309b5cddda1aa2b19bdfec9df0e765f2de506401c071d38d1b1"
url: "https://pub.dev"
source: hosted
version: "1.12.0"
version: "1.12.1"
state_notifier:
dependency: transitive
description:
@ -1776,10 +1776,10 @@ packages:
dependency: transitive
description:
name: stream_channel
sha256: ba2aa5d8cc609d96bbb2899c28934f9e1af5cddbd60a827822ea467161eb54e7
sha256: "969e04c80b8bcdf826f8f16579c7b14d780458bd97f56d107d3950fdbeef059d"
url: "https://pub.dev"
source: hosted
version: "2.1.2"
version: "2.1.4"
stream_transform:
dependency: transitive
description:
@ -1792,10 +1792,10 @@ packages:
dependency: transitive
description:
name: string_scanner
sha256: "688af5ed3402a4bde5b3a6c15fd768dbf2621a614950b17f04626c431ab3c4c3"
sha256: "921cd31725b72fe181906c6a94d987c78e3b98c2e205b397ea399d4054872b43"
url: "https://pub.dev"
source: hosted
version: "1.3.0"
version: "1.4.1"
super_sliver_list:
dependency: "direct main"
description:
@ -1816,18 +1816,18 @@ packages:
dependency: transitive
description:
name: term_glyph
sha256: a29248a84fbb7c79282b40b8c72a1209db169a2e0542bce341da992fe1bc7e84
sha256: "7f554798625ea768a7518313e58f83891c7f5024f88e46e7182a4558850a4b8e"
url: "https://pub.dev"
source: hosted
version: "1.2.1"
version: "1.2.2"
test_api:
dependency: transitive
description:
name: test_api
sha256: "664d3a9a64782fcdeb83ce9c6b39e78fd2971d4e37827b9b06c3aa1edc5e760c"
sha256: fb31f383e2ee25fbbfe06b40fe21e1e458d14080e3c67e7ba0acfde4df4e0bbd
url: "https://pub.dev"
source: hosted
version: "0.7.3"
version: "0.7.4"
time:
dependency: transitive
description:
@ -2016,10 +2016,10 @@ packages:
dependency: transitive
description:
name: vm_service
sha256: f6be3ed8bd01289b34d679c2b62226f63c0e69f9fd2e50a6b3c1c729a961041b
sha256: "0968250880a6c5fe7edc067ed0a13d4bae1577fe2771dcf3010d52c4a9d3ca14"
url: "https://pub.dev"
source: hosted
version: "14.3.0"
version: "14.3.1"
volume_controller:
dependency: transitive
description:
@ -2189,5 +2189,5 @@ packages:
source: hosted
version: "2.2.2"
sdks:
dart: ">=3.6.0 <4.0.0"
dart: ">=3.7.0-0 <4.0.0"
flutter: ">=3.27.0"