-
Notifications
You must be signed in to change notification settings - Fork 41
/
eh_provider.dart
124 lines (102 loc) · 3.11 KB
/
eh_provider.dart
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
// This source code is a part of Project Violet.
// Copyright (C) 2020-2024. violet-team. Licensed under the Apache-2.0 License.
import 'package:html_unescape/html_unescape.dart';
import 'package:shared_preferences/shared_preferences.dart';
import 'package:violet/component/eh/eh_headers.dart';
import 'package:violet/component/eh/eh_parser.dart';
import 'package:violet/component/image_provider.dart';
import 'package:violet/settings/settings.dart';
import 'package:violet/thread/semaphore.dart';
class EHentaiImageProvider extends VioletImageProvider {
// List<String> urls;
int count;
bool initialized = false;
bool isEHentai;
String thumbnail;
List<String> pagesUrl;
late List<String?> urls;
late List<String> imgUrls;
late Semaphore pageThrottler;
EHentaiImageProvider({
required this.count,
required this.thumbnail,
required this.pagesUrl,
required this.isEHentai,
});
@override
Future<void> init() async {
if (initialized) return;
pageThrottler = Semaphore(maxCount: 1);
urls = List<String?>.filled(count, null);
// for (int i = 0; i < pagesUrl.length; i++) {
// var phtml = await EHSession.requestString(pagesUrl[i]);
// urls.addAll(EHParser.getImagesUrl(phtml));
// }
imgUrls = List<String>.filled(count, '');
initialized = true;
}
@override
Future<List<String>> getSmallImagesUrl() async {
var phtml = await EHSession.requestString('${pagesUrl[0]}&inline_set=ts_l');
return EHParser.getThumbnailImages(phtml);
}
@override
Future<String> getThumbnailUrl() async {
return thumbnail;
}
@override
Future<Map<String, String>> getHeader(int page) async {
final prefs = await SharedPreferences.getInstance();
var cookie = prefs.getString('eh_cookies');
return {'Cookie': cookie ?? ''};
}
@override
Future<String> getImageUrl(int page) async {
if (imgUrls[page] != '') {
return imgUrls[page];
}
await pageThrottler.acquire();
if (urls[page] == null) {
// 40item per page
var ppage = page ~/ 40;
var phtml =
await EHSession.requestString('${pagesUrl[ppage]}&inline_set=ts_m');
var pages = EHParser.getImagesUrl(phtml);
for (int i = 0; i < pages.length; i++) {
urls[ppage * 40 + i] = pages[i];
}
}
pageThrottler.release();
var img = await EHSession.requestString(urls[page]!);
if (Settings.downloadEhRawImage) {
var unescape = HtmlUnescape();
return imgUrls[page] =
unescape.convert(EHParser.getOriginalImageAddress(img));
}
return imgUrls[page] = EHParser.getImageAddress(img);
}
@override
bool canGetImageUrlSync() => false;
@override
String? getImageUrlSync(int page) => null;
@override
int length() {
return count;
}
@override
Future<double> getEstimatedImageHeight(int page, double baseWidth) async {
return -1;
}
@override
bool isRefreshable() {
return false;
}
@override
Future<void> refresh() async {}
@override
Future<void> refreshPartial(List<bool> target) async {}
@override
Future<double> getOriginalImageHeight(int page) async {
return -1;
}
}