/* * Copyright (C) Contributors to the Suwayomi project * * This Source Code Form is subject to the terms of the Mozilla Public * License, v. 2.0. If a copy of the MPL was not distributed with this * file, You can obtain one at https://mozilla.org/MPL/2.0/. */ import { t as translate } from 'i18next'; import { TManga, TranslationKey } from '@/typings.ts'; import { requestManager } from '@/lib/requests/RequestManager.ts'; import { ChapterConditionInput, GetMangasChapterIdsWithStateQuery, GetMangaToMigrateQuery, GetMangaToMigrateToFetchMutation, UpdateMangaCategoriesPatchInput, } from '@/lib/graphql/generated/graphql.ts'; import { Chapters } from '@/lib/data/Chapters.ts'; import { makeToast } from '@/components/util/Toast.tsx'; export type MangaAction = | 'download' | 'delete' | 'mark_as_read' | 'mark_as_unread' | 'remove_from_library' | 'change_categories' | 'migrate'; export const actionToTranslationKey: { [key in MangaAction]: { action: { single: TranslationKey; selected: TranslationKey; }; success: TranslationKey; error: TranslationKey; }; } = { download: { action: { single: 'chapter.action.download.add.label.action', selected: 'chapter.action.download.add.button.selected', }, success: 'chapter.action.download.add.label.success', error: 'chapter.action.download.add.label.error', }, delete: { action: { single: 'chapter.action.download.delete.label.action', selected: 'chapter.action.download.delete.button.selected', }, success: 'chapter.action.download.delete.label.success', error: 'chapter.action.download.delete.label.error', }, mark_as_read: { action: { single: 'chapter.action.mark_as_read.add.label.action.current', selected: 'chapter.action.mark_as_read.add.button.selected', }, success: 'chapter.action.mark_as_read.add.label.success', error: 'chapter.action.mark_as_read.add.label.error', }, mark_as_unread: { action: { single: 'chapter.action.mark_as_read.remove.label.action', selected: 'chapter.action.mark_as_read.remove.button.selected', }, success: 'chapter.action.mark_as_read.remove.label.success', error: 'chapter.action.mark_as_read.remove.label.error', }, remove_from_library: { action: { single: 'manga.action.library.remove.label.action', selected: 'manga.action.library.remove.button.selected', }, success: 'manga.action.library.remove.label.success', error: 'manga.action.library.remove.label.error', }, change_categories: { action: { single: 'manga.action.category.label.action', selected: 'manga.action.category.button.selected', }, success: 'manga.action.category.label.success', error: 'manga.action.category.label.error', }, migrate: { action: { single: 'global.button.migrate', selected: 'global.button.migrate', // not supported }, success: 'manga.action.migrate.label.success', error: 'manga.action.migrate.label.error', }, }; export type MangaChapterCountInfo = { chapters: Pick }; export type MangaDownloadInfo = Pick & MangaChapterCountInfo; export type MangaUnreadInfo = Pick & MangaChapterCountInfo; export type MangaLastFetchedInfo = Pick; export type MangaThumbnailInfo = Pick; export type MigrateMode = 'copy' | 'migrate'; type MarkAsReadOptions = { wasManuallyMarkedAsRead: boolean }; type ChangeCategoriesOptions = { changeCategoriesPatch: UpdateMangaCategoriesPatchInput }; type MigrateOptions = { mangaIdToMigrateTo: number; mode: MigrateMode; migrateChapters?: boolean; migrateCategories?: boolean; }; type PerformActionOptions = Action extends 'mark_as_read' ? MarkAsReadOptions & PropertiesNever & PropertiesNever : Action extends 'change_categories' ? PropertiesNever & ChangeCategoriesOptions & PropertiesNever : Action extends 'migrate' ? PropertiesNever & PropertiesNever & MigrateOptions : Partial & Partial & Partial; export class Mangas { static getIds(mangas: { id: number }[]): number[] { return mangas.map((manga) => manga.id); } static isNotDownloaded({ downloadCount }: MangaDownloadInfo): boolean { return downloadCount === 0; } static getNotDownloaded(mangas: Mangas[]): Mangas[] { return mangas.filter(Mangas.isNotDownloaded); } static isFullyDownloaded({ downloadCount, chapters: { totalCount } }: MangaDownloadInfo): boolean { return downloadCount === totalCount; } static getFullyDownloaded(mangas: Mangas[]): Mangas[] { return mangas.filter(Mangas.isFullyDownloaded); } static isPartiallyDownloaded(manga: MangaDownloadInfo): boolean { return !Mangas.isNotDownloaded(manga) && !Mangas.isFullyDownloaded(manga); } static getPartiallyDownloaded(mangas: Mangas[]): Mangas[] { return mangas.filter(Mangas.isPartiallyDownloaded); } static isUnread({ unreadCount, chapters: { totalCount } }: MangaUnreadInfo): boolean { return unreadCount === totalCount; } static getUnread(mangas: Mangas[]): Mangas[] { return mangas.filter(Mangas.isUnread); } static isFullyRead({ unreadCount }: MangaUnreadInfo): boolean { return unreadCount === 0; } static getFullyRead(mangas: Mangas[]): Mangas[] { return mangas.filter(Mangas.isFullyRead); } static isPartiallyRead(manga: MangaUnreadInfo): boolean { return !Mangas.isUnread(manga) && !Mangas.isFullyRead(manga); } static getPartiallyRead(mangas: Mangas[]): Mangas[] { return mangas.filter(Mangas.isPartiallyRead); } static getThumbnailUrl(manga: MangaLastFetchedInfo & Partial): string { return manga.thumbnailUrl ? `${manga.thumbnailUrl}?fetchedAt=${manga.lastFetchedAt}` : 'nonExistingMangaUrl'; } static async getChapterIdsWithState( mangaIds: number[], state: Pick, ): Promise { const { data } = await requestManager.getMangasChapterIdsWithState(mangaIds, state).response; return data.chapters.nodes; } static async downloadChapters(mangaIds: number[]): Promise { const chapters = await Mangas.getChapterIdsWithState(mangaIds, { isDownloaded: false }); return Chapters.download(Chapters.getIds(chapters)); } static async deleteChapters(mangaIds: number[]): Promise { const chapters = await Mangas.getChapterIdsWithState(mangaIds, { isDownloaded: true }); return Chapters.delete(Chapters.getIds(chapters)); } static async markAsRead(mangaIds: number[], wasManuallyMarkedAsRead: boolean = false): Promise { const chapters = await Mangas.getChapterIdsWithState(mangaIds, { isRead: false }); return Chapters.markAsRead(chapters, wasManuallyMarkedAsRead); } static async markAsUnread(mangaIds: number[]): Promise { const chapters = await Mangas.getChapterIdsWithState(mangaIds, { isRead: true }); return Chapters.markAsUnread(Chapters.getIds(chapters)); } static async removeFromLibrary(mangaIds: number[]): Promise { return Mangas.executeAction( 'remove_from_library', mangaIds.length, () => requestManager.updateMangas(mangaIds, { inLibrary: false }).response, ); } static async changeCategories(mangaIds: number[], patch: UpdateMangaCategoriesPatchInput): Promise { return Mangas.executeAction( 'change_categories', mangaIds.length, () => requestManager.updateMangasCategories(mangaIds, patch).response, ); } private static async migrateChapters( mangaToMigrate: GetMangaToMigrateQuery['manga'], mangaToMigrateToInfo: GetMangaToMigrateToFetchMutation, ): Promise { if (!mangaToMigrate.chapters || !mangaToMigrateToInfo.fetchChapters?.chapters) { throw new Error('Chapters are missing'); } const chaptersToMigrate = mangaToMigrate.chapters.nodes; const chaptersToMigrateTo = mangaToMigrateToInfo.fetchChapters?.chapters; const migratableChapters = Chapters.getMatchingChapterNumberChapters(chaptersToMigrate, chaptersToMigrateTo); const readChapters: number[] = []; const bookmarkedChapters: number[] = []; migratableChapters.forEach(([chapterToMigrate, chapterToMigrateTo]) => { const { isRead, isBookmarked } = chapterToMigrate; if (isRead) { readChapters.push(chapterToMigrateTo.id); } if (isBookmarked) { bookmarkedChapters.push(chapterToMigrateTo.id); } }); await Promise.all([ requestManager.updateChapters(readChapters, { isRead: true }).response, requestManager.updateChapters(bookmarkedChapters, { isBookmarked: true }).response, ]); } private static async migrateCategories( mangaToMigrate: GetMangaToMigrateQuery['manga'], mangaToMigrateTo: GetMangaToMigrateToFetchMutation['fetchManga']['manga'], ): Promise { if (!mangaToMigrate?.categories) { throw new Error('Categories are missing'); } requestManager.updateMangasCategories([mangaToMigrateTo.id], { addToCategories: mangaToMigrate.categories.nodes.map((category) => category.id), }); } static async migrate( mangaId: number, mangaIdToMigrateTo: number, { mode, migrateChapters, migrateCategories }: Omit, ): Promise { return Mangas.executeAction('migrate', 1, async () => { const [{ data: mangaToMigrateData }, { data: mangaToMigrateToData }] = await Promise.all([ requestManager.getMangaToMigrate(mangaId, { migrateChapters, migrateCategories }).response, requestManager.getMangaToMigrateToFetch(mangaIdToMigrateTo, { migrateChapters, migrateCategories }) .response, ]); if (!mangaToMigrateData.manga || !mangaToMigrateToData?.fetchManga.manga) { throw new Error('Mangas::migrate: missing manga data'); } if ( migrateChapters && (!mangaToMigrateData.manga.chapters || !mangaToMigrateToData.fetchChapters?.chapters) ) { throw new Error('Mangas::migrate: missing chapters data'); } await Promise.all([ migrateChapters ? Mangas.migrateChapters(mangaToMigrateData.manga, mangaToMigrateToData) : undefined, migrateCategories ? Mangas.migrateCategories(mangaToMigrateData.manga, mangaToMigrateToData.fetchManga.manga) : undefined, !mangaToMigrateToData.fetchManga.manga.inLibrary ? requestManager.updateManga(mangaIdToMigrateTo, { inLibrary: true }).response : undefined, mode === 'migrate' ? requestManager.updateManga(mangaId, { inLibrary: false }).response : undefined, ]); }); } private static async executeAction( action: MangaAction, itemCount: number, fnToExecute: () => Promise, ): Promise { try { await fnToExecute(); makeToast(translate(actionToTranslationKey[action].success, { count: itemCount }), 'success'); } catch (e) { makeToast(translate(actionToTranslationKey[action].error, { count: itemCount }), 'error'); throw e; } } static async performAction( action: Action, mangaIds: number[], { wasManuallyMarkedAsRead, changeCategoriesPatch, mangaIdToMigrateTo, ...migrateOptions }: PerformActionOptions, ): Promise { switch (action) { case 'download': return Mangas.downloadChapters(mangaIds); case 'delete': return Mangas.deleteChapters(mangaIds); case 'mark_as_read': return Mangas.markAsRead(mangaIds, wasManuallyMarkedAsRead!); case 'mark_as_unread': return Mangas.markAsUnread(mangaIds); case 'remove_from_library': return Mangas.removeFromLibrary(mangaIds); case 'change_categories': return Mangas.changeCategories(mangaIds, changeCategoriesPatch!); case 'migrate': { return Mangas.migrate(mangaIds[0], mangaIdToMigrateTo!, migrateOptions as unknown as MigrateOptions); } default: throw new Error(`Mangas::performAction: unknown action "${action}"`); } } }