mangayomi-mirror/lib/utils/extensions/chapter.dart

47 lines
1.6 KiB
Dart

import 'package:flutter/material.dart';
import 'package:mangayomi/main.dart';
import 'package:mangayomi/models/chapter.dart';
import 'package:mangayomi/models/download.dart';
import 'package:mangayomi/modules/manga/reader/providers/push_router.dart';
import 'package:mangayomi/modules/manga/reader/providers/reader_controller_provider.dart';
import 'package:mangayomi/services/download_manager/download_isolate_pool.dart';
import 'package:mangayomi/services/download_manager/m_downloader.dart';
extension ChapterExtension on Chapter {
Future<void> pushToReaderView(
BuildContext context, {
bool ignoreIsRead = false,
}) async {
if (ignoreIsRead || !isRead!) {
await pushMangaReaderView(context: context, chapter: this);
} else {
final filteredChaps = manga.value!.getFilteredChapterList();
bool exist = false;
for (var filteredChap in filteredChaps.reversed) {
if (filteredChap.toJson().toString() == toJson().toString()) {
exist = true;
}
if (exist && !filteredChap.isRead!) {
await pushMangaReaderView(context: context, chapter: filteredChap);
break;
}
}
}
}
void cancelDownloads(int? downloadId) {
// Cancel via the Isolate pool (new system)
DownloadIsolatePool.instance.cancelTask('$id');
DownloadIsolatePool.instance.cancelTask('m3u8_$id');
// Clean the map for compatibility
isolateChapsSendPorts.remove('$id');
isar.writeTxnSync(() {
isar.downloads.deleteSync(id!);
if (downloadId != null) {
isar.downloads.deleteSync(downloadId);
}
});
}
}